granules.h

Go to the documentation of this file.

#ifndef GRANULES_H
#define GRANULES_H

#include <boost/date_time/posix_time/posix_time.hpp>

#include <config.h>

#if HAVE_BOOST_THREAD
#include <boost/thread/thread_only.hpp>
#include <boost/chrono.hpp>
#endif


#include <global.h>
#include <conduitFriends.h>
#include <handleHelper.h>



class Granules {
public:

    template <class CTYPE> friend class Instant;
    friend class CAFE;
    Granules(){};

private:
        HandleHelper helper;
    CAFEStatus cafeStatus;

    ChannelRequestDataTypePolicy  channelRequestDataTypePolicy;

    ChannelRequestPolicyKind methodKind; //for channelExecutePut

    ChannelRequestPolicy  channelRequestPolicyPut;
    ChannelRequestStatus  channelRequestStatusPut;

    ChannelRequestPolicy  channelRequestPolicyGet;
    ChannelRequestStatus  channelRequestStatusGet;

    ChannelRequestMetaDataClient      channelRequestMetaDataClient;
    ChannelRequestMetaData            channelRequestMetaData;
    ChannelRequestMetaData            channelRequestMetaPrimitive;

    ChannelRequestPolicy  channelRequestPolicyGetCtrl;
    ChannelRequestStatus  channelRequestStatusGetCtrl;

    ChannelRequestMetaDataClient    channelRequestMetaCtrlClient;
    ChannelRequestMetaData          channelRequestMetaCtrl;

    ChannelTimeoutPolicy        channelTimeoutPolicyGet;
    ChannelTimeoutPolicy        channelTimeoutPolicyPut;

    int  channelVerifyPut      (const unsigned int, chtype); //isChannelConnected //writeAccess
    int  channelPreparePut     (const unsigned int); //nelem offset requestType
    int  channelExecutePut     (const unsigned int);

    int  waitForPutEvent    (const unsigned int, double);
    bool isPutCallbackDone  (const unsigned int  _handle);

    int  channelVerifyGet       (const unsigned int, chtype); //isChannelConnected //readAccess
    int  channelPrepareGet      (const unsigned int); //nelem offset requestType
    int  channelExecuteGet      (const unsigned int); //report status
    int  channelExecuteGetNoWait(const unsigned int); //report status

        int waitForManyGetEvents(const unsigned int * handleArray,  unsigned int arrayLength, map<unsigned int, int> & bundleResponse);

    int  waitForGetEvent    (const unsigned int, double);
    bool isGetCallbackDone  (const unsigned int  _handle);

    int  channelVerifyGetCtrl  (const unsigned int, chtype); //isChannelConnected //readAccess
    int  channelPrepareGetCtrl (const unsigned int); //nelem offset requestType
    int  channelExecuteGetCtrl (const unsigned int); //report status
    int  channelExecuteGetCtrlNoWait(const unsigned int  _handle);

    int  waitForGetCtrlEvent(const unsigned int, double);
    bool isGetCtrlCallbackDone(const unsigned int  _handle);

    int  status;

    chtype convertMatrix(const chtype nativeType, const chtype clientT);

};



#endif // GRANULES_H