import threading
import select
import multiprocessing
-import queue
+try:
+ import queue as queue
+except ImportError:
+ import Queue as queue
import logging
-class VppTransport:
+class VppTransport(object):
def __init__(self, parent, read_timeout, server_address):
self.connected = False
self.read_timeout = read_timeout if read_timeout > 0 else 1
return 0
def disconnect(self):
+ rv = 0
try: # Might fail, if VPP closes socket before packet makes it out
rv = self.parent.api.sockclnt_delete(index=self.socket_index)
except IOError:
self.socket.close()
self.sque.put(True) # Terminate listening thread
self.message_thread.join()
+ return rv
def suspend(self):
pass
def callback(self):
raise NotImplemented
- def get_callback(self, async):
+ def get_callback(self, do_async):
return self.callback
def get_msg_index(self, name):