except:
pass
-def recv_msg(conn, ns3_wrapper):
+def recv_msg(conn):
msg = []
chunk = ''
try:
chunk = conn.recv(1024)
except (OSError, socket.error), e:
- import traceback
- err = traceback.format_exc()
- ns3_wrapper.logger.error(err)
-
if e[0] != errno.EINTR:
raise
# Ignore eintr errors
conn.settimeout(5)
try:
- (msg_type, args, kwargs) = recv_msg(conn, ns3_wrapper)
+ (msg_type, args, kwargs) = recv_msg(conn)
except socket.timeout, e:
# Ingore time-out
close_socket(conn)