FGFS-4.1/gr-air-modes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Don't need locks for queue inserts

Browse Source
This commit is contained in:
Nick Foster 2013-06-03 09:17:17 -04:00
parent ba55d24e92
commit 4fe2334b28
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
python/zmq_socket.py
View File

@ -40,8 +40,6 @@ class zmq_pubsub_iface(threading.Thread):
self._subaddr = subaddr self._subaddr = subaddr
self._pubaddr = pubaddr self._pubaddr = pubaddr
self._sub_connected = False self._sub_connected = False
#self._pub_connected = False
self._publock = threading.Lock()
self._pubsub = pubsub() self._pubsub = pubsub()
if pubaddr is not None: if pubaddr is not None:
self._pubsocket.bind(pubaddr) self._pubsocket.bind(pubaddr)
@ -77,9 +75,8 @@ class zmq_pubsub_iface(threading.Thread):
def __setitem__(self, key, val): def __setitem__(self, key, val):
if not self._pubaddr: if not self._pubaddr:
raise Exception("No publisher address set") raise Exception("No publisher address set")
with self._publock: if not self.shutdown.is_set():
if not self.shutdown.is_set(): self._queue.put([key, val.to_string()]) #TODO FIXME MSGQ
self._queue.put([key, val.to_string()]) #TODO FIXME MSGQ
def __getitem__(self, key): def __getitem__(self, key):
return self._pubsub[key] return self._pubsub[key]