summaryrefslogtreecommitdiff
path: root/ext/Log4Qt/src/telnetappender.h
diff options
context:
space:
mode:
authorTomasz Sterna <tomek@xiaoka.com>2014-07-11 21:06:39 +0200
committerTomasz Sterna <tomek@xiaoka.com>2014-07-11 21:06:39 +0200
commitefb33d6494d88c27c8766553b6a963ddf2654458 (patch)
tree76dd5e56b79191074998c0fb6bf7b81276116a4b /ext/Log4Qt/src/telnetappender.h
parent072da88eee57e5d16f0b75c7b90c8a0bc6a60cb3 (diff)
Included Log4Qt in project
Diffstat (limited to 'ext/Log4Qt/src/telnetappender.h')
-rw-r--r--ext/Log4Qt/src/telnetappender.h228
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.
+ * &nbsp;
+ * \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