static void recv_rout ( int  conn_id, DIS_PACKET *  packet, int  size, int  status  )

static

Definition at line 143 of file dic.c.

References COMMAND, dic_serv::conn_id, Curr_conn_id, Debug_on, Dic_conns, dic_release_service(), Dic_timer_q, dim_panic(), dim_print_date_time(), dll_empty(), dll_get_next(), dna_get_node_task(), Dns_dic_conn_id, do_cmnd_callback(), dtq_clear_entry(), dtq_rem_entry(), execute_service(), id_get_ptr(), locate_command(), MAX_NODE_NAME, MAX_TASK_NAME, move_to_notok_service(), NOT_PENDING, ONCE_ONLY, dic_serv::pending, dic_serv::prev, release_conn(), request_dns_info(), dic_serv::serv_id, dic_serv::serv_name, DIC_CONNECTION::service_head, service_id, DIS_PACKET::service_id, service_tmout(), SRC_DIC, STA_CONN, STA_DATA, STA_DISC, DIC_CONNECTION::task_name, dic_serv::timeout, dic_serv::timer_ent, dic_serv::tmout_done, dic_serv::type, WAITING_CMND_ANSWER, WAITING_DNS_UP, and WAITING_SERVER_UP.

Referenced by dic_find_server_conns(), handle_dns_info(), and open_dns().

{
        register DIC_SERVICE *servp, *auxp;
        register DIC_CONNECTION *dic_connp;
        int service_id, once_only, found = 0;
        char node[MAX_NODE_NAME], task[MAX_TASK_NAME];
        void move_to_notok_service();
        void do_cmnd_callback();
        void dim_panic(char *);

        dic_connp = &Dic_conns[conn_id] ;
        switch( status )
        {
        case STA_DISC:
                if(Debug_on)
                {
                        dna_get_node_task(conn_id, node, task);
                        dim_print_date_time();
                        printf("Conn %d: Server %s on node %s Disconnected\n",
                                conn_id, task, node);
                        fflush(stdout);
                }
                if( !(servp = (DIC_SERVICE *) dic_connp->service_head) )
                {
                        release_conn( conn_id );
                        break;
                }
                while( (servp = (DIC_SERVICE *) dll_get_next(
                                        (DLL *) dic_connp->service_head,
                                        (DLL *) servp)) )
                {
#ifdef DEBUG
                        printf("\t %s was in the service list\n",servp->serv_name);
                        fflush(stdout);
#endif
/*
        Will be done later by the DNS answer
                        service_tmout( servp->serv_id );
*/
                        if(!strcmp(dic_connp->task_name,"DIS_DNS"))
                        {
                                service_tmout( servp->serv_id );
                        }
                        else if(Dns_dic_conn_id <= 0)
                        {
                                service_tmout( servp->serv_id );
                        }
/*
                        servp->pending = WAITING_DNS_UP;
                        servp->conn_id = 0;
*/
                        auxp = servp->prev;
                        move_to_notok_service( servp );
                        servp = auxp;
                }               
                if( (servp = (DIC_SERVICE *) Cmnd_head) ) 
                {
                        while( (servp = (DIC_SERVICE *) dll_get_next(
                                                        (DLL *) Cmnd_head,
                                                        (DLL *) servp)) )
                        {
                                if( servp->conn_id == conn_id )
                                {
#ifdef DEBUG
                                        printf("\t%s was in the Command list\n", servp->serv_name);
                                        printf("servp = %x, type = %d, pending = %d\n",servp, servp->type, servp->pending);
                                        fflush(stdout);
#endif
                                        auxp = servp->prev;
                                        if( (servp->type == ONCE_ONLY ) &&
                                                (servp->pending == WAITING_SERVER_UP))
                                        {
                                                service_tmout( servp->serv_id );
                                        }
                                        else if( (servp->type == COMMAND ) &&
                                                (servp->pending == WAITING_CMND_ANSWER))
                                        {
                                                service_tmout( servp->serv_id );
                                        }
                                        else 
                                        {
                                                servp->pending = WAITING_DNS_UP;
                                                dic_release_service( (unsigned)servp->serv_id );
                                        }
                                        servp = auxp;
                                }
                        }
                }
                release_conn( conn_id );
                request_dns_info(0);
                break;
        case STA_DATA:
                if( !(DIC_SERVICE *) dic_connp->service_head )
                        break;
                service_id = vtohl(packet->service_id);
                if((unsigned)service_id & 0x80000000)  /* Service removed by server */
                {
                        service_id &= 0x7fffffff;
                        if( (servp = (DIC_SERVICE *) id_get_ptr(service_id, SRC_DIC))) 
                        {
                                if( servp->type != COMMAND )
                                {
                                        service_tmout( servp->serv_id );
/*
                                        servp->pending = WAITING_DNS_UP;
                                        servp->conn_id = 0;
*/
                                        move_to_notok_service( servp );
                                }
                                else
                                {
                                        service_tmout( servp->serv_id );
                                        break;
                                }
                        }
                        else
                        {
/*
                                print_packet(packet);
*/
                                if( (servp = (DIC_SERVICE *) Cmnd_head) ) 
                                {
                                        while( (servp = (DIC_SERVICE *) dll_get_next(
                                                        (DLL *) Cmnd_head,
                                                        (DLL *) servp)) )
                                        {
                                                if( servp->conn_id == conn_id )
                                                {
#ifdef DEBUG
                                                        printf("\t%s was in the Command list\n", servp->serv_name);
                                                        fflush(stdout);
#endif
                                                        auxp = servp->prev;
                                                        if( (servp->type == ONCE_ONLY ) &&
                                                                (servp->pending == WAITING_SERVER_UP))
                                                        {
                                                                service_tmout( servp->serv_id );
                                                        }
                                                        else if( (servp->type == COMMAND ) &&
                                                                (servp->pending == WAITING_CMND_ANSWER))
                                                        {
                                                                service_tmout( servp->serv_id );
                                                        }
                                                        else 
                                                        {
                                                                servp->pending = WAITING_DNS_UP;
                                                                dic_release_service( (unsigned)servp->serv_id );
                                                        }
                                                        servp = auxp;
                                                }
                                        }
                                }
                        }                       
                        if( dll_empty((DLL *)dic_connp->service_head) ) {
                                if( (servp = (DIC_SERVICE *) Cmnd_head) ) {
                                        while( (servp = (DIC_SERVICE *) dll_get_next(
                                                        (DLL *) Cmnd_head,
                                                        (DLL *) servp)) )
                                        {
                                                if( servp->conn_id == conn_id)
                                                        found = 1;
                                        }
                                }
                                if( !found)
                                {
                                        release_conn( conn_id );
                                }
                        }
                        request_dns_info(0);
                        break;
                }
                if( (servp = (DIC_SERVICE *) id_get_ptr(service_id, SRC_DIC)))
                {
                        if(servp->serv_id == service_id)
                        {
                                once_only = 0;
                                if(servp->type == ONCE_ONLY)
                                        once_only = 1;
                                else 
                                {
                                        if( servp->timeout > 0 ) 
                                        {
                                                if(servp->timer_ent)
                                                        dtq_clear_entry( servp->timer_ent );
                                        }
                                }
                                Curr_conn_id = conn_id;
                                execute_service(packet, servp, size);
                                Curr_conn_id = 0;
                                if( once_only )
                                {
                                        auxp = locate_command(servp->serv_name);
                                        if((auxp) && (auxp != servp))
                                        {
                                                servp->pending = WAITING_DNS_UP;
                                                dic_release_service( (unsigned)servp->serv_id );
                                        }
                                        else
                                        {
                                                servp->pending = NOT_PENDING;
                                                servp->tmout_done = 0;
                                                if( servp->timer_ent )
                                                {
                                                        dtq_rem_entry( Dic_timer_q, servp->timer_ent );
                                                        servp->timer_ent = 0;
                                                }
                                        }
                                }
                        }
                }
/*
                else
                {
                        print_packet(packet);
                        if(Error_user_routine)
                                (Error_user_routine)( packet->buffer );
                }
*/
                break;
        case STA_CONN:
                if(Debug_on)
                {
                        dna_get_node_task(conn_id, node, task);
                        dim_print_date_time();
                        printf("Conn %d: Server %s on node %s Connected\n",
                                conn_id, task, node);
                        fflush(stdout);
                }
                break;
        default:        dim_panic( "recv_rout(): Bad switch" );
        }
}

Here is the call graph for this function:

Here is the caller graph for this function: