int do_update_service	(	unsigned	service_id,
		int *	client_ids
	)

Definition at line 1714 of file dis.c.

References check_client(), COMMAND, req_ent::conn_id, req_ent::delay_delete, serv::delay_delete, DIM_ERROR, DIMSVCINVAL, dis_remove_service(), dll_empty(), dll_get_next(), error_handler(), execute_service(), find_client(), serv::id, id_get_ptr(), Last_n_clients, release_conn(), release_request(), req_ent::req_id, req_ent::reqpp, serv::request_head, cli_ent::requestp_head, service_id, Serving, sprintf(), SRC_DIS, str, TIMED_ONLY, req_ent::to_delete, serv::to_delete, and req_ent::type.

Referenced by dis_selective_update_service(), dis_update_service(), and Java_dim_Server_selectiveUpdateService().

{
        register REQUEST *reqp;
        register SERVICE *servp;
        REQUEST_PTR *reqpp;
        CLIENT *clip;
        register int found = 0;
        int to_delete = 0, more, conn_id;
        char str[128];
        int release_request();
        int n_clients = 0;

        DISABLE_AST
        if(Serving == -1)
        {
                ENABLE_AST
                return(found);
        }
        if(!service_id)
        {
                sprintf(str, "Update Service - Invalid service id");
                error_handler(0, DIM_ERROR, DIMSVCINVAL, str, -1);
                ENABLE_AST
                return(found);
        }
        servp = (SERVICE *)id_get_ptr(service_id, SRC_DIS);
        if(!servp)
        {
                ENABLE_AST
                return(found);
        }
        if(servp->id != (int)service_id)
        {
                ENABLE_AST
                return(found);
        }
        servp->delay_delete = 1;
        reqp = servp->request_head;
        while( (reqp = (REQUEST *) dll_get_next((DLL *)servp->request_head,
                (DLL *) reqp)) ) 
        {
/*
if(Debug_on)
{
dim_print_date_time();
printf("Updating %s (id = %d, ptr = %08lX) for %s@%s (req_id = %d, req_ptr = %08lX)\n",
           servp->name, (int)service_id, (unsigned dim_long)servp, 
           Net_conns[reqp->conn_id].task, Net_conns[reqp->conn_id].node, reqp->req_id, (unsigned dim_long)reqp);
}
*/
                if(check_client(reqp, client_ids))
                {
                        reqp->delay_delete = 1;
                        n_clients++;
                }
        }
        ENABLE_AST
        {
        DISABLE_AST
        Last_n_clients = n_clients;
        reqp = servp->request_head;
        while( (reqp = (REQUEST *) dll_get_next((DLL *)servp->request_head,
                (DLL *) reqp)) ) 
        {
                if(reqp->delay_delete && ((reqp->type & 0xFFF) != COMMAND))
                {
                if(check_client(reqp, client_ids))
                {
                        if( (reqp->type & 0xFFF) != TIMED_ONLY ) 
                        {
/*
                                DISABLE_AST
*/
                                execute_service(reqp->req_id);
                                found++;
                                ENABLE_AST
                                {
                                DISABLE_AST
                                }
                        }
                }
                }
        }
        ENABLE_AST
        }
        {
        DISABLE_AST
        reqp = servp->request_head;
        while( (reqp = (REQUEST *) dll_get_next((DLL *)servp->request_head,
                (DLL *) reqp)) ) 
        {
                if(check_client(reqp, client_ids))
                {
                        reqp->delay_delete = 0;
                        if(reqp->to_delete)
                                to_delete = 1;
                }
        }
        ENABLE_AST
        }
        if(to_delete)
        {
                DISABLE_AST
                do
                {
                        more = 0;
                        reqp = servp->request_head;
                        while( (reqp = (REQUEST *) dll_get_next((DLL *)servp->request_head,
                                (DLL *) reqp)) ) 
                        {
                                if(reqp->to_delete & 0x1)
                                {
                                        more = 1;
                                        reqp->to_delete = 0;
                                        release_conn(reqp->conn_id, 1, 0);
                                        break;
                                }
                                else if(reqp->to_delete & 0x2)
                                {
                                        more = 1;
                                        reqp->to_delete = 0;
                                        reqpp = reqp->reqpp;
                                        conn_id = reqp->conn_id;
                                        release_request(reqp, reqpp, 1);
                                        clip = find_client(conn_id);
                                        if(clip)
                                        {
                                                if( dll_empty((DLL *)clip->requestp_head) ) 
                                                {
                                                        release_conn( conn_id, 0, 0);
                                                }
                                        }
                                        break;
                                }
                        }
                }while(more);
                ENABLE_AST
        }
        {
        DISABLE_AST
        servp->delay_delete = 0;
        if(servp->to_delete)
        {
                dis_remove_service(servp->id);
        }
        ENABLE_AST
        }

        return(found);
}

Here is the call graph for this function:

Here is the caller graph for this function: