From 731d78ee31654a4188ad0b9632f43c2032cb7675 Mon Sep 17 00:00:00 2001 From: eeb Date: Wed, 11 Jun 2003 13:51:17 +0000 Subject: [PATCH] * Single event queue per network interface. * Pre-allocated server requests, individually posted for receives Servers now configured by XXX_NREQ (# requests) and XXX_MAXREQSIZE (size of each replies buffer). * Asynchronous server-side reply completion/notification. struct ptlrpc_reply_state objects splits off state reply so request can be reposted immediately. * exp_outstanding_reply now a list of replies * bulk descriptors sized so bd_iov can contain all the fragments. ptlrpc_prep_bulk_page() is now returns void (i.e. no errors; may fail an LASSERT if the bulk desc was sized incorrectly). * NOT tested saved locks yet; bringing up to date with b_devel first... --- lnet/klnds/socklnd/socklnd_cb.c | 2 +- lnet/klnds/toelnd/toenal_cb.c | 4 ++-- lustre/portals/knals/socknal/socknal_cb.c | 2 +- lustre/portals/knals/toenal/toenal_cb.c | 4 ++-- 4 files changed, 6 insertions(+), 6 deletions(-) diff --git a/lnet/klnds/socklnd/socklnd_cb.c b/lnet/klnds/socklnd/socklnd_cb.c index 388554d..6cf3cc4 100644 --- a/lnet/klnds/socklnd/socklnd_cb.c +++ b/lnet/klnds/socklnd/socklnd_cb.c @@ -1296,10 +1296,10 @@ ksocknal_process_receive (ksock_sched_t *sched, long *irq_flags) goto out; /* (later) */ default: + LBUG (); } /* Not Reached */ - LBUG (); out: spin_lock_irqsave (&sched->kss_lock, *irq_flags); diff --git a/lnet/klnds/toelnd/toenal_cb.c b/lnet/klnds/toelnd/toenal_cb.c index 8270196..7dfb0fa 100644 --- a/lnet/klnds/toelnd/toenal_cb.c +++ b/lnet/klnds/toelnd/toenal_cb.c @@ -894,9 +894,9 @@ ktoenal_process_receive (ksock_conn_t *conn, long *irq_flags) spin_lock_irqsave (&ktoenal_data.ksnd_sched_lock, *irq_flags); goto get_fmb; /* => go get a fwd msg buffer */ default: + LBUG (); } /* Not Reached */ - LBUG (); } PROF_START(lib_parse); @@ -935,10 +935,10 @@ ktoenal_process_receive (ksock_conn_t *conn, long *irq_flags) goto out; /* (later) */ default: + LBUG (); } /* Not Reached */ - LBUG (); out: spin_lock_irqsave (&ktoenal_data.ksnd_sched_lock, *irq_flags); diff --git a/lustre/portals/knals/socknal/socknal_cb.c b/lustre/portals/knals/socknal/socknal_cb.c index 388554d..6cf3cc4 100644 --- a/lustre/portals/knals/socknal/socknal_cb.c +++ b/lustre/portals/knals/socknal/socknal_cb.c @@ -1296,10 +1296,10 @@ ksocknal_process_receive (ksock_sched_t *sched, long *irq_flags) goto out; /* (later) */ default: + LBUG (); } /* Not Reached */ - LBUG (); out: spin_lock_irqsave (&sched->kss_lock, *irq_flags); diff --git a/lustre/portals/knals/toenal/toenal_cb.c b/lustre/portals/knals/toenal/toenal_cb.c index 8270196..7dfb0fa 100644 --- a/lustre/portals/knals/toenal/toenal_cb.c +++ b/lustre/portals/knals/toenal/toenal_cb.c @@ -894,9 +894,9 @@ ktoenal_process_receive (ksock_conn_t *conn, long *irq_flags) spin_lock_irqsave (&ktoenal_data.ksnd_sched_lock, *irq_flags); goto get_fmb; /* => go get a fwd msg buffer */ default: + LBUG (); } /* Not Reached */ - LBUG (); } PROF_START(lib_parse); @@ -935,10 +935,10 @@ ktoenal_process_receive (ksock_conn_t *conn, long *irq_flags) goto out; /* (later) */ default: + LBUG (); } /* Not Reached */ - LBUG (); out: spin_lock_irqsave (&ktoenal_data.ksnd_sched_lock, *irq_flags); -- 1.8.3.1