espressif/openthread
1
0
Fork 0
mirror of https://github.com/espressif/openthread.git synced 2026-07-29 23:27:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

[spinel-py] Allow for waiting for a given property change (#1081)

Browse Source 
* [spinel-py] Allow to wait for a particular property

* [spinel-py] Added reset command to codec.py
This commit is contained in:
Wojciech Bober
2016-12-15 09:04:55 -08:00
committed by Jonathan Hui
parent 2455a1e056
commit 430f4839ff
1 changed files with 24 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tools/spinel-cli/spinel/codec.py
+24 -3
View File
@@ -848,13 +848,28 @@ class WpanApi(SpinelCodec):
with self.__queue_prop[tid].mutex:
self.__queue_prop[tid].queue.clear()
def queue_wait_for_prop(self, _prop, tid=SPINEL.HEADER_DEFAULT, timeout=TIMEOUT_PROP):
def queue_get(self, tid, timeout = None):
try:
item = self.__queue_prop[tid].get(True, timeout)
# self.__queue_prop[tid].task_done()
if (timeout):
item = self.__queue_prop[tid].get(True, timeout)
else:
item = self.__queue_prop[tid].get_nowait()
except Queue.Empty:
item = None
return item
def queue_wait_for_prop(self, _prop, tid=SPINEL.HEADER_DEFAULT, timeout=TIMEOUT_PROP):
start = time.time()
item = self.queue_get(tid, timeout)
if (_prop is not None):
while (item and (item.prop != _prop)):
self.__queue_prop[tid].put_nowait(item)
reminder = timeout - (time.time() - start)
if (reminder <= 0.0):
item = None
break
item = self.queue_get(tid, reminder)
# self.__queue_prop[tid].task_done()
return item
def ip_send(self, pkt):
@@ -868,6 +883,12 @@ class WpanApi(SpinelCodec):
self.transact(SPINEL.CMD_PROP_VALUE_SET, pay)
def cmd_reset(self):
self.queue_wait_prepare(None, SPINEL.HEADER_ASYNC)
self.transact(SPINEL.CMD_RESET, "", SPINEL.HEADER_DEFAULT)
result = self.queue_wait_for_prop(SPINEL.PROP_LAST_STATUS, SPINEL.HEADER_ASYNC, 5)
return (result is not None and result.value == 114)
def cmd_send(self, command_id, payload="", tid=SPINEL.HEADER_DEFAULT):
self.queue_wait_prepare(None, tid)
self.transact(command_id, payload, tid)