Compare commits
1 Commits
800c99ac41
...
c9e9a3949f
Author | SHA1 | Date |
---|---|---|
|
c9e9a3949f |
|
@ -2,14 +2,17 @@ import time
|
||||||
|
|
||||||
import trio
|
import trio
|
||||||
import pytest
|
import pytest
|
||||||
|
|
||||||
import tractor
|
import tractor
|
||||||
from tractor.ipc import (
|
from tractor.ipc._ringbuf import (
|
||||||
open_ringbuf,
|
open_ringbuf,
|
||||||
RBToken,
|
RBToken,
|
||||||
RingBuffSender,
|
RingBuffSender,
|
||||||
RingBuffReceiver
|
RingBuffReceiver
|
||||||
)
|
)
|
||||||
from tractor._testing.samples import generate_sample_messages
|
from tractor._testing.samples import (
|
||||||
|
generate_sample_messages,
|
||||||
|
)
|
||||||
|
|
||||||
# in case you don't want to melt your cores, uncomment dis!
|
# in case you don't want to melt your cores, uncomment dis!
|
||||||
pytestmark = pytest.mark.skip
|
pytestmark = pytest.mark.skip
|
||||||
|
|
|
@ -13,43 +13,12 @@
|
||||||
|
|
||||||
# You should have received a copy of the GNU Affero General Public License
|
# You should have received a copy of the GNU Affero General Public License
|
||||||
# along with this program. If not, see <https://www.gnu.org/licenses/>.
|
# along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||||
# import platform
|
|
||||||
|
|
||||||
# from ._transport import (
|
'''
|
||||||
# MsgTransportKey as MsgTransportKey,
|
A modular IPC layer supporting the power of cross-process SC!
|
||||||
# MsgType as MsgType,
|
|
||||||
# MsgTransport as MsgTransport,
|
|
||||||
# MsgpackTransport as MsgpackTransport
|
|
||||||
# )
|
|
||||||
|
|
||||||
# from ._tcp import MsgpackTCPStream as MsgpackTCPStream
|
|
||||||
# from ._uds import MsgpackUDSStream as MsgpackUDSStream
|
|
||||||
|
|
||||||
# from ._types import (
|
|
||||||
# transport_from_addr as transport_from_addr,
|
|
||||||
# transport_from_stream as transport_from_stream,
|
|
||||||
# )
|
|
||||||
|
|
||||||
|
'''
|
||||||
from ._chan import (
|
from ._chan import (
|
||||||
_connect_chan as _connect_chan,
|
_connect_chan as _connect_chan,
|
||||||
Channel as Channel
|
Channel as Channel
|
||||||
)
|
)
|
||||||
|
|
||||||
# if platform.system() == 'Linux':
|
|
||||||
# from ._linux import (
|
|
||||||
# EFD_SEMAPHORE as EFD_SEMAPHORE,
|
|
||||||
# EFD_CLOEXEC as EFD_CLOEXEC,
|
|
||||||
# EFD_NONBLOCK as EFD_NONBLOCK,
|
|
||||||
# open_eventfd as open_eventfd,
|
|
||||||
# write_eventfd as write_eventfd,
|
|
||||||
# read_eventfd as read_eventfd,
|
|
||||||
# close_eventfd as close_eventfd,
|
|
||||||
# EventFD as EventFD,
|
|
||||||
# )
|
|
||||||
|
|
||||||
# from ._ringbuf import (
|
|
||||||
# RBToken as RBToken,
|
|
||||||
# RingBuffSender as RingBuffSender,
|
|
||||||
# RingBuffReceiver as RingBuffReceiver,
|
|
||||||
# open_ringbuf as open_ringbuf
|
|
||||||
# )
|
|
||||||
|
|
Loading…
Reference in New Issue