v3_grpc_test.go 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857
  1. // Copyright 2016 CoreOS, Inc.
  2. //
  3. // Licensed under the Apache License, Version 2.0 (the "License");
  4. // you may not use this file except in compliance with the License.
  5. // You may obtain a copy of the License at
  6. //
  7. // http://www.apache.org/licenses/LICENSE-2.0
  8. //
  9. // Unless required by applicable law or agreed to in writing, software
  10. // distributed under the License is distributed on an "AS IS" BASIS,
  11. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. // See the License for the specific language governing permissions and
  13. // limitations under the License.
  14. package integration
  15. import (
  16. "fmt"
  17. "reflect"
  18. "testing"
  19. "time"
  20. "github.com/coreos/etcd/etcdserver/api/v3rpc"
  21. "github.com/coreos/etcd/etcdserver/api/v3rpc/rpctypes"
  22. pb "github.com/coreos/etcd/etcdserver/etcdserverpb"
  23. "github.com/coreos/etcd/pkg/testutil"
  24. "golang.org/x/net/context"
  25. "google.golang.org/grpc"
  26. )
  27. // TestV3PutOverwrite puts a key with the v3 api to a random cluster member,
  28. // overwrites it, then checks that the change was applied.
  29. func TestV3PutOverwrite(t *testing.T) {
  30. defer testutil.AfterTest(t)
  31. clus := NewClusterV3(t, &ClusterConfig{Size: 3})
  32. defer clus.Terminate(t)
  33. kvc := toGRPC(clus.RandClient()).KV
  34. key := []byte("foo")
  35. reqput := &pb.PutRequest{Key: key, Value: []byte("bar")}
  36. respput, err := kvc.Put(context.TODO(), reqput)
  37. if err != nil {
  38. t.Fatalf("couldn't put key (%v)", err)
  39. }
  40. // overwrite
  41. reqput.Value = []byte("baz")
  42. respput2, err := kvc.Put(context.TODO(), reqput)
  43. if err != nil {
  44. t.Fatalf("couldn't put key (%v)", err)
  45. }
  46. if respput2.Header.Revision <= respput.Header.Revision {
  47. t.Fatalf("expected newer revision on overwrite, got %v <= %v",
  48. respput2.Header.Revision, respput.Header.Revision)
  49. }
  50. reqrange := &pb.RangeRequest{Key: key}
  51. resprange, err := kvc.Range(context.TODO(), reqrange)
  52. if err != nil {
  53. t.Fatalf("couldn't get key (%v)", err)
  54. }
  55. if len(resprange.Kvs) != 1 {
  56. t.Fatalf("expected 1 key, got %v", len(resprange.Kvs))
  57. }
  58. kv := resprange.Kvs[0]
  59. if kv.ModRevision <= kv.CreateRevision {
  60. t.Errorf("expected modRev > createRev, got %d <= %d",
  61. kv.ModRevision, kv.CreateRevision)
  62. }
  63. if !reflect.DeepEqual(reqput.Value, kv.Value) {
  64. t.Errorf("expected value %v, got %v", reqput.Value, kv.Value)
  65. }
  66. }
  67. func TestV3TxnTooManyOps(t *testing.T) {
  68. defer testutil.AfterTest(t)
  69. clus := NewClusterV3(t, &ClusterConfig{Size: 3})
  70. defer clus.Terminate(t)
  71. kvc := toGRPC(clus.RandClient()).KV
  72. // unique keys
  73. i := new(int)
  74. keyf := func() []byte {
  75. *i++
  76. return []byte(fmt.Sprintf("key-%d", i))
  77. }
  78. addCompareOps := func(txn *pb.TxnRequest) {
  79. txn.Compare = append(txn.Compare,
  80. &pb.Compare{
  81. Result: pb.Compare_GREATER,
  82. Target: pb.Compare_CREATE,
  83. Key: keyf(),
  84. })
  85. }
  86. addSuccessOps := func(txn *pb.TxnRequest) {
  87. txn.Success = append(txn.Success,
  88. &pb.RequestUnion{
  89. Request: &pb.RequestUnion_RequestPut{
  90. RequestPut: &pb.PutRequest{
  91. Key: keyf(),
  92. Value: []byte("bar"),
  93. },
  94. },
  95. })
  96. }
  97. addFailureOps := func(txn *pb.TxnRequest) {
  98. txn.Failure = append(txn.Failure,
  99. &pb.RequestUnion{
  100. Request: &pb.RequestUnion_RequestPut{
  101. RequestPut: &pb.PutRequest{
  102. Key: keyf(),
  103. Value: []byte("bar"),
  104. },
  105. },
  106. })
  107. }
  108. tests := []func(txn *pb.TxnRequest){
  109. addCompareOps,
  110. addSuccessOps,
  111. addFailureOps,
  112. }
  113. for i, tt := range tests {
  114. txn := &pb.TxnRequest{}
  115. for j := 0; j < v3rpc.MaxOpsPerTxn+1; j++ {
  116. tt(txn)
  117. }
  118. _, err := kvc.Txn(context.Background(), txn)
  119. if err != rpctypes.ErrTooManyOps {
  120. t.Errorf("#%d: err = %v, want %v", i, err, rpctypes.ErrTooManyOps)
  121. }
  122. }
  123. }
  124. func TestV3TxnDuplicateKeys(t *testing.T) {
  125. defer testutil.AfterTest(t)
  126. clus := NewClusterV3(t, &ClusterConfig{Size: 3})
  127. defer clus.Terminate(t)
  128. putreq := &pb.RequestUnion{Request: &pb.RequestUnion_RequestPut{RequestPut: &pb.PutRequest{Key: []byte("abc"), Value: []byte("def")}}}
  129. delKeyReq := &pb.RequestUnion{Request: &pb.RequestUnion_RequestDeleteRange{
  130. RequestDeleteRange: &pb.DeleteRangeRequest{
  131. Key: []byte("abc"),
  132. },
  133. },
  134. }
  135. delInRangeReq := &pb.RequestUnion{Request: &pb.RequestUnion_RequestDeleteRange{
  136. RequestDeleteRange: &pb.DeleteRangeRequest{
  137. Key: []byte("a"), RangeEnd: []byte("b"),
  138. },
  139. },
  140. }
  141. delOutOfRangeReq := &pb.RequestUnion{Request: &pb.RequestUnion_RequestDeleteRange{
  142. RequestDeleteRange: &pb.DeleteRangeRequest{
  143. Key: []byte("abb"), RangeEnd: []byte("abc"),
  144. },
  145. },
  146. }
  147. kvc := toGRPC(clus.RandClient()).KV
  148. tests := []struct {
  149. txnSuccess []*pb.RequestUnion
  150. werr error
  151. }{
  152. {
  153. txnSuccess: []*pb.RequestUnion{putreq, putreq},
  154. werr: rpctypes.ErrDuplicateKey,
  155. },
  156. {
  157. txnSuccess: []*pb.RequestUnion{putreq, delKeyReq},
  158. werr: rpctypes.ErrDuplicateKey,
  159. },
  160. {
  161. txnSuccess: []*pb.RequestUnion{putreq, delInRangeReq},
  162. werr: rpctypes.ErrDuplicateKey,
  163. },
  164. {
  165. txnSuccess: []*pb.RequestUnion{delKeyReq, delInRangeReq, delKeyReq, delInRangeReq},
  166. werr: nil,
  167. },
  168. {
  169. txnSuccess: []*pb.RequestUnion{putreq, delOutOfRangeReq},
  170. werr: nil,
  171. },
  172. }
  173. for i, tt := range tests {
  174. txn := &pb.TxnRequest{Success: tt.txnSuccess}
  175. _, err := kvc.Txn(context.Background(), txn)
  176. if err != tt.werr {
  177. t.Errorf("#%d: err = %v, want %v", i, err, tt.werr)
  178. }
  179. }
  180. }
  181. // TestV3PutMissingLease ensures that a Put on a key with a bogus lease fails.
  182. func TestV3PutMissingLease(t *testing.T) {
  183. defer testutil.AfterTest(t)
  184. clus := NewClusterV3(t, &ClusterConfig{Size: 3})
  185. defer clus.Terminate(t)
  186. kvc := toGRPC(clus.RandClient()).KV
  187. key := []byte("foo")
  188. preq := &pb.PutRequest{Key: key, Lease: 123456}
  189. tests := []func(){
  190. // put case
  191. func() {
  192. if presp, err := kvc.Put(context.TODO(), preq); err == nil {
  193. t.Errorf("succeeded put key. req: %v. resp: %v", preq, presp)
  194. }
  195. },
  196. // txn success case
  197. func() {
  198. txn := &pb.TxnRequest{}
  199. txn.Success = append(txn.Success, &pb.RequestUnion{
  200. Request: &pb.RequestUnion_RequestPut{
  201. RequestPut: preq}})
  202. if tresp, err := kvc.Txn(context.TODO(), txn); err == nil {
  203. t.Errorf("succeeded txn success. req: %v. resp: %v", txn, tresp)
  204. }
  205. },
  206. // txn failure case
  207. func() {
  208. txn := &pb.TxnRequest{}
  209. txn.Failure = append(txn.Failure, &pb.RequestUnion{
  210. Request: &pb.RequestUnion_RequestPut{
  211. RequestPut: preq}})
  212. cmp := &pb.Compare{
  213. Result: pb.Compare_GREATER,
  214. Target: pb.Compare_CREATE,
  215. Key: []byte("bar"),
  216. }
  217. txn.Compare = append(txn.Compare, cmp)
  218. if tresp, err := kvc.Txn(context.TODO(), txn); err == nil {
  219. t.Errorf("succeeded txn failure. req: %v. resp: %v", txn, tresp)
  220. }
  221. },
  222. // ignore bad lease in failure on success txn
  223. func() {
  224. txn := &pb.TxnRequest{}
  225. rreq := &pb.RangeRequest{Key: []byte("bar")}
  226. txn.Success = append(txn.Success, &pb.RequestUnion{
  227. Request: &pb.RequestUnion_RequestRange{
  228. RequestRange: rreq}})
  229. txn.Failure = append(txn.Failure, &pb.RequestUnion{
  230. Request: &pb.RequestUnion_RequestPut{
  231. RequestPut: preq}})
  232. if tresp, err := kvc.Txn(context.TODO(), txn); err != nil {
  233. t.Errorf("failed good txn. req: %v. resp: %v", txn, tresp)
  234. }
  235. },
  236. }
  237. for i, f := range tests {
  238. f()
  239. // key shouldn't have been stored
  240. rreq := &pb.RangeRequest{Key: key}
  241. rresp, err := kvc.Range(context.TODO(), rreq)
  242. if err != nil {
  243. t.Errorf("#%d. could not rangereq (%v)", i, err)
  244. } else if len(rresp.Kvs) != 0 {
  245. t.Errorf("#%d. expected no keys, got %v", i, rresp)
  246. }
  247. }
  248. }
  249. // TestV3DeleteRange tests various edge cases in the DeleteRange API.
  250. func TestV3DeleteRange(t *testing.T) {
  251. defer testutil.AfterTest(t)
  252. tests := []struct {
  253. keySet []string
  254. begin string
  255. end string
  256. wantSet [][]byte
  257. deleted int64
  258. }{
  259. // delete middle
  260. {
  261. []string{"foo", "foo/abc", "fop"},
  262. "foo/", "fop",
  263. [][]byte{[]byte("foo"), []byte("fop")}, 1,
  264. },
  265. // no delete
  266. {
  267. []string{"foo", "foo/abc", "fop"},
  268. "foo/", "foo/",
  269. [][]byte{[]byte("foo"), []byte("foo/abc"), []byte("fop")}, 0,
  270. },
  271. // delete first
  272. {
  273. []string{"foo", "foo/abc", "fop"},
  274. "fo", "fop",
  275. [][]byte{[]byte("fop")}, 2,
  276. },
  277. // delete tail
  278. {
  279. []string{"foo", "foo/abc", "fop"},
  280. "foo/", "fos",
  281. [][]byte{[]byte("foo")}, 2,
  282. },
  283. // delete exact
  284. {
  285. []string{"foo", "foo/abc", "fop"},
  286. "foo/abc", "",
  287. [][]byte{[]byte("foo"), []byte("fop")}, 1,
  288. },
  289. // delete none, [x,x)
  290. {
  291. []string{"foo"},
  292. "foo", "foo",
  293. [][]byte{[]byte("foo")}, 0,
  294. },
  295. }
  296. for i, tt := range tests {
  297. clus := NewClusterV3(t, &ClusterConfig{Size: 3})
  298. kvc := toGRPC(clus.RandClient()).KV
  299. ks := tt.keySet
  300. for j := range ks {
  301. reqput := &pb.PutRequest{Key: []byte(ks[j]), Value: []byte{}}
  302. _, err := kvc.Put(context.TODO(), reqput)
  303. if err != nil {
  304. t.Fatalf("couldn't put key (%v)", err)
  305. }
  306. }
  307. dreq := &pb.DeleteRangeRequest{
  308. Key: []byte(tt.begin),
  309. RangeEnd: []byte(tt.end)}
  310. dresp, err := kvc.DeleteRange(context.TODO(), dreq)
  311. if err != nil {
  312. t.Fatalf("couldn't delete range on test %d (%v)", i, err)
  313. }
  314. if tt.deleted != dresp.Deleted {
  315. t.Errorf("expected %d on test %v, got %d", tt.deleted, i, dresp.Deleted)
  316. }
  317. rreq := &pb.RangeRequest{Key: []byte{0x0}, RangeEnd: []byte{0xff}}
  318. rresp, err := kvc.Range(context.TODO(), rreq)
  319. if err != nil {
  320. t.Errorf("couldn't get range on test %v (%v)", i, err)
  321. }
  322. if dresp.Header.Revision != rresp.Header.Revision {
  323. t.Errorf("expected revision %v, got %v",
  324. dresp.Header.Revision, rresp.Header.Revision)
  325. }
  326. keys := [][]byte{}
  327. for j := range rresp.Kvs {
  328. keys = append(keys, rresp.Kvs[j].Key)
  329. }
  330. if !reflect.DeepEqual(tt.wantSet, keys) {
  331. t.Errorf("expected %v on test %v, got %v", tt.wantSet, i, keys)
  332. }
  333. // can't defer because tcp ports will be in use
  334. clus.Terminate(t)
  335. }
  336. }
  337. // TestV3TxnInvaildRange tests txn
  338. func TestV3TxnInvaildRange(t *testing.T) {
  339. defer testutil.AfterTest(t)
  340. clus := NewClusterV3(t, &ClusterConfig{Size: 3})
  341. defer clus.Terminate(t)
  342. kvc := toGRPC(clus.RandClient()).KV
  343. preq := &pb.PutRequest{Key: []byte("foo"), Value: []byte("bar")}
  344. for i := 0; i < 3; i++ {
  345. _, err := kvc.Put(context.Background(), preq)
  346. if err != nil {
  347. t.Fatalf("couldn't put key (%v)", err)
  348. }
  349. }
  350. _, err := kvc.Compact(context.Background(), &pb.CompactionRequest{Revision: 2})
  351. if err != nil {
  352. t.Fatalf("couldn't compact kv space (%v)", err)
  353. }
  354. // future rev
  355. txn := &pb.TxnRequest{}
  356. txn.Success = append(txn.Success, &pb.RequestUnion{
  357. Request: &pb.RequestUnion_RequestPut{
  358. RequestPut: preq}})
  359. rreq := &pb.RangeRequest{Key: []byte("foo"), Revision: 100}
  360. txn.Success = append(txn.Success, &pb.RequestUnion{
  361. Request: &pb.RequestUnion_RequestRange{
  362. RequestRange: rreq}})
  363. if _, err := kvc.Txn(context.TODO(), txn); err != rpctypes.ErrFutureRev {
  364. t.Errorf("err = %v, want %v", err, rpctypes.ErrFutureRev)
  365. }
  366. // compacted rev
  367. tv, _ := txn.Success[1].Request.(*pb.RequestUnion_RequestRange)
  368. tv.RequestRange.Revision = 1
  369. if _, err := kvc.Txn(context.TODO(), txn); err != rpctypes.ErrCompacted {
  370. t.Errorf("err = %v, want %v", err, rpctypes.ErrCompacted)
  371. }
  372. }
  373. func TestV3TooLargeRequest(t *testing.T) {
  374. defer testutil.AfterTest(t)
  375. clus := NewClusterV3(t, &ClusterConfig{Size: 3})
  376. defer clus.Terminate(t)
  377. kvc := toGRPC(clus.RandClient()).KV
  378. // 2MB request value
  379. largeV := make([]byte, 2*1024*1024)
  380. preq := &pb.PutRequest{Key: []byte("foo"), Value: largeV}
  381. _, err := kvc.Put(context.Background(), preq)
  382. if err != rpctypes.ErrRequestTooLarge {
  383. t.Errorf("err = %v, want %v", err, rpctypes.ErrRequestTooLarge)
  384. }
  385. }
  386. // TestV3Hash tests hash.
  387. func TestV3Hash(t *testing.T) {
  388. defer testutil.AfterTest(t)
  389. clus := NewClusterV3(t, &ClusterConfig{Size: 3})
  390. defer clus.Terminate(t)
  391. cli := clus.RandClient()
  392. kvc := toGRPC(cli).KV
  393. m := toGRPC(cli).Maintenance
  394. preq := &pb.PutRequest{Key: []byte("foo"), Value: []byte("bar")}
  395. for i := 0; i < 3; i++ {
  396. _, err := kvc.Put(context.Background(), preq)
  397. if err != nil {
  398. t.Fatalf("couldn't put key (%v)", err)
  399. }
  400. }
  401. resp, err := m.Hash(context.Background(), &pb.HashRequest{})
  402. if err != nil || resp.Hash == 0 {
  403. t.Fatalf("couldn't hash (%v, hash %d)", err, resp.Hash)
  404. }
  405. }
  406. // TestV3StorageQuotaAPI tests the V3 server respects quotas at the API layer
  407. func TestV3StorageQuotaAPI(t *testing.T) {
  408. defer testutil.AfterTest(t)
  409. clus := NewClusterV3(t, &ClusterConfig{Size: 3})
  410. clus.Members[0].QuotaBackendBytes = 64 * 1024
  411. clus.Members[0].Stop(t)
  412. clus.Members[0].Restart(t)
  413. defer clus.Terminate(t)
  414. kvc := toGRPC(clus.Client(0)).KV
  415. key := []byte("abc")
  416. // test small put that fits in quota
  417. smallbuf := make([]byte, 512)
  418. if _, err := kvc.Put(context.TODO(), &pb.PutRequest{Key: key, Value: smallbuf}); err != nil {
  419. t.Fatal(err)
  420. }
  421. // test big put
  422. bigbuf := make([]byte, 64*1024)
  423. _, err := kvc.Put(context.TODO(), &pb.PutRequest{Key: key, Value: bigbuf})
  424. if err == nil || err != rpctypes.ErrNoSpace {
  425. t.Fatalf("big put got %v, expected %v", err, rpctypes.ErrNoSpace)
  426. }
  427. // test big txn
  428. puttxn := &pb.RequestUnion{
  429. Request: &pb.RequestUnion_RequestPut{
  430. RequestPut: &pb.PutRequest{
  431. Key: key,
  432. Value: bigbuf,
  433. },
  434. },
  435. }
  436. txnreq := &pb.TxnRequest{}
  437. txnreq.Success = append(txnreq.Success, puttxn)
  438. _, txnerr := kvc.Txn(context.TODO(), txnreq)
  439. if txnerr == nil || err != rpctypes.ErrNoSpace {
  440. t.Fatalf("big txn got %v, expected %v", err, rpctypes.ErrNoSpace)
  441. }
  442. }
  443. // TestV3StorageQuotaApply tests the V3 server respects quotas during apply
  444. func TestV3StorageQuotaApply(t *testing.T) {
  445. testutil.AfterTest(t)
  446. clus := NewClusterV3(t, &ClusterConfig{Size: 2})
  447. defer clus.Terminate(t)
  448. kvc0 := toGRPC(clus.Client(0)).KV
  449. kvc1 := toGRPC(clus.Client(1)).KV
  450. // force a node to have a different quota
  451. clus.Members[0].QuotaBackendBytes = 64 * 1024
  452. clus.Members[0].Stop(t)
  453. clus.Members[0].Restart(t)
  454. clus.waitLeader(t, clus.Members)
  455. key := []byte("abc")
  456. // test small put still works
  457. smallbuf := make([]byte, 1024)
  458. _, serr := kvc0.Put(context.TODO(), &pb.PutRequest{Key: key, Value: smallbuf})
  459. if serr != nil {
  460. t.Fatal(serr)
  461. }
  462. // test big put
  463. bigbuf := make([]byte, 64*1024)
  464. _, err := kvc1.Put(context.TODO(), &pb.PutRequest{Key: key, Value: bigbuf})
  465. if err != nil {
  466. t.Fatal(err)
  467. }
  468. // small quota machine should reject put
  469. // first, synchronize with the cluster via quorum get
  470. kvc0.Range(context.TODO(), &pb.RangeRequest{Key: []byte("foo")})
  471. if _, err := kvc0.Put(context.TODO(), &pb.PutRequest{Key: key, Value: smallbuf}); err == nil {
  472. t.Fatalf("past-quota instance should reject put")
  473. }
  474. // large quota machine should reject put
  475. if _, err := kvc1.Put(context.TODO(), &pb.PutRequest{Key: key, Value: smallbuf}); err == nil {
  476. t.Fatalf("past-quota instance should reject put")
  477. }
  478. // reset large quota node to ensure alarm persisted
  479. clus.Members[1].Stop(t)
  480. clus.Members[1].Restart(t)
  481. clus.waitLeader(t, clus.Members)
  482. if _, err := kvc1.Put(context.TODO(), &pb.PutRequest{Key: key, Value: smallbuf}); err == nil {
  483. t.Fatalf("alarmed instance should reject put after reset")
  484. }
  485. }
  486. // TestV3AlarmDeactivate ensures that space alarms can be deactivated so puts go through.
  487. func TestV3AlarmDeactivate(t *testing.T) {
  488. clus := NewClusterV3(t, &ClusterConfig{Size: 3})
  489. defer clus.Terminate(t)
  490. kvc := toGRPC(clus.RandClient()).KV
  491. mt := toGRPC(clus.RandClient()).Maintenance
  492. alarmReq := &pb.AlarmRequest{
  493. MemberID: 123,
  494. Action: pb.AlarmRequest_ACTIVATE,
  495. Alarm: pb.AlarmType_NOSPACE,
  496. }
  497. if _, err := mt.Alarm(context.TODO(), alarmReq); err != nil {
  498. t.Fatal(err)
  499. }
  500. key := []byte("abc")
  501. smallbuf := make([]byte, 512)
  502. _, err := kvc.Put(context.TODO(), &pb.PutRequest{Key: key, Value: smallbuf})
  503. if err == nil && err != rpctypes.ErrNoSpace {
  504. t.Fatalf("put got %v, expected %v", err, rpctypes.ErrNoSpace)
  505. }
  506. alarmReq.Action = pb.AlarmRequest_DEACTIVATE
  507. if _, err = mt.Alarm(context.TODO(), alarmReq); err != nil {
  508. t.Fatal(err)
  509. }
  510. if _, err = kvc.Put(context.TODO(), &pb.PutRequest{Key: key, Value: smallbuf}); err != nil {
  511. t.Fatal(err)
  512. }
  513. }
  514. func TestV3RangeRequest(t *testing.T) {
  515. defer testutil.AfterTest(t)
  516. tests := []struct {
  517. putKeys []string
  518. reqs []pb.RangeRequest
  519. wresps [][]string
  520. wmores []bool
  521. }{
  522. // single key
  523. {
  524. []string{"foo", "bar"},
  525. []pb.RangeRequest{
  526. // exists
  527. {Key: []byte("foo")},
  528. // doesn't exist
  529. {Key: []byte("baz")},
  530. },
  531. [][]string{
  532. {"foo"},
  533. {},
  534. },
  535. []bool{false, false},
  536. },
  537. // multi-key
  538. {
  539. []string{"a", "b", "c", "d", "e"},
  540. []pb.RangeRequest{
  541. // all in range
  542. {Key: []byte("a"), RangeEnd: []byte("z")},
  543. // [b, d)
  544. {Key: []byte("b"), RangeEnd: []byte("d")},
  545. // out of range
  546. {Key: []byte("f"), RangeEnd: []byte("z")},
  547. // [c,c) = empty
  548. {Key: []byte("c"), RangeEnd: []byte("c")},
  549. // [d, b) = empty
  550. {Key: []byte("d"), RangeEnd: []byte("b")},
  551. // ["\0", "\0") => all in range
  552. {Key: []byte{0}, RangeEnd: []byte{0}},
  553. },
  554. [][]string{
  555. {"a", "b", "c", "d", "e"},
  556. {"b", "c"},
  557. {},
  558. {},
  559. {},
  560. {"a", "b", "c", "d", "e"},
  561. },
  562. []bool{false, false, false, false, false, false},
  563. },
  564. // revision
  565. {
  566. []string{"a", "b", "c", "d", "e"},
  567. []pb.RangeRequest{
  568. {Key: []byte("a"), RangeEnd: []byte("z"), Revision: 0},
  569. {Key: []byte("a"), RangeEnd: []byte("z"), Revision: 1},
  570. {Key: []byte("a"), RangeEnd: []byte("z"), Revision: 2},
  571. {Key: []byte("a"), RangeEnd: []byte("z"), Revision: 3},
  572. },
  573. [][]string{
  574. {"a", "b", "c", "d", "e"},
  575. {},
  576. {"a"},
  577. {"a", "b"},
  578. },
  579. []bool{false, false, false, false},
  580. },
  581. // limit
  582. {
  583. []string{"foo", "bar"},
  584. []pb.RangeRequest{
  585. // more
  586. {Key: []byte("a"), RangeEnd: []byte("z"), Limit: 1},
  587. // no more
  588. {Key: []byte("a"), RangeEnd: []byte("z"), Limit: 2},
  589. },
  590. [][]string{
  591. {"bar"},
  592. {"bar", "foo"},
  593. },
  594. []bool{true, false},
  595. },
  596. // sort
  597. {
  598. []string{"b", "a", "c", "d", "c"},
  599. []pb.RangeRequest{
  600. {
  601. Key: []byte("a"), RangeEnd: []byte("z"),
  602. Limit: 1,
  603. SortOrder: pb.RangeRequest_ASCEND,
  604. SortTarget: pb.RangeRequest_KEY,
  605. },
  606. {
  607. Key: []byte("a"), RangeEnd: []byte("z"),
  608. Limit: 1,
  609. SortOrder: pb.RangeRequest_DESCEND,
  610. SortTarget: pb.RangeRequest_KEY,
  611. },
  612. {
  613. Key: []byte("a"), RangeEnd: []byte("z"),
  614. Limit: 1,
  615. SortOrder: pb.RangeRequest_ASCEND,
  616. SortTarget: pb.RangeRequest_CREATE,
  617. },
  618. {
  619. Key: []byte("a"), RangeEnd: []byte("z"),
  620. Limit: 1,
  621. SortOrder: pb.RangeRequest_DESCEND,
  622. SortTarget: pb.RangeRequest_MOD,
  623. },
  624. {
  625. Key: []byte("z"), RangeEnd: []byte("z"),
  626. Limit: 1,
  627. SortOrder: pb.RangeRequest_DESCEND,
  628. SortTarget: pb.RangeRequest_CREATE,
  629. },
  630. },
  631. [][]string{
  632. {"a"},
  633. {"d"},
  634. {"b"},
  635. {"c"},
  636. {},
  637. },
  638. []bool{true, true, true, true, false},
  639. },
  640. }
  641. for i, tt := range tests {
  642. clus := NewClusterV3(t, &ClusterConfig{Size: 3})
  643. for _, k := range tt.putKeys {
  644. kvc := toGRPC(clus.RandClient()).KV
  645. req := &pb.PutRequest{Key: []byte(k), Value: []byte("bar")}
  646. if _, err := kvc.Put(context.TODO(), req); err != nil {
  647. t.Fatalf("#%d: couldn't put key (%v)", i, err)
  648. }
  649. }
  650. for j, req := range tt.reqs {
  651. kvc := toGRPC(clus.RandClient()).KV
  652. resp, err := kvc.Range(context.TODO(), &req)
  653. if err != nil {
  654. t.Errorf("#%d.%d: Range error: %v", i, j, err)
  655. continue
  656. }
  657. if len(resp.Kvs) != len(tt.wresps[j]) {
  658. t.Errorf("#%d.%d: bad len(resp.Kvs). got = %d, want = %d, ", i, j, len(resp.Kvs), len(tt.wresps[j]))
  659. continue
  660. }
  661. for k, wKey := range tt.wresps[j] {
  662. respKey := string(resp.Kvs[k].Key)
  663. if respKey != wKey {
  664. t.Errorf("#%d.%d: key[%d]. got = %v, want = %v, ", i, j, k, respKey, wKey)
  665. }
  666. }
  667. if resp.More != tt.wmores[j] {
  668. t.Errorf("#%d.%d: bad more. got = %v, want = %v, ", i, j, resp.More, tt.wmores[j])
  669. }
  670. wrev := int64(len(tt.putKeys) + 1)
  671. if resp.Header.Revision != wrev {
  672. t.Errorf("#%d.%d: bad header revision. got = %d. want = %d", i, j, resp.Header.Revision, wrev)
  673. }
  674. }
  675. clus.Terminate(t)
  676. }
  677. }
  678. func newClusterV3NoClients(t *testing.T, cfg *ClusterConfig) *ClusterV3 {
  679. cfg.UseGRPC = true
  680. clus := &ClusterV3{cluster: NewClusterByConfig(t, cfg)}
  681. clus.Launch(t)
  682. return clus
  683. }
  684. // TestTLSGRPCRejectInsecureClient checks that connection is rejected if server is TLS but not client.
  685. func TestTLSGRPCRejectInsecureClient(t *testing.T) {
  686. defer testutil.AfterTest(t)
  687. cfg := ClusterConfig{Size: 3, ClientTLS: &testTLSInfo}
  688. clus := newClusterV3NoClients(t, &cfg)
  689. defer clus.Terminate(t)
  690. // nil out TLS field so client will use an insecure connection
  691. clus.Members[0].ClientTLSInfo = nil
  692. client, err := NewClientV3(clus.Members[0])
  693. if err != nil && err != grpc.ErrClientConnTimeout {
  694. t.Fatalf("unexpected error (%v)", err)
  695. } else if client == nil {
  696. // Ideally, no client would be returned. However, grpc will
  697. // return a connection without trying to handshake first so
  698. // the connection appears OK.
  699. return
  700. }
  701. defer client.Close()
  702. ctx, cancel := context.WithTimeout(context.TODO(), 5*time.Second)
  703. conn := client.ActiveConnection()
  704. st, err := conn.State()
  705. if err != nil {
  706. t.Fatal(err)
  707. } else if st != grpc.Ready {
  708. t.Fatalf("expected Ready, got %v", st)
  709. }
  710. // rpc will fail to handshake, triggering a connection state change
  711. donec := make(chan error, 1)
  712. go func() {
  713. reqput := &pb.PutRequest{Key: []byte("foo"), Value: []byte("bar")}
  714. _, perr := toGRPC(client).KV.Put(ctx, reqput)
  715. donec <- perr
  716. }()
  717. st, err = conn.WaitForStateChange(ctx, st)
  718. if err != nil {
  719. t.Fatalf("unexpected error waiting for change (%v)", err)
  720. } else if st == grpc.Ready {
  721. t.Fatalf("expected failure state, got %v", st)
  722. }
  723. cancel()
  724. if perr := <-donec; perr == nil {
  725. t.Fatalf("expected client error on put")
  726. }
  727. }
  728. // TestTLSGRPCRejectSecureClient checks that connection is rejected if client is TLS but not server.
  729. func TestTLSGRPCRejectSecureClient(t *testing.T) {
  730. defer testutil.AfterTest(t)
  731. cfg := ClusterConfig{Size: 3}
  732. clus := newClusterV3NoClients(t, &cfg)
  733. defer clus.Terminate(t)
  734. clus.Members[0].ClientTLSInfo = &testTLSInfo
  735. client, err := NewClientV3(clus.Members[0])
  736. if client != nil || err == nil {
  737. t.Fatalf("expected no client")
  738. } else if err != grpc.ErrClientConnTimeout {
  739. t.Fatalf("unexpected error (%v)", err)
  740. }
  741. }
  742. // TestTLSGRPCAcceptSecureAll checks that connection is accepted if both client and server are TLS
  743. func TestTLSGRPCAcceptSecureAll(t *testing.T) {
  744. defer testutil.AfterTest(t)
  745. cfg := ClusterConfig{Size: 3, ClientTLS: &testTLSInfo}
  746. clus := newClusterV3NoClients(t, &cfg)
  747. defer clus.Terminate(t)
  748. client, err := NewClientV3(clus.Members[0])
  749. if err != nil {
  750. t.Fatalf("expected tls client (%v)", err)
  751. }
  752. defer client.Close()
  753. reqput := &pb.PutRequest{Key: []byte("foo"), Value: []byte("bar")}
  754. if _, err := toGRPC(client).KV.Put(context.TODO(), reqput); err != nil {
  755. t.Fatalf("unexpected error on put over tls (%v)", err)
  756. }
  757. }