@@ -273,30 +273,6 @@ def test_address_already_in_use(self):
273
273
store1 = c10d .TCPStore (addr , port , 1 , True ) # noqa: F841
274
274
store2 = c10d .TCPStore (addr , port , 1 , True ) # noqa: F841
275
275
276
- def _test_numkeys_delkeys (self , fs ):
277
- # We start off with one init key in the store to coordinate workers
278
- self .assertEqual (fs .num_keys (), 1 )
279
- fs .add ("key" , 1 )
280
- fs .add ("key" , 2 )
281
- fs .add ("key" , 3 )
282
- fs .set ("key0" , "value0" )
283
- fs .add ("key3" , 1 )
284
- fs .set ("key1" , "value1" )
285
- self .assertEqual (fs .num_keys (), 5 )
286
- fs .delete_key ("key" )
287
- self .assertEqual (fs .num_keys (), 4 )
288
- with self .assertRaises (RuntimeError ):
289
- fs .get ("key" )
290
- fs .delete_key ("key0" )
291
- fs .delete_key ("key3" )
292
- self .assertEqual (fs .num_keys (), 2 )
293
- fs .set ("key4" , "value2" )
294
- self .assertEqual (fs .num_keys (), 3 )
295
- self .assertEqual (b"value1" , fs .get ("key1" ))
296
- self .assertEqual (b"value2" , fs .get ("key4" ))
297
-
298
- def test_numkeys_delkeys (self ):
299
- self ._test_numkeys_delkeys (self ._create_store ())
300
276
301
277
@skip_if_win32 ()
302
278
class PrefixTCPStoreTest (TestCase , StoreTestBase ):
0 commit comments