 |
Qorus Integration Engine® Enterprise Edition 6.0.16_prod
|
|
Qorus Integration Engine® Enterprise Edition 6.0.16_prod
|
this class handles stream classes that use an I/O thread to send data More...
Public Member Methods | |
| destructor () | |
| waits for any I/O to complete and then returns | |
| nothing | cleanup () |
| called when the thread resource is still allocated and the thread exits or one of Qore::throw_thread_resource_exceptions() or Qore::throw_thread_resource_exceptions_to_mark() is called | |
| disconnect () | |
| Disconnects the connection. | |
| flush () | |
| flushes all remote I/O, signals the I/O thread to terminate and waits for confirmation, then checks for background I/O errors, in which case an exception is thrown in this thread More... | |
| abstract private | terminateIoWait (string action) |
| flushes all remote I/O, signals the I/O thread the terminate and waits for confirmation, then checks for background I/O errors, in which case an exception is thrown in this thread | |
| abstract private | stopIoThreadImpl () |
| signal the I/O thread to top sending data | |
| abstract private bool | submitImpl () |
| puts data on the queue for sending in the background I/O thread More... | |
Private Member Methods | |
| bool | terminateIoWaitIntern (string action) |
| flushes all remote I/O, signals the I/O thread the terminate and waits for confirmation, then checks for background I/O errors, in which case an exception is thrown in this thread More... | |
Additional Inherited Members | |
 Private:Internal Member Methods inherited from OMQ::AbstractParallelStream | |
| destructor () | |
| wait for any I/O in progress to complete | |
| nothing | cleanupBase () |
| called by child classes when the thread resource is still allocated and the thread exits or one of Qore::throw_thread_resource_exceptions() or Qore::throw_thread_resource_exceptions_to_mark() is called | |
| bool | inTransaction () |
| Returns True if a remote transaction is in progress. More... | |
| OMQ::StreamInfo | getInfo () |
| returns performance information about the stream | |
| abstract private | socketThreadImpl () |
| this method implements the background thread that handles the actual DataStream socket sends | |
| abstract private | startStreamImpl () |
| opens the remote transaction before starting the background I/O socket thread | |
| abstract OMQ::StreamConfig | config () |
| returns the configuration object | |
| Qore::Thread::Counter | cnt () |
| confirmation counter for the socket I/O thread | |
| OMQ::StreamInfo | m_info () |
| stream information | |
| waitIoComplete () | |
| waits for the I/O thread to complete and returns | |
| markIoInProgress () | |
| marks the current connection as in progress; must be already checked beforehand that it's not in progress | |
| markIoComplete () | |
| performs thread cleanup on the background I/O thread if any is registered and running | |
| checkError (string cmd) | |
| checks for an error in the background send thread; if there is one, then rethrows the exception in the main application / data thread | |
| startStream () | |
| opens the remote transaction by calling startStreamImpl() and starts the background I/O socket thread More... | |
| socketThread (*ThreadLocalData my_tld) | |
| sets up thread-local data if possible and calls socketThreadImpl() that implements the background socket I/O for the object | |
| abortIo (string reason) | |
| signals the end of queue operations | |
| bool | abortIoWait (string reason) |
| signals the end of queue operations and waits until the socket thread terminates More... | |
| beginTransaction (OMQ::DbStreamConfig m_config) | |
| starts or continues a remote transaction | |
| commit (OMQ::DbStreamConfig m_config) | |
| commits a remote transaction | |
| rollback (OMQ::DbStreamConfig m_config) | |
| rolls back a remote transaction | |
| Static Private:Internal Member Methods inherited from OMQ::AbstractParallelStream | |
| static | staticCleanup () |
| performs static thread resource cleanup on I/O thread resources | |
| static | checkStream (QorusSystemRestHelper helper, string op) |
| checks if there is a stream operation running in the background, if so, a user-friendly exception is thrown | |
| static | beginTransaction (QorusSystemRestHelper remote, string datasource, *timeout timeout_ms, *reference info) |
| starts a transaction in a remote datasource More... | |
| Private:Internal Attributes inherited from OMQ::AbstractParallelStream | |
| const | DO_DISCONNECT = True |
| A constant for rollback() methods to perform real disconnect. | |
| const | DONT_DISCONNECT = False |
| A constant for rollback() methods to keep the network connection alive. | |
| Qore::Thread::Queue | dataq |
| Queue for the socket I/O thread. | |
| *hash< auto > | thread_ex |
| exception info for send thread to communicate errors to the primary data thread | |
| string | objid |
| stream object identifier | |
| const | StreamTerminatedError = "STREAM-TERMINATED" |
| stream terminated error | |
| const | ThreadKey = "_STREAM_" |
| thread-local data key | |
this class handles stream classes that use an I/O thread to send data
such classes have the following characteristics:
| OMQ::AbstractParallelWriteStream::flush | ( | ) |
flushes all remote I/O, signals the I/O thread to terminate and waits for confirmation, then checks for background I/O errors, in which case an exception is thrown in this thread
use this method when a remote operation should be continued in the same HTTP connection, for example
|
pure virtual |
puts data on the queue for sending in the background I/O thread
Implemented in OMQ::DbRemoteSend, and OMQ::FsRemoteSend.
|
private |
flushes all remote I/O, signals the I/O thread the terminate and waits for confirmation, then checks for background I/O errors, in which case an exception is thrown in this thread
called by terminateIoWait()