#NEWLINE# def test_repl_to_node_usync_success( self ) : #NEWLINE# #INDENT# rinfo = { #NEWLINE# #INDENT# 'id' : 3 , #NEWLINE# 'point' : ( - 1 ) , #NEWLINE# 'max_row' : 10 , #NEWLINE# 'hash' : 'c' , #NEWLINE# #UNINDENT# } #NEWLINE# self . http = ReplHttp ( json . dumps ( rinfo ) ) #NEWLINE# local_sync = self . broker . get_sync ( ) #NEWLINE# self . assertEqual ( self . replicator . _repl_to_node ( self . fake_node , self . broker , '0' , self . fake_info ) , True ) #NEWLINE# self . replicator . _usync_db . assert_has_calls ( [ mock . call ( max ( rinfo [ 'point' ] , local_sync ) , self . broker , self . http , rinfo [ 'id' ] , self . fake_info [ 'id' ] ) ] )