#NEWLINE# def __init__( self , options , command ) : #NEWLINE# #INDENT# name = ( '[mrun] ' + ' ' . join ( sys . argv [ 1 : ] ) ) #NEWLINE# if ( len ( name ) > 256 ) : #NEWLINE# #INDENT# name = ( name [ : 256 ] + '...' ) #NEWLINE# #UNINDENT# super ( MPIScheduler , self ) . __init__ ( name , options , command ) #NEWLINE# self . used_tasks = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# self . id = 0 #NEWLINE# self . p = None #NEWLINE# self . publisher = ctx . socket ( zmq . PUB ) #NEWLINE# port = self . publisher . bind_to_random_port ( 'tcp://0.0.0.0' ) #NEWLINE# host = socket . gethostname ( ) #NEWLINE# self . publisher_port = ( 'tcp://%s:%d' % ( host , port ) )