|
Bayonne2 / Common C++ 2 Framework
|
All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
|
Bayonne2 / Common C++ 2 Framework
|
The SerialService is a thead service object that is meant to service attached serial ports. More...
#include <serial.h>
Public Types | |
| enum | Throw { throwNothing, throwObject, throwException } |
| How to raise error. More... | |
| typedef enum Thread::Throw | Throw |
| How to raise error. More... | |
| enum | Cancel { cancelInitial =0, cancelDeferred =1, cancelImmediate, cancelDisabled, cancelManual, cancelDefault =cancelDeferred } |
| How work cancellation. More... | |
| typedef enum Thread::Cancel | Cancel |
| How work cancellation. More... | |
| enum | Suspend { suspendEnable, suspendDisable } |
| How work suspend. More... | |
| typedef enum Thread::Suspend | Suspend |
| How work suspend. More... | |
Public Member Functions | |
| void | update (unsigned char flag=0xff) |
| Notify service thread that a port has been added or removed, or a timer changed, so that a new schedule can be computed for expiring attached ports. More... | |
| SerialService (int pri=0, size_t stack=0, const char *id=NULL) | |
| Create a service thread for attaching serial ports. More... | |
| virtual | ~SerialService () |
| Terminate the service thread and update attached objects. More... | |
| int | getCount (void) |
| Get current reference count. More... | |
| int | start (Semaphore *start=0) |
| When a new thread is created, it does not begin immediate execution. More... | |
| int | detach (Semaphore *start=0) |
| Start a new thread as "detached". More... | |
| Thread * | getParent (void) |
| Gets the pointer to the Thread class which created the current thread object. More... | |
| void | suspend (void) |
| Suspends execution of the selected thread. More... | |
| void | resume (void) |
| Resumes execution of the selected thread. More... | |
| Cancel | getCancel (void) |
| Used to retrieve the cancellation mode in effect for the selected thread. More... | |
| bool | isRunning (void) const |
| Verifies if the thread is still running or has already been terminated but not yet deleted. More... | |
| bool | isDetached (void) const |
| Check if this thread is detached. More... | |
| void | join (void) |
| Blocking call which unlocks when thread terminates. More... | |
| bool | isThread (void) const |
| Tests to see if the current execution context is the same as the specified thread object. More... | |
| cctid_t | getId (void) const |
| Get system thread numeric identifier. More... | |
| const char * | getName (void) const |
| Get the name string for this thread, to use in debug messages. More... | |
Static Public Member Functions | |
| static Thread * | get (void) |
| static void | setStack (size_t size=0) |
| Set base stack limit before manual stack sizes have effect. More... | |
| static void | sleep (timeout_t msec) |
| A thread-safe sleep call. More... | |
| static void | yield (void) |
| Yields the current thread's CPU time slice to allow another thread to begin immediate execution. More... | |
| static Throw | getException (void) |
| Get exception mode of the current thread. More... | |
| static void | setException (Throw mode) |
| Set exception mode of the current thread. More... | |
| static Cancel | enterCancel (void) |
| This is used to help build wrapper functions in libraries around system calls that should behave as cancellation points but don't. More... | |
| static void | exitCancel (Cancel cancel) |
| This is used to restore a cancel block. More... | |
Protected Member Functions | |
| virtual void | onUpdate (unsigned char flag) |
| A virtual handler for processing user defined update requests (1-254) which have been posted through Update. More... | |
| virtual void | onEvent (void) |
| A virtual handler for event loop calls. More... | |
| virtual void | onCallback (SerialPort *port) |
| A virtual handler for adding support for additional callback events into SerialPort. More... | |
| void | setName (const char *text) |
| Set the name of the current thread. More... | |
| virtual void | final (void) |
| A thread that is self terminating, either by invoking exit() or leaving it's run(), will have this method called. More... | |
| virtual void | initial (void) |
| The initial method is called by a newly created thread when it starts execution. More... | |
| virtual void * | getExtended (void) |
| Since getParent() and getThread() only refer to an object of the Thread "base" type, this virtual method can be replaced in a derived class with something that returns data specific to the derived class that can still be accessed through the pointer returned by getParent() and getThread(). More... | |
| virtual void | notify (Thread *) |
| When a thread terminates, it now sends a notification message to the parent thread which created it. More... | |
| void | exit (void) |
| Used to properly exit from a Thread derived run() or initial() method. More... | |
| void | sync (void) |
| Used to wait for a join or cancel, in place of explicit exit. More... | |
| bool | testCancel (void) |
| test a cancellation point for deferred thread cancellation. More... | |
| void | setCancel (Cancel mode) |
| Sets thread cancellation mode. More... | |
| void | setSuspend (Suspend mode) |
| Sets the thread's ability to be suspended from execution. More... | |
| void | terminate (void) |
| Used by another thread to terminate the current thread. More... | |
| void | clrParent (void) |
| clear parent thread relationship. More... | |
Private Member Functions | |
| void | attach (SerialPort *port) |
| Attach a new serial port to this service thread. More... | |
| void | detach (SerialPort *port) |
| Detach a serial port from this service thread. More... | |
| void | run (void) |
| The service thread itself. More... | |
| void | nameMutex (const char *name) |
| Enable setting of mutex name for deadlock debug. More... | |
| void | enterMutex (void) |
| Entering a Mutex locks the mutex for the current thread. More... | |
| void | enter (void) |
| Future abi will use enter/leave/test members. More... | |
| void | leave (void) |
| Future abi will use enter/leave/test members. More... | |
| bool | test (void) |
| Future abi will use enter/leave/test members. More... | |
| bool | tryEnterMutex (void) |
| Tries to lock the mutex for the current thread. More... | |
| void | leaveMutex (void) |
| Leaving a mutex frees that mutex for use by another thread. More... | |
Static Private Member Functions | |
| static void | setDebug (bool mode) |
| Enable or disable deadlock debugging. More... | |
Private Attributes | |
| fd_set | connect |
| int | iosync [2] |
| int | hiwater |
| int | count |
| SerialPort * | first |
| SerialPort * | last |
Friends | |
| class | SerialPort |
The SerialService is a thead service object that is meant to service attached serial ports.
Multiple pool objects may be created and multiple serial ports may be attached to the same thread of of execution. This allows one to balance threads and the serial ports they service.
The TTYPort and TTYService classes are used to form thread-pool serviced serial I/O protocol sets. These can be used when one has a large number of serial devices to manage, and a single (or limited number of) thread(s) can then be used to service the tty port objects present. Each tty port supports a timer control and several virtual methods that the service thread can call when events occur. This model provides for "callback" event management, whereby the service thread performs a "callback" into the port object when events occur. Specific events supported include the expiration of a TTYPort timer, pending input data waiting to be read, and "sighup" connection breaks.
|
inherited |
How work cancellation.
|
inherited |
How work suspend.
|
inherited |
How to raise error.
|
inherited |
How work cancellation.
| Enumerator | |
|---|---|
| cancelInitial |
used internally, do not use |
| cancelDeferred |
exit thread on cancellation pointsuch as yield |
| cancelImmediate |
exit befor cancellation |
| cancelDisabled |
ignore cancellation |
| cancelManual |
unimplemented (working in progress)
|
| cancelDefault |
default you should use this for compatibility instead of deferred |
|
inherited |
|
inherited |
| SerialService::SerialService | ( | int | pri = 0, |
| size_t | stack = 0, |
||
| const char * | id = NULL |
||
| ) |
Create a service thread for attaching serial ports.
The thread begins execution with the first attached port.
| pri | of this thread to run under. |
| stack | stack size. |
| id | stack ID. |
|
virtual |
Terminate the service thread and update attached objects.
|
private |
Attach a new serial port to this service thread.
| port | of SerialPort derived object to attach. |
|
inlineprotectedinherited |
|
private |
Detach a serial port from this service thread.
| port | of SerialPort derived object to remove. |
|
inherited |
Start a new thread as "detached".
This is an alternative start() method that resolves some issues with later glibc implimentations which incorrectly impliment self-detach.
| start | optional starting semaphore to alternately use. |
|
inlineinherited |
|
staticinherited |
This is used to help build wrapper functions in libraries around system calls that should behave as cancellation points but don't.
|
inherited |
Entering a Mutex locks the mutex for the current thread.
This also can be done using the ENTER_CRITICAL macro or by using the ++ operator on a mutex.
|
protectedinherited |
|
staticinherited |
This is used to restore a cancel block.
| cancel | type that was saved. |
|
protectedvirtualinherited |
A thread that is self terminating, either by invoking exit() or leaving it's run(), will have this method called.
It can be used to self delete the current object assuming the object was created with new on the heap rather than stack local, hence one may often see final defined as "delete this" in a derived thread class. A final method, while running, cannot be terminated or cancelled by another thread. Final is called for all cancellation type (even immediate).
You can safe delete thread ("delete this") class on final, but you should exit ASAP (or do not try to call CommonC++ methods...)
Reimplemented in ThreadQueue.
|
staticinherited |
|
inlineinherited |
|
inline |
|
staticinherited |
Get exception mode of the current thread.
|
protectedvirtualinherited |
Since getParent() and getThread() only refer to an object of the Thread "base" type, this virtual method can be replaced in a derived class with something that returns data specific to the derived class that can still be accessed through the pointer returned by getParent() and getThread().
|
inherited |
Get system thread numeric identifier.
|
inlineinherited |
|
inlineinherited |
|
protectedvirtualinherited |
The initial method is called by a newly created thread when it starts execution.
This method is ran with deferred cancellation disabled by default. The Initial method is given a separate handler so that it can create temporary objects on it's own stack frame, rather than having objects created on run() that are only needed by startup and yet continue to consume stack space.
Reimplemented in TCPSession, and UnixSession.
|
inherited |
Check if this thread is detached.
|
inherited |
Verifies if the thread is still running or has already been terminated but not yet deleted.
|
inherited |
Tests to see if the current execution context is the same as the specified thread object.
|
inherited |
Blocking call which unlocks when thread terminates.
|
inlineinherited |
|
inherited |
Leaving a mutex frees that mutex for use by another thread.
If the mutex has been entered (invoked) multiple times (recursivily) by the same thread, then it will need to be exited the same number of instances before it is free for re-use. This operation can also be done using the LEAVE_CRITICAL macro or by the – operator on a mutex.
|
inlineinherited |
|
protectedvirtualinherited |
When a thread terminates, it now sends a notification message to the parent thread which created it.
The actual use of this notification is left to be defined in a derived class.
| - | the thread that has terminated. |
|
protectedvirtual |
A virtual handler for adding support for additional callback events into SerialPort.
| port | serial port currently being evaluated. |
|
protectedvirtual |
A virtual handler for event loop calls.
This can be used to extend event loop processing.
|
protectedvirtual |
A virtual handler for processing user defined update requests (1-254) which have been posted through Update.
| flag | of update request. |
|
inherited |
Resumes execution of the selected thread.
|
privatevirtual |
The service thread itself.
Implements Thread.
|
protectedinherited |
Sets thread cancellation mode.
Threads can either be set immune to termination (cancelDisabled), can be set to terminate when reaching specific "thread cancellation points" (cancelDeferred) or immediately when Terminate is requested (cancelImmediate).
| mode | for cancellation of the current thread. |
|
inlinestaticinherited |
|
staticinherited |
Set exception mode of the current thread.
|
protectedinherited |
Set the name of the current thread.
If the name is passed as NULL, then the default name is set (usually object pointer).
| text | name to use. |
|
inlinestaticinherited |
|
protectedinherited |
Sets the thread's ability to be suspended from execution.
The thread may either have suspend enabled (suspendEnable) or disabled (suspendDisable).
| mode | for suspend. |
|
staticinherited |
A thread-safe sleep call.
On most Posix systems, "sleep()" is implimented with SIGALRM making it unusable from multipe threads. Pthread libraries often define an alternate "sleep" handler such as usleep(), nanosleep(), or nap(), that is thread safe, and also offers a higher timer resolution.
| msec | timeout in milliseconds. |
|
inherited |
When a new thread is created, it does not begin immediate execution.
This is because the derived class virtual tables are not properly loaded at the time the C++ object is created within the constructor itself, at least in some compiler/system combinations. The thread can either be told to wait for an external semaphore, or it can be started directly after the constructor completes by calling the start() method.
| start | optional starting semaphore to alternately use. |
|
inherited |
Suspends execution of the selected thread.
Pthreads do not normally support suspendable threads, so the behavior is simulated with signals. On systems such as Linux that define threads as processes, SIGSTOP and SIGCONT may be used.
|
protectedinherited |
Used to wait for a join or cancel, in place of explicit exit.
|
protectedinherited |
Used by another thread to terminate the current thread.
Termination actually occurs based on the current setCancel() mode. When the current thread does terminate, control is returned to the requesting thread. terminate() should always be called at the start of any destructor of a class derived from Thread to assure the remaining part of the destructor is called without the thread still executing.
|
inlineinherited |
|
protectedinherited |
test a cancellation point for deferred thread cancellation.
|
inherited |
Tries to lock the mutex for the current thread.
Behaves like enterMutex , except that it doesn't block the calling thread if the mutex is already locked by another thread.
| void SerialService::update | ( | unsigned char | flag = 0xff | ) |
Notify service thread that a port has been added or removed, or a timer changed, so that a new schedule can be computed for expiring attached ports.
This can also be used to pass requests to the OnUpdate() event handler.
| flag | event for OnUpdate, termination, or reschedule. |
|
staticinherited |
Yields the current thread's CPU time slice to allow another thread to begin immediate execution.
|
friend |
|
private |
|
private |
1.8.6