cta_ua_pushmanager.h

Aller à la documentation de ce fichier.

#ifndef __CTAUAPUSHNANAGER_H__
#define __CTAUAPUSHMANAGER_H__

#include "uabasenodes.h"
#include "uathread.h"
#include "servermanager.h"
#include "string"
#include <vector>
#include <list>

#include "../uaclient/uasession.h"

class Callback: public UaClientSdk::UaSessionCallback,
        public UaClientSdk::UaSubscriptionCallback {
public:

    Callback() {
    }
    ;
    virtual ~Callback() {
    }
    ;

    virtual void connectionStatusChanged(OpcUa_UInt32 clientConnectionId,
            UaClientSdk::UaClient::ServerStatus serverStatus) {
        printf("-- Event connectionStatusChanged ----------------------\n");
        printf("clientConnectionId %d \n", clientConnectionId);
        printf("serverStatus %d \n", serverStatus);
        printf("-------------------------------------------------------\n");
    }
    ;

    virtual void dataChange(OpcUa_UInt32 clientSubscriptionHandle,
            const UaDataNotifications& dataNotifications,
            const UaDiagnosticInfos& /*diagnosticInfos*/) {
        printf("-- Event dataChange -----------------------------------\n");
        printf("-------------------------------------------------------\n");
    }
    ;

    virtual void subscriptionStatusChanged(
            OpcUa_UInt32 /*clientSubscriptionHandle*/,
            const UaStatus& /*status*/) {
    }
    ;

    virtual void newEvents(OpcUa_UInt32 clientSubscriptionHandle,
            UaEventFieldLists& eventFieldList) {
        printf("-- Event newEvents ------------------------------------\n");
        printf("-------------------------------------------------------\n");
    }
};

namespace CTA_UA {
class NodeManagerCTA;
class ControllerObject;
struct myStruct;
}
namespace CTA_Slc {
class XmlManager;
}

namespace CTA_UA {

class PushManager: public UaThread {
    UA_DISABLE_COPY(PushManager);

public:
    static PushManager *singleton;
    static PushManager *getInstance();
    PushManager();
    virtual ~PushManager();
    UaStatus connect(UaString& sUrl,
            UaClientSdk::SessionSecurityInfo& sessionSecurityInfo);

    // Start up trame manager for internal monitoring
    void startUp(ServerManager* pServerManager, std::string url);

    // Shut down trame manager to stop internal monitoring
    void shutDown();

    // Add a variable for traming- must be called before startUp
    void addVariableToPush(std::string name, ControllerObject *pControler);
    void run();
    void callMethod(std::string command);

private:
    // List of variable of trame
    std::list<std::string> listPush;

    // Internal session used for monitoring
    UaClientSdk::UaSession* m_pSession;
    std::string m_dataIdDescriptorRef;

    CTA_Slc::XmlManager *m_pAnalyserManager;

    OpcUa_Boolean m_stop;
    OpcUa_Boolean m_pause;

    // Server manager used for internal monitoring
    ServerManager* m_pServerManager;
    ControllerObject *m_pControler;
};

} // end namespace
#endif