#NEWLINE# def request_uplink_info( self , context , agent ) : #NEWLINE# #INDENT# 'Process uplink message from an agent.' #NEWLINE# LOG . debug ( 'request_uplink_info from %(agent)s' , { #NEWLINE# #INDENT# 'agent' : agent , #NEWLINE# #UNINDENT# } ) #NEWLINE# event_type = 'agent.request.uplink' #NEWLINE# payload = { #NEWLINE# #INDENT# 'agent' : agent , #NEWLINE# #UNINDENT# } #NEWLINE# timestamp = time . ctime ( ) #NEWLINE# data = ( event_type , payload ) #NEWLINE# pri = ( self . obj . PRI_LOW_START + 1 ) #NEWLINE# self . obj . pqueue . put ( ( pri , timestamp , data ) ) #NEWLINE# LOG . debug ( 'Added request uplink info into queue.' ) #NEWLINE# return 0