libassa 3.5.1
Loading...
Searching...
No Matches
Public Types | Public Member Functions | Private Member Functions | Static Private Member Functions | Private Attributes | Friends | List of all members
ASSA::CharInBuffer Class Reference

CharInBuffer is a bucket for the character-based streams/messages. More...

#include <CharInBuffer.h>

Public Types

enum  state_t { start , waiting , complete , error }
 States: start, waiting, complete, error. More...
 

Public Member Functions

 CharInBuffer (size_t size_, const string &delimiter_)
 Constructor.
 
 operator void * () const
 Test the state of an object.
 
const charc_str () const
 Get the constant character pointer to the buffer.
 
size_t length () const
 Bytes in the buffer so far.
 
size_t size () const
 Bytes in the buffer so far.
 
void reset ()
 Discard all accumulated characters and be ready to receive a new message.
 
void dump () const
 Write the state of an object to the log file.
 
state_t state () const
 Report the current state of the object.
 

Private Member Functions

void state (state_t new_state_)
 Go to the new state.
 
void chop ()
 Remove the delimiter from the end of the buffer.
 

Static Private Member Functions

static const charstate_name (state_t state_)
 Report the state name.
 

Private Attributes

state_t m_state
 Internal state of an object.
 
std::string m_buffer
 Buffer to store the bytes received.
 
size_t m_max_size
 Maximum allowable size (delimiter included) before overflow occurs.
 
std::string m_delimiter
 Delimiter. Multibyte delimiter is allowed.
 

Friends

ASSA::Socketoperator>> (ASSA::Socket &, ASSA::CharInBuffer &)
 Read bytes from Socket stream until either record delimiter is detected, or EOF occured, or Socket stream is exhausted.
 

Detailed Description

CharInBuffer is a bucket for the character-based streams/messages.

It helps in reading, parsing, and storing record-oriented character streams from Socket stream asynchronously. The record terminator can be multibyte. The terminator is detected and removed from the bucket. When terminator is detected, the block of characters collected in the bucket is ready to be processed further by the application according to its communication protocol. If either Socket read() error is encountered, or an overflow occurs (number of characters read exceeds the maximum limit), the object goes into the error state and won't accept further input, unless reset.

Definition at line 44 of file CharInBuffer.h.

Member Enumeration Documentation

◆ state_t

States: start, waiting, complete, error.

Enumerator
start 

start state

waiting 

incomplete record is in the buffer

complete 

matched end-of-record - full record

error 

overflow or Socket I/O error

Definition at line 85 of file CharInBuffer.h.

85 {
86 start,
87 waiting,
88 complete,
89 error
90 };
@ start
start state
@ complete
matched end-of-record - full record
@ error
overflow or Socket I/O error
@ waiting
incomplete record is in the buffer

Constructor & Destructor Documentation

◆ CharInBuffer()

CharInBuffer::CharInBuffer ( size_t  size_,
const string &  delimiter_ 
)

Constructor.

Parameters
size_Maximum expected size before buffer overflow
delimiter_End-of-record character(s). Can be multi-byte.

Definition at line 24 of file CharInBuffer.cpp.

27{
28 trace_with_mask ("CharInBuffer::CharInBuffer", CHARINBUF);
29
30 if (m_max_size == 0 || m_delimiter.length () == 0) {
31 state (error);
32 }
33 state (waiting);
34}
#define trace_with_mask(s, m)
trace_with_mask() is used to trace function call chain in C++ program.
Definition Logger.h:437
A wrapper class to provide AutoPtr with reference semantics.
Definition AutoPtr.h:32
state_t m_state
Internal state of an object.
std::string m_delimiter
Delimiter. Multibyte delimiter is allowed.
size_t m_max_size
Maximum allowable size (delimiter included) before overflow occurs.
state_t state() const
Report the current state of the object.
@ CHARINBUF
Class CharInBuffer messages
Definition LogMask.h:50

References ASSA::CHARINBUF, error, m_delimiter, m_max_size, state(), trace_with_mask, and waiting.

Member Function Documentation

◆ c_str()

const char * ASSA::CharInBuffer::c_str ( ) const
inline

Get the constant character pointer to the buffer.

Definition at line 66 of file CharInBuffer.h.

66{ return m_buffer.c_str (); }
std::string m_buffer
Buffer to store the bytes received.

References m_buffer.

◆ chop()

void CharInBuffer::chop ( )
inlineprivate

Remove the delimiter from the end of the buffer.

Definition at line 144 of file CharInBuffer.h.

146{
147 m_buffer.replace (m_buffer.find (m_delimiter), m_delimiter.length (), "");
148}

References m_buffer, and m_delimiter.

◆ dump()

void CharInBuffer::dump ( ) const

Write the state of an object to the log file.

Definition at line 50 of file CharInBuffer.cpp.

52{
53 DL((CHARINBUF,"== CharInBuffer state ==\n"));
54 DL((CHARINBUF,"m_state = %s\n", state_name (m_state)));
55 DL((CHARINBUF,"m_max_size = %d\n", m_max_size));
56
57 MemDump::dump_to_log (TRACE, "m_delimiter:\n",
58 m_delimiter.c_str (), m_delimiter.length ());
59
60 MemDump::dump_to_log (TRACE, "m_buffer:\n",
61 m_buffer.c_str (), m_buffer.length ());
62
63 DL((CHARINBUF,"========================\n"));
64}
#define DL(X)
A macro for writing debug message to the Logger.
Definition Logger.h:273
static const char * state_name(state_t state_)
Report the state name.
static void dump_to_log(unsigned long mask_, const char *info_, const char *msg_, int len_)
Write hex/ascii dump of a memory region to log file.
Definition MemDump.cpp:111
@ TRACE
Function call trace
Definition LogMask.h:26

References ASSA::CHARINBUF, DL, ASSA::MemDump::dump_to_log(), m_buffer, m_delimiter, m_max_size, m_state, state_name(), and ASSA::TRACE.

◆ length()

size_t ASSA::CharInBuffer::length ( ) const
inline

Bytes in the buffer so far.

Definition at line 69 of file CharInBuffer.h.

69{ return m_buffer.length (); }

References m_buffer.

◆ operator void *()

CharInBuffer::operator void * ( ) const
inline

Test the state of an object.

Returns
true if the object holds a complete message; false otherwise (eof, buffer overflow, or incomplete)

Definition at line 127 of file CharInBuffer.h.

129{
130 return (m_state == complete
131 ? (void *) (-1) // good state
132 : (void *) 0); // bad state
133}

◆ reset()

void CharInBuffer::reset ( )
inline

Discard all accumulated characters and be ready to receive a new message.

Definition at line 136 of file CharInBuffer.h.

138{
139 m_buffer = "";
140 state (waiting);
141}

References m_buffer, state(), and waiting.

◆ size()

size_t ASSA::CharInBuffer::size ( ) const
inline

Bytes in the buffer so far.

Definition at line 72 of file CharInBuffer.h.

72{ return m_buffer.size (); }

References m_buffer.

◆ state() [1/2]

state_t ASSA::CharInBuffer::state ( ) const
inline

Report the current state of the object.

Definition at line 93 of file CharInBuffer.h.

93{ return m_state; }

References m_state.

Referenced by CharInBuffer(), and reset().

◆ state() [2/2]

void ASSA::CharInBuffer::state ( state_t  new_state_)
inlineprivate

Go to the new state.

Definition at line 100 of file CharInBuffer.h.

100{ m_state = new_state_; }

References m_state.

◆ state_name()

const char * CharInBuffer::state_name ( state_t  state_)
staticprivate

Report the state name.

Definition at line 37 of file CharInBuffer.cpp.

39{
40 static const char* vmsg[] =
41 { "start", "waiting", "complete", "error", "unknown state" };
42
44 return vmsg [sizeof (vmsg)-1];
45 }
46 return vmsg [state_];
47}

References error.

Referenced by dump().

Friends And Related Symbol Documentation

◆ operator>>

ASSA::Socket & operator>> ( ASSA::Socket s_,
ASSA::CharInBuffer b_ 
)
friend

Read bytes from Socket stream until either record delimiter is detected, or EOF occured, or Socket stream is exhausted.

Returns
Socket reference

If match, bite off delimiter and set the state to complete. If not, continue reading till either there is no more characters to read, or Socket error (Fail or EOF), or buffer overflow. If overflow occurs, set the state to 'error' and terminate.

Definition at line 80 of file CharInBuffer.cpp.

81{
82 trace_with_mask ("Socket >> CharInBuffer", CHARINBUF);
83 register char c;
84
85 if (b_.state () != CharInBuffer::waiting) {
86 DL((CHARINBUF,"Wrong state %s\n", b_.state_name (b_.state ())));
87 return s_;
88 }
89
90 while (s_.read (&c, 1) == 1)
91 {
92 b_.m_buffer += c;
93
94 if (b_.m_buffer.size() < b_.m_delimiter.size()) { // Bug # 1252926
95 continue;
96 }
97
98 if (b_.m_buffer.substr (
99 b_.m_buffer.size ()-b_.m_delimiter.size ()) == b_.m_delimiter)
100 {
101 b_.chop ();
102 b_.m_state = CharInBuffer::complete;
103 return s_;
104 }
105
106 if (b_.m_buffer.length () >= b_.m_max_size) {
107 b_.m_state = CharInBuffer::error;
108 break;
109 }
110 }
111
112 if (!s_) { // EOF or error
113 b_.state (CharInBuffer::error);
114 }
115
116 return s_;
117}

Member Data Documentation

◆ m_buffer

std::string ASSA::CharInBuffer::m_buffer
private

Buffer to store the bytes received.

Definition at line 110 of file CharInBuffer.h.

Referenced by c_str(), chop(), dump(), length(), reset(), and size().

◆ m_delimiter

std::string ASSA::CharInBuffer::m_delimiter
private

Delimiter. Multibyte delimiter is allowed.

Definition at line 116 of file CharInBuffer.h.

Referenced by CharInBuffer(), chop(), and dump().

◆ m_max_size

size_t ASSA::CharInBuffer::m_max_size
private

Maximum allowable size (delimiter included) before overflow occurs.

Definition at line 113 of file CharInBuffer.h.

Referenced by CharInBuffer(), and dump().

◆ m_state

state_t ASSA::CharInBuffer::m_state
private

Internal state of an object.

Definition at line 107 of file CharInBuffer.h.

Referenced by dump(), state(), and state().


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