void set_rpc_info	(	int *	tag,
		char *	buffer,
		int *	size
	)

Definition at line 1824 of file dns.c.

References node::conn_id, Debug, dim_print_date_time(), dis_get_conn_id(), dis_selective_update_service, find_services(), Memory::free(), i, Memory::malloc(), MAX_NAME, Net_conns, Rpc_id, Rpc_info, Rpc_info_size, serv::serv_def, serv::serv_id, serv::serv_name, service_exists(), and node::servp.

Referenced by main().

{
        char aux[MAX_NAME], rpcaux[MAX_NAME+32], *ptr, *rpcptr;
    int i, n, rpc, id[2], conn_id;
        DNS_SERVICE *servp, *aux_servp;

        if(size){}
        if(tag){}
        if(Debug)
        {
                dim_print_date_time();
                conn_id = dis_get_conn_id();
                printf(" Got Browse Request <%s> from conn: %d %s@%s\n", buffer, conn_id,
                        Net_conns[conn_id].task,Net_conns[conn_id].node);
        }
        n = find_services(buffer);
        if(Debug)
        {
                dim_print_date_time();
                conn_id = dis_get_conn_id();
                printf(" Browse Request <%s> found %d services\n", buffer, n);
        }
        if(!Rpc_info_size)
        {
                Rpc_info = malloc((size_t)(MAX_NAME*(n+1)*2));
                Rpc_info_size = MAX_NAME*(n+1)*2;
        }
        else if(Rpc_info_size < MAX_NAME*n*2)
        {
                free(Rpc_info);
                Rpc_info = malloc((size_t)(MAX_NAME*(n+1)*2));
                Rpc_info_size = MAX_NAME*(n+1)*2;
        }
        Rpc_info[0] = '\0';
        rpcptr = Rpc_info;
        for(i = 0; i < n; i++)
        {               
                rpc = 0;
                servp = Service_info_list[i];
                if(strstr(servp->serv_name,"/Rpc"))
                {
                        strcpy(aux,servp->serv_name);
                        if( (ptr = strstr(aux,"/RpcIn")) )
                        {
                                *ptr = '\0';
                                rpc = 1;
                                if( (ptr = strstr(Rpc_info, aux)) )
                                {
                                        ptr += (int)strlen(aux);
                                        if(*ptr == '|')
                                                rpc = 2;
                                }
                        }
                        if( (ptr = strstr(aux,"/RpcOut")) )
                        {
                                *ptr = '\0';
                                rpc = 1;
                                if( (ptr = strstr(Rpc_info, aux)) )
                                {
                                        ptr += (int)strlen(aux);
                                        if(*ptr == '|')
                                                rpc = 2;
                                }
                        }
                        if(rpc == 1)
                        {
                                strcpy(rpcaux, aux);
                                strcat(rpcaux,"|");
                                strcat(aux,"/RpcIn");
                                if( (aux_servp = service_exists(aux)) )
                                {
                                        strcat(rpcaux, aux_servp->serv_def);
                                        strcat(rpcaux,",");
                                        ptr = strstr(aux,"/RpcIn");
                                        *ptr = '\0';
                                        strcat(aux,"/RpcOut");
                                        if( (aux_servp = service_exists(aux)) )
                                        {
                                                strcat(rpcaux,aux_servp->serv_def);
                                                strcat(rpcaux,"|RPC\n");
                                                strcpy(rpcptr, rpcaux);
                                                rpcptr += (int)strlen(rpcaux);
                                        }
                                }
                        }
                }
                else
                {
                        strcpy(rpcaux, servp->serv_name);
                        strcat(rpcaux,"|");
                        strcat(rpcaux,servp->serv_def);
                        if(servp->serv_id & 0x10000000)
                                strcat(rpcaux,"|CMD\n");
                        else
                                strcat(rpcaux,"|\n");
                        strcpy(rpcptr, rpcaux);
                        rpcptr += (int)strlen(rpcaux);
                }
        }
        *rpcptr = '\0';
        id[0] = dis_get_conn_id();
        id[1] = 0;
        dis_selective_update_service(Rpc_id, id); 
        free(Service_info_list);
}

Here is the call graph for this function:

Here is the caller graph for this function: