/usr/include/Poco/Net/SocketStream.h is in libpoco-dev 1.8.0.1-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 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 | //
// SocketStream.h
//
// Library: Net
// Package: Sockets
// Module: SocketStream
//
// Definition of the SocketStream class.
//
// Copyright (c) 2005-2006, Applied Informatics Software Engineering GmbH.
// and Contributors.
//
// SPDX-License-Identifier: BSL-1.0
//
#ifndef Net_SocketStream_INCLUDED
#define Net_SocketStream_INCLUDED
#include "Poco/Net/Net.h"
#include "Poco/Net/StreamSocket.h"
#include "Poco/BufferedBidirectionalStreamBuf.h"
#include <istream>
#include <ostream>
namespace Poco {
namespace Net {
class StreamSocketImpl;
class Net_API SocketStreamBuf: public Poco::BufferedBidirectionalStreamBuf
/// This is the streambuf class used for reading from and writing to a socket.
{
public:
SocketStreamBuf(const Socket& socket);
/// Creates a SocketStreamBuf with the given socket.
///
/// The socket's SocketImpl must be a StreamSocketImpl,
/// otherwise an InvalidArgumentException is thrown.
~SocketStreamBuf();
/// Destroys the SocketStreamBuf.
StreamSocketImpl* socketImpl() const;
/// Returns the internal SocketImpl.
protected:
int readFromDevice(char* buffer, std::streamsize length);
int writeToDevice(const char* buffer, std::streamsize length);
private:
enum
{
STREAM_BUFFER_SIZE = 1024
};
StreamSocketImpl* _pImpl;
};
class Net_API SocketIOS: public virtual std::ios
/// The base class for SocketStream, SocketInputStream and
/// SocketOutputStream.
///
/// This class is needed to ensure the correct initialization
/// order of the stream buffer and base classes.
{
public:
SocketIOS(const Socket& socket);
/// Creates the SocketIOS with the given socket.
///
/// The socket's SocketImpl must be a StreamSocketImpl,
/// otherwise an InvalidArgumentException is thrown.
~SocketIOS();
/// Destroys the SocketIOS.
///
/// Flushes the buffer, but does not close the socket.
SocketStreamBuf* rdbuf();
/// Returns a pointer to the internal SocketStreamBuf.
void close();
/// Flushes the stream and closes the socket.
StreamSocket socket() const;
/// Returns the underlying socket.
protected:
SocketStreamBuf _buf;
};
class Net_API SocketOutputStream: public SocketIOS, public std::ostream
/// An output stream for writing to a socket.
{
public:
explicit SocketOutputStream(const Socket& socket);
/// Creates the SocketOutputStream with the given socket.
///
/// The socket's SocketImpl must be a StreamSocketImpl,
/// otherwise an InvalidArgumentException is thrown.
~SocketOutputStream();
/// Destroys the SocketOutputStream.
///
/// Flushes the buffer, but does not close the socket.
};
class Net_API SocketInputStream: public SocketIOS, public std::istream
/// An input stream for reading from a socket.
///
/// When using formatted input from a SocketInputStream,
/// always ensure that a receive timeout is set for the
/// socket. Otherwise your program might unexpectedly
/// hang.
///
/// However, using formatted input from a SocketInputStream
/// is not recommended, due to the read-ahead behavior of
/// istream with formatted reads.
{
public:
explicit SocketInputStream(const Socket& socket);
/// Creates the SocketInputStream with the given socket.
///
/// The socket's SocketImpl must be a StreamSocketImpl,
/// otherwise an InvalidArgumentException is thrown.
~SocketInputStream();
/// Destroys the SocketInputStream.
};
class Net_API SocketStream: public SocketIOS, public std::iostream
/// An bidirectional stream for reading from and writing to a socket.
///
/// When using formatted input from a SocketStream,
/// always ensure that a receive timeout is set for the
/// socket. Otherwise your program might unexpectedly
/// hang.
///
/// However, using formatted input from a SocketStream
/// is not recommended, due to the read-ahead behavior of
/// istream with formatted reads.
{
public:
explicit SocketStream(const Socket& socket);
/// Creates the SocketStream with the given socket.
///
/// The socket's SocketImpl must be a StreamSocketImpl,
/// otherwise an InvalidArgumentException is thrown.
~SocketStream();
/// Destroys the SocketStream.
///
/// Flushes the buffer, but does not close the socket.
};
//
// inlines
//
inline StreamSocketImpl* SocketStreamBuf::socketImpl() const
{
return _pImpl;
}
} } // namespace Poco::Net
#endif // Net_SocketStream_INCLUDED
|