From f4e91ff23cfa2f8b313f18547e296e387daee795 Mon Sep 17 00:00:00 2001 From: eeb Date: Mon, 14 Oct 2002 18:04:52 +0000 Subject: [PATCH] Changed test for src_eq_h into an assertion (always valid) --- lustre/ptlrpc/service.c | 32 +++++++++++++++----------------- 1 file changed, 15 insertions(+), 17 deletions(-) diff --git a/lustre/ptlrpc/service.c b/lustre/ptlrpc/service.c index 99fdd76..52b6eee 100644 --- a/lustre/ptlrpc/service.c +++ b/lustre/ptlrpc/service.c @@ -31,33 +31,31 @@ extern int request_in_callback(ptl_event_t *ev); static int ptlrpc_check_event(struct ptlrpc_service *svc, struct ptlrpc_thread *thread, ptl_event_t *event) { - int rc = 0; + int rc; ENTRY; spin_lock(&svc->srv_lock); + if (thread->t_flags & SVC_STOPPING) GOTO(out, rc = 1); LASSERT ((thread->t_flags & SVC_EVENT) == 0); + LASSERT (ptl_is_valid_handle (&svc->srv_eq_h)); - if (ptl_is_valid_handle(&svc->srv_eq_h)) { - int err; - err = PtlEQGet(svc->srv_eq_h, event); - - if (err == PTL_OK) { - thread->t_flags |= SVC_EVENT; - GOTO(out, rc = 1); - } - - if (err != PTL_EQ_EMPTY) { - CERROR("BUG: PtlEQGet returned %d\n", err); - LBUG(); - } - + rc = PtlEQGet(svc->srv_eq_h, event); + switch (rc) + { + case PTL_OK: + thread->t_flags |= SVC_EVENT; + GOTO(out, rc = 1); + + case PTL_EQ_EMPTY: GOTO(out, rc = 0); + + default: + CERROR("BUG: PtlEQGet returned %d\n", rc); + LBUG(); } - - EXIT; out: spin_unlock(&svc->srv_lock); return rc; -- 1.8.3.1