/usr/include/gloox/connectiontcpbase.h is in libgloox-dev 1.0.13-3build1.
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 | /*
Copyright (c) 2004-2015 by Jakob Schröter <js@camaya.net>
This file is part of the gloox library. http://camaya.net/gloox
This software is distributed under a license. The full license
agreement can be found in the file LICENSE in this distribution.
This software may not be copied, modified, sold or distributed
other than expressed in the named license agreement.
This software is distributed without any warranty.
*/
#ifndef CONNECTIONTCPBASE_H__
#define CONNECTIONTCPBASE_H__
#include "gloox.h"
#include "connectionbase.h"
#include "logsink.h"
#include "mutex.h"
#include <string>
namespace gloox
{
namespace util
{
class Mutex;
}
/**
* @brief This is a base class for a simple TCP connection.
*
* You should not need to use this class directly.
*
* @author Jakob Schröter <js@camaya.net>
* @since 0.9
*/
class GLOOX_API ConnectionTCPBase : public ConnectionBase
{
public:
/**
* Constructs a new ConnectionTCPBase object.
* @param logInstance The log target. Obtain it from ClientBase::logInstance().
* @param server A server to connect to.
* @param port The port to connect to. The default of -1 means that XMPP SRV records
* will be used to find out about the actual host:port.
* @note To properly use this object, you have to set a ConnectionDataHandler using
* registerConnectionDataHandler(). This is not necessary if this object is
* part of a 'connection chain', e.g. with ConnectionHTTPProxy.
*/
ConnectionTCPBase( const LogSink& logInstance, const std::string& server, int port = -1 );
/**
* Constructs a new ConnectionTCPBase object.
* @param cdh An ConnectionDataHandler-derived object that will handle incoming data.
* @param logInstance The log target. Obtain it from ClientBase::logInstance().
* @param server A server to connect to.
* @param port The port to connect to. The default of -1 means that SRV records will be used
* to find out about the actual host:port.
*/
ConnectionTCPBase( ConnectionDataHandler* cdh, const LogSink& logInstance,
const std::string& server, int port = -1 );
/**
* Virtual destructor
*/
virtual ~ConnectionTCPBase();
// reimplemented from ConnectionBase
virtual bool send( const std::string& data );
// reimplemented from ConnectionBase
virtual ConnectionError receive();
// reimplemented from ConnectionBase
virtual void disconnect();
// reimplemented from ConnectionBase
virtual void cleanup();
// reimplemented from ConnectionBase
virtual void getStatistics( long int &totalIn, long int &totalOut );
/**
* Gives access to the raw socket of this connection. Use it wisely. You can
* select()/poll() it and use ConnectionTCPBase::recv( -1 ) to fetch the data.
* @return The socket of the active connection, or -1 if no connection is established.
*/
int socket() const { return m_socket; }
/**
* This function allows to set an existing socket with an established
* connection to use in this connection. You will still need to call connect() in order to
* negotiate the XMPP stream. You should not set a new socket after having called connect().
* @param socket The existing socket.
*/
void setSocket( int socket ) { m_cancel = false; m_state = StateConnected; m_socket = socket; }
/**
* Returns the local port.
* @return The local port.
*/
virtual int localPort() const;
/**
* Returns the locally bound IP address.
* @return The locally bound IP address.
*/
virtual const std::string localInterface() const;
protected:
ConnectionTCPBase& operator=( const ConnectionTCPBase& );
void init( const std::string& server, int port );
bool dataAvailable( int timeout = -1 );
void cancel();
const LogSink& m_logInstance;
util::Mutex m_sendMutex;
util::Mutex m_recvMutex;
char* m_buf;
int m_socket;
long int m_totalBytesIn;
long int m_totalBytesOut;
const int m_bufsize;
bool m_cancel;
};
}
#endif // CONNECTIONTCPBASE_H__
|