AjpBaseSocket Class Reference

#include <AjpBaseSocket.h>

Inheritance diagram for AjpBaseSocket:

[legend]

Collaboration diagram for AjpBaseSocket:

[legend]

List of all members.

Public Member Functions
	AjpBaseSocket (ISocketHandler &h)
void	OnRawData (const char *buf, size_t sz)
	This callback is executed after a successful read from the socket.
virtual void	OnHeader (short id, short len)=0
virtual void	OnPacket (const char *buf, size_t sz)=0
Protected Member Functions
unsigned char	get_byte (const char *buf, int &ptr)
bool	get_boolean (const char *buf, int &ptr)
short	get_integer (const char *buf, int &ptr)
std::string	get_string (const char *buf, int &ptr)
void	put_byte (char *buf, int &ptr, unsigned char zz)
void	put_boolean (char *buf, int &ptr, bool zz)
void	put_integer (char *buf, int &ptr, short zz)
void	put_string (char *buf, int &ptr, const std::string &zz)
Static Protected Attributes
static Initializer	Init
Private Attributes
int	m_state
int	m_length
int	m_ptr
char	m_message [8192]
Classes
class	Initializer

---

Detailed Description

Definition at line 43 of file AjpBaseSocket.h.

---

Constructor & Destructor Documentation

AjpBaseSocket::AjpBaseSocket

(

ISocketHandler &

h

)

Definition at line 127 of file AjpBaseSocket.cpp.

                                              : TcpSocket(h)
, m_state(0)
, m_length(4)
, m_ptr(0)
{
}

---

Member Function Documentation

void AjpBaseSocket::OnRawData	(	const char *	buf,
		size_t	len
	)			[virtual]

This callback is executed after a successful read from the socket.

Parameters:

	buf	Pointer to the data
	len	Length of the data

Reimplemented from TcpSocket.

Definition at line 136 of file AjpBaseSocket.cpp.

References DEB, get_integer(), m_length, m_message, m_ptr, m_state, OnHeader(), and OnPacket().

{
DEB(fprintf(stderr, "OnRawData: %d bytes\n", sz);)
        size_t ptr = 0;
        while (true)
        {
                size_t left = sz - ptr;
DEB(fprintf(stderr, " left: %d bytes\n", left);
fprintf(stderr, " state: %d\n", m_state);)
                switch (m_state)
                {
                case 0:
                        {
                                size_t missing = m_length - m_ptr;
                                short len = (short)(missing < left ? missing : left);
                                memcpy(m_message + m_ptr, buf + ptr, len);
                                m_ptr += len;
                                ptr += len;
                                if (m_ptr < m_length)
                                {
                                        return; // read more
                                }
                                int p = 0;
                                short id = get_integer(m_message, p);
                                short length = get_integer(m_message, p);
                                OnHeader(id, length);
                                m_state = 1;
                                m_length = length;
                                m_ptr = 0; // bytes in m_message
                        }
                        break;
                case 1:
                        {
                                size_t missing = m_length - m_ptr;
                                short len = (short)(missing < left ? missing : left);
                                memcpy(m_message + m_ptr, buf + ptr, len);
                                m_ptr += len;
                                ptr += len;
                                if (m_ptr < m_length)
                                {
                                        return; // read more
                                }
                                OnPacket(m_message, m_ptr);
                                m_state = 0;
                                m_length = 4;
                                m_ptr = 0;
                        }
                        break;
                }
        }
}

virtual void AjpBaseSocket::OnHeader	(	short	id,
		short	len
	)			[pure virtual]

Implemented in Ajp13Socket.

Referenced by OnRawData().

virtual void AjpBaseSocket::OnPacket	(	const char *	buf,
		size_t	sz
	)			[pure virtual]

Implemented in Ajp13Socket.

Referenced by OnRawData().

unsigned char AjpBaseSocket::get_byte	(	const char *	buf,
		int &	ptr
	)			[protected]

Definition at line 190 of file AjpBaseSocket.cpp.

Referenced by Ajp13Socket::ReceiveForwardRequest().

{
        return (unsigned char)buf[ptr++];
}

bool AjpBaseSocket::get_boolean	(	const char *	buf,
		int &	ptr
	)			[protected]

Definition at line 197 of file AjpBaseSocket.cpp.

Referenced by Ajp13Socket::ReceiveForwardRequest().

{
        return ( (unsigned char)buf[ptr++] & 1) == 1 ? true : false;
}

short AjpBaseSocket::get_integer	(	const char *	buf,
		int &	ptr
	)			[protected]

Definition at line 204 of file AjpBaseSocket.cpp.

Referenced by get_string(), OnRawData(), and Ajp13Socket::ReceiveForwardRequest().

{
        short n;
        memcpy(&n, buf + ptr, 2);
        ptr += 2;
        return ntohs(n);
}

std::string AjpBaseSocket::get_string	(	const char *	buf,
		int &	ptr
	)			[protected]

Definition at line 214 of file AjpBaseSocket.cpp.

References get_integer().

Referenced by Ajp13Socket::ReceiveForwardRequest().

{
        short len = get_integer(buf, ptr);
        if (len != -1)
        {
                std::string tmp = buf + ptr;
                ptr += len;
                ptr++; // skip trailing 0x0
                tmp.resize(len);
                return tmp;
        }
        return "";
}

void AjpBaseSocket::put_byte	(	char *	buf,
		int &	ptr,
		unsigned char	zz
	)			[protected]

Definition at line 230 of file AjpBaseSocket.cpp.

Referenced by Ajp13Socket::OnTransferLimit(), put_string(), Ajp13Socket::ReceiveBody(), and Ajp13Socket::Respond().

{
        buf[ptr++] = zz;
}

void AjpBaseSocket::put_boolean	(	char *	buf,
		int &	ptr,
		bool	zz
	)			[protected]

Definition at line 237 of file AjpBaseSocket.cpp.

Referenced by Ajp13Socket::OnTransferLimit().

{
        buf[ptr++] = zz ? 1 : 0;
}

void AjpBaseSocket::put_integer	(	char *	buf,
		int &	ptr,
		short	zz
	)			[protected]

Definition at line 244 of file AjpBaseSocket.cpp.

Referenced by Ajp13Socket::OnTransferLimit(), put_string(), Ajp13Socket::ReceiveBody(), and Ajp13Socket::Respond().

{
        short tmp = htons(zz);
        memcpy(buf + ptr, &tmp, 2);
        ptr += 2;
}

void AjpBaseSocket::put_string	(	char *	buf,
		int &	ptr,
		const std::string &	zz
	)			[protected]

Definition at line 253 of file AjpBaseSocket.cpp.

References put_byte(), and put_integer().

Referenced by Ajp13Socket::Respond().

{
        put_integer(buf, ptr, (short)zz.size() );
        memcpy(buf + ptr, zz.c_str(), zz.size());
        ptr += (int)zz.size();
        put_byte(buf, ptr, 0);
}

---

Member Data Documentation

AjpBaseSocket::Initializer AjpBaseSocket::Init [static, protected]

Definition at line 78 of file AjpBaseSocket.h.

int AjpBaseSocket::m_state [private]

Definition at line 81 of file AjpBaseSocket.h.

Referenced by OnRawData().

int AjpBaseSocket::m_length [private]

Definition at line 82 of file AjpBaseSocket.h.

Referenced by OnRawData().

int AjpBaseSocket::m_ptr [private]

Definition at line 83 of file AjpBaseSocket.h.

Referenced by OnRawData().

char AjpBaseSocket::m_message[8192] [private]

Definition at line 84 of file AjpBaseSocket.h.

Referenced by OnRawData().

---

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

• AjpBaseSocket.h
• AjpBaseSocket.cpp