(self)
| 297 | self._req_param = -1 |
| 298 | |
| 299 | def close(self): |
| 300 | # First empty the queue from all packets |
| 301 | while not self.request_queue.empty(): |
| 302 | self.request_queue.get() |
| 303 | # Then force an unlock of the mutex if we are waiting for a packet |
| 304 | # we didn't get back due to a disconnect for example. |
| 305 | try: |
| 306 | self.wait_lock.release() |
| 307 | except Exception: |
| 308 | pass |
| 309 | |
| 310 | def request_param_setvalue(self, pk): |
| 311 | """Place a param set value request on the queue. When this is sent to |
no outgoing calls
no test coverage detected