| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142 |
- // -*- C++ -*-
- // Module: Log4CPLUS
- // File: socket.h
- // Created: 4/2003
- // Author: Tad E. Smith
- //
- //
- // Copyright 2003-2015 Tad E. Smith
- //
- // Licensed under the Apache License, Version 2.0 (the "License");
- // you may not use this file except in compliance with the License.
- // You may obtain a copy of the License at
- //
- // http://www.apache.org/licenses/LICENSE-2.0
- //
- // Unless required by applicable law or agreed to in writing, software
- // distributed under the License is distributed on an "AS IS" BASIS,
- // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- // See the License for the specific language governing permissions and
- // limitations under the License.
- /** @file */
- #ifndef LOG4CPLUS_HELPERS_SOCKET_HEADER_
- #define LOG4CPLUS_HELPERS_SOCKET_HEADER_
- #include <log4cplus/config.hxx>
- #if defined (LOG4CPLUS_HAVE_PRAGMA_ONCE)
- #pragma once
- #endif
- #include <log4cplus/tstring.h>
- #include <log4cplus/helpers/socketbuffer.h>
- namespace log4cplus {
- namespace helpers {
- enum SocketState { ok,
- not_opened,
- bad_address,
- connection_failed,
- broken_pipe,
- invalid_access_mode,
- message_truncated,
- accept_interrupted
- };
- typedef std::ptrdiff_t SOCKET_TYPE;
- extern LOG4CPLUS_EXPORT SOCKET_TYPE const INVALID_SOCKET_VALUE;
- class LOG4CPLUS_EXPORT AbstractSocket {
- public:
- // ctor and dtor
- AbstractSocket();
- AbstractSocket(SOCKET_TYPE sock, SocketState state, int err);
- AbstractSocket(const AbstractSocket&);
- virtual ~AbstractSocket() = 0;
- // methods
- /// Close socket
- virtual void close();
- virtual bool isOpen() const;
- virtual void shutdown();
- AbstractSocket& operator=(const AbstractSocket& rhs);
- protected:
- // Methods
- virtual void copy(const AbstractSocket& rhs);
- // Data
- SOCKET_TYPE sock;
- SocketState state;
- int err;
- };
- /**
- * This class implements client sockets (also called just "sockets").
- * A socket is an endpoint for communication between two machines.
- */
- class LOG4CPLUS_EXPORT Socket : public AbstractSocket {
- public:
- // ctor and dtor
- Socket();
- Socket(SOCKET_TYPE sock, SocketState state, int err);
- Socket(const tstring& address, unsigned short port, bool udp = false);
- virtual ~Socket();
- // methods
- virtual bool read(SocketBuffer& buffer);
- virtual bool write(const SocketBuffer& buffer);
- virtual bool write(const std::string & buffer);
- };
- /**
- * This class implements server sockets. A server socket waits for
- * requests to come in over the network. It performs some operation
- * based on that request, and then possibly returns a result to the
- * requester.
- */
- class LOG4CPLUS_EXPORT ServerSocket : public AbstractSocket {
- public:
- // ctor and dtor
- ServerSocket(unsigned short port);
- virtual ~ServerSocket();
- Socket accept();
- void interruptAccept ();
- protected:
- std::ptrdiff_t interruptHandles[2];
- };
- LOG4CPLUS_EXPORT SOCKET_TYPE openSocket(unsigned short port, SocketState& state);
- LOG4CPLUS_EXPORT SOCKET_TYPE connectSocket(const log4cplus::tstring& hostn,
- unsigned short port, bool udp,
- SocketState& state);
- LOG4CPLUS_EXPORT SOCKET_TYPE acceptSocket(SOCKET_TYPE sock, SocketState& state);
- LOG4CPLUS_EXPORT int closeSocket(SOCKET_TYPE sock);
- LOG4CPLUS_EXPORT int shutdownSocket(SOCKET_TYPE sock);
- LOG4CPLUS_EXPORT long read(SOCKET_TYPE sock, SocketBuffer& buffer);
- LOG4CPLUS_EXPORT long write(SOCKET_TYPE sock,
- const SocketBuffer& buffer);
- LOG4CPLUS_EXPORT long write(SOCKET_TYPE sock,
- const std::string & buffer);
- LOG4CPLUS_EXPORT tstring getHostname (bool fqdn);
- LOG4CPLUS_EXPORT int setTCPNoDelay (SOCKET_TYPE, bool);
- } // end namespace helpers
- } // end namespace log4cplus
- #endif // LOG4CPLUS_HELPERS_SOCKET_HEADER_
|