File tree 2 files changed +9
-8
lines changed
main/java/org/opensearch/index/remote
test/java/org/opensearch/index/remote
2 files changed +9
-8
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 @@ -152,15 +152,16 @@ public void testComputeTimeLagOnUpdate() throws InterruptedException {
152
152
transferTracker .updateLocalRefreshTimeMs (currentTimeMsUsingSystemNanos ());
153
153
154
154
transferTracker .updateLatestLocalFileNameLengthMap (List .of ("test" ), k -> 1L );
155
- // Sleep for 100ms and then the lag should be within 100ms +/- 20ms
156
- Thread .sleep (100 );
157
- assertTrue (Math .abs (transferTracker .getTimeMsLag () - 100 ) <= 20 );
155
+ // Sleep for 100ms and then the lag should not be shorter
156
+ long span = 100 ;
157
+ Thread .sleep (span );
158
+ assertTrue ("Lag is not expected to be shorter than span [" + span + "ms]" , transferTracker .getTimeMsLag () >= span );
158
159
159
160
transferTracker .updateRemoteRefreshTimeMs (transferTracker .getLocalRefreshTimeMs ());
160
161
transferTracker .updateLocalRefreshTimeMs (currentTimeMsUsingSystemNanos ());
161
- long random = randomIntBetween (50 , 200 );
162
- Thread .sleep (random );
163
- assertTrue (Math . abs ( transferTracker .getTimeMsLag () - random ) <= 20 );
162
+ long randomSpan = randomIntBetween (50 , 200 );
163
+ Thread .sleep (randomSpan );
164
+ assertTrue ("Lag is not expected to be shorter than span [" + randomSpan + "ms]" , transferTracker .getTimeMsLag () >= randomSpan );
164
165
}
165
166
166
167
public void testAddUploadBytesStarted () {
You can’t perform that action at this time.
0 commit comments