diff options
| author | Tomasz Sterna <tomek@xiaoka.com> | 2014-07-11 21:06:39 +0200 |
|---|---|---|
| committer | Tomasz Sterna <tomek@xiaoka.com> | 2014-07-11 21:06:39 +0200 |
| commit | efb33d6494d88c27c8766553b6a963ddf2654458 (patch) | |
| tree | 76dd5e56b79191074998c0fb6bf7b81276116a4b /ext/Log4Qt/src/telnetappender.h | |
| parent | 072da88eee57e5d16f0b75c7b90c8a0bc6a60cb3 (diff) | |
Included Log4Qt in project
Diffstat (limited to 'ext/Log4Qt/src/telnetappender.h')
| -rw-r--r-- | ext/Log4Qt/src/telnetappender.h | 228 |
1 files changed, 228 insertions, 0 deletions
diff --git a/ext/Log4Qt/src/telnetappender.h b/ext/Log4Qt/src/telnetappender.h new file mode 100644 index 0000000..b1c2021 --- /dev/null +++ b/ext/Log4Qt/src/telnetappender.h @@ -0,0 +1,228 @@ +/****************************************************************************** + * + * package: Log4Qt + * file: telnetappender.h + * created: July 2010 + * author: Andreas Bacher + * + * + * Copyright 2010 Andreas Bacher + * + * 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. + * + ******************************************************************************/ + +#ifndef LOG4QT_TELNETAPPENDER_H +#define LOG4QT_TELNETAPPENDER_H + +/****************************************************************************** + * Dependencies + ******************************************************************************/ + +#include "appenderskeleton.h" + +#include <QtCore/QString> + +#include <QtNetwork/QHostAddress> + +/****************************************************************************** + * Declarations + ******************************************************************************/ + +class QTcpServer; +class QTcpSocket; + +namespace Log4Qt +{ + + /*! + * \brief The class TelnetAppender appends log events to a read-only socket (telnet) + *T + * \note All the functions declared in this class are thread-safe. + * + * \note The ownership and lifetime of objects of this class are managed. + * See \ref Ownership "Object ownership" for more details. + */ + class LOG4QT_EXPORT TelnetAppender : public AppenderSkeleton + { + Q_OBJECT + + /*! + * The property holds the port used by the telenet appender. + * + * The default is 23 for the port. + * + * \sa port, port(), setPort() + */ + Q_PROPERTY(int port READ port WRITE setPort) + + /*! + * The property holds, if the writer flushes after all write operations. + * + * The default is false for flushing. + * + * \sa immediateFlush(), setImmediateFlush() + */ + Q_PROPERTY(bool immediateFlush READ immediateFlush WRITE setImmediateFlush) + + Q_PROPERTY(QHostAddress address READ address WRITE setAddress) + + public: + TelnetAppender(QObject *pParent = 0); + TelnetAppender(Layout *pLayout, + QObject *pParent = 0); + TelnetAppender(Layout *pLayout, + const QHostAddress& address, + int port, + QObject *pParent = 0); + TelnetAppender(Layout *pLayout, + int port, + QObject *pParent = 0); + virtual ~TelnetAppender(); + + private: + TelnetAppender(const TelnetAppender &rOther); // Not implemented + TelnetAppender &operator=(const TelnetAppender &rOther); // Not implemented + + public: + virtual bool requiresLayout() const; + virtual void activateOptions(); + virtual void close(); + + /*! + * Sets the listening port of the telnet server (default = 23) + */ + void setPort(int port); + /*! + * Returns the listening port of the telnet server + */ + int port() const; + /*! + * Set the property immediate flush (default: false) + */ + void setImmediateFlush(bool immediateFlush); + /*! + * Returns <true> immediate flush is enabled + */ + bool immediateFlush() const; + + /*! + * Sets the listenning address of the telnet server (default QHostAddress::Any) + */ + void setAddress(const QHostAddress& address); + /*! + * Returns the listenning address of the telnet server + */ + QHostAddress address() const; + /*! + * Set the welcome message which is send on + */ + void setWelcomeMessage(const QString & welcomeMessage); + + protected: + virtual void append(const LoggingEvent &rEvent); + + /*! + * Tests if all entry conditions for using append() in this class are + * met. + * + * If a conditions is not met, an error is logged and the function + * returns false. Otherwise the result of + * AppenderSkeleton::checkEntryConditions() is returned. + * + * The checked conditions are: + * - A writer has been set (APPENDER_USE_MISSING_WRITER_ERROR) + * + * The function is called as part of the checkEntryConditions() chain + * started by AppenderSkeleton::doAppend(). + * + * \sa AppenderSkeleton::doAppend(), + * AppenderSkeleton::checkEntryConditions() + */ + virtual bool checkEntryConditions() const; + + /*! + * Creates and starts (listening) the TCP server + */ + void openServer(); + /*! + * Stops and destroys the TCP server + */ + void closeServer(); + + QList<QTcpSocket*> clients() const; + +#ifndef QT_NO_DEBUG_STREAM + /*! + * Writes all object member variables to the given debug stream + * \a rDebug and returns the stream. + * + * <tt> + * %TelnetAppender(name:"WA" filter:"0x0" + * isactive:false isclosed:false layout:"TTCC" + * referencecount:1 threshold:"NULL port:"23") + * </tt> + * \sa QDebug, operator<<(QDebug debug, const LogObject &rLogObject ) + */ + + virtual QDebug debug(QDebug &rDebug) const; +#endif // QT_NO_DEBUG_STREAM + + virtual bool handleIoErrors() const; + + private slots: + /*! + * Handles a new incomming connection + */ + void onNewConnection(); + /*! + * Handles a client disconnect + */ + void onClientDisconnected(); + + private: + QHostAddress mAddress; + int mPort; + QTcpServer * mpTcpServer; + QList<QTcpSocket*> mTcpSockets; + QString mWelcomeMessage; + volatile bool mImmediateFlush; + + void sendWelcomeMessage(QTcpSocket * pClientConnection); + }; + + + /************************************************************************** + * Operators, Helper + **************************************************************************/ + + + /************************************************************************** + * Inline + **************************************************************************/ + + inline bool TelnetAppender::immediateFlush() const + { // QMutexLocker locker(&mObjectGuard); // Read/Write of int is safe + return mImmediateFlush; } + + inline void TelnetAppender::setImmediateFlush(bool immediateFlush) + { // QMutexLocker locker(&mObjectGuard); // Read/Write of int is safe + mImmediateFlush = immediateFlush; } + +} // namespace Log4Qt + + +// Q_DECLARE_TYPEINFO(Log4Qt::TelnetAppender, Q_COMPLEX_TYPE); // Use default + + +#endif // LOG4QT_TELNETAPPENDER_H |
