"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "tests/integration/v3_alarm_test.go" between
etcd-3.5.6.tar.gz and etcd-3.5.7.tar.gz

About: etcd is a distributed reliable key-value store for the most critical data of a distributed system (written in "Go").

v3_alarm_test.go  (etcd-3.5.6)	:	v3_alarm_test.go  (etcd-3.5.7)
skipping to change at line 93		skipping to change at line 93
if len(resp.Alarms) != 0 {		if len(resp.Alarms) != 0 {
break		break
}		}
select {		select {
case <-stopc:		case <-stopc:
t.Fatalf("timed out waiting for alarm")		t.Fatalf("timed out waiting for alarm")
case <-time.After(10 * time.Millisecond):		case <-time.After(10 * time.Millisecond):
}		}
}		}
		// txn with non-mutating Ops should go through when NOSPACE alarm is rais
		ed
		_, err = kvc0.Txn(context.TODO(), &pb.TxnRequest{
		Compare: []*pb.Compare{
		{
		Key: key,
		Result: pb.Compare_EQUAL,
		Target: pb.Compare_CREATE,
		TargetUnion: &pb.Compare_CreateRevision{CreateRev
		ision: 0},
		},
		},
		Success: []*pb.RequestOp{
		{
		Request: &pb.RequestOp_RequestDeleteRange{
		RequestDeleteRange: &pb.DeleteRangeReques
		t{
		Key: key,
		},
		},
		},
		},
		})
		if err != nil {
		t.Fatal(err)
		}
ctx, cancel := context.WithTimeout(context.TODO(), RequestWaitTimeout)		ctx, cancel := context.WithTimeout(context.TODO(), RequestWaitTimeout)
defer cancel()		defer cancel()
// small quota machine should reject put		// small quota machine should reject put
if _, err := kvc0.Put(ctx, &pb.PutRequest{Key: key, Value: smallbuf}); er r == nil {		if _, err := kvc0.Put(ctx, &pb.PutRequest{Key: key, Value: smallbuf}); er r == nil {
t.Fatalf("past-quota instance should reject put")		t.Fatalf("past-quota instance should reject put")
}		}
// large quota machine should reject put		// large quota machine should reject put
if _, err := kvc1.Put(ctx, &pb.PutRequest{Key: key, Value: smallbuf}); er r == nil {		if _, err := kvc1.Put(ctx, &pb.PutRequest{Key: key, Value: smallbuf}); er r == nil {
End of changes. 1 change blocks.
0 lines changed or deleted		27 lines changed or added

---