@@ -119,13 +119,15 @@ def setUp(self):
119
119
rados_patcher = mock .patch .object (rbd_utils , 'rados' )
120
120
self .mock_rados = rados_patcher .start ()
121
121
self .addCleanup (rados_patcher .stop )
122
- self .mock_rados .Rados = mock .Mock
123
- self .mock_rados .Rados .ioctx = mock .Mock ()
124
- self .mock_rados .Rados .connect = mock .Mock ()
125
- self .mock_rados .Rados .shutdown = mock .Mock ()
126
- self .mock_rados .Rados .open_ioctx = mock .Mock ()
127
- self .mock_rados .Rados .open_ioctx .return_value = \
128
- self .mock_rados .Rados .ioctx
122
+ self .mock_rados .Rados = mock .Mock ()
123
+ self .rados_inst = mock .Mock ()
124
+ self .mock_rados .Rados .return_value = self .rados_inst
125
+ self .rados_inst .ioctx = mock .Mock ()
126
+ self .rados_inst .connect = mock .Mock ()
127
+ self .rados_inst .shutdown = mock .Mock ()
128
+ self .rados_inst .open_ioctx = mock .Mock ()
129
+ self .rados_inst .open_ioctx .return_value = \
130
+ self .rados_inst .ioctx
129
131
self .mock_rados .Error = Exception
130
132
131
133
rbd_patcher = mock .patch .object (rbd_utils , 'rbd' )
@@ -339,33 +341,31 @@ def test_rbd_volume_proxy_init(self, mock_connect_from_rados,
339
341
340
342
def test_connect_to_rados_default (self ):
341
343
ret = self .driver ._connect_to_rados ()
342
- self .mock_rados . Rados .connect .assert_called_once_with (
344
+ self .rados_inst .connect .assert_called_once_with (
343
345
timeout = self .rbd_connect_timeout )
344
- self .assertTrue (self .mock_rados .Rados .open_ioctx .called )
345
- self .assertIsInstance (ret [0 ], self .mock_rados .Rados )
346
- self .assertEqual (self .mock_rados .Rados .ioctx , ret [1 ])
347
- self .mock_rados .Rados .open_ioctx .assert_called_with (self .rbd_pool )
346
+ self .assertTrue (self .rados_inst .open_ioctx .called )
347
+ self .assertEqual (self .rados_inst .ioctx , ret [1 ])
348
+ self .rados_inst .open_ioctx .assert_called_with (self .rbd_pool )
348
349
349
350
def test_connect_to_rados_different_pool (self ):
350
351
ret = self .driver ._connect_to_rados ('alt_pool' )
351
- self .mock_rados . Rados .connect .assert_called_once_with (
352
+ self .rados_inst .connect .assert_called_once_with (
352
353
timeout = self .rbd_connect_timeout )
353
- self .assertTrue (self .mock_rados .Rados .open_ioctx .called )
354
- self .assertIsInstance (ret [0 ], self .mock_rados .Rados )
355
- self .assertEqual (self .mock_rados .Rados .ioctx , ret [1 ])
356
- self .mock_rados .Rados .open_ioctx .assert_called_with ('alt_pool' )
354
+ self .assertTrue (self .rados_inst .open_ioctx .called )
355
+ self .assertEqual (self .rados_inst .ioctx , ret [1 ])
356
+ self .rados_inst .open_ioctx .assert_called_with ('alt_pool' )
357
357
358
358
def test_connect_to_rados_error (self ):
359
- self .mock_rados . Rados .open_ioctx .side_effect = self .mock_rados .Error
359
+ self .rados_inst .open_ioctx .side_effect = self .mock_rados .Error
360
360
self .assertRaises (self .mock_rados .Error ,
361
361
self .driver ._connect_to_rados )
362
- self .mock_rados . Rados .open_ioctx .assert_called_once_with (
362
+ self .rados_inst .open_ioctx .assert_called_once_with (
363
363
self .rbd_pool )
364
- self .mock_rados . Rados .shutdown .assert_called_once_with ()
364
+ self .rados_inst .shutdown .assert_called_once_with ()
365
365
366
366
def test_connect_to_rados_unicode_arg (self ):
367
367
self .driver ._connect_to_rados (u'unicode_pool' )
368
- self .mock_rados . Rados .open_ioctx .assert_called_with (
368
+ self .rados_inst .open_ioctx .assert_called_with (
369
369
test .MatchType (str ))
370
370
371
371
def test_ceph_args_none (self ):
0 commit comments