struct ptlrpc_srv_ni *sni = rqbd->rqbd_srv_ni;
struct ptlrpc_service *svc = sni->sni_service;
unsigned long flags;
-
+
LASSERT (rqbd->rqbd_refcount == 0);
LASSERT (list_empty(&rqbd->rqbd_reqs));
spin_lock_irqsave(&svc->srv_lock, flags);
- /* schedule request buffer for re-use.
+ /* schedule request buffer for re-use.
* NB I can only do this after I've disposed of their
* reqs; particularly the embedded req */
list_add_tail(&rqbd->rqbd_list, &svc->srv_idle_rqbds);
}
static int
-ptlrpc_server_handle_reply (struct ptlrpc_service *svc)
+ptlrpc_server_handle_reply (struct ptlrpc_service *svc)
{
struct ptlrpc_reply_state *rs;
unsigned long flags;
* in mds_steal_ack_locks() */
CWARN("All locks stolen from rs %p x"LPD64".t"LPD64
" o%d NID %s\n",
- rs,
+ rs,
rs->rs_xid, rs->rs_transno,
- rs->rs_msg.opc,
+ rs->rs_msg.opc,
ptlrpc_peernid2str(&exp->exp_connection->c_peer, str));
}
- if ((!been_handled && rs->rs_on_net) ||
+ if ((!been_handled && rs->rs_on_net) ||
nlocks > 0) {
spin_unlock_irqrestore(&svc->srv_lock, flags);
}
while (nlocks-- > 0)
- ldlm_lock_decref(&rs->rs_locks[nlocks],
+ ldlm_lock_decref(&rs->rs_locks[nlocks],
rs->rs_modes[nlocks]);
spin_lock_irqsave(&svc->srv_lock, flags);
/* Off the net */
svc->srv_n_difficult_replies--;
spin_unlock_irqrestore(&svc->srv_lock, flags);
-
+
class_export_put (exp);
rs->rs_export = NULL;
ptlrpc_rs_decref (rs);
atomic_dec (&svc->srv_outstanding_replies);
RETURN(1);
}
-
+
/* still on the net; callback will schedule */
spin_unlock_irqrestore (&svc->srv_lock, flags);
RETURN(1);
#ifndef __KERNEL__
/* FIXME make use of timeout later */
int
-liblustre_check_services (void *arg)
+liblustre_check_services (void *arg)
{
int did_something = 0;
int rc;
}
}
- /*
- * deconstruct service specific state created by ptlrpc_start_thread()
- */
lc_watchdog_delete(watchdog);
out_srv_init:
+ /*
+ * deconstruct service specific state created by ptlrpc_start_thread()
+ */
if (svc->srv_done != NULL)
svc->srv_done(thread);
list_entry(service->srv_request_queue.next,
struct ptlrpc_request,
rq_list);
-
+
list_del(&req->rq_list);
service->srv_n_queued_reqs--;
service->srv_n_active_reqs++;