#NEWLINE# def discover( self , name ) : #NEWLINE# #INDENT# sock = socket . socket ( socket . AF_INET , socket . SOCK_STREAM ) #NEWLINE# sock . settimeout ( self . timeout ) #NEWLINE# try : #NEWLINE# #INDENT# data = brine . dump ( ( 'RPYC' , 'QUERY' , ( servers , ) ) ) #NEWLINE# sock . connect ( ( self . ip , self . port ) ) #NEWLINE# sock . send ( data ) #NEWLINE# try : #NEWLINE# #INDENT# data = sock . recv ( MAX_DGRAM_SIZE ) #NEWLINE# #UNINDENT# except ( socket . error , socket . timeout ) : #NEWLINE# #INDENT# servers = ( ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# servers = brine . load ( data ) #NEWLINE# #UNINDENT# #UNINDENT# finally : #NEWLINE# #INDENT# sock . close ( ) #NEWLINE# #UNINDENT# return servers