/usr/include/pion/net/HTTPRequestReader.hpp is in libpion-net-dev 4.0.7+dfsg-3.1ubuntu2.
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 | // ------------------------------------------------------------------
// 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_HTTPREQUESTREADER_HEADER__
#define __PION_HTTPREQUESTREADER_HEADER__
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/function.hpp>
#include <boost/function/function2.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <pion/PionConfig.hpp>
#include <pion/net/HTTPRequest.hpp>
#include <pion/net/HTTPReader.hpp>
namespace pion { // begin namespace pion
namespace net { // begin namespace net (Pion Network Library)
///
/// HTTPRequestReader: asynchronously reads and parses HTTP requests
///
class HTTPRequestReader :
public HTTPReader,
public boost::enable_shared_from_this<HTTPRequestReader>
{
public:
/// function called after the HTTP message has been parsed
typedef boost::function3<void, HTTPRequestPtr, TCPConnectionPtr,
const boost::system::error_code&> FinishedHandler;
// default destructor
virtual ~HTTPRequestReader() {}
/**
* creates new HTTPRequestReader objects
*
* @param tcp_conn TCP connection containing a new message to parse
* @param handler function called after the message has been parsed
*/
static inline boost::shared_ptr<HTTPRequestReader>
create(TCPConnectionPtr& tcp_conn, FinishedHandler handler)
{
return boost::shared_ptr<HTTPRequestReader>
(new HTTPRequestReader(tcp_conn, handler));
}
protected:
/**
* protected constructor restricts creation of objects (use create())
*
* @param tcp_conn TCP connection containing a new message to parse
* @param handler function called after the message has been parsed
*/
HTTPRequestReader(TCPConnectionPtr& tcp_conn, FinishedHandler handler)
: HTTPReader(true, tcp_conn), m_http_msg(new HTTPRequest),
m_finished(handler)
{
m_http_msg->setRemoteIp(tcp_conn->getRemoteIp());
setLogger(PION_GET_LOGGER("pion.net.HTTPRequestReader"));
}
/// Reads more bytes from the TCP connection
virtual void readBytes(void) {
getTCPConnection()->async_read_some(boost::bind(&HTTPRequestReader::consumeBytes,
shared_from_this(),
boost::asio::placeholders::error,
boost::asio::placeholders::bytes_transferred));
}
/// Called after we have finished reading/parsing the HTTP message
virtual void finishedReading(const boost::system::error_code& ec) {
// call the finished handler with the finished HTTP message
if (m_finished) m_finished(m_http_msg, getTCPConnection(), ec);
}
/// Returns a reference to the HTTP message being parsed
virtual HTTPMessage& getMessage(void) { return *m_http_msg; }
/// The new HTTP message container being created
HTTPRequestPtr m_http_msg;
/// function called after the HTTP message has been parsed
FinishedHandler m_finished;
};
/// data type for a HTTPRequestReader pointer
typedef boost::shared_ptr<HTTPRequestReader> HTTPRequestReaderPtr;
} // end namespace net
} // end namespace pion
#endif
|