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

private

Definition at line 682 of file diccpp.cxx.

References dic_info_service_stamped(), dim_init(), DimInfo::doIt(), DimInfo::itsData, DimInfo::itsDataSize, DimInfo::itsHandler, DimInfo::itsId, DimInfo::itsName, DimInfo::itsNolinkBuf, DimInfo::itsNolinkSize, MONIT_FIRST, and rpc_user_routine().

{

        itsId = 0;
//      itsTagId = 0;
        itsInit = 0;
        itsWaiting = 0;
        itsName = new char[(int)strlen(name)+1];
        strcpy(itsName,name);
        itsHandler = this;
        itsDataSize = 0;
        itsData = 0;
        itsDataOutSize = 0;
        itsDataOut = 0;
        itsNolinkBuf = nolink;
        itsNolinkSize = nolinksize;
        if(nolinksize > 0)
        {
                itsNolinkBuf = new char[nolinksize];
                itsNolinkSize = nolinksize;
                memcpy(itsNolinkBuf, nolink, (size_t)nolinksize);
        }
        itsNameOut = new char[(int)strlen(name)+1+10];
        strcpy(itsNameOut,name);
        strcat(itsNameOut,(char *)"/RpcIn");
        itsNameIn = new char[(int)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, (dim_long)itsHandler, 
                                itsNolinkBuf, itsNolinkSize);
//                      dim_usleep(200000);
                        itsInit = 1;
                }
        }
        if(size)
        {
                doIt(data, size);
        }
}

Here is the call graph for this function: