/usr/include/pion/net/HTTPReader.hpp is in libpion-net-dev 4.0.7+dfsg-2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 | // ------------------------------------------------------------------
// pion-net: a C++ framework for building lightweight HTTP interfaces
// ------------------------------------------------------------------
// Copyright (C) 2007-2008 Atomic Labs, Inc. (http://www.atomiclabs.com)
//
// Distributed under the Boost Software License, Version 1.0.
// See http://www.boost.org/LICENSE_1_0.txt
//
#ifndef __PION_HTTPREADER_HEADER__
#define __PION_HTTPREADER_HEADER__
#include <boost/asio.hpp>
#include <pion/PionConfig.hpp>
#include <pion/net/HTTPParser.hpp>
#include <pion/net/HTTPMessage.hpp>
#include <pion/net/TCPConnection.hpp>
#include <pion/net/TCPTimer.hpp>
namespace pion { // begin namespace pion
namespace net { // begin namespace net (Pion Network Library)
///
/// HTTPReader: asynchronously reads and parses HTTP messages
///
class PION_NET_API HTTPReader :
public HTTPParser
{
public:
// default destructor
virtual ~HTTPReader() {}
/// Incrementally reads & parses the HTTP message
void receive(void);
/// returns a shared pointer to the TCP connection
inline TCPConnectionPtr& getTCPConnection(void) { return m_tcp_conn; }
/// sets the maximum number of seconds for read operations
inline void setTimeout(boost::uint32_t seconds) { m_read_timeout = seconds; }
protected:
/**
* protected constructor: only derived classes may create objects
*
* @param is_request if true, the message is parsed as an HTTP request;
* if false, the message is parsed as an HTTP response
* @param tcp_conn TCP connection containing a new message to parse
*/
HTTPReader(const bool is_request, TCPConnectionPtr& tcp_conn)
: HTTPParser(is_request), m_tcp_conn(tcp_conn),
m_read_timeout(DEFAULT_READ_TIMEOUT)
{}
/**
* Consumes bytes that have been read using an HTTP parser
*
* @param read_error error status from the last read operation
* @param bytes_read number of bytes consumed by the last read operation
*/
void consumeBytes(const boost::system::error_code& read_error,
std::size_t bytes_read);
/// Consumes bytes that have been read using an HTTP parser
void consumeBytes(void);
/// Reads more bytes from the TCP connection
virtual void readBytes(void) = 0;
/// Called after we have finished reading/parsing the HTTP message
virtual void finishedReading(const boost::system::error_code& ec) = 0;
/// Returns a reference to the HTTP message being parsed
virtual HTTPMessage& getMessage(void) = 0;
private:
/// reads more bytes for parsing, with timeout support
void readBytesWithTimeout(void);
/**
* Handles errors that occur during read operations
*
* @param read_error error status from the last read operation
*/
void handleReadError(const boost::system::error_code& read_error);
/// default maximum number of seconds for read operations
static const boost::uint32_t DEFAULT_READ_TIMEOUT;
/// The HTTP connection that has a new HTTP message to parse
TCPConnectionPtr m_tcp_conn;
/// pointer to a TCPTimer object if read timeouts are enabled
TCPTimerPtr m_timer_ptr;
/// maximum number of seconds for read operations
boost::uint32_t m_read_timeout;
};
} // end namespace net
} // end namespace pion
#endif
|