static void dis_insert_request ( int  conn_id, DIC_PACKET *  dic_packet, int  size, int  status  )

static

Definition at line 1146 of file dis_old.c.

References COMMAND, req_ent::conn_id, cli_ent::conn_id, exit_ent::conn_id, Curr_conn_id, req_ent::delay_delete, DIM_DELETE, dis_dns_ent::dis_client_id, Dis_timer_q, dis_update_service(), dll_get_next(), dll_init(), dll_insert_queue(), serv::dnsp, cli_ent::dnsp, dtq_add_entry(), execute_command(), execute_service(), find_client(), find_release_request(), find_service(), req_ent::first_time, req_ent::format, DIC_PACKET::format, Memory::free(), id_free(), id_get(), Last_client, Memory::malloc(), MONIT_FIRST, MONIT_ONLY, ONCE_ONLY, release_conn(), req_ent::req_id, reqp_ent::reqp, req_ent::reqpp, serv::request_head, cli_ent::requestp_head, req_ent::service_id, DIC_PACKET::service_id, DIC_PACKET::service_name, req_ent::service_ptr, SRC_DIS, req_ent::timeout, DIC_PACKET::timeout, req_ent::timr_ent, req_ent::to_delete, type, req_ent::type, DIC_PACKET::type, and UPDATE.

{
        register SERVICE *servp;
        register REQUEST *newp, *reqp;
        CLIENT *clip;
        REQUEST_PTR *reqpp;
        int type, new_client = 0, found = 0;
        int find_release_request();
        DIS_DNS_CONN *dnsp;

        if(size){}
        /* status = 1 => new connection, status = -1 => conn. lost */
        if(!Client_head) 
        {
                Client_head = (CLIENT *)malloc(sizeof(CLIENT));
                dll_init( (DLL *) Client_head );
        }
        if(status != 0)
        {
                if(status == -1) /* release all requests from conn_id */
                {
                        release_conn(conn_id, 0, 0);
                }
        } 
        else 
        {
                if(!(servp = find_service(dic_packet->service_name)))
                {
                        release_conn(conn_id, 0, 0);
                        return;
                }
                dic_packet->type = vtohl(dic_packet->type);
                type = dic_packet->type & 0xFFF;
                /*
                if(type == COMMAND) 
                {
                        Curr_conn_id = conn_id;
                        execute_command(servp, dic_packet);
                        Curr_conn_id = 0;
                        return;
                }
                */
                if(type == DIM_DELETE) 
                {
                        find_release_request(conn_id, vtohl(dic_packet->service_id));
                        return;
                }
                newp = (REQUEST *)/*my_*/malloc(sizeof(REQUEST));
                newp->service_ptr = servp;
                newp->service_id = vtohl(dic_packet->service_id);
                newp->type = dic_packet->type;
                newp->timeout = vtohl(dic_packet->timeout);
                newp->format = vtohl(dic_packet->format);
                newp->conn_id = conn_id;
                newp->first_time = 1;
                newp->delay_delete = 0;
                newp->to_delete = 0;
                newp->timr_ent = 0;
                newp->req_id = id_get((void *)newp, SRC_DIS);
                newp->reqpp = 0;
                if(type == ONCE_ONLY) 
                {
                        execute_service(newp->req_id);
                        id_free(newp->req_id, SRC_DIS);
                        free(newp);
                        return;
                }
                if(type == COMMAND) 
                {
                        Curr_conn_id = conn_id;
                        execute_command(servp, dic_packet);
                        Curr_conn_id = 0;
                        reqp = servp->request_head;
                        while( (reqp = (REQUEST *) dll_get_next((DLL *)servp->request_head,
                                (DLL *) reqp)) ) 
                        {
                                if(reqp->conn_id == conn_id)
                                {
                                        id_free(newp->req_id, SRC_DIS);
                                        free(newp);
                                        found = 1;
                                        break;
                                }
                        }
                        if(!found)
                                dll_insert_queue( (DLL *) servp->request_head, (DLL *) newp );
                        return;
                }
                dll_insert_queue( (DLL *) servp->request_head, (DLL *) newp );
                if(!(clip = find_client(conn_id)))
                {
                        clip = (CLIENT *)malloc(sizeof(CLIENT));
                        clip->conn_id = conn_id;
                        clip->dnsp = servp->dnsp;
                        clip->requestp_head = (REQUEST_PTR *)malloc(sizeof(REQUEST_PTR));
                        dll_init( (DLL *) clip->requestp_head );
                        dll_insert_queue( (DLL *) Client_head, (DLL *) clip );
                        new_client = 1;
                }
                reqpp = (REQUEST_PTR *)malloc(sizeof(REQUEST_PTR));
                reqpp->reqp = newp;
                dll_insert_queue( (DLL *) clip->requestp_head, (DLL *) reqpp );
                newp->reqpp = reqpp;
                if((type != MONIT_ONLY) && (type != UPDATE))
                {
                        execute_service(newp->req_id);
                }
                if((type != MONIT_ONLY) && (type != MONIT_FIRST))
                {
                        if(newp->timeout != 0)
                        {
                                newp->timr_ent = dtq_add_entry( Dis_timer_q,
                                                        newp->timeout, 
                                                        execute_service,
                                                        newp->req_id );
                        }
                }
                if(new_client)
                {
                        Last_client = conn_id;
                        dnsp = clip->dnsp;
                        if(dnsp->dis_client_id)
                          dis_update_service(dnsp->dis_client_id);
                }
        }
}

Here is the call graph for this function: