static void rpcin_routine ( void *  tagp, void *  buf, int *  size  )

static

Definition at line 181 of file discpp.cxx.

References dis_get_conn_id(), dis_get_timeout(), dis_selective_update_service, ids, DimCore::inCallback, DimRpc::itsDataIn, DimRpc::itsIdOut, DimRpc::itsKilled, DimRpc::itsSizeIn, DimRpc::itsTimeout, DimRpc::rpcHandler(), size, t, and time.

Referenced by DimRpc::declareIt().

{
        time_t tt1 = 0, tt2 = 0;

//      int *tag = (int *)tagp;
//      int id = *tag;
        DimRpc *t;
        int tout, clientId, ids[2];
//      long tid;

//      t = (DimRpc *)id_get_ptr(id, SRC_DIS);
        t = *(DimRpc **)tagp;
        t->itsDataIn = buf;
        t->itsSizeIn = *size;
        clientId = dis_get_conn_id();
        tout = dis_get_timeout(t->itsIdOut, clientId);
        t->itsTimeout = tout;
//      tid = 0;
        if(tout > 0)
        {
                tt1 = time((time_t *)0);
                t->itsKilled = 0;
//              dtq_start_timer(t->itsTimeout,(void(*)(void *))timeout_rout,(void *)t);
//              tid = dim_start_thread((void(*)(void *))timeout_rout,(void *)t);
        }
        DimCore::inCallback = 2;
        t->rpcHandler();
        DimCore::inCallback = 0;
        t->itsDataIn = 0;
        t->itsSizeIn = 0;
        if(tout > 0)
        {
                tt2 = time((time_t *)0);
                if((tt2 - tt1) > tout)
                        t->itsKilled = 1;
        }
        if(!t->itsKilled)
        {
//              if(tid)
//              {
//                      dtq_stop_timer((void *)t);
//                      dim_stop_thread(tid);
//              }
                ids[0] = clientId;
                ids[1] = 0;
                dis_selective_update_service(t->itsIdOut, ids);
        }
}

Here is the call graph for this function:

Here is the caller graph for this function: