1 /*

     2 * Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).

     3 * All rights reserved.

     4 *

     5 * This program is free software: you can redistribute it and/or modify

     6 * it under the terms of the GNU Lesser General Public License as published by

     7 * the Free Software Foundation, version 2.1 of the License.

     8 * 

     9 * This program is distributed in the hope that it will be useful,

    10 * but WITHOUT ANY WARRANTY; without even the implied warranty of

    11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

    12 * GNU Lesser General Public License for more details.

    13 *

    14 * You should have received a copy of the GNU Lesser General Public License

    15 * along with this program.  If not, 

    16 * see "http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html/".

    17 *

    18 * Description:                                                         

    19 *

    20 */   

    21 

    22 #ifndef XQSERVICECHANNEL_H

    23 #define XQSERVICECHANNEL_H

    24 

    25 #include <xqserviceglobal.h>

    26 #include <QObject>

    27 #include <QVariant>

    28 

    29 

    30 class XQServiceChannelPrivate;

    31 class XQSharableFile;

    32 

    33 class XQServiceRequestCompletedAsync

    34 {

    35 public:

    36     virtual void requestCompletedAsync(const QVariant &retValue) = 0;

    37     virtual void requestErrorAsync(int err) = 0;

    38 };

    39 

    40 class XQSERVICE_EXPORT XQServiceChannel : public QObject

    41 {

    42     Q_OBJECT

    43 public:

    44     enum XQServiceCommand {

    45         ReturnValueDelivered = 1,

    46         ClientDisconnected

    47     };

    48     explicit XQServiceChannel(const QString& channel, bool isServer, QObject *parent=0);

    49     virtual ~XQServiceChannel();

    50 

    51     bool connectChannel();

    52     

    53     QString channel() const;

    54 

    55     //TODO: implement 2 separate apis sendSync sendAsync

    56     static bool send(const QString& channel, 

    57                      const QString& msg,

    58                      const QByteArray &data, QVariant &retValue, 

    59                      bool sync, XQServiceRequestCompletedAsync* rc = NULL);

    60     

    61     static bool send(const QString& channel, 

    62                      const QString& msg,

    63                      const QByteArray &data,

    64                      QVariant &retValue, 

    65                      bool sync,

    66                      XQServiceRequestCompletedAsync* rc,

    67                      const void *userData);  // Any caller given data

    68 

    69     static bool cancelPendingSend(const QString& channel);

    70 

    71     static QVariant sendLocally(const QString& ch, const QString& msg,

    72                                 const QByteArray &data, const XQSharableFile &sf );

    73     

    74     static void sendCommand(const QString& ch,const XQServiceCommand cmd);

    75     static int latestError();

    76 	

    77 	

    78     virtual QVariant receive(const QString& msg, const QByteArray &data, const XQSharableFile &sf );

    79     virtual void commandReceive(const XQServiceCommand cmd);

    80     

    81 Q_SIGNALS:

    82     void received(const QString& msg, const QByteArray &data, const XQSharableFile &sf);

    83     void commandReceived(const XQServiceCommand cmd);

    84     

    85 protected:

    86 

    87 private:

    88     XQServiceChannelPrivate* d;

    89 };

    90 

    91 #endif