← Back to branch summary

~rogpeppe/gozk/factor-out-service

« back to all changes in this revision

Viewing changes to gozk_test.go

  • Committer: Gustavo Niemeyer
  • Date: 2011-01-17 07:43:00 UTC
  • Revision ID: gustavo@niemeyer.net-20110117074300-mptpptqo4wycotuc
Makefile fixes + make gofmt.

Show diffs side-by-side

added added

removed removed

Lines of Context:
gozk_test.go
2
2
 
3
3
 
4
4
import (
5
 
    . "gocheck"
 
5
    .   "gocheck"
6
6
    "gozk"
7
7
)
8
8
 
132
132
func (s *S) TestCreateAndGet(c *C) {
133
133
    zk, _ := s.init(c)
134
134
 
135
 
    path, err := zk.Create("/test-", "bababum", gozk.SEQUENCE | gozk.EPHEMERAL,
136
 
                           gozk.WorldACL(gozk.PERM_ALL))
 
135
    path, err := zk.Create("/test-", "bababum", gozk.SEQUENCE|gozk.EPHEMERAL,
 
136
        gozk.WorldACL(gozk.PERM_ALL))
137
137
    c.Assert(err, IsNil)
138
138
    c.Assert(path, Matches, "/test-[0-9]+")
139
139
 
150
150
    zk, _ := s.init(c)
151
151
 
152
152
    _, err := zk.Create("/test", "", gozk.EPHEMERAL,
153
 
                        gozk.WorldACL(gozk.PERM_ALL))
 
153
        gozk.WorldACL(gozk.PERM_ALL))
154
154
    c.Assert(err, IsNil)
155
155
 
156
156
    stat, err := zk.Set("/test", "bababum", -1) // Any version.
170
170
    c.Check(gozk.CountPendingWatches(), Equals, 1)
171
171
 
172
172
    _, err := zk.Create("/test", "one", gozk.EPHEMERAL,
173
 
                        gozk.WorldACL(gozk.PERM_ALL))
 
173
        gozk.WorldACL(gozk.PERM_ALL))
174
174
    c.Assert(err, IsNil)
175
175
 
176
176
    data, stat, watch, err := zk.GetW("/test")
232
232
    c.Check(gozk.CountPendingWatches(), Equals, 1)
233
233
 
234
234
    _, err := zk.Create("/test", "one", gozk.EPHEMERAL,
235
 
                        gozk.WorldACL(gozk.PERM_ALL))
 
235
        gozk.WorldACL(gozk.PERM_ALL))
236
236
    c.Assert(err, IsNil)
237
237
 
238
238
    _, _, _, err = zk.GetW("/test")
289
289
    c.Check(gozk.CountPendingWatches(), Equals, 2)
290
290
 
291
291
    _, err = zk.Create("/test1", "", gozk.EPHEMERAL,
292
 
                       gozk.WorldACL(gozk.PERM_ALL))
 
292
        gozk.WorldACL(gozk.PERM_ALL))
293
293
    c.Assert(err, IsNil)
294
294
 
295
295
    event := <-watch
311
311
    c.Check(gozk.CountPendingWatches(), Equals, 2)
312
312
 
313
313
    _, err = zk.Create("/test2", "", gozk.EPHEMERAL,
314
 
                       gozk.WorldACL(gozk.PERM_ALL))
 
314
        gozk.WorldACL(gozk.PERM_ALL))
315
315
    c.Assert(err, IsNil)
316
316
 
317
317
    event = <-watch
365
365
    c.Assert(ok, Equals, false)
366
366
 
367
367
    _, err = zk.Create("/test", "", gozk.EPHEMERAL,
368
 
                       gozk.WorldACL(gozk.PERM_ALL))
 
368
        gozk.WorldACL(gozk.PERM_ALL))
369
369
    c.Assert(err, IsNil)
370
370
 
371
371
    event := <-watch
403
403
    zk, _ := s.init(c)
404
404
 
405
405
    _, err := zk.Create("/test", "", gozk.EPHEMERAL,
406
 
                        gozk.WorldACL(gozk.PERM_ALL))
 
406
        gozk.WorldACL(gozk.PERM_ALL))
407
407
    c.Assert(err, IsNil)
408
408
 
409
409
    err = zk.Delete("/test", 5)
436
436
    zk, _ := s.init(c)
437
437
 
438
438
    _, err := zk.Create("/test", "", gozk.EPHEMERAL,
439
 
                        gozk.WorldACL(gozk.PERM_ALL))
 
439
        gozk.WorldACL(gozk.PERM_ALL))
440
440
    c.Assert(err, IsNil)
441
441
 
442
442
    _, watch, err := zk.ExistsW("/test")
455
455
    zk, _ := s.init(c)
456
456
 
457
457
    _, err := zk.Create("/test", "", gozk.EPHEMERAL,
458
 
                        gozk.WorldACL(gozk.PERM_ALL))
 
458
        gozk.WorldACL(gozk.PERM_ALL))
459
459
    c.Assert(err, IsNil)
460
460
 
461
461
    acl, stat, err := zk.GetACL("/test")
475
475
    zk, _ := s.init(c)
476
476
 
477
477
    _, err := zk.Create("/test", "", gozk.EPHEMERAL,
478
 
                        gozk.WorldACL(gozk.PERM_ALL))
 
478
        gozk.WorldACL(gozk.PERM_ALL))
479
479
    c.Assert(err, IsNil)
480
480
 
481
481
    err = zk.SetACL("/test", gozk.WorldACL(gozk.PERM_ALL), 5)
494
494
    zk, _ := s.init(c)
495
495
 
496
496
    acl := []gozk.ACL{{gozk.PERM_READ, "digest",
497
 
                       "joe:enQcM3mIEHQx7IrPNStYBc0qfs8="}}
 
497
        "joe:enQcM3mIEHQx7IrPNStYBc0qfs8="}}
498
498
 
499
499
    _, err := zk.Create("/test", "", gozk.EPHEMERAL, acl)
500
500
    c.Assert(err, IsNil)