#NEWLINE# def __init__( self , cb ) : #NEWLINE# #INDENT# self . cb = x #NEWLINE# self . delay = options . delay #NEWLINE# self . key = ( 'K' * options . ksize ) #NEWLINE# self . value = ( b'V' * options . vsize ) #NEWLINE# self . kv = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# for x in range ( options . batch ) : #NEWLINE# #INDENT# self . kv [ ( self . key + str ( x ) ) ] = self . value #NEWLINE# #UNINDENT# self . wait_time = 0 #NEWLINE# self . opcount = 0 #NEWLINE# self . end_time = ( time ( ) + options . duration ) #NEWLINE# self . _do_stop = False #NEWLINE# self . start ( )