rosbridge_server.autobahn_websocket.OutgoingValve Class Reference

Public Member Functions
def	__init__ (self, proto)
def	pauseProducing (self)
def	relay (self, message)
def	resumeProducing (self)
def	stopProducing (self)

Private Attributes
	_finished
	_proto
	_valve

Detailed Description

Allows the Autobahn transport to pause outgoing messages from rosbridge.

The purpose of this valve is to connect backpressure from the WebSocket client
back to the rosbridge protocol, which depends on backpressure for queueing.
Without this flow control, rosbridge will happily keep writing messages to
the WebSocket until the system runs out of memory.

This valve is closed and opened automatically by the Twisted TCP server.
In practice, Twisted should only close the valve when its userspace write buffer
is full and it should only open the valve when that buffer is empty.

When the valve is closed, the rosbridge protocol instance's outgoing writes
must block until the valve is opened.

Definition at line 70 of file autobahn_websocket.py.

Constructor & Destructor Documentation

def rosbridge_server.autobahn_websocket.OutgoingValve.__init__	(		self,
			proto
	)

Definition at line 85 of file autobahn_websocket.py.

Member Function Documentation

def rosbridge_server.autobahn_websocket.OutgoingValve.pauseProducing

(

self

)

Definition at line 97 of file autobahn_websocket.py.

def rosbridge_server.autobahn_websocket.OutgoingValve.relay	(		self,
			message
	)

Definition at line 91 of file autobahn_websocket.py.

def rosbridge_server.autobahn_websocket.OutgoingValve.resumeProducing

(

self

)

Definition at line 101 of file autobahn_websocket.py.

def rosbridge_server.autobahn_websocket.OutgoingValve.stopProducing

(

self

)

Definition at line 104 of file autobahn_websocket.py.

Member Data Documentation

rosbridge_server.autobahn_websocket.OutgoingValve._finished

private

Definition at line 88 of file autobahn_websocket.py.

rosbridge_server.autobahn_websocket.OutgoingValve._proto

private

Definition at line 86 of file autobahn_websocket.py.

rosbridge_server.autobahn_websocket.OutgoingValve._valve

private

Definition at line 87 of file autobahn_websocket.py.

---

The documentation for this class was generated from the following file:

• autobahn_websocket.py