(trans, key, ov)
| 553 | ov.AcceptEx(listener.fileno(), conn.fileno()) |
| 554 | |
| 555 | def finish_accept(trans, key, ov): |
| 556 | ov.getresult() |
| 557 | # Use SO_UPDATE_ACCEPT_CONTEXT so getsockname() etc work. |
| 558 | buf = struct.pack('@P', listener.fileno()) |
| 559 | conn.setsockopt(socket.SOL_SOCKET, |
| 560 | _overlapped.SO_UPDATE_ACCEPT_CONTEXT, buf) |
| 561 | conn.settimeout(listener.gettimeout()) |
| 562 | return conn, conn.getpeername() |
| 563 | |
| 564 | async def accept_coro(future, conn): |
| 565 | # Coroutine closing the accept socket if the future is cancelled |
nothing calls this directly
no test coverage detected