jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity

Drop happy eyeballs inf delay

try_msgspec
Tyler Goodlet 2021-06-27 00:47:49 -04:00
parent 1a068add5d
commit 1c4d418f81
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tractor/_ipc.py
View File

@ -2,7 +2,6 @@
Inter-process comms abstractions Inter-process comms abstractions
""" """
from functools import partial from functools import partial
import math
import struct import struct
import typing import typing
from typing import Any, Tuple, Optional from typing import Any, Tuple, Optional
@ -49,9 +48,8 @@ class MsgpackTCPStream:
assert isinstance(rsockname, tuple) assert isinstance(rsockname, tuple)
self._raddr = rsockname[:2] self._raddr = rsockname[:2]
# start and seed first entry to read loop # start first entry to read loop
self._agen = self._iter_packets() self._agen = self._iter_packets()
# self._agen.asend(None) is None
self._send_lock = trio.StrictFIFOLock() self._send_lock = trio.StrictFIFOLock()
@ -225,7 +223,6 @@ class Channel:
stream = await trio.open_tcp_stream( stream = await trio.open_tcp_stream(
*destaddr, *destaddr,
happy_eyeballs_delay=math.inf,
**kwargs **kwargs
) )
self.msgstream = self.stream_serializer_type(stream) self.msgstream = self.stream_serializer_type(stream)