File tree 2 files changed +4
-4
lines changed
main/java/org/opensearch/index/remote
test/java/org/opensearch/index/remote
2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -65,7 +65,7 @@ public class RemoteSegmentTransferTracker extends RemoteTransferTracker {
65
65
private volatile long remoteRefreshSeqNo ;
66
66
67
67
/**
68
- * The refresh time of most recent remote refresh.
68
+ * The refresh time of the most recent remote refresh.
69
69
*/
70
70
private volatile long remoteRefreshTimeMs ;
71
71
@@ -76,7 +76,7 @@ public class RemoteSegmentTransferTracker extends RemoteTransferTracker {
76
76
private volatile long remoteRefreshStartTimeMs = -1 ;
77
77
78
78
/**
79
- * The refresh time(clock) of most recent remote refresh.
79
+ * The refresh time(clock) of the most recent remote refresh.
80
80
*/
81
81
private volatile long remoteRefreshClockTimeMs ;
82
82
Original file line number Diff line number Diff line change @@ -154,13 +154,13 @@ public void testComputeTimeLagOnUpdate() throws InterruptedException {
154
154
transferTracker .updateLatestLocalFileNameLengthMap (List .of ("test" ), k -> 1L );
155
155
// Sleep for 100ms and then the lag should be within 100ms +/- 20ms
156
156
Thread .sleep (100 );
157
- assertTrue (Math . abs ( transferTracker .getTimeMsLag () - 100 ) <= 20 );
157
+ assertTrue (transferTracker .getTimeMsLag () >= 100 );
158
158
159
159
transferTracker .updateRemoteRefreshTimeMs (transferTracker .getLocalRefreshTimeMs ());
160
160
transferTracker .updateLocalRefreshTimeMs (currentTimeMsUsingSystemNanos ());
161
161
long random = randomIntBetween (50 , 200 );
162
162
Thread .sleep (random );
163
- assertTrue (Math . abs ( transferTracker .getTimeMsLag () - random ) <= 20 );
163
+ assertTrue (transferTracker .getTimeMsLag () >= random );
164
164
}
165
165
166
166
public void testAddUploadBytesStarted () {
You can’t perform that action at this time.
0 commit comments