@@ -55,12 +55,12 @@ def test_above_30(self):
55
55
"""Message above 30 bytes are never copied by 0MQ."""
56
56
for i in range (5 , 16 ): # 32, 64,..., 65536
57
57
s = (2 ** i ) * x
58
- self . assertEqual ( grc (s ), 2 )
58
+ rc = grc (s )
59
59
m = zmq .Frame (s , copy = False )
60
- self .assertEqual (grc (s ), 4 )
60
+ self .assertEqual (grc (s ), rc + 2 )
61
61
del m
62
- await_gc (s , 2 )
63
- self .assertEqual (grc (s ), 2 )
62
+ await_gc (s , rc )
63
+ self .assertEqual (grc (s ), rc )
64
64
del s
65
65
66
66
def test_str (self ):
@@ -106,8 +106,7 @@ def test_lifecycle1(self):
106
106
"""Run through a ref counting cycle with a copy."""
107
107
for i in range (5 , 16 ): # 32, 64,..., 65536
108
108
s = (2 ** i ) * x
109
- rc = 2
110
- self .assertEqual (grc (s ), rc )
109
+ rc = rc_0 = grc (s )
111
110
m = zmq .Frame (s , copy = False )
112
111
rc += 2
113
112
self .assertEqual (grc (s ), rc )
@@ -135,16 +134,15 @@ def test_lifecycle1(self):
135
134
rc -= 2
136
135
await_gc (s , rc )
137
136
self .assertEqual (grc (s ), rc )
138
- self .assertEqual (rc , 2 )
137
+ self .assertEqual (rc , rc_0 )
139
138
del s
140
139
141
140
@skip_pypy
142
141
def test_lifecycle2 (self ):
143
142
"""Run through a different ref counting cycle with a copy."""
144
143
for i in range (5 , 16 ): # 32, 64,..., 65536
145
144
s = (2 ** i ) * x
146
- rc = 2
147
- self .assertEqual (grc (s ), rc )
145
+ rc = rc_0 = grc (s )
148
146
m = zmq .Frame (s , copy = False )
149
147
rc += 2
150
148
self .assertEqual (grc (s ), rc )
@@ -171,7 +169,7 @@ def test_lifecycle2(self):
171
169
rc -= 2
172
170
await_gc (s , rc )
173
171
self .assertEqual (grc (s ), rc )
174
- self .assertEqual (rc , 2 )
172
+ self .assertEqual (rc , rc_0 )
175
173
del s
176
174
177
175
def test_tracker (self ):
0 commit comments