#include <happyhttp.h>

Public Member Functions
	Connection (const char *host, int port)

	~Connection ()

void	setcallbacks (ResponseBegin_CB begincb, ResponseData_CB datacb, ResponseComplete_CB completecb, void *userdata)

void	connect ()

void	close ()

void	pump ()

bool	outstanding () const

void	request (const char method, const char url, const char headers[]=0, const unsigned char body=0, int bodysize=0)

void	putrequest (const char method, const char url)

void	putheader (const char header, const char value)

void	putheader (const char *header, int numericvalue)

void	endheaders ()

void	send (const unsigned char *buf, int numbytes)

Protected Attributes
ResponseBegin_CB	m_ResponseBeginCB

ResponseData_CB	m_ResponseDataCB

ResponseComplete_CB	m_ResponseCompleteCB

void *	m_UserData

Friends
class	Response

Detailed Description

Definition at line 145 of file happyhttp.h.

Constructor & Destructor Documentation

◆ Connection()

happyhttp::Connection::Connection	(	const char *	host,
		int	port
	)

Definition at line 229 of file happyhttp.cpp.

                                                   :
        m_ResponseBeginCB(0),
        m_ResponseDataCB(0),
        m_ResponseCompleteCB(0),
        m_UserData(0),
        m_State( IDLE ),
        m_Host( host ),
        m_Port( port ),
        m_Sock(-1)
{
}

◆ ~Connection()

happyhttp::Connection::~Connection ( )

Definition at line 298 of file happyhttp.cpp.

{
        close();
}

References close().

Member Function Documentation

◆ close()

void happyhttp::Connection::close ( )

Definition at line 278 of file happyhttp.cpp.

{
#ifdef WIN32
        if( m_Sock >= 0 )
                ::closesocket( m_Sock );
#else
        if( m_Sock >= 0 )
                ::close( m_Sock );
#endif
        m_Sock = -1;
 
        // discard any incomplete responses
        while( !m_Outstanding.empty() )
        {
                delete m_Outstanding.front();
                m_Outstanding.pop_front();
        }
}

References close().

Referenced by close(), pump(), and ~Connection().

◆ connect()

void happyhttp::Connection::connect ( )

Definition at line 255 of file happyhttp.cpp.

{
        in_addr* addr = atoaddr( m_Host.c_str() );
        if( !addr )
                throw Wobbly( "Invalid network address" );
 
        sockaddr_in address;
        memset( (char*)&address, 0, sizeof(address) );
        address.sin_family = AF_INET;
        address.sin_port = htons( m_Port );
        address.sin_addr.s_addr = addr->s_addr;
 
        m_Sock = socket( AF_INET, SOCK_STREAM, 0 );
        if( m_Sock < 0 )
                BailOnSocketError( "socket()" );
 
//      printf("Connecting to %s on port %d.\n",inet_ntoa(*addr), port);
 
        if( ::connect( m_Sock, (sockaddr const*)&address, sizeof(address) ) < 0 )
                BailOnSocketError( "connect()" );
}

References happyhttp::atoaddr(), happyhttp::BailOnSocketError(), and connect().

Referenced by connect(), and send().

◆ endheaders()

void happyhttp::Connection::endheaders ( )

Definition at line 390 of file happyhttp.cpp.

{
        if( m_State != REQ_STARTED )
                throw Wobbly( "Cannot send header" );
        m_State = IDLE;
 
        m_Buffer.push_back( "" );
 
        string msg;
        vector< string>::const_iterator it;
        for( it = m_Buffer.begin(); it != m_Buffer.end(); ++it )
                msg += (*it) + "\r\n";
 
        m_Buffer.clear();
 
//      printf( "%s", msg.c_str() );
        send( (const unsigned char*)msg.c_str(), msg.size() );
}

References send().

Referenced by request(), Test3(), Test4(), and Test5().

◆ outstanding()

bool happyhttp::Connection::outstanding ( ) const

inline

Definition at line 179 of file happyhttp.h.

180 { return !m_Outstanding.empty(); }

Referenced by Test1(), Test2(), Test3(), Test4(), and Test5().

◆ pump()

void happyhttp::Connection::pump ( )

Definition at line 433 of file happyhttp.cpp.

{
        if( m_Outstanding.empty() )
                return;         // no requests outstanding
 
        assert( m_Sock >0 );    // outstanding requests but no connection!
 
        if( !datawaiting( m_Sock ) )
                return;                         // recv will block
 
        unsigned char buf[ 2048 ];
        int a = recv( m_Sock, (char*)buf, sizeof(buf), 0 );
        if( a<0 )
                BailOnSocketError( "recv()" );
 
        if( a== 0 )
        {
                // connection has closed
 
                Response* r = m_Outstanding.front();
                r->notifyconnectionclosed();
                assert( r->completed() );
                delete r;
                m_Outstanding.pop_front();
 
                // any outstanding requests will be discarded
                close();
        }
        else
        {
                int used = 0;
                while( used < a && !m_Outstanding.empty() )
                {
 
                        Response* r = m_Outstanding.front();
                        int u = r->pump( &buf[used], a-used );
 
                        // delete response once completed
                        if( r->completed() )
                        {
                                delete r;
                                m_Outstanding.pop_front();
                        }
                        used += u;
                }
 
                // NOTE: will lose bytes if response queue goes empty
                // (but server shouldn't be sending anything if we don't have
                // anything outstanding anyway)
                assert( used == a );    // all bytes should be used up by here.
        }
}

References happyhttp::BailOnSocketError(), close(), happyhttp::Response::completed(), happyhttp::datawaiting(), happyhttp::Response::notifyconnectionclosed(), and happyhttp::Response::pump().

Referenced by Test1(), Test2(), Test3(), Test4(), and Test5().

◆ putheader() [1/2]

void happyhttp::Connection::putheader	(	const char *	header,
		const char *	value
	)

Definition at line 376 of file happyhttp.cpp.

{
        if( m_State != REQ_STARTED )
                throw Wobbly( "putheader() failed" );
        m_Buffer.push_back( string(header) + ": " + string( value ) );
}

Referenced by putheader(), putrequest(), request(), Test3(), Test4(), and Test5().

◆ putheader() [2/2]

void happyhttp::Connection::putheader	(	const char *	header,
		int	numericvalue
	)

Definition at line 383 of file happyhttp.cpp.

{
        char buf[32];
        sprintf( buf, "%d", numericvalue );
        putheader( header, buf );
}

References putheader().

◆ putrequest()

void happyhttp::Connection::putrequest	(	const char *	method,
		const char *	url
	)

Definition at line 354 of file happyhttp.cpp.

{
        if( m_State != IDLE )
                throw Wobbly( "Request already issued" );
 
        m_State = REQ_STARTED;
 
        char req[ 512 ];
        sprintf( req, "%s %s HTTP/1.1", method, url );
        m_Buffer.push_back( req );
 
        putheader( "Host", m_Host.c_str() );    // required for HTTP1.1
 
        // don't want any fancy encodings please
        putheader("Accept-Encoding", "identity");
 
        // Push a new response onto the queue
        Response *r = new Response( method, *this );
        m_Outstanding.push_back( r );
}

References putheader(), and Response.

Referenced by request(), Test3(), Test4(), and Test5().

◆ request()

void happyhttp::Connection::request	(	const char *	method,
		const char *	url,
		const char *	headers[] = `0`,
		const unsigned char *	body = `0`,
		int	bodysize = `0`
	)

Definition at line 303 of file happyhttp.cpp.

{
 
        bool gotcontentlength = false;  // already in headers?
 
        // check headers for content-length
        // TODO: check for "Host" and "Accept-Encoding" too
        // and avoid adding them ourselves in putrequest()
        if( headers )
        {
                const char** h = headers;
                while( *h )
                {
                        const char* name = *h++;
                        const char* value = *h++;
                        assert( value != 0 );   // name with no value!
 
                        if( 0==strcasecmp( name, "content-length" ) )
                                gotcontentlength = true;
                }
        }
 
        putrequest( method, url );
 
        if( body && !gotcontentlength )
                putheader( "Content-Length", bodysize );
 
        if( headers )
        {
                const char** h = headers;
                while( *h )
                {
                        const char* name = *h++;
                        const char* value = *h++;
                        putheader( name, value );
                }
        }
        endheaders();
 
        if( body )
                send( body, bodysize );
 
}

References endheaders(), putheader(), putrequest(), and send().

Referenced by Test1(), and Test2().

◆ send()

void happyhttp::Connection::send	(	const unsigned char *	buf,
		int	numbytes
	)

Definition at line 411 of file happyhttp.cpp.

{
//      fwrite( buf, 1,numbytes, stdout );
 
        if( m_Sock < 0 )
                connect();
 
        while( numbytes > 0 )
        {
#ifdef WIN32
                int n = ::send( m_Sock, (const char*)buf, numbytes, 0 );
#else
                int n = ::send( m_Sock, buf, numbytes, 0 );
#endif
                if( n<0 )
                        BailOnSocketError( "send()" );
                numbytes -= n;
                buf += n;
        }
}

References happyhttp::BailOnSocketError(), connect(), and send().

Referenced by endheaders(), request(), send(), Test3(), Test4(), and Test5().

◆ setcallbacks()

void happyhttp::Connection::setcallbacks	(	ResponseBegin_CB	begincb,
		ResponseData_CB	datacb,
		ResponseComplete_CB	completecb,
		void *	userdata
	)

Definition at line 242 of file happyhttp.cpp.

{
        m_ResponseBeginCB = begincb;
        m_ResponseDataCB = datacb;
        m_ResponseCompleteCB = completecb;
        m_UserData = userdata;
}

References m_ResponseBeginCB, m_ResponseCompleteCB, m_ResponseDataCB, and m_UserData.

Referenced by Test1(), Test2(), Test3(), Test4(), and Test5().

Friends And Related Symbol Documentation

◆ Response

friend class Response

friend

Definition at line 147 of file happyhttp.h.

Referenced by putrequest().

Member Data Documentation

◆ m_ResponseBeginCB

ResponseBegin_CB happyhttp::Connection::m_ResponseBeginCB

protected

Definition at line 217 of file happyhttp.h.

Referenced by setcallbacks().

◆ m_ResponseCompleteCB

ResponseComplete_CB happyhttp::Connection::m_ResponseCompleteCB

protected

Definition at line 219 of file happyhttp.h.

Referenced by setcallbacks().

◆ m_ResponseDataCB

ResponseData_CB happyhttp::Connection::m_ResponseDataCB

protected

Definition at line 218 of file happyhttp.h.

Referenced by setcallbacks().

◆ m_UserData

void* happyhttp::Connection::m_UserData

protected

Definition at line 220 of file happyhttp.h.

Referenced by setcallbacks().

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

Public Member Functions

Protected Attributes

Friends

Detailed Description

Constructor & Destructor Documentation

◆ Connection()

◆ ~Connection()

Member Function Documentation

◆ close()

◆ connect()

◆ endheaders()

◆ outstanding()

◆ pump()

◆ putheader() [1/2]

◆ putheader() [2/2]

◆ putrequest()

◆ request()

◆ send()

◆ setcallbacks()

Friends And Related Symbol Documentation

◆ Response

Member Data Documentation

◆ m_ResponseBeginCB

◆ m_ResponseCompleteCB

◆ m_ResponseDataCB

◆ m_UserData