Compare commits
1 Commits
c9e9a3949f
...
800c99ac41
Author | SHA1 | Date |
---|---|---|
|
800c99ac41 |
|
@ -2,17 +2,14 @@ import time
|
||||||
|
|
||||||
import trio
|
import trio
|
||||||
import pytest
|
import pytest
|
||||||
|
|
||||||
import tractor
|
import tractor
|
||||||
from tractor.ipc._ringbuf import (
|
from tractor.ipc import (
|
||||||
open_ringbuf,
|
open_ringbuf,
|
||||||
RBToken,
|
RBToken,
|
||||||
RingBuffSender,
|
RingBuffSender,
|
||||||
RingBuffReceiver
|
RingBuffReceiver
|
||||||
)
|
)
|
||||||
from tractor._testing.samples import (
|
from tractor._testing.samples import generate_sample_messages
|
||||||
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,12 +13,43 @@
|
||||||
|
|
||||||
# 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 (
|
||||||
A modular IPC layer supporting the power of cross-process SC!
|
# MsgTransportKey as MsgTransportKey,
|
||||||
|
# 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