ISISDS.h

Go to the documentation of this file.

#ifndef ISISDS_H
#define ISISDS_H

#include "isisds_command.h"
#include "../newicp/CRPTProxy.h"

#import "..\\isisicp\\isisicp.tlb" named_guids

class ThreadedClass
{
private:
        HANDLE m_thread_handle;
        unsigned m_thread_id;

public:
        ThreadedClass() : m_thread_handle(0), m_thread_id(0) {}
        void start()
        {
                m_thread_handle = (HANDLE)_beginthreadex(NULL, 0, startHelper, this, 0, &m_thread_id);
        }
        
        void cleanup()
        {
                if (m_thread_handle != 0)
                {
                        CloseHandle(m_thread_handle);
                        m_thread_handle = 0;
                }
                m_thread_id = 0;
        }
        virtual void run() { }
        bool isRunning() { return WaitForSingleObject(m_thread_handle, 0) == WAIT_TIMEOUT; }
        virtual ~ThreadedClass() { cleanup(); }

protected:
        static unsigned __stdcall startHelper(void* arg)
        { 
                ((ThreadedClass*)arg)->run();
                _endthreadex(0);
                return 0;
        }
};

struct ISISCRPT_STRUCT;

class ISISDSRequest : public ThreadedClass, ISIS::Base
{
private:
        std::string m_address;
        CRPTProxy& m_crpt;
        CComPtr<isisicpLib::Idae> m_dae;
        SOCKET m_socket; //< client socket requests received on

        bool processCommand(ISISDSAccessMode access_type, const char* command_in, const char* comm_data_in, int comm_data_len_in,
                                                                   char*& comm_data_out, ISISDSDataType& type_out, int* dims_array_out, int& ndims_out, bool& free_out);

public:
        ISISDSRequest(SOCKET s, const char* address, CRPTProxy& crpt) : ThreadedClass(), ISIS::Base(), m_socket(s), m_crpt(crpt), m_address(address) { setLoggerName("ISISDSRequest"); }
        virtual void run();
        virtual ~ISISDSRequest() { closesocket(m_socket); }
        const char* address() const { return m_address.c_str(); }
};

class ISISDS : public ThreadedClass, ISIS::Base
{
private:
        std::list<ISISDSRequest*> m_requests;
        CRPTProxy m_crpt;
        CComPtr<isisicpLib::Idae> m_dae;

public:
        ISISDS();
        virtual void run();
        virtual ~ISISDS();
        int doit();

};

extern ISISDS* m_ds;

#endif /* ISISDS_H */