(self, value)
| 260 | return self._tcp_cork |
| 261 | |
| 262 | def set_tcp_cork(self, value): |
| 263 | value = bool(value) |
| 264 | if self._tcp_cork == value: |
| 265 | return |
| 266 | self._tcp_cork = value |
| 267 | if self._socket is None: |
| 268 | return |
| 269 | if self._socket.family not in (socket.AF_INET, socket.AF_INET6): |
| 270 | return |
| 271 | if self._tcp_nodelay: |
| 272 | self._socket.setsockopt(socket.IPPROTO_TCP, |
| 273 | socket.TCP_NODELAY, |
| 274 | False) |
| 275 | self._tcp_nodelay = False |
| 276 | if CORK is not None: # pragma: no branch |
| 277 | self._socket.setsockopt(socket.IPPROTO_TCP, CORK, value) |
| 278 | |
| 279 | |
| 280 | class StreamProtocol(asyncio.streams.FlowControlMixin, asyncio.Protocol): |
no outgoing calls