MCPcopy
hub / github.com/ha/doozerd / TestDoozerGet

Function TestDoozerGet

src/pkg/peer/peer_test.go:27–54  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

25
26
27func TestDoozerGet(t *testing.T) {
28 l := mustListen()
29 defer l.Close()
30 u := mustListenUDP(l.Addr().String())
31 defer u.Close()
32
33 go Main("a", "X", "", "", "", nil, u, l, nil, 1e9, 2e9, 3e9, 101)
34
35 cl := dial(l.Addr().String())
36
37 _, err := cl.Set("/x", store.Missing, []byte{'a'})
38 assert.Equal(t, nil, err)
39
40 ents, rev, err := cl.Get("/x", nil)
41 assert.Equal(t, nil, err)
42 assert.NotEqual(t, store.Dir, rev)
43 assert.Equal(t, []byte{'a'}, ents)
44
45 //cl.Set("/test/a", store.Missing, []byte{'1'})
46 //cl.Set("/test/b", store.Missing, []byte{'2'})
47 //cl.Set("/test/c", store.Missing, []byte{'3'})
48
49 //ents, rev, err = cl.Get("/test", 0)
50 //sort.SortStrings(ents)
51 //assert.Equal(t, store.Dir, rev)
52 //assert.Equal(t, nil, err)
53 //assert.Equal(t, []string{"a", "b", "c"}, ents)
54}
55
56
57func TestDoozerSet(t *testing.T) {

Callers

nothing calls this directly

Calls 7

mustListenFunction · 0.85
mustListenUDPFunction · 0.85
MainFunction · 0.85
dialFunction · 0.85
SetMethod · 0.80
GetMethod · 0.65
StringMethod · 0.45

Tested by

no test coverage detected