pdscmsg.h

/*
*
* $LastChangedDate: 2014-08-14 12:47:21 -0400 (Thu, 14 Aug 2014) $
*   $LastChangedBy: ed $
*        $Revision: 61 $
*          $Author: ed $
*             $URL: svn+ssh://svn.vremsoft.com/var/share/svn/tags/platfom3.4.3/platformlib/qnxtalk/pdscmsg.h $
*              $Id: pdscmsg.h 61 2014-08-14 16:47:21Z ed $
*           edc@vremsoft.com
*
*       19
*
*             *** 2014<c> ***
*
*
*/
 
#ifndef MSG_H
#define MSG_H
 
#if defined(__GNUC__) || defined(_WIN32)
#pragma pack(push,1)
#endif
 
#include <qglobal.h>
#define  _CHAR    qint8
#define  _UCHAR   quint8
#define  _UINT    quint32
#define  _INT       qint32
#define  _SHORT qint16
#define  _USHORT  quint16
#define  _SIZET   quint32
 
#ifdef PDS_NATIVE       // set up a trick so we can use this file on NT for compiling
#include <pds.h>        // we are on a native qnx with a build for pds.h
#else
#pragma pack(1)
 
#ifndef PblId           // we are on NT and no-one has define PblID
typedef struct          // define the exact size for NT, cannot send the pds.h to NT it is too wild
{
    _UCHAR  pbl_id[163]; // make a dummy struct for NT to use and ref for returns only
 
} PblId;
 
#ifndef PBLNAME_MAX
#define PBLNAME_MAX     64
#endif
#ifndef PBLDESC_MAX
#define PBLDESC_MAX     256
 
// Ascii string limit in the NT     ..added for backward compatibility JGM
#ifdef _WIN32
#ifndef ASCII_STR_MAX
#define ASCII_STR_MAX   255
#endif
#endif
 
#if defined(__GNUC__) || defined(_WIN32)        //added win32, which also include win64 BTW..  JGM
typedef  _UCHAR  ArticleType;
 
#define at_char  0
 
#define at_int2 at_char + 1
 
#define at_int4 at_int2 + 1
 
#define at_float at_int4 + 1
 
#define at_double at_float + 1
 
#define at_struct at_double + 1
 
#define at_stream at_struct + 1
 
#define at_ascii at_stream + 1
 
#define at_error at_ascii + 1
 
/* these are PDS only */
 
#define at_time_sec at_error + 1
 
#define at_time_milli at_time_sec + 1
 
#define at_alarm at_time_milli + 1
 
#define at_variant at_alarm  + 1
 
#else
typedef enum {
    /* these types are the same as Net2 */
 
    at_char = 0,
 
    at_int2,
 
    at_int4,
 
    at_float,
 
    at_double,
 
    at_struct,
 
    at_stream,
 
    at_ascii,
 
    at_error,
 
    /* these are PDS only */
    at_time_sec,
 
    at_time_milli,
 
    at_alarm,
 
    at_variant
} ArticleType;
 
#endif
 
#if defined(__GNUC__) || defined(_WIN32)
// enums should never go out a network, but since watcom optimizes automatically and todd started this with qnx we must comply
typedef  _UCHAR  UpdateId;
 
#define         ui_login 0
#define         ui_publisher    ui_login + 1
#define     ui_subscriber   ui_publisher + 1
 
#else
typedef enum {
    ui_login,
    ui_publisher,
    ui_subscriber
} UpdateId;
#endif
 
typedef _CHAR PblDesc[PBLDESC_MAX + 1];
 
 
#if defined(__GNUC__) || defined(_WIN32)
 
typedef struct
{
    ArticleType type;
    _SIZET typeSz;
    PblDesc desc;
    _SIZET articleSz;
 
    _SIZET firstArticle;
 
    _SIZET nbrArticles;
 
    UpdateId who;
} PblHdr;
#endif
 
 
 
#endif
#endif
#endif
 
typedef struct 
{
    ArticleType type;
 
    _SIZET typeSz;
 
    _SIZET articleSz;
 
    _SIZET firstArticle;
 
    _SIZET nbrArticles;
 
 
    UpdateId who;
} PblHdrExtended;
 
 
#define JUST_DONT_USE           0
 
#define TIMER_P_HANDLE          1
 
#define SUBSCRIBE_ALL           2
 
#define NAME_FOUND_EXT        'a'
 
#define NAME_FOUND          'A'
 
#define PUBLISH_THIS            'B'
 
#define SUBSCRIBE_TO_THIS       'C'
 
#define UPDATE_THIS         'D'
 
#define SUBSCRIBER_FOUND        'E'
 
#define UPDATE_ALL_SUBSCRIBERS      'F'
 
#define PUBLISH_DATA_PBLID      'G'
 
#define DELETE_ALL_PUBLISHERS       'H'
 
#define DELETE_ALL_SUBSCRIBERS      'I'
 
#define DELETE_THIS_PUBLISHER       'J'
 
#define DELETE_THIS_SUBSCRIBER      'K'
 
#define PROCEEDURE_ERROR        'L'
 
#define PUBLICATION_ERROR       'M'
 
#define SUBSCRIPTION_ERROR      'N'
 
#define PUBLISHER_FOUND         'O'
 
#define NO_PUBLICATION          'P'
 
#define PUBLISH_THIS_WITH_INFO      'Q'
 
#define FLOATING_NAME_FOUND     'r'
 
#define PUBLICATION_EXISTS_BEGIN    'S'
 
#define PUBLICATION_EXISTS_END      's'
 
#define NAME_LOST           'X'
 
#define SOCKET_UP           'Y'
 
#define HEART_BEAT          'Z'
 
#define TIMER_P_TIMER           500
 
#define HEART_BEAT_TIMER        5
 
 
#define SOCKET_TIME_OUT         30
 
typedef struct
{
     _UCHAR  Command;
    _INT          ID;
    _SHORT    PublisherLocal;
 
    _INT      PublisherID;
 
} SubscriberValidity;
 
typedef struct
{
     _UCHAR  Command;
 
    _INT          ID;
 
} DeleteThisPubSub;  // delete this Publication to discrition
 
 
typedef struct
{
     _UCHAR  Command;
 
    _INT          ID;
 
}PubSubError;  // delete this Publication to discrition
 
 
typedef struct
{
     _UCHAR  Command;
 
}DeleteAllPubSub;   // delete all the publications or discirtions
 
 
 
typedef struct {
     _UCHAR  Command;
     _INT         ID;
     _UINT NameLength;
} PublishSubScribeHeader;       // publish or subscribe to
 
typedef struct {
     _UCHAR  Command;
    _INT     ID;
    _CHAR PublicationName [PBLNAME_MAX + 1];
    _CHAR PublicationDesc [PBLDESC_MAX + 1];
    _UCHAR  articleType;
    _UINT maxCount;
    _UINT articleSize;
} PublishSubScribeHeaderWithInfo;       // publish or subscribe to
 
 
typedef struct {
     _UCHAR  Command;
    _INT      ID;
    _UINT ErrorNameLength;
} BridgeError;  // Name of error
 
typedef struct {
    PublishSubScribeHeader hdr;
 
    _UINT index;
 
     _UINT count;
 
}  SubscribeToThis;
 
typedef struct                  // this creates a PblID on the NT side.
{
     _UCHAR  Command;
 
    _INT          ID;
 
    _UINT sizePblId;
 
    PblId         pbl;
} PublisherCreated;             // a publisher was created
 
 
typedef PubSubError PublisherSimilar;
 
typedef struct {
     _UCHAR  Command;
 
    _INT          ID;
 
    _UINT sizePblId;
 
    PblId         pbl;
 
    _UINT index;
 
    _UINT count;
 
    _UINT articleSize;
 
     _UCHAR  articleType;
} UpdateDataHeader;
 
 
typedef struct
{
     _UCHAR  Command;
 
    _INT          ID;
 
    _UINT sizePblId;
 
    PblId         pbl;
 
    _UINT index;
 
    _UINT count;
 
} ReqUpdata;
 
#ifdef _WIN32
#define USETHIS 1
#endif
 
#if USETHIS
typedef struct
{
     _UCHAR  Command;
 
    _CHAR PublicationName [PBLNAME_MAX + 1];
 
    _CHAR PublicationDesc [PBLDESC_MAX + 1];
 
     _UCHAR  articleType;
 
    _UINT maxCount;
 
    _UINT articleSize;
 
} ExtendedPublicationNameFound;
#endif
 
 
 
#if defined(__GNUC__) || defined(_WIN32)
#pragma pack(pop)
#endif
 
#endif