Compare commits
1 Commits
c9e9a3949f
...
800c99ac41
Author | SHA1 | Date |
---|---|---|
|
800c99ac41 |
|
@ -2,17 +2,14 @@ import time
|
|||
|
||||
import trio
|
||||
import pytest
|
||||
|
||||
import tractor
|
||||
from tractor.ipc._ringbuf import (
|
||||
from tractor.ipc import (
|
||||
open_ringbuf,
|
||||
RBToken,
|
||||
RingBuffSender,
|
||||
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!
|
||||
pytestmark = pytest.mark.skip
|
||||
|
|
|
@ -13,12 +13,43 @@
|
|||
|
||||
# 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/>.
|
||||
# import platform
|
||||
|
||||
'''
|
||||
A modular IPC layer supporting the power of cross-process SC!
|
||||
# from ._transport import (
|
||||
# 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 (
|
||||
_connect_chan as _connect_chan,
|
||||
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