Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions .travis.yml
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,8 @@ matrix:
python: "3.5"
- os: linux
python: "3.6"
- os: linux
python: "3.7"
- os: osx
osx_image: xcode8.3
language: generic
Expand Down
8 changes: 4 additions & 4 deletions examples/common/async_asyncio_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,10 +15,10 @@
# ----------------------------------------------------------------------- #
# Import the required async client
# ----------------------------------------------------------------------- #
from pymodbus.client.async.tcp import AsyncModbusTCPClient as ModbusClient
# from pymodbus.client.async.udp import (
from pymodbus.client.asynchronous.tcp import AsyncModbusTCPClient as ModbusClient
# from pymodbus.client.asynchronous.udp import (
# AsyncModbusUDPClient as ModbusClient)
from pymodbus.client.async import schedulers
from pymodbus.client.asynchronous import schedulers

else:
import sys
Expand Down Expand Up @@ -66,7 +66,7 @@ async def start_async_test(client):
# are not known to these tests. Furthermore, some use the same memory
# blocks for the two sets, so a change to one is a change to the other.
# Keep both of these cases in mind when testing as the following will
# _only_ pass with the supplied async modbus server (script supplied).
# _only_ pass with the supplied asynchronous modbus server (script supplied).
# ----------------------------------------------------------------------- #
log.debug("Write to a Coil and read back")
rq = await client.write_coil(0, True, unit=UNIT)
Expand Down
4 changes: 2 additions & 2 deletions examples/common/async_asyncio_serial_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,9 +12,9 @@
if IS_PYTHON3 and PYTHON_VERSION >= (3, 4):
import logging
import asyncio
from pymodbus.client.async.serial import (
from pymodbus.client.asynchronous.serial import (
AsyncModbusSerialClient as ModbusClient)
from pymodbus.client.async import schedulers
from pymodbus.client.asynchronous import schedulers
else:
import sys
sys.stderr("This example needs to be run only on python 3.4 and above")
Expand Down
6 changes: 3 additions & 3 deletions examples/common/async_tornado_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,14 +9,14 @@

import functools
from tornado.ioloop import IOLoop
from pymodbus.client.async import schedulers
from pymodbus.client.asynchronous import schedulers

# ---------------------------------------------------------------------------#
# choose the requested modbus protocol
# ---------------------------------------------------------------------------#

# from pymodbus.client.async.udp import AsyncModbusUDPClient as ModbusClient
from pymodbus.client.async.tcp import AsyncModbusTCPClient as ModbusClient
# from pymodbus.client.asynchronous.udp import AsyncModbusUDPClient as ModbusClient
from pymodbus.client.asynchronous.tcp import AsyncModbusTCPClient as ModbusClient

# ---------------------------------------------------------------------------#
# configure the client logging
Expand Down
4 changes: 2 additions & 2 deletions examples/common/async_tornado_client_serial.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,13 +12,13 @@
import functools

from tornado.ioloop import IOLoop
from pymodbus.client.async import schedulers
from pymodbus.client.asynchronous import schedulers

# ---------------------------------------------------------------------------#
# choose the requested modbus protocol
# ---------------------------------------------------------------------------#

from pymodbus.client.async.serial import AsyncModbusSerialClient
from pymodbus.client.asynchronous.serial import AsyncModbusSerialClient

# ---------------------------------------------------------------------------#
# configure the client logging
Expand Down
8 changes: 4 additions & 4 deletions examples/common/async_twisted_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,15 +11,15 @@
# --------------------------------------------------------------------------- #
from twisted.internet import reactor

from pymodbus.client.async.tcp import AsyncModbusTCPClient
# from pymodbus.client.async.udp import AsyncModbusUDPClient
from pymodbus.client.async import schedulers
from pymodbus.client.asynchronous.tcp import AsyncModbusTCPClient
# from pymodbus.client.asynchronous.udp import AsyncModbusUDPClient
from pymodbus.client.asynchronous import schedulers

# --------------------------------------------------------------------------- #
# choose the requested modbus protocol
# --------------------------------------------------------------------------- #

#from pymodbus.client.async import ModbusUdpClientProtocol
#from pymodbus.client.asynchronous import ModbusUdpClientProtocol

# --------------------------------------------------------------------------- #
# configure the client logging
Expand Down
6 changes: 3 additions & 3 deletions examples/common/async_twisted_client_serial.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,9 @@
"""

from twisted.internet import reactor
from pymodbus.client.async import schedulers
from pymodbus.client.async.serial import AsyncModbusSerialClient
from pymodbus.client.async.twisted import ModbusClientProtocol
from pymodbus.client.asynchronous import schedulers
from pymodbus.client.asynchronous.serial import AsyncModbusSerialClient
from pymodbus.client.asynchronous.twisted import ModbusClientProtocol

import logging
logging.basicConfig()
Expand Down
2 changes: 1 addition & 1 deletion examples/common/asynchronous_processor.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
from twisted.internet import serialport, reactor
from twisted.internet.protocol import ClientFactory
from pymodbus.factory import ClientDecoder
from pymodbus.client.async.twisted import ModbusClientProtocol
from pymodbus.client.asynchronous.twisted import ModbusClientProtocol

# --------------------------------------------------------------------------- #
# Choose the framer you want to use
Expand Down
6 changes: 3 additions & 3 deletions examples/common/asynchronous_server.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,9 +10,9 @@
# --------------------------------------------------------------------------- #
# import the various server implementations
# --------------------------------------------------------------------------- #
from pymodbus.server.async import StartTcpServer
from pymodbus.server.async import StartUdpServer
from pymodbus.server.async import StartSerialServer
from pymodbus.server.asynchronous import StartTcpServer
from pymodbus.server.asynchronous import StartUdpServer
from pymodbus.server.asynchronous import StartSerialServer

from pymodbus.device import ModbusDeviceIdentification
from pymodbus.datastore import ModbusSequentialDataBlock
Expand Down
2 changes: 1 addition & 1 deletion examples/common/callback_server.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
# --------------------------------------------------------------------------- #
# import the modbus libraries we need
# --------------------------------------------------------------------------- #
from pymodbus.server.async import StartTcpServer
from pymodbus.server.asynchronous import StartTcpServer
from pymodbus.device import ModbusDeviceIdentification
from pymodbus.datastore import ModbusSparseDataBlock
from pymodbus.datastore import ModbusSlaveContext, ModbusServerContext
Expand Down
2 changes: 1 addition & 1 deletion examples/common/custom_datablock.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
# import the modbus libraries we need
# --------------------------------------------------------------------------- #
from __future__ import print_function
from pymodbus.server.async import StartTcpServer
from pymodbus.server.asynchronous import StartTcpServer
from pymodbus.device import ModbusDeviceIdentification
from pymodbus.datastore import ModbusSparseDataBlock
from pymodbus.datastore import ModbusSlaveContext, ModbusServerContext
Expand Down
2 changes: 1 addition & 1 deletion examples/common/dbstore_update_server.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
# --------------------------------------------------------------------------- #
# import the modbus libraries we need
# --------------------------------------------------------------------------- #
from pymodbus.server.async import StartTcpServer
from pymodbus.server.asynchronous import StartTcpServer
from pymodbus.device import ModbusDeviceIdentification
from pymodbus.datastore import ModbusSequentialDataBlock
from pymodbus.datastore import ModbusServerContext
Expand Down
2 changes: 1 addition & 1 deletion examples/common/updating_server.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
# --------------------------------------------------------------------------- #
# import the modbus libraries we need
# --------------------------------------------------------------------------- #
from pymodbus.server.async import StartTcpServer
from pymodbus.server.asynchronous import StartTcpServer
from pymodbus.device import ModbusDeviceIdentification
from pymodbus.datastore import ModbusSequentialDataBlock
from pymodbus.datastore import ModbusSlaveContext, ModbusServerContext
Expand Down
4 changes: 2 additions & 2 deletions examples/contrib/asynchronous_asyncio_serial_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
if IS_PYTHON3 and PYTHON_VERSION >= (3, 4):
import asyncio
from serial_asyncio import create_serial_connection
from pymodbus.client.async.asyncio import ModbusClientProtocol
from pymodbus.client.asynchronous.asyncio import ModbusClientProtocol
from pymodbus.transaction import ModbusAsciiFramer, ModbusRtuFramer
from pymodbus.factory import ClientDecoder
else:
Expand Down Expand Up @@ -43,7 +43,7 @@ async def start_async_test(client):
# are not known to these tests. Furthermore, some use the same memory
# blocks for the two sets, so a change to one is a change to the other.
# Keep both of these cases in mind when testing as the following will
# _only_ pass with the supplied async modbus server (script supplied).
# _only_ pass with the supplied asynchronous modbus server (script supplied).
# ----------------------------------------------------------------------- #
log.debug("Write to a Coil and read back")
rq = await client.write_coil(0, True, unit=UNIT)
Expand Down
2 changes: 1 addition & 1 deletion examples/contrib/modbus_scraper.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@
from pymodbus.datastore import ModbusSequentialDataBlock
from pymodbus.datastore import ModbusSlaveContext
from pymodbus.factory import ClientDecoder
from pymodbus.client.async import ModbusClientProtocol
from pymodbus.client.asynchronous import ModbusClientProtocol

#--------------------------------------------------------------------------#
# Configure the client logging
Expand Down
2 changes: 1 addition & 1 deletion examples/contrib/modbus_simulator.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
from optparse import OptionParser
from twisted.internet import reactor

from pymodbus.server.async import StartTcpServer
from pymodbus.server.asynchronous import StartTcpServer
from pymodbus.datastore import ModbusServerContext,ModbusSlaveContext

# -------------------------------------------------------------------------- #
Expand Down
2 changes: 1 addition & 1 deletion examples/functional/asynchronous_ascii_client.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
#!/usr/bin/env python
import unittest
from pymodbus.client.async import ModbusSerialClient as ModbusClient
from pymodbus.client.asynchronous import ModbusSerialClient as ModbusClient
from base_runner import Runner

class AsynchronousAsciiClient(Runner, unittest.TestCase):
Expand Down
2 changes: 1 addition & 1 deletion examples/functional/asynchronous_rtu_client.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
#!/usr/bin/env python
import unittest
from pymodbus.client.async import ModbusSerialClient as ModbusClient
from pymodbus.client.asynchronous import ModbusSerialClient as ModbusClient
from base_runner import Runner

class AsynchronousRtuClient(Runner, unittest.TestCase):
Expand Down
2 changes: 1 addition & 1 deletion examples/functional/asynchronous_tcp_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
import unittest
from twisted.internet import reactor, protocol
from pymodbus.constants import Defaults
from pymodbus.client.async import ModbusClientProtocol
from pymodbus.client.asynchronous import ModbusClientProtocol
from base_runner import Runner

class AsynchronousTcpClient(Runner, unittest.TestCase):
Expand Down
2 changes: 1 addition & 1 deletion examples/gui/bottle/frontend.py
Original file line number Diff line number Diff line change
Expand Up @@ -260,7 +260,7 @@ def RunDebugModbusFrontend(server, port=8080):
# ------------------------------------------------------------
# an example server configuration
# ------------------------------------------------------------
from pymodbus.server.async import ModbusServerFactory
from pymodbus.server.asynchronous import ModbusServerFactory
from pymodbus.constants import Defaults
from pymodbus.device import ModbusDeviceIdentification
from pymodbus.datastore import ModbusSequentialDataBlock
Expand Down
2 changes: 1 addition & 1 deletion examples/gui/gtk/simulator.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
# --------------------------------------------------------------------------- #
from twisted.internet import reactor
from twisted.internet import error as twisted_error
from pymodbus.server.async import ModbusServerFactory
from pymodbus.server.asynchronous import ModbusServerFactory
from pymodbus.datastore import ModbusServerContext,ModbusSlaveContext

#--------------------------------------------------------------------------#
Expand Down
2 changes: 1 addition & 1 deletion examples/gui/gui_common.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
# -------------------------------------------------------------------------- #
from twisted.internet import reactor
from twisted.internet import error as twisted_error
from pymodbus.server.async import ModbusServerFactory
from pymodbus.server.asynchronous import ModbusServerFactory
from pymodbus.datastore import ModbusServerContext,ModbusSlaveContext

# -------------------------------------------------------------------------- #
Expand Down
2 changes: 1 addition & 1 deletion examples/gui/tk/simulator.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@
# --------------------------------------------------------------------------- #
from twisted.internet import reactor
from twisted.internet import error as twisted_error
from pymodbus.server.async import ModbusServerFactory
from pymodbus.server.asynchronous import ModbusServerFactory
from pymodbus.datastore import ModbusServerContext,ModbusSlaveContext

#--------------------------------------------------------------------------#
Expand Down
2 changes: 1 addition & 1 deletion examples/gui/wx/simulator.py
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
# --------------------------------------------------------------------------- #
from twisted.internet import reactor
from twisted.internet import error as twisted_error
from pymodbus.server.async import ModbusServerFactory
from pymodbus.server.asynchronous import ModbusServerFactory
from pymodbus.datastore import ModbusServerContext,ModbusSlaveContext

#--------------------------------------------------------------------------#
Expand Down
2 changes: 1 addition & 1 deletion examples/twisted/plugins/pymodbus_plugin.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
from twisted.application import internet

from pymodbus.constants import Defaults
from pymodbus.server.async import ModbusServerFactory
from pymodbus.server.asynchronous import ModbusServerFactory
from pymodbus.transaction import ModbusSocketFramer
from pymodbus.internal.ptwisted import InstallManagementConsole

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,21 +4,21 @@

Example run::

from pymodbus.client.async import schedulers
from pymodbus.client.asynchronous import schedulers

# Import The clients

from pymodbus.client.async.tcp import AsyncModbusTCPClient as Client
from pymodbus.client.async.serial import AsyncModbusSerialClient as Client
from pymodbus.client.async.udp import AsyncModbusUDPClient as Client
from pymodbus.client.asynchronous.tcp import AsyncModbusTCPClient as Client
from pymodbus.client.asynchronous.serial import AsyncModbusSerialClient as Client
from pymodbus.client.asynchronous.udp import AsyncModbusUDPClient as Client

# For tornado based async client use
# For tornado based asynchronous client use
event_loop, future = Client(schedulers.IO_LOOP, port=5020)

# For twisted based async client use
# For twisted based asynchronous client use
event_loop, future = Client(schedulers.REACTOR, port=5020)

# For asyncio based async client use
# For asyncio based asynchronous client use
event_loop, client = Client(schedulers.ASYNC_IO, port=5020)

# Here event_loop is a thread which would control the backend and future is
Expand Down Expand Up @@ -73,7 +73,7 @@ class AsyncModbusClientMixin(BaseAsyncModbusClient):
def __init__(self, host="127.0.0.1", port=Defaults.Port, framer=None,
source_address=None, timeout=None, **kwargs):
"""
Initializes a Modbus TCP/UDP async client
Initializes a Modbus TCP/UDP asynchronous client
:param host: Host IP address
:param port: Port
:param framer: Framer to use
Expand Down
Loading