static void rpc_user_routine ( void *  tagp, void *  bufp, int *  sizep  )

static

Definition at line 518 of file diccpp.cxx.

References dic_get_quality(), DimClient::getNoDataCopy(), DimRpcInfo::itsConnected, DimRpcInfo::itsData, DimRpcInfo::itsDataSize, DimRpcInfo::itsHandler, DimRpcInfo::itsInit, DimRpcInfo::itsNolinkBuf, DimRpcInfo::itsNolinkSize, DimRpcInfo::itsSize, DimRpcInfo::itsWaiting, DimRpcInfo::rpcInfoHandler(), size, DimTimer::stop(), t, wake_up, and DimRpcInfo::wakeUp.

Referenced by DimRpcInfo::doIt(), and DimRpcInfo::subscribe().

{
//      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(size > 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;
                        }
                }
                else if (size == 0)
                {
                        if(t->itsDataSize)
                        {
                                delete[] (char *)(t->itsData);
                                t->itsDataSize = 0;
                        }
                }
        }
        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)
                {
                        if(size > 0)
                                memcpy(t->itsData, buf, (size_t)size);
                        else
                                t->itsData = buf;
                }
                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
}

Here is the call graph for this function:

Here is the caller graph for this function: