(stream, length)
| 278 | |
| 279 | |
| 280 | def recv_exact(stream, length): |
| 281 | chunks = [] |
| 282 | remaining = length |
| 283 | while remaining: |
| 284 | chunk = stream.recv(remaining) |
| 285 | check(chunk, "daemon closed during rendezvous response") |
| 286 | chunks.append(chunk) |
| 287 | remaining -= len(chunk) |
| 288 | return b"".join(chunks) |
| 289 | |
| 290 | |
| 291 | def probe_future_generation_rendezvous( |
no test coverage detected