dferry/connection/pendingreply_p.h

0001 /*
0002    Copyright (C) 2014 Andreas Hartmetz <ahartmetz@gmail.com>
0003
0004    This library is free software; you can redistribute it and/or
0005    modify it under the terms of the GNU Library General Public
0006    License as published by the Free Software Foundation; either
0007    version 2 of the License, or (at your option) any later version.
0008
0009    This library is distributed in the hope that it will be useful,
0010    but WITHOUT ANY WARRANTY; without even the implied warranty of
0011    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
0012    Library General Public License for more details.
0013
0014    You should have received a copy of the GNU Library General Public License
0015    along with this library; see the file COPYING.LGPL.  If not, write to
0016    the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
0017    Boston, MA 02110-1301, USA.
0018
0019    Alternatively, this file is available under the Mozilla Public License
0020    Version 1.1.  You may obtain a copy of the License at
0021    http://www.mozilla.org/MPL/
0022 */
0023
0024 #ifndef PENDINGREPLY_P_H
0025 #define PENDINGREPLY_P_H
0026
0027 #include "error.h"
0028 #include "icompletionlistener.h"
0029 #include "message.h"
0030 #include "timer.h"
0031
0032 class PendingReply;
0033 class ConnectionPrivate;
0034
0035 class PendingReplyPrivate : public ICompletionListener
0036 {
0037 public:
0038     PendingReplyPrivate(EventDispatcher *dispatcher, int timeout)
0039        : m_replyTimeout(dispatcher),
0040          m_isFinished(false),
0041          m_reserved(0)
0042     {
0043         if (timeout >= 0) {
0044             m_replyTimeout.setRepeating(false);
0045             m_replyTimeout.setCompletionListener(this);
0046             m_replyTimeout.start(timeout);
0047         }
0048     }
0049
0050     // for Connection
0051     void handleReceived(Message *reply);
0052     void handleError(Error error);
0053     // for m_replyTimeout
0054     void handleCompletion(void *task) override;
0055
0056     PendingReply *m_owner = nullptr;
0057     union {
0058         ConnectionPrivate *connection = nullptr;
0059         Message *reply;
0060     } m_connectionOrReply;
0061     void *m_cookie = nullptr;
0062     Timer m_replyTimeout;
0063     IMessageReceiver *m_receiver = nullptr;
0064     Error m_error;
0065     uint32 m_serial = 0;
0066     bool m_isFinished : 1;
0067     uint32 m_reserved : 31;
0068 };
0069
0070 #endif // PENDINGREPLY_P_H