void update_servers	(	int *	tag,
		DNS_DID *	buffer,
		int *	size
	)

Definition at line 304 of file webDid.c.

References item::busy, find_node(), find_server(), First_time, Memory::free(), item::isSMI, JSONHeader, Memory::malloc(), MAX_NAME, MAX_TASK_NAME, DNS_SERVICE_INFO::n_clients, N_nodes, N_servers, bitem::n_services, N_services, DNS_SERVER_INFO::n_services, item::name, DNS_SERVICE_INFO::name, item::next, DNS_SERVER_INFO::node, DNS_SERVER_INFO::pid, prepareJSONHeader(), prepareJSONTree(), item::server, DNS_DID::server, item::service_ptr, DNS_DID::services, sll_init(), sll_insert_queue(), DNS_SERVICE_INFO::status, str, DNS_SERVER_INFO::task, and DNS_SERVICE_INFO::type.

Referenced by did_init().

{
int n_services, service_size;
SERVER *servp;
NODE *nodep;
int j;
char str[MAX_NAME], sname[MAX_NAME], *ptr;
int prepareJSONTree();
int prepareJSONHeader();

        if(tag){}
        if(!Node_head)
        {
                Node_head = (NODE *)malloc(sizeof(NODE));
                sll_init((SLL *)Node_head);
        }
        if(First_time)
        {
                First_time = 0;
        }

        if(!*size)
                return;
        if(*(char *)buffer == -1)
        {
                N_servers = 0;
                N_services = 0;
                return;
        }
        buffer->server.n_services = vtohl(buffer->server.n_services);
        buffer->server.pid = vtohl(buffer->server.pid);
        n_services = buffer->server.n_services;

        if(n_services == 1)
          return;
        strcpy(sname, buffer->server.task);
        if(n_services > 1)
        {
                for(j = 0; j < n_services; j++)
                {
                        buffer->services[j].type = vtohl(
                                buffer->services[j].type);
                        buffer->services[j].status = vtohl(
                                buffer->services[j].status);
                        buffer->services[j].n_clients = vtohl(
                                buffer->services[j].n_clients);
                        if((int)strlen(sname) == MAX_TASK_NAME-4-1)
                        {
                                strcpy(str,buffer->services[j].name);
                                if( (ptr = strstr(str,"/CLIENT_LIST")) )
                                {
                                        *ptr = '\0';
                                        strcpy(sname,str);
                                }
                        }
                }
        }
        if (!(nodep = find_node(buffer->server.node)))
        {
                if(n_services)
                {
                        N_nodes++;
                        nodep = (NODE *)malloc(sizeof(NODE));
                        strcpy(nodep->name,buffer->server.node);
                        nodep->hasSMI = 0;
                        nodep->server_head = (SERVER *)malloc(sizeof(SERVER));
                        sll_init((SLL *)nodep->server_head);
                        sll_insert_queue((SLL *)Node_head,(SLL *)nodep);
                }
        }
        if (!(servp = find_server(nodep,buffer->server.pid)))
        {
                if(n_services)
                {
                        servp = (SERVER *)malloc(sizeof(SERVER));
                        strcpy(servp->name,sname);
                        servp->next = 0;
                        servp->busy = 0;
                        servp->server.n_services = 0;
                        servp->service_ptr = 0;
                        servp->isSMI = 0;
                        if(strstr(sname,"_SMI"))
                        {
                                servp->isSMI = 1;
                                nodep->hasSMI = 1;
                        }
                        sll_insert_queue((SLL *)nodep->server_head,(SLL *)servp);
                }
        }
        if(n_services != 0)
        {
                if(n_services == servp->server.n_services)
                {
                        return;
                }
                if(servp->server.n_services == 0)
                        N_servers++;
                if(servp->server.n_services != -1)
                        N_services -= servp->server.n_services;
                memcpy(&servp->server,&buffer->server,sizeof(DNS_SERVER_INFO));
                if(servp->service_ptr)
                {
                        free(servp->service_ptr);
                        servp->service_ptr = 0;
                }
                if(n_services != -1)
                {
                        service_size = n_services*(int)sizeof(DNS_SERVICE_INFO);
                        servp->service_ptr = (DNS_SERVICE_INFO *)malloc((size_t)service_size);
                        memcpy(servp->service_ptr, buffer->services, (size_t)service_size);
                        N_services += n_services;
                }
                servp->busy = 1;
        }
        else
        {
          if(servp)
            {
                N_servers--;
                if(servp->server.n_services != -1)
                  {
                        N_services -= servp->server.n_services;
                  }
                servp->server.n_services = 0;
                servp->busy = -1;
                servp->isSMI = 0;
            }
        }
        if(JSONHeader[0])
          prepareJSONHeader();
}

Here is the call graph for this function:

Here is the caller graph for this function: