comms.repository._HandlerThread Class Reference

Implementation of a processing thread to handle requests to a repository adapter asynchronously. More...

Inheritance diagram for comms.repository._HandlerThread:

Public Member Functions
def	__init__ (self, repository, request_queue, response_queue, logger)
def	run (self)
	Starts the thread and enters its processing loop to handle requests asynchronously.
def	stop (self)
	Stops the thread's processing loop.

Protected Member Functions
bool	_dispatch_request (self, request)
	Implements the dispatching of a request to the appropriate Qt signals.
def	_handle_get_children_request (self, request)
def	_handle_data_point_exists_request (self, request)
def	_handle_create_data_point_request (self, request)
def	_handle_delete_data_point_request (self, request)
def	_handle_read_meta_data_request (self, request)
def	_handle_write_meta_data_request (self, request)

Protected Attributes
	_terminate
	_repository
	_repository_has_server_alias
	_request_queue
	_response_queue
	_logger

Detailed Description

Implementation of a processing thread to handle requests to a repository adapter asynchronously.

Constructor & Destructor Documentation

__init__()

def comms.repository._HandlerThread.__init__	(		self,
			repository,
			request_queue,
			response_queue,
			logger
	)

Reimplemented in comms.repository._PersistentHandlerThread, and comms.repository._RuntimeHandlerThread.

Member Function Documentation

_dispatch_request()

bool comms.repository._HandlerThread._dispatch_request (   self,   request  )

protected

Implements the dispatching of a request to the appropriate Qt signals.

This can be overridden by child thread classes to extent the types of requests to be handled.

Reimplemented in comms.repository._RuntimeHandlerThread.

_handle_create_data_point_request()

def comms.repository._HandlerThread._handle_create_data_point_request (   self,   request  )

protected

_handle_data_point_exists_request()

def comms.repository._HandlerThread._handle_data_point_exists_request (   self,   request  )

protected

_handle_delete_data_point_request()

def comms.repository._HandlerThread._handle_delete_data_point_request (   self,   request  )

protected

_handle_get_children_request()

def comms.repository._HandlerThread._handle_get_children_request (   self,   request  )

protected

_handle_read_meta_data_request()

def comms.repository._HandlerThread._handle_read_meta_data_request (   self,   request  )

protected

_handle_write_meta_data_request()

def comms.repository._HandlerThread._handle_write_meta_data_request (   self,   request  )

protected

run()

def comms.repository._HandlerThread.run

(

self

)

Starts the thread and enters its processing loop to handle requests asynchronously.

stop()

def comms.repository._HandlerThread.stop

(

self

)

Stops the thread's processing loop.

Member Data Documentation

_logger

comms.repository._HandlerThread._logger

protected

_repository

comms.repository._HandlerThread._repository

protected

_repository_has_server_alias

comms.repository._HandlerThread._repository_has_server_alias

protected

_request_queue

comms.repository._HandlerThread._request_queue

protected

_response_queue

comms.repository._HandlerThread._response_queue

protected

_terminate

comms.repository._HandlerThread._terminate

protected

---

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

• clients/configTool/src/rtctk/configtool/comms/repository.py