(self, value)
| 389 | self.condition.notify_all() |
| 390 | |
| 391 | def send(self, value): |
| 392 | check(self.process.stdin is not None, "client stdin is already closed") |
| 393 | payload = json.dumps(value, separators=(",", ":")) |
| 394 | try: |
| 395 | self.process.stdin.write(payload + "\n") |
| 396 | self.process.stdin.flush() |
| 397 | except (BrokenPipeError, OSError) as exc: |
| 398 | raise SmokeFailure("thin client closed while sending: " + str(exc)) from exc |
| 399 | |
| 400 | def wait_response(self, request_id, timeout=START_TIMEOUT): |
| 401 | deadline = time.monotonic() + timeout |
no test coverage detected