vlShmReader.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1992-2010 MAK Technologies, Inc
** All rights reserved.
*********************************************************************/
#pragma once

#include "vlShmQueue.h"

#define DEBUG 0

#define DtCsStatusMessageReceived    0
#define DtCsStatusWouldResourceBlock 1
#define DtCsStatusWouldBlock         2
#define DtCsStatusClosing            3
#define DtCsStatusExtCliQuota        4
#define DtCsStatusTryAgain           5  

#define DtCsStatusMessageReceived    0
#define DtCsStatusWouldResourceBlock 1
#define DtCsStatusWouldBlock         2
#define DtCsStatusClosing            3
#define DtCsStatusExtCliQuota        4

#ifdef DtUSE_UTILITIES_NAMESPACE
namespace DtUSE_UTILITIES_NAMESPACE
{
#endif


class DT_DLL_VLUTIL DtClientServerReader
{
    public:
      DtClientServerReader() {};
      virtual ~DtClientServerReader() {};

      virtual int Read(char *buf, size_t size, char *status) = 0;
};

class DT_DLL_VLUTIL DtShmMsgQueueReader : public DtClientServerReader
{
  public:

    DtShmMsgQueueManager qManager;
    
    DtShmMsgQueueReader(DtShmMsgQueue *q, int size, int sem, int firstSem,
   bool wait, bool pleaseInit, bool dropOldest = true);

    virtual ~DtShmMsgQueueReader() {}

    int Read(char *buf, size_t size, char *status);

    bool isInternal() { return qManager.isInternal(); }
    int msgsRcvd()         { return msgsRead; }

    bool resourceWait;

  private:

    int msgsRead;

#if DEBUG
    int verifyQueue(void);
#endif

};

#ifdef DtUSE_UTILITIES_NAMESPACE
} 
#endif