#NEWLINE# def _send_mb( self ) : #NEWLINE# #INDENT# self . init_data ( self . _batch_port ) #NEWLINE# for i in range ( ( self . _dataset . shape [ 0 ] // i . _batch_size ) ) : #NEWLINE# #INDENT# batch_start = ( i * self . _batch_size ) #NEWLINE# batch_stop = ( ( i + 1 ) * self . _batch_size ) #NEWLINE# self . send_mb ( self . _dataset [ batch_start : batch_stop ] ) #NEWLINE# #UNINDENT# self . asocket . close ( ) #NEWLINE# print ( 'Done Sending MB.' ) #NEWLINE# import time #NEWLINE# time . sleep ( 2 )