X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lnet%2Flnet%2Flib-eq.c;h=fec269a9a664033568e14345868a5049d9626093;hb=294c39d488fcd95a523466c7726ff1b5a8327890;hp=2fcc98a0882bb3fb275aef4426815b1ef3cfbe60;hpb=a07e9d350b3e500c7be877f6dcf54380b86a9cbe;p=fs%2Flustre-release.git diff --git a/lnet/lnet/lib-eq.c b/lnet/lnet/lib-eq.c index 2fcc98a..fec269a 100644 --- a/lnet/lnet/lib-eq.c +++ b/lnet/lnet/lib-eq.c @@ -138,6 +138,7 @@ failed: lnet_eq_free(eq); return -ENOMEM; } +EXPORT_SYMBOL(LNetEQAlloc); /** * Release the resources associated with an event queue if it's idle; @@ -204,6 +205,7 @@ LNetEQFree(lnet_handle_eq_t eqh) return rc; } +EXPORT_SYMBOL(LNetEQFree); void lnet_eq_enqueue_event(lnet_eq_t *eq, lnet_event_t *ev) @@ -255,8 +257,8 @@ lnet_eq_dequeue_event(lnet_eq_t *eq, lnet_event_t *ev) if (LNET_SEQ_GT(eq->eq_deq_seq, new_event->sequence)) RETURN(0); - /* We've got a new event... */ - *ev = *new_event; + /* We've got a new event... */ + *ev = *new_event; CDEBUG(D_INFO, "event: %p, sequence: %lu, eq->size: %u\n", new_event, eq->eq_deq_seq, eq->eq_size); @@ -300,6 +302,7 @@ LNetEQGet (lnet_handle_eq_t eventq, lnet_event_t *event) return LNetEQPoll(&eventq, 1, 0, event, &which); } +EXPORT_SYMBOL(LNetEQGet); /** * Block the calling process until there is an event in the EQ. @@ -325,16 +328,17 @@ LNetEQWait (lnet_handle_eq_t eventq, lnet_event_t *event) return LNetEQPoll(&eventq, 1, LNET_TIME_FOREVER, event, &which); } +EXPORT_SYMBOL(LNetEQWait); #ifdef __KERNEL__ static int lnet_eq_wait_locked(int *timeout_ms) { - int tms = *timeout_ms; - int wait; - cfs_waitlink_t wl; - cfs_time_t now; + int tms = *timeout_ms; + int wait; + cfs_waitlink_t wl; + cfs_time_t now; if (tms == 0) return -1; /* don't want to wait and no new event */ @@ -388,11 +392,11 @@ lnet_eq_cond_wait(struct timespec *ts) static int lnet_eq_wait_locked(int *timeout_ms) { - lnet_ni_t *eq_waitni = NULL; - int tms = *timeout_ms; - int wait; - struct timeval then; - struct timeval now; + lnet_ni_t *eq_waitni = NULL; + int tms = *timeout_ms; + int wait; + struct timeval then; + struct timeval now; if (the_lnet.ln_eq_waitni != NULL) { /* I have a single NI that I have to call into, to get @@ -501,8 +505,8 @@ lnet_eq_wait_locked(int *timeout_ms) * \retval -ENOENT If there's an invalid handle in \a eventqs. */ int -LNetEQPoll (lnet_handle_eq_t *eventqs, int neq, int timeout_ms, - lnet_event_t *event, int *which) +LNetEQPoll(lnet_handle_eq_t *eventqs, int neq, int timeout_ms, + lnet_event_t *event, int *which) { int wait = 1; int rc; @@ -517,7 +521,7 @@ LNetEQPoll (lnet_handle_eq_t *eventqs, int neq, int timeout_ms, lnet_eq_wait_lock(); - for (;;) { + for (;;) { #ifndef __KERNEL__ lnet_eq_wait_unlock();