Whamcloud - gitweb
git://git.whamcloud.com
/
fs
/
lustre-release.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
LU-1617 build: skip generated files in .gitignore
[fs/lustre-release.git]
/
lnet
/
lnet
/
lib-eq.c
diff --git
a/lnet/lnet/lib-eq.c
b/lnet/lnet/lib-eq.c
index
2fcc98a
..
fec269a
100644
(file)
--- a/
lnet/lnet/lib-eq.c
+++ b/
lnet/lnet/lib-eq.c
@@
-138,6
+138,7
@@
failed:
lnet_eq_free(eq);
return -ENOMEM;
}
lnet_eq_free(eq);
return -ENOMEM;
}
+EXPORT_SYMBOL(LNetEQAlloc);
/**
* Release the resources associated with an event queue if it's idle;
/**
* Release the resources associated with an event queue if it's idle;
@@
-204,6
+205,7
@@
LNetEQFree(lnet_handle_eq_t eqh)
return rc;
}
return rc;
}
+EXPORT_SYMBOL(LNetEQFree);
void
lnet_eq_enqueue_event(lnet_eq_t *eq, lnet_event_t *ev)
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);
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);
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);
}
return LNetEQPoll(&eventq, 1, 0,
event, &which);
}
+EXPORT_SYMBOL(LNetEQGet);
/**
* Block the calling process until there is an event in the EQ.
/**
* 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);
}
return LNetEQPoll(&eventq, 1, LNET_TIME_FOREVER,
event, &which);
}
+EXPORT_SYMBOL(LNetEQWait);
#ifdef __KERNEL__
static int
lnet_eq_wait_locked(int *timeout_ms)
{
#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 */
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)
{
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
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
* \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;
{
int wait = 1;
int rc;
@@
-517,7
+521,7
@@
LNetEQPoll (lnet_handle_eq_t *eventqs, int neq, int timeout_ms,
lnet_eq_wait_lock();
lnet_eq_wait_lock();
-
for (;;) {
+ for (;;) {
#ifndef __KERNEL__
lnet_eq_wait_unlock();
#ifndef __KERNEL__
lnet_eq_wait_unlock();