@@ -4313,11 +4313,15 @@ protected long doGenerateSeqNoForOperation(Operation operation) {
4313
4313
* Verifies that a segment containing only no-ops can be used to look up _version and _seqno.
4314
4314
*/
4315
4315
public void testSegmentContainsOnlyNoOps () throws Exception {
4316
- Engine .NoOpResult noOpResult = engine .noOp (new Engine .NoOp (1 , primaryTerm .get (),
4316
+ final long seqNo = randomLongBetween (0 , 1000 );
4317
+ final long term = this .primaryTerm .get ();
4318
+ Engine .NoOpResult noOpResult = engine .noOp (new Engine .NoOp (seqNo , term ,
4317
4319
randomFrom (Engine .Operation .Origin .values ()), randomNonNegativeLong (), "test" ));
4318
4320
assertThat (noOpResult .getFailure (), nullValue ());
4321
+ assertThat (noOpResult .getSeqNo (), equalTo (seqNo ));
4322
+ assertThat (noOpResult .getTerm (), equalTo (term ));
4319
4323
engine .refresh ("test" );
4320
- Engine .DeleteResult deleteResult = engine .delete (replicaDeleteForDoc ("id" , 1 , 2 , randomNonNegativeLong ()));
4324
+ Engine .DeleteResult deleteResult = engine .delete (replicaDeleteForDoc ("id" , 1 , seqNo + between ( 1 , 1000 ) , randomNonNegativeLong ()));
4321
4325
assertThat (deleteResult .getFailure (), nullValue ());
4322
4326
engine .refresh ("test" );
4323
4327
}
@@ -4343,8 +4347,11 @@ public void testRandomOperations() throws Exception {
4343
4347
assertThat (delete .getFailure (), nullValue ());
4344
4348
break ;
4345
4349
case NO_OP :
4346
- Engine .NoOpResult noOp = engine .noOp (new Engine .NoOp (i , primaryTerm .get (),
4350
+ long seqNo = i ;
4351
+ Engine .NoOpResult noOp = engine .noOp (new Engine .NoOp (seqNo , primaryTerm .get (),
4347
4352
randomFrom (Engine .Operation .Origin .values ()), randomNonNegativeLong (), "" ));
4353
+ assertThat (noOp .getTerm (), equalTo (primaryTerm .get ()));
4354
+ assertThat (noOp .getSeqNo (), equalTo (seqNo ));
4348
4355
assertThat (noOp .getFailure (), nullValue ());
4349
4356
break ;
4350
4357
default :
0 commit comments