gds_codex.h

/***************************************************************************
 *   Copyright (C) 2009,2011 by VremSoft                                   *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 *   This program is distributed in the hope that it will be useful,       *
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
 *   GNU General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this program; if not, write to the                         *
 *   Free Software Foundation, Inc.,                                       *
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
 ***************************************************************************/
 
/*
*
* $LastChangedDate: 2016-04-28 11:12:16 -0400 (Thu, 28 Apr 2016) $
*   $LastChangedBy: ed $
*        $Revision: 690 $
*          $Author: ed $
*             $URL: svn+ssh://svn.vremsoft.com/var/share/svn/tags/platfom3.4.3/platformlib/qnxtalk/gds_codex.h $
*              $Id: gds_codex.h 690 2016-04-28 15:12:16Z ed $
*           edc@vremsoft.com
*
*       19
*
*             *** 2014<c> ***
*
*
*/
 
#ifndef GDS_CODEX_H
#define GDS_CODEX_H
 
#include <QtCore>
#include <QTcpSocket>
#include <publicationregistration.h>
#include <publication.h>
 
 
 
#include "pdscmsg.h"
#include "vqsubscriber.h"
#include "vqpublisher.h"
#include "vqdefines.h"
#include "qnxsprur.h"
 
 
// #define HOLD_PUBLICATION_NAMES
 
namespace QXX {
 
class PLATFORMSHARED_EXPORT gds_codex : public QTcpSocket
{
    Q_OBJECT
 
private :
 
    QMutex creationLock;
 
    QnxSprur &plugin;
 
    qint32 blockSize;
 
    QString routerVersion;
 
    bool valid;
 
    PblHdr NULL_hdr;
 
    QMutex idLock;
 
    long ID;
 
    DLock < int > Socket;
 
    DLock < long > heartbeats;
 
    QMutex ourGdsSubscribersLock;
    VASubscriberMap ourGdsSubscribers;
    VASubscriberNamesMap ourGdsSubscribersbNames;
 
    VQSubscriber *findSubscriber ( long id );
 
    QMutex ourGdsPublishersLock;
    VAPublisherMap ourGdsPublishers;
 
    QMutex RequestUpdateLock;
 
    VQPublisher *findPublisher ( long id );
 
    void UpDatePDS (
        long id,
        PblId pb,
        void *data,
        int index,
        int count,
        ArticleType type,
        size_t ArticleSize );
 
 
    int uniqueID;
    int socketD;
    bool aquiredConnection;
 
    QMap<QString,char> flashOffCopyNames;
    QMap<QString,char> flashOffCopyRemoteNames;
 
public :
    gds_codex (QnxSprur &Plugin, int UniqueID, QObject *parent = 0 );
 
    virtual ~gds_codex();
 
    const QString GetVersion ( void ) const { return routerVersion; }
 
    int RegisterSubscriber ( long id, VQSubscriber *sub );
 
    int UnRegisterSubscriber(long id);
 
    int RegisterPublisher ( long id, VQPublisher *pub );
 
    int UnRegisterPublisher ( long id );
 
    virtual void UserSendMessage ( int length, void *msg );
 
    long getGdsId ( void );
 
    void DataFromGds ( VQSubscriber *sub, void *data, int index, int count, ArticleType type, size_t articleSize );
 
    void DataFromGds ( VQPublisher *sub, void *data, int index, int count, ArticleType type, size_t articleSize );
 
    void RequestUpdate ( long id, PblId pb, ArticleType type,  VremVArray &values, int index );
 
    void CreationLock ( void )
    {
        creationLock.lock();
    }   // CreationLock
 
    void CreationUnlock ( void )
    {
        creationLock.unlock();
    }   // CreationUnlock
 
 
    virtual void NameFound( QString &name,  PblHdr *hdr);
 
 
private slots :
    void codex ( QByteArray message );
 
    void slot_connected();
    void slot_disconnected();
    void slot_readyRead();
 
signals :
    void sigSendingData ( int, QByteArray );
 
public slots :
 
    void slot_newpublication(QString newPub);
    void slot_lostpublication(QString Pub);
 
signals :
    void sigNameFound ( QString name, PblHdr hdr );
 
    void sigNameLost ( QString name, PblHdr hdr );
 
    void sigRouterVersion ( QString version );
 
    void sigRouterVersionHeartBeat ( QString beat );
 
     void sigRouterReceived ( );
 
 
    void sigMessageError ( QString err );
 
    void sigSocketState ( bool );
 
    void sigLibError ( QString err );
 
    void SignalLostRemoteDescriptor(int);
    void SignalLostRemotePublication(int,QString);
    void SignalNewRemotePublication(int,QString);
 
 
 
 
};  // gds_codex
 
}
 
#if 0
namespace Ui
{
    class codexClass : public gds_codex
    {
    };  // codexClass
 
}   // namespace Ui
 
#endif
 
#endif  // GDS_CODEX_H