source: trunk/FACT++/dim/src/diccpp.cxx@ 13322

#define DIMLIB
#include <dic.hxx>
#include <stdio.h>

char *DimClient::dimDnsNode = 0;
DimErrorHandler *DimClient::itsCltError = 0;
char *DimClient::serverName = 0;
int DimClient::dicNoCopy = 0;

extern "C" {
static void user_routine(void *tagp, void *bufp, int *size)
{
//      int *tag = (int *)tagp;
        char *buf = (char *)bufp;
//      int id = *tag;
        DimInfo *t;

//      t = (DimInfo *)id_get_ptr(id, SRC_DIC);
        t = * (DimInfo **)tagp;
        if(DimClient::getNoDataCopy() == 0)
        {
                if(!t->itsDataSize)
                {
                        t->itsData = new char[*size];
                        t->itsDataSize = *size;
                }
                else if(t->itsDataSize < *size)
                {
                        delete[] (char *)(t->itsData);
                        t->itsData = new char[*size];
                        t->itsDataSize = *size;
                }
                memcpy(t->itsData, buf, *size);
        }
        else
        {
                t->itsData = buf;
        }
        t->itsSize = *size;
        if(t->itsHandler)
        {
                t->itsHandler->itsService = t;
                DimCore::inCallback = 1;
                t->itsHandler->infoHandler();
                DimCore::inCallback = 0;
        }
        else
        {
                DimCore::inCallback = 1;
                t->infoHandler();
                DimCore::inCallback = 0;
        }
}
}

void DimInfo::infoHandler()
{
        char *data;
        if(DimClient::getNoDataCopy() == 1)
        {
                data = (char *)itsData;
                if(!itsDataSize)
                {
                        itsData = new char[itsSize];
                        itsDataSize = itsSize;
                }
                else if(itsDataSize < itsSize)
                {
                        delete[] (char *)(itsData);
                        itsData = new char[itsSize];
                        itsDataSize = itsSize;
                }
                memcpy(itsData, data, itsSize);
        }
}

void DimInfo::doIt()
{
        dim_init();
        DISABLE_AST

//      itsTagId = id_get((void *)this, SRC_DIC);
        itsId = dic_info_service(itsName,itsType,itsTime, 0, 0,
//              user_routine, itsTagId, 
                user_routine, (long)this, 
                itsNolinkBuf, itsNolinkSize);
        ENABLE_AST
}

int DimInfo::getQuality()
{
        return dic_get_quality(itsId);
}

int DimInfo::getTimestamp()
{

        dic_get_timestamp(itsId, &secs, &millisecs);
        return(secs);
}

int DimInfo::getTimestampMillisecs()
{
        return(millisecs);
}


char *DimInfo::getFormat()
{
        char *def;
        int len = 0, new_len;

        if(itsFormat)
        {
                len = strlen(itsFormat)+1;
                if(len > 1)
                        return itsFormat;
        }
        def = dic_get_format(itsId);
        new_len = strlen(def)+1;
        if(new_len > len)
        {
                if(itsFormat)
                        delete[] itsFormat;
                itsFormat = new char[strlen(def)+1];
        }
        strcpy(itsFormat, def);
        return itsFormat;
}

void DimInfo::timerHandler()
{
//      itsTagId = id_get((void *)this, SRC_DIC);
        itsId = dic_info_service(itsName,itsType,itsTime, 0, 0,
//              user_routine, itsTagId, 
                user_routine, (long)this, 
                itsNolinkBuf, itsNolinkSize);
}

void DimInfo::subscribe(char *name, int time, void *nolink, int nolinksize,
        DimInfoHandler *handler)
{
        itsId = 0;
//      itsTagId = 0;
        itsData = 0;
        itsFormat = 0;
        itsHandler = handler;
        itsName = new char[strlen(name)+1];
        strcpy(itsName,name);
        itsDataSize = 0;
        itsSize = 0;
        itsNolinkBuf = new char[nolinksize];
        itsNolinkSize = nolinksize;
        memcpy(itsNolinkBuf, nolink, nolinksize);
        if(!time)
        {
                itsType = MONITORED;
                itsTime = 0;
        }       
        else if(time > 0)
        {
                itsType = MONITORED;
                itsTime = time;
        }
        else
        {
                itsType = ONCE_ONLY;
                itsTime = 30;
        }
        doIt();
}


DimInfo::~DimInfo()
{
//      if(itsTagId)
//              id_free(itsTagId, SRC_DIC);
        dic_release_service(itsId);
        delete[] (char *)itsNolinkBuf;
        if(itsDataSize)
                delete[] (char *)itsData;
        delete[] itsName;
        if(itsFormat)
                delete[] itsFormat;
}

void *DimInfo::getData()
{
//      if(!this->itsSize)
//              return itsNolinkBuf;
/*
        if(DimClient::getNoDataCopy() == 1)
        {
                if(!DimCore::inCallback)
                        return (void *)0;
        }
*/
        return this->itsData;
}

void DimStampedInfo::doIt()
{
        dim_init();
        DISABLE_AST
//      itsTagId = id_get((void *)this, SRC_DIC);
        itsId = dic_info_service_stamped(itsName,itsType,itsTime, 0, 0,
//              user_routine, itsTagId, 
                user_routine, (long)this, 
                itsNolinkBuf, itsNolinkSize);
        ENABLE_AST
}

void DimStampedInfo::subscribe(char *name, int time, void *nolink, int nolinksize,
        DimInfoHandler *handler)
{
        itsId = 0;
        itsFormat = 0;
        itsHandler = handler;
        itsName = new char[strlen(name)+1];
        strcpy(itsName,name);
        itsDataSize = 0;
        itsNolinkBuf = new char[nolinksize];
        itsNolinkSize = nolinksize;
        memcpy(itsNolinkBuf, nolink, nolinksize);
        if(!time)
        {
                itsType = MONITORED;
                itsTime = 0;
        }       
        else if(time > 0)
        {
                itsType = MONITORED;
                itsTime = time;
        }
        else
        {
                itsType = ONCE_ONLY;
                itsTime = 30;
        }
        doIt();
}

DimStampedInfo::~DimStampedInfo()
{
}

void DimUpdatedInfo::doIt()
{
        dim_init();
        DISABLE_AST
//      itsTagId = id_get((void *)this, SRC_DIC);
        itsId = dic_info_service_stamped(itsName,itsType,itsTime, 0, 0,
//              user_routine, itsTagId, 
                user_routine, (long)this, 
                itsNolinkBuf, itsNolinkSize);
        ENABLE_AST
}

void DimUpdatedInfo::subscribe(char *name, int time, void *nolink, int nolinksize,
        DimInfoHandler *handler)
{
        itsId = 0;
        itsFormat = 0;
        itsHandler = handler;
        itsName = new char[strlen(name)+1];
        strcpy(itsName,name);
        itsDataSize = 0;
        itsNolinkBuf = new char[nolinksize];
        itsNolinkSize = nolinksize;
        memcpy(itsNolinkBuf, nolink, nolinksize);
        if(!time)
        {
                itsType = MONIT_ONLY;
                itsTime = 0;
        }       
        else if(time > 0)
        {
                itsType = UPDATE;
                itsTime = time;
        }
        doIt();
}

DimUpdatedInfo::~DimUpdatedInfo()
{
}

extern "C" {
static void data_user_routine(void *tagp, void *bufp, int *size)
{
//      int *tag = (int *)tagp;
        char *buf = (char *)bufp;
//      int id = *tag;
        DimCurrentInfo *t;

//      t = (DimCurrentInfo *)id_get_ptr(id, SRC_DIC);
        t = * (DimCurrentInfo **)tagp;
        if(!t->itsDataSize)
        {
                t->itsData = new char[*size];
                t->itsDataSize = *size;
        }
        else if(t->itsDataSize < *size)
        {
                delete[] (char *)(t->itsData);
                t->itsData = new char[*size];
                t->itsDataSize = *size;
        }
        memcpy(t->itsData, buf, *size);
        t->itsSize = *size;
        t->wakeUp = 1;
#ifdef __VMS
        sys$wake(0,0);
#endif
#ifdef WIN32
        wake_up();
#endif
}
}

void DimCurrentInfo::subscribe(char *name, int time, void *nolink, int nolinksize)
{

        int timeout;

//      itsTagId = 0;
        if(!time)
                timeout = 10;
        else
                timeout = time;
        itsName = new char[strlen(name)+1];
        strcpy(itsName,name);
        itsDataSize = 0;
        itsNolinkBuf = new char[nolinksize];
        itsNolinkSize = nolinksize;
        memcpy(itsNolinkBuf, nolink, nolinksize);
        wakeUp = 0;
//      itsTagId = id_get((void *)this, SRC_DIC);
        dic_info_service(itsName,ONCE_ONLY,timeout, 0, 0,
//              data_user_routine, itsTagId, 
                data_user_routine, (long)this, 
                itsNolinkBuf, itsNolinkSize);
}

DimCurrentInfo::~DimCurrentInfo()
{
        delete[] (char *)itsNolinkBuf;

//      if(itsTagId)
//              id_free(itsTagId, SRC_DIC);
        if(itsDataSize)
                delete[] (char *)itsData;
        delete[] itsName;
}

void *DimCurrentInfo::getData()
{
        while(!wakeUp)
        {
#ifdef __VMS
                sys$hiber();
#else
                dim_wait();
#endif
        }
        return this->itsData;
}

extern "C" {
static void cmnd_done(void *tagp, int *result)
{
//      int *tag = (int *)tagp;
//      int id = *tag;
        DimCmnd *t;

//      t = (DimCmnd *)id_get_ptr(id, SRC_DIC);
        t = *(DimCmnd **)tagp;
        t->result = *result;
        t->wakeUp = 1;
#ifdef __VMS
        sys$wake(0,0);
#endif
#ifdef WIN32
        wake_up();
#endif
}
}

int DimCmnd::send(char *name, void *data, int datasize) 
{
//      int id;
        if(DimCore::inCallback) 
        {
                dic_cmnd_service(name, data, datasize);
                return(1);
        }
        else
        {
                wakeUp = 0;
//              id = id_get((void *)this, SRC_DIC);
                dic_cmnd_callback(name, data, datasize, 
//                      cmnd_done, id);
                        cmnd_done, (long)this);
                while(!wakeUp)
                {
#ifdef __VMS
                        sys$hiber();
#else
                        dim_wait();
#endif
                }
//              id_free(id, SRC_DIC);
                return(result);
        }
}

void DimCmnd::sendNB(char *name, void *data, int datasize) 
{
        dic_cmnd_service(name, data, datasize);
}

extern "C" {
static void rpc_user_routine(void *tagp, void *bufp, int *sizep)
{
//      int *tag = (int *)tagp;
        char *buf = (char *)bufp;
        int size = *sizep;
//      int id = *tag;
        DimRpcInfo *t;
        int quality;

//      t = (DimRpcInfo *)id_get_ptr(id, SRC_DIC);
        t = *(DimRpcInfo **)tagp;
        quality = dic_get_quality(0);
        if(quality == -1)
        {
                buf = (char *)t->itsNolinkBuf;
                size = t->itsNolinkSize;
        }
        if(DimClient::getNoDataCopy() == 0)
        {
                if(!t->itsDataSize)
                {
                        t->itsData = new char[size];
                        t->itsDataSize = size;
                }
                else if(t->itsDataSize < size)
                {
                        delete[] (char *)(t->itsData);
                        t->itsData = new char[size];
                        t->itsDataSize = size;
                }
        }
        if(!t->itsConnected)
        {
                t->itsConnected = 1;
        }
        if(t->itsWaiting)
        {
                t->stop();
//dim_print_date_time();
//printf("DIM RPC: Stopped Timer, Data Received for %s\n", t->getName());
                if(DimClient::getNoDataCopy() == 0)
                        memcpy(t->itsData, buf, size);
                else
                        t->itsData = buf;
                t->itsSize = size;
                t->wakeUp = 1;
                if(t->itsInit)
                {
                        t->itsWaiting = 1;
                        t->itsHandler->rpcInfoHandler();
                }
                if(t->itsWaiting != 2)
                        t->itsWaiting = 0;
        }
#ifdef __VMS
        sys$wake(0,0);
#endif
#ifdef WIN32
        wake_up();
#endif
}
}

void DimRpcInfo::timerHandler()
{
        char *buf;
        int size;
                
        buf = (char *)itsNolinkBuf;
        size = itsNolinkSize;

        if(DimClient::getNoDataCopy() == 0)
        {
                if(!itsDataSize)
                {
                        itsData = new char[size];
                        itsDataSize = size;
                }
                else if(itsDataSize < size)
                {
                        delete[] (char *)(itsData);
                        itsData = new char[size];
                        itsDataSize = size;
                }
        }
        if(itsWaiting)
        {
                if(DimClient::getNoDataCopy() == 0)
                        memcpy(itsData, buf, size);
                else
                        itsData = buf;
                itsSize = size;
//dim_print_date_time();
//printf("DIM RPC: Timer fired, No Data Received for %s\n", itsName);
                wakeUp = 1;
                if(itsInit)
                {
                        itsWaiting = 1;
                        itsHandler->rpcInfoHandler();
                }
                if(itsWaiting != 2)
                        itsWaiting = 0;
        }
#ifdef __VMS
        sys$wake(0,0);
#endif
#ifdef WIN32
        wake_up();
#endif
}

void DimRpcInfo::rpcInfoHandler()
{
        char *data;
        if(DimClient::getNoDataCopy() == 1)
        {
                data = (char *)itsData;
                if(!itsDataSize)
                {
                        itsData = new char[itsSize];
                        itsDataSize = itsSize;
                }
                else if(itsDataSize < itsSize)
                {
                        delete[] (char *)(itsData);
                        itsData = new char[itsSize];
                        itsDataSize = itsSize;
                }
                memcpy(itsData, data, itsSize);
        }
}

void DimRpcInfo::subscribe(char *name, void *data, int size,
        void *nolink, int nolinksize, int timeout)
{

        itsId = 0;
//      itsTagId = 0;
        itsInit = 0;
        itsWaiting = 0;
        itsName = new char[strlen(name)+1];
        strcpy(itsName,name);
        itsHandler = this;
        itsDataSize = 0;
        itsData = 0;
        itsDataOutSize = 0;
        itsDataOut = 0;
        itsNolinkBuf = new char[nolinksize];
        itsNolinkSize = nolinksize;
        memcpy(itsNolinkBuf, nolink, nolinksize);
        itsNameOut = new char[strlen(name)+1+10];
        strcpy(itsNameOut,name);
        strcat(itsNameOut,(char *)"/RpcIn");
        itsNameIn = new char[strlen(name)+1+10];
        strcpy(itsNameIn,name);
        strcat(itsNameIn,(char *)"/RpcOut");
        itsTimeout = timeout;
        dim_init();
        {
                if(!itsId)
                {
//                      itsTagId = id_get((void *)itsHandler, SRC_DIC);

//                      itsId = dic_info_service_stamped(itsNameIn,MONIT_ONLY,itsTimeout, 
                        itsConnected = 0;
//                      itsId = dic_info_service_stamped(itsNameIn,MONITORED,itsTimeout, 
                        itsId = dic_info_service_stamped(itsNameIn,MONIT_FIRST,itsTimeout, 
                                0, 0,
//                              rpc_user_routine, itsTagId, 
                                rpc_user_routine, (long)itsHandler, 
                                itsNolinkBuf, itsNolinkSize);
//                      dim_usleep(200000);
                        itsInit = 1;
                }
        }
        if(size)
        {
                doIt(data, size);
        }
}
        
void DimRpcInfo::doIt(void *data, int size)
{
        int ret;

        wakeUp = 0;
        if(DimClient::getNoDataCopy() == 0)
        {
                if(!itsDataOut)
                {
                        itsDataOut = new char[size];
                        itsDataOutSize = size;
                }
                else if(itsDataOutSize < size)
                {
                        delete[] (char *)itsDataOut;
                        itsDataOut = new char[size];
                        itsDataOutSize = size;
                }
                memcpy(itsDataOut, data, size);
        }
        else
        {
                itsDataOut = data;
        }
        while(!itsConnected)
                dim_wait();
        itsWaiting = 1;
        if(itsTimeout)
                start(itsTimeout);
//dim_print_date_time();
//printf("DIM RPC: Started Timer for %s - %d secs\n", itsName, itsTimeout);
        ret = DimClient::sendCommand(itsNameOut, itsDataOut, size); 
        if(!ret)
        {
                if(itsTimeout)
                        stop();
//dim_print_date_time();
//printf("DIM RPC: Stopped Timer, Command failed for %s\n", itsName);
//              rpc_user_routine((int *)&itsTagId, itsNolinkBuf, &itsNolinkSize);
                rpc_user_routine((long *)&itsHandler, itsNolinkBuf, &itsNolinkSize);
        }
/*
        else
        {
                if(itsTimeout)
                        start(itsTimeout);
        }
*/
}

void *DimRpcInfo::getData()
{
        while(!wakeUp)
        {
#ifdef __VMS
                sys$hiber();
#else
                dim_wait();
#endif
        }
/*
        if(DimClient::getNoDataCopy() == 1)
        {
                if(!DimCore::inCallback)
                        return (void *)0;
        }
*/
        return this->itsData;
}

DimRpcInfo::~DimRpcInfo() 
{
//      if(itsTagId)
//              id_free(itsTagId, SRC_DIC);
//dim_print_date_time();
//printf("DIM RPC: Deleting RPC and Timer for %s\n", itsName);
        if(itsId)
                dic_release_service(itsId);
        delete[] (char *)itsNolinkBuf;
        if(itsDataSize)
                delete[] (char *)itsData;
        if(itsDataOutSize)
                delete[] (char *)itsDataOut;
        delete[] itsName;
        delete[] itsNameIn;
        delete[] itsNameOut;
}

DimBrowser::DimBrowser()
{
        int i;
        for(i = 0; i<5; i++)
        {
                itsData[i] = 0;
                itsData[i] = 0;
        }
        currIndex = -1;
        none = 0;
        browserRpc = 0;
}

DimBrowser::~DimBrowser()
{
        int i;
        for(i = 0; i<5; i++)
        {
                if(itsData[i])
                        delete itsData[i];
        }
        if(browserRpc)
                delete browserRpc;
}

int DimBrowser::getServices(const char * serviceName) 
{
        return getServices(serviceName, 0);
}

int DimBrowser::getServices(const char * serviceName, int timeout) 
{
        char *str;

//      DimRpcInfo rpc((char *)"DIS_DNS/SERVICE_INFO",(char *)"\0");
//      rpc.setData((char *)serviceName);
//      str = rpc.getString();
        if(!browserRpc)
                browserRpc = new DimRpcInfo((char *)"DIS_DNS/SERVICE_INFO",timeout,(char *)"\0");
        browserRpc->setData((char *)serviceName);
        str = browserRpc->getString();  
        if(itsData[0])
                delete itsData[0];
        itsData[0] = new TokenString(str,(char *)"|\n"); 
        currIndex = 0;
        if(!itsData[0]->getNTokens())
                return(0);
        return( itsData[0]->getNTokens((char *)"\n") + 1); 
}

int DimBrowser::getServers() 
{
        return getServers(0);
}

int DimBrowser::getServers(int timeout) 
{
        char *str, *pid_str;
        int size, totsize;
        DimCurrentInfo srv((char *)"DIS_DNS/SERVER_LIST", timeout, (char *)"\0");
        str = srv.getString();
        size = strlen(str)+1;
        totsize = srv.getSize();

        if(itsData[1])
                delete itsData[1];
        itsData[1] = new TokenString(str,(char *)"|@\n"); 
        currIndex = 1;
        if(!str[0])
                return(0);
        if(totsize > size)
        {
                pid_str = str + strlen(str) + 1;
                if(itsData[4])
                        delete itsData[4];
                itsData[4] = new TokenString(pid_str,(char *)"|"); 
        }
        return(itsData[1]->getNTokens((char *)"|") +1); 
}

int DimBrowser::getServerServices(const char *serverName) 
{
        return getServerServices(serverName, 0);
}

int DimBrowser::getServerServices(const char *serverName, int timeout) 
{
        char *str;
        char *name = new char[strlen(serverName) + 20];
        strcpy(name,(char *)serverName);
        strcat(name,(char *)"/SERVICE_LIST");
        DimCurrentInfo srv(name, timeout, (char *)"\0");
        delete[] name;
        str = srv.getString();  
        if(itsData[2])
                delete itsData[2];
        itsData[2] = new TokenString(str,(char *)"|\n"); 
        currIndex = 2;
        if(!itsData[2]->getNTokens())
                return(0);
        return(itsData[2]->getNTokens((char *)"\n") + 1); 
}

int DimBrowser::getServerClients(const char *serverName)
{
        return getServerClients(serverName, 0);
}

int DimBrowser::getServerClients(const char *serverName, int timeout) 
{
        char *str;
        char *name = new char[strlen(serverName) + 20];
        strcpy(name,(char *)serverName);
        strcat(name,(char *)"/CLIENT_LIST");
        DimCurrentInfo srv(name, timeout, (char *)"\0");
        delete[] name;
        str = srv.getString();  
        if(itsData[3])
                delete itsData[3];
        itsData[3] = new TokenString(str,(char *)"|@\n"); 
        currIndex = 3;
        return(itsData[3]->getNTokens((char *)"@") ); 
}
        
int DimBrowser::getNextService(char *&service, char *&format)
{
        int ret, type;

        service = format = &none;
        ret = itsData[0]->getToken(currToken);
        if(!ret) return 0;
        service = currToken;
        ret = itsData[0]->getToken(currToken);
        if(!itsData[0]->cmpToken((char *)"|"))
                return 0;
        ret = itsData[0]->getToken(currToken);
        if(!itsData[0]->cmpToken((char *)"|"))
        {
                format = currToken;
                ret = itsData[0]->getToken(currToken);
                if(!itsData[0]->cmpToken((char *)"|"))      
                        return 0;
        }
        ret = itsData[0]->getToken(currToken);
        type = DimSERVICE;
        if(!itsData[0]->cmpToken((char *)"\n"))
        {
                if(itsData[0]->cmpToken((char *)"CMD"))
                        type = DimCOMMAND;
                if(itsData[0]->cmpToken((char *)"RPC"))
                        type = DimRPC;
                ret = itsData[0]->getToken(currToken);
                if(!itsData[0]->cmpToken((char *)"\n"))
                        return 0;
        }
        return type;
}
        
int DimBrowser::getNextServer(char *&server, char *&node)
{
        int ret;

        server = node = &none;
        ret = itsData[1]->getToken(currToken);
        if(!ret) return 0;
        server = currToken;
        ret = itsData[1]->getToken(currToken);
        if(!itsData[1]->cmpToken((char *)"@"))
                return 0;
        while(1)
        {
                ret = itsData[1]->getToken(currToken);
                node = currToken;
                itsData[1]->pushToken();
                ret = itsData[1]->getToken(currToken);
                if(itsData[1]->cmpToken((char *)"@"))
                {
                        strcat(server,"@");
                        strcat(server,node);
                }
                else
                        break;
        }
        if(!itsData[1]->cmpToken((char *)"|"))
                itsData[1]->popToken();
        return 1;
}

int DimBrowser::getNextServer(char *&server, char *&node, int &pid)
{
        int ret, lpid = 0;
        char *tok;

        ret = getNextServer(server, node);
        if(ret && itsData[4])
        {
                ret = itsData[4]->getToken(tok);
                if(ret)
                {
                        sscanf(tok,"%d",&lpid);
                        pid = lpid;
                }
        }
        if(!ret) 
                return 0;
        ret = itsData[4]->getToken(tok);
        return 1;
}
        
int DimBrowser::getNextServerService(char *&service, char *&format)
{
        int ret, type;

        service = format = &none;
        ret = itsData[2]->getToken(currToken);
        if(!ret) return 0;
        service = currToken;
        ret = itsData[2]->getToken(currToken);
        if(!itsData[2]->cmpToken((char *)"|"))
                return 0;
        ret = itsData[2]->getToken(currToken);
        if(!itsData[2]->cmpToken((char *)"|"))
        {
                format = currToken;
                ret = itsData[2]->getToken(currToken);
                if(!itsData[2]->cmpToken((char *)"|"))
                        return 0;
        }
        ret = itsData[2]->getToken(currToken);
        type = DimSERVICE;
        if(!itsData[2]->cmpToken((char *)"\n"))
        {
                if(itsData[2]->cmpToken((char *)"CMD"))
                        type = DimCOMMAND;
                if(itsData[2]->cmpToken((char *)"RPC"))
                        type = DimRPC;
                ret = itsData[2]->getToken(currToken);
                if(!itsData[2]->cmpToken((char *)"\n"))
                        return 0;
        }
        return type;
}
        
int DimBrowser::getNextServerClient(char *&client, char *&node)
{
        int ret;

        client = node = &none;
        ret = itsData[3]->getToken(currToken);
        if(!ret) return 0;
        client = currToken;
        ret = itsData[3]->getToken(currToken);
        if(!itsData[3]->cmpToken((char *)"@"))
                return 0;
        ret = itsData[3]->getToken(currToken);
        node = currToken;
        itsData[3]->pushToken();
        ret = itsData[3]->getToken(currToken);
        if(!itsData[3]->cmpToken((char *)"|"))
                itsData[3]->popToken();
        return 1;
}

DimClient::DimClient()
{
        itsCltError = this;
}

DimClient::~DimClient() 
{
        if(dimDnsNode)
                delete[] dimDnsNode;
}

int DimClient::sendCommand(const char *name, int data)
{ 
        DimCmnd a;
        return a.send((char *)name, &data, sizeof(int));
}

int DimClient::sendCommand(const char *name, float data)
{ 
        DimCmnd a;
        return a.send((char *)name, &data, sizeof(float));
}

int DimClient::sendCommand(const char *name, double data)
{ 
        DimCmnd a;
        return a.send((char *)name, &data, sizeof(double));
}

int DimClient::sendCommand(const char *name, longlong data)
{ 
        DimCmnd a;
        return a.send((char *)name, &data, sizeof(longlong));
}

int DimClient::sendCommand(const char *name, short data)
{ 
        DimCmnd a;
        return a.send((char *)name, &data, sizeof(short));
}

int DimClient::sendCommand(const char *name, const char *data)
{ 
        DimCmnd a;
        return a.send((char *)name, (char *)data, strlen(data)+1);
}

int DimClient::sendCommand(const char *name, void *data, int datasize)
{
        DimCmnd a;
        return a.send((char *)name, data, datasize);
}

void DimClient::sendCommandNB(const char *name, int data)
{
        DimCmnd a;
        a.sendNB((char *)name, &data, sizeof(int));
}

void DimClient::sendCommandNB(const char *name, float data)
{
        DimCmnd a;
        a.sendNB((char *)name, &data, sizeof(float));
}

void DimClient::sendCommandNB(const char *name, double data)
{
        DimCmnd a;
        a.sendNB((char *)name, &data, sizeof(double));
}

void DimClient::sendCommandNB(const char *name, longlong data)
{
        DimCmnd a;
        a.sendNB((char *)name, &data, sizeof(longlong));
}

void DimClient::sendCommandNB(const char *name, short data)
{
        DimCmnd a;
        a.sendNB((char *)name, &data, sizeof(short));
}

void DimClient::sendCommandNB(const char *name, char *data)
{
        DimCmnd a;
        a.sendNB((char *)name, data, strlen(data)+1);
}

void DimClient::sendCommandNB(const char *name, void *data, int datasize)
{
        DimCmnd a;
        a.sendNB((char *)name, data, datasize);
}

int DimClient::setExitHandler(const char *srvName)
{
        DimCmnd a;
        int ret, tag = 1;
        char *name = new char[strlen(srvName) + 20];
        strcpy(name,(char *)srvName);
        strcat(name,"/SET_EXIT_HANDLER");
        ret =  a.send(name, &tag, sizeof(int));
        delete[] name;
        return ret;
}

int DimClient::killServer(const char *srvName)
{
        DimCmnd a;
        int ret, tag = 1;
        char *name = new char[strlen(srvName) + 20];
        strcpy(name,(char *)srvName);
        strcat(name,"/EXIT");
        ret = a.send(name, &tag, sizeof(int));
        delete[] name;
        return ret;
}

int DimClient::setDnsNode(const char *node)
{
        dic_set_dns_node((char *)node);
        dic_close_dns();
        return 1;
}

int DimClient::setDnsNode(const char *node, int port)
{
        dic_set_dns_port(port);
        dic_set_dns_node((char *)node);
        dic_close_dns();
        return 1;
}

char *DimClient::getDnsNode()
{
        if(!dimDnsNode)
                dimDnsNode = new char[256];
        if(dic_get_dns_node(dimDnsNode))
                return dimDnsNode;
        else
                return 0;
}

int DimClient::getDnsPort() 
{
        return dic_get_dns_port();
}

void DimClient::setNoDataCopy()
{
        dicNoCopy = 1;
}

int DimClient::getNoDataCopy()
{
        return dicNoCopy;
}

extern "C" {
//static void clt_error_user_routine(char*, int);
static void clt_error_user_routine(int severity, int code, char *msg)
{

        DimCore::inCallback = 2;
        if(DimClient::itsCltError != 0)
                DimClient::itsCltError->errorHandler(severity, code, msg);
        DimCore::inCallback = 0;
}
}

void DimClient::addErrorHandler(DimErrorHandler *handler)
{
        if(handler == 0)
        {
                dic_add_error_handler(0);
                DimClient::itsCltError = 0;
        }
        else
        {
                DimClient::itsCltError = handler;
                dic_add_error_handler(clt_error_user_routine);
        }
}

void DimClient::addErrorHandler()
{
        DimClient::itsCltError = this;
        dic_add_error_handler(clt_error_user_routine);
}

int DimClient::getServerId()
{
        if(!serverName)
                serverName = new char[128];
        serverName[0] = '\0';
        return dic_get_server(serverName);
}

int DimClient::getServerPid()
{
        int pid, ret;

        ret = dic_get_server_pid(&pid);
        if(!ret)
                return 0;
        return pid;
}

char *DimClient::getServerName()
{
        if(!serverName)
                serverName = new char[128];
        serverName[0] = '\0';
        dic_get_server(serverName);
        return(serverName);
}

/*
char *DimClient::getServerServices(int serverId)
{
        return dic_get_server_services(serverId);
}

char *DimClient::getServerServices()
{
        int id;
        if((id = dic_get_conn_id()))
                return dic_get_server_services(id);
        return (char *)0;
}
*/
char **DimClient::getServerServices()
{
        static TokenString *data = 0;
        int id, len = 0, index = 0;
        char *services;
        static char** list = 0;
        char *sep;

        if(data)
        {
                delete data;
                data = 0;
        }
        if(list)
        {
                delete[] list;
                list = 0;
        }
        if((id = dic_get_conn_id()))
        {
                services = dic_get_server_services(id);
                if(services)
                {
                        data = new TokenString(services,(char *)"\n");
                        len = data->getNTokens();
                        list = new char*[len];
                        while(data->getToken(list[index]))
                        {
                                data->getToken(sep);
                                index++;
                        }
                }
        }
        if(!len)
                list = new char*[1];
        list[index] = 0;
        return list;
}

int DimClient::inCallback()
{
        if(DimCore::inCallback)
                return 1;
        return 0;
}