Feature #712
Implement socket-based transport
| Status: | Resolved | Start date: | 11/10/2011 | |
|---|---|---|---|---|
| Priority: | High | Due date: | ||
| Assignee: | J. Moringen | % Done: | 100% | |
| Category: | Python | |||
| Target version: | rsb-0.7 |
Related issues
Associated revisions
Initial partial implementation of socket-based transport
refs #712
refs #712
- rsb/__init__.py: accept "socket" as transport name; look up
corresponding connector class - rsb/eventprocessing.py: added class BroadcastProcessor
- rsb/transport/socket/__init__.py: new file; contains initial
implementation of socket-based transport
Partially usable socket transport
refs #712
refs #712
- rsb/transport/rsbspread/conversion.py: provide event <->
notification conversion - without fragmentation - in separate
functions - rsb/transport/socket/__init__.py: implemented event distribution in
Bus; implemented __getBus in Connector; event <-> notification
conversion in {InPush,Out}Connector - test/__init__.py: added socket transport tests
- test/sockettransporttest.py: new file; contains unit test for socket
transport
Extended implementation in rsb/transport/socket/__init__.py
refs #712
refs #712
- rsb/transport/socket/__init__.py: added handshake; added some
logging; perform state management via (de)activate methods;
implemented notification routing in BusServer
Fixed connector class name in rsb/__init__.py
refs #712
refs #712
- rsb/__init__.py: in Participant.getConnector fixed connector class
name rsb.transport.socket.{In -> InPush}Connector
Fixed server construction in rsb/transport/socket/__init__.py
refs #712
refs #712
- rsb/transport/socket/__init__.py: store host, port and backlog
parameters in slots; use in activate method
Shutdown improvements in rsb/transport/socket/__init__.py
fixes #712
fixes #712
- rsb/transport/socket/__init__.py: added error hook to BusConnection;
fixed state management of BusConnection; fixed state management of
Bus and BusServer; added removeConnector function to removed
connectors from a bus after deactivation; implemented state
management in Connector class
Fixes and cleanup in rsb/transport/socket/__init__.py
refs #712
refs #712
- rsb/transport/socket/__init__.py: simplifications in
BusConnection.{__del__,deactivate}; fixed routing of incoming events
in Bus
Fixed routing in Bus in rsb/transport/socket/__init__.py
refs #712
refs #712
- rsb/transport/socket/__init__.py: notifications should only be
deliver to connectors whose scope are superscopes of the
notifications' scopes
Fixed deadlock in rsb/transport/socket/__init__.py
refs #712
refs #712
- rsb/transport/socket/__init__.py: fix deadlock that would happen
when a connection received a notification while the owning bus was
being deactivated; added some comments; minor cleanup
History
#1 Updated by S. Wrede almost 12 years ago
- Priority changed from Normal to High
- Target version changed from rsb-1.0 to rsb-0.7
#2 Updated by J. Moringen almost 12 years ago
- % Done changed from 30 to 60
#3 Updated by J. Moringen almost 12 years ago
- % Done changed from 60 to 80
#4 Updated by J. Moringen almost 12 years ago
- Status changed from In Progress to Resolved
- % Done changed from 80 to 100
Applied in changeset r3648.