cli.seq_server.myBobServer Class Reference

Sequencer server class. More...

Public Member Functions
def	proc_reader (self)
def	start_seq_shell (self)
def	stop_seq_shell (self)
def	talk_to_client (self, reader, writer)
def	start_server (self)
def	final_cleanup (self)
def	sig_handler (self)
	KILL signal handle. More...
def	do_clear (self, arg)
def	do_quit (self, line)

Static Public Attributes
	host = attr.ib(default="localhost")
	port = attr.ib(default=8000)
	redis = attr.ib(default=None)
	log_level = attr.ib(default=logging.INFO)
	proc = attr.ib(default=None, init=False)
	q = attr.ib(default=attr.Factory(asyncio.Queue), init=False)
	running_flag = attr.ib(default=True, init=False)
	reader_flag = attr.ib(default=True, init=False)
	reader_task = attr.ib(default=None, init=False)

Detailed Description

Sequencer server class.

Member Function Documentation

do_clear()

def cli.seq_server.myBobServer.do_clear	(		self,
			arg
	)

Kills suboprocess

do_quit()

def cli.seq_server.myBobServer.do_quit	(		self,
			line
	)

quit command

final_cleanup()

def cli.seq_server.myBobServer.final_cleanup

(

self

)

Attempts to finish the process cleanly

proc_reader()

def cli.seq_server.myBobServer.proc_reader

(

self

)

Read stdout from connected pipe

sig_handler()

def cli.seq_server.myBobServer.sig_handler

(

self

)

KILL signal handle.

start_seq_shell()

def cli.seq_server.myBobServer.start_seq_shell

(

self

)

Starts the `seq shell` subprocess.

The `seq server` is a wrapper around a `seq shell` process.
The `seq server` listens for commands from the network and forwards
them to the `seq shell` process.
The replies from `seq shell` in stdout are read in the asynchronous
function proc_reader() which forwards them to the `seq shell`
stdout.

When a clean session is needed, the process is terminated (clear
command) and a new one is started.

start_server()

def cli.seq_server.myBobServer.start_server

(

self

)

Creates a Socket Server using async.start_server.

Commands incomming in the socket will be processed by
self.talk_to_client.

See: https://docs.python.org/3/library/asyncio-stream.html#asyncio.start_server

stop_seq_shell()

def cli.seq_server.myBobServer.stop_seq_shell

(

self

)

unused

talk_to_client()

def cli.seq_server.myBobServer.talk_to_client	(		self,
			reader,
			writer
	)

Handles incomming strings from the Socket Server and forwards
them to the stdin of the Subprocess `seq shell`.
It also echoes the incomming strings back to the client.

Member Data Documentation

host

cli.seq_server.myBobServer.host = attr.ib(default="localhost")

static

log_level

cli.seq_server.myBobServer.log_level = attr.ib(default=logging.INFO)

static

port

cli.seq_server.myBobServer.port = attr.ib(default=8000)

static

proc

cli.seq_server.myBobServer.proc = attr.ib(default=None, init=False)

static

q

cli.seq_server.myBobServer.q = attr.ib(default=attr.Factory(asyncio.Queue), init=False)

static

reader_flag

cli.seq_server.myBobServer.reader_flag = attr.ib(default=True, init=False)

static

reader_task

cli.seq_server.myBobServer.reader_task = attr.ib(default=None, init=False)

static

redis

cli.seq_server.myBobServer.redis = attr.ib(default=None)

static

running_flag

cli.seq_server.myBobServer.running_flag = attr.ib(default=True, init=False)

static

---

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

• seq/seqcli/src/seq/cli/seq_server.py