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

Drop happy eyeballs inf delay

msgspec_not_fucked
Tyler Goodlet 2021-06-27 00:47:49 -04:00
parent 6463aa1559
commit d8dcee3713
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)