1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
# encoding: tarantool
import sys
from lib.memcached_connection import MemcachedConnection
exec memcached "cas bad blah 0 0 0\r\n"
exec memcached "cas bad 0 blah 0 0\r\n"
exec memcached "cas bad 0 0 blah 0\r\n"
exec memcached "cas bad 0 0 0 blah\r\n"
print """# gets foo (should not exist) """
exec memcached "gets foo\r\n"
print """# set foo """
exec memcached "set foo 0 0 6\r\nbarval\r\n"
print """# gets foo and verify identifier exists """
exec memcached "gets foo\r\n"
print """# cas fail """
exec memcached "cas foo 0 0 6 123\r\nbarva2\r\n"
print """# gets foo and verify identifier exists """
sys.stdout.write("gets foo\r\n")
result = exec memcached silent "gets foo\r\n"
unique_id = int(result.split()[4])
print """# cas success """
sys.stdout.write("cas foo 0 0 6 <unique_id>\r\nbarva2\r\n")
result = exec memcached silent "cas foo 0 0 6 %d\r\nbarva2\r\n" % unique_id
sys.stdout.write(result)
print """# cas failure (reusing the same key) """
sys.stdout.write("cas foo 0 0 6 <unique_id>\r\nbarva2\r\n")
result = exec memcached silent "cas foo 0 0 6 %d\r\nbarva2\r\n" % unique_id
sys.stdout.write(result)
print """# delete foo """
exec memcached "delete foo\r\n"
print """# cas missing """
sys.stdout.write("cas foo 0 0 6 <unique_id>\r\nbarva2\r\n")
result = exec memcached silent "cas foo 0 0 6 %d\r\nbarva2\r\n" % unique_id
sys.stdout.write(result)
print """# set foo1 """
exec memcached "set foo1 0 0 1\r\n1\r\n"
print """# set foo2 """
exec memcached "set foo2 0 0 1\r\n2\r\n"
print """# gets foo1 check """
result = exec memcached "gets foo1\r\n"
foo1_cas = int(result.split()[4])
print """# gets foo2 check """
result = exec memcached "gets foo2\r\n"
foo2_cas = int(result.split()[4])
print """# validate foo1 != foo2 """
if foo1_cas != foo2_cas:
print "pass: foo1_cas != foo2_cas"
else:
print "fail: foo1_cas == foo2_cas"
memcached1 = server.memcached
memcached2 = MemcachedConnection('localhost', server.memcached_port)
print """# gets foo from memcached1 - should success """
result = exec memcached1 silent "gets foo1\r\n"
mem1_cas = int(result.split()[4])
print """# gets foo from memcached2 - should success """
result = exec memcached2 silent "gets foo1\r\n"
mem2_cas = int(result.split()[4])
print """# send 'cas foo1' from memcached1 """
send memcached1 silent "cas foo1 0 0 6 %d\r\nbarva2\r\n" % mem1_cas
print """# send 'cas foo1' from memcached2 """
send memcached2 silent "cas foo1 0 0 4 %d\r\npear\r\n" % mem2_cas
print """# recv reply 'cas foo1' from memcached1 """
result = recv memcached1 silent
mem1_cas_result = result.split()[0]
print """# recv reply 'cas foo1' from memcached2 """
result = recv memcached2 silent
mem2_cas_result = result.split()[0]
if mem1_cas_result == "STORED" and mem2_cas_result == "EXISTS":
print "race cas: pass"
elif mem1_cas_result == "EXISTS" and mem2_cas_result == "STORED":
print "race cas: pass"
else:
print "race cas: fail"
print "cas 1 = %s" % mem1_cas_result
print "cas 2 = %s" % mem2_cas_result
print """# set bug15 """
exec memcached "set bug15 0 0 1\r\n0\r\n"
print """# Check out the first gets. """
result = exec memcached silent "gets bug15\r\n"
bug15_cas = int(result.split()[4])
print """# Increment. """
exec memcached "incr bug15 1\r\n"
print """# Validate a changed CAS. """
result = exec memcached silent "gets bug15\r\n"
next_bug15_cas = int(result.split()[4])
print """# validate bug15_cas != next_bug15_cas """
if bug15_cas != next_bug15_cas:
print "pass: bug15_cas != next_bug15_cas"
else:
print "fail: bug15_cas == next_bug15_cas"
# resore default suite config
server.stop()
server.deploy(self.suite_ini["config"])
# vim: syntax=python
|
