/usr/include/pion/net/HTTPResponseReader.hpp is in libpion-net-dev 4.0.7+dfsg-3.1ubuntu4.
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_HTTPRESPONSEREADER_HEADER__
#define __PION_HTTPRESPONSEREADER_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/HTTPResponse.hpp>
#include <pion/net/HTTPReader.hpp>
namespace pion { // begin namespace pion
namespace net { // begin namespace net (Pion Network Library)
///
/// HTTPResponseReader: asynchronously reads and parses HTTP responses
///
class HTTPResponseReader :
public HTTPReader,
public boost::enable_shared_from_this<HTTPResponseReader>
{
public:
/// function called after the HTTP message has been parsed
typedef boost::function3<void, HTTPResponsePtr, TCPConnectionPtr,
const boost::system::error_code&> FinishedHandler;
// default destructor
virtual ~HTTPResponseReader() {}
/**
* creates new HTTPResponseReader objects
*
* @param tcp_conn TCP connection containing a new message to parse
* @param http_request the request we are responding to
* @param handler function called after the message has been parsed
*/
static inline boost::shared_ptr<HTTPResponseReader>
create(TCPConnectionPtr& tcp_conn, const HTTPRequest& http_request,
FinishedHandler handler)
{
return boost::shared_ptr<HTTPResponseReader>
(new HTTPResponseReader(tcp_conn, http_request, handler));
}
protected:
/**
* protected constructor restricts creation of objects (use create())
*
* @param tcp_conn TCP connection containing a new message to parse
* @param http_request the request we are responding to
* @param handler function called after the message has been parsed
*/
HTTPResponseReader(TCPConnectionPtr& tcp_conn, const HTTPRequest& http_request,
FinishedHandler handler)
: HTTPReader(false, tcp_conn), m_http_msg(new HTTPResponse(http_request)),
m_finished(handler)
{
m_http_msg->setRemoteIp(tcp_conn->getRemoteIp());
setLogger(PION_GET_LOGGER("pion.net.HTTPResponseReader"));
}
/// Reads more bytes from the TCP connection
virtual void readBytes(void) {
getTCPConnection()->async_read_some(boost::bind(&HTTPResponseReader::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
HTTPResponsePtr m_http_msg;
/// function called after the HTTP message has been parsed
FinishedHandler m_finished;
};
/// data type for a HTTPResponseReader pointer
typedef boost::shared_ptr<HTTPResponseReader> HTTPResponseReaderPtr;
} // end namespace net
} // end namespace pion
#endif
|