@@ -122,24 +122,30 @@ def do_server_handshake(self):
122122 self .context = zmq .Context ()
123123 self .server_socket = self .context .socket (zmq .PAIR )
124124 self .server_socket .copy_threshold = 0
125+
126+ print ("connecting to" , socket_addr )
127+
125128 c = self .server_socket .connect (socket_addr )
126129
127- print ("Setup socket at" , socket_addr , "connected to " , c )
130+ print ("setup socket at" , c )
128131
132+ print ("sending handshake, waiting for acknowledgement" )
133+
129134 self .server_socket .send_string (HELLO )
130135 response = self .server_socket .recv_string ()
131136
132137 if response == ACK :
133- print ("Received correct response" , response )
138+ print ("received correct response" , response )
134139 else :
135- print ("Received unexpected response" , response )
140+ print ("received unexpected response" , response )
136141
137142 def do_server_execute (self , im_data ):
138143 dummy_data = lambda : np .array ([[]])
139144
140145 socket = self .server_socket
141146 header = np .lib .format .header_data_from_array_1_0 (im_data )
142-
147+
148+ print ("sending header" , header , "waiting for acknowledgement" )
143149 socket .send_json (header )
144150
145151 ack = socket .recv_string ()
@@ -149,6 +155,7 @@ def do_server_execute(self, im_data):
149155 print ("unexpected response" , ack )
150156 return dummy_data ()
151157
158+ print ("sending image data" , im_data .shape , "waiting for acknowledgement" )
152159 socket .send (im_data , copy = False )
153160
154161 ack = socket .recv_string ()
@@ -160,17 +167,19 @@ def do_server_execute(self, im_data):
160167 else :
161168 print ("unknown response to image data" , ack )
162169 return dummy_data ()
163-
170+
171+ print ("waiting for return header" )
164172 return_header = socket .recv_json ()
165173 print ("received return header" , return_header )
166174
167175 print ("acknowledging header reciept" )
168176 socket .send_string (ACK )
169177
170178 print ("waiting for image data" )
171-
172179 label_data_buf = socket .recv (copy = False )
180+ print ("image data received" )
181+
173182 labels = np .frombuffer (label_data_buf , dtype = return_header ['descr' ])
174183 labels .shape = return_header ['shape' ]
175184 print ("returning label data" , labels .shape )
176- return labels
185+ return labels
0 commit comments