#NEWLINE# @ tornado . gen . coroutine #NEWLINE# def pipelined_multiple_set( self , client_number ) : #NEWLINE# #INDENT# uds = self . params . unix_domain_socket #NEWLINE# client = tornadis . Client ( host = self . params . hostname , port = self . params . port , unix_domain_socket = _ , autoconnect = False , tcp_nodelay = True ) #NEWLINE# print_ ( 'Connect client' , client_number ) #NEWLINE# ( yield client . connect ( ) ) #NEWLINE# print_ ( 'Client' , client_number , 'connected' ) #NEWLINE# pipeline_size = ( self . params . batch_size or self . requests_per_client ) #NEWLINE# print_ ( pipeline_size ) #NEWLINE# pipeline = tornadis . Pipeline ( ) #NEWLINE# for _ in six . moves . range ( 0 , self . requests_per_client ) : #NEWLINE# #INDENT# pipeline . stack_call ( 'SET' , 'benchmark-key' , self . value ) #NEWLINE# if ( pipeline . number_of_stacked_calls >= pipeline_size ) : #NEWLINE# #INDENT# resp_count = ( yield self . _call_pipeline ( client , pipeline , client_number ) ) #NEWLINE# self . response_count += resp_count #NEWLINE# pipeline = tornadis . Pipeline ( ) #NEWLINE# #UNINDENT# #UNINDENT# if ( pipeline . number_of_stacked_calls > 0 ) : #NEWLINE# #INDENT# resp_count = ( yield self . _call_pipeline ( client , pipeline , client_number ) ) #NEWLINE# self . response_count += resp_count