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-3963 lnet: convert cfs_atomic primitives
[fs/lustre-release.git]
/
lnet
/
klnds
/
qswlnd
/
qswlnd.c
diff --git
a/lnet/klnds/qswlnd/qswlnd.c
b/lnet/klnds/qswlnd/qswlnd.c
index
e62b094
..
fa8e8f4
100644
(file)
--- a/
lnet/klnds/qswlnd/qswlnd.c
+++ b/
lnet/klnds/qswlnd/qswlnd.c
@@
-144,9
+144,9
@@
kqswnal_shutdown(lnet_ni_t *ni)
/**********************************************************************/
/* wait for sends that have allocated a tx desc to launch or give up */
/**********************************************************************/
/* wait for sends that have allocated a tx desc to launch or give up */
- while (
cfs_
atomic_read (&kqswnal_data.kqn_pending_txs) != 0) {
+ while (atomic_read (&kqswnal_data.kqn_pending_txs) != 0) {
CDEBUG(D_NET, "waiting for %d pending sends\n",
CDEBUG(D_NET, "waiting for %d pending sends\n",
-
cfs_
atomic_read (&kqswnal_data.kqn_pending_txs));
+ atomic_read (&kqswnal_data.kqn_pending_txs));
cfs_pause(cfs_time_seconds(1));
}
cfs_pause(cfs_time_seconds(1));
}
@@
-176,9
+176,9
@@
kqswnal_shutdown(lnet_ni_t *ni)
kqswnal_data.kqn_shuttingdown = 2;
wake_up_all (&kqswnal_data.kqn_sched_waitq);
kqswnal_data.kqn_shuttingdown = 2;
wake_up_all (&kqswnal_data.kqn_sched_waitq);
- while (
cfs_
atomic_read (&kqswnal_data.kqn_nthreads) != 0) {
+ while (atomic_read (&kqswnal_data.kqn_nthreads) != 0) {
CDEBUG(D_NET, "waiting for %d threads to terminate\n",
CDEBUG(D_NET, "waiting for %d threads to terminate\n",
-
cfs_
atomic_read (&kqswnal_data.kqn_nthreads));
+ atomic_read (&kqswnal_data.kqn_nthreads));
cfs_pause(cfs_time_seconds(1));
}
cfs_pause(cfs_time_seconds(1));
}
@@
-252,7
+252,7
@@
kqswnal_shutdown(lnet_ni_t *ni)
/* resets flags, pointers to NULL etc */
memset(&kqswnal_data, 0, sizeof (kqswnal_data));
/* resets flags, pointers to NULL etc */
memset(&kqswnal_data, 0, sizeof (kqswnal_data));
- CDEBUG (D_MALLOC, "done kmem %d\n",
cfs_
atomic_read(&libcfs_kmemory));
+ CDEBUG (D_MALLOC, "done kmem %d\n", atomic_read(&libcfs_kmemory));
module_put(THIS_MODULE);
}
module_put(THIS_MODULE);
}
@@
-288,7
+288,7
@@
kqswnal_startup (lnet_ni_t *ni)
*kqswnal_tunables.kqn_credits);
}
*kqswnal_tunables.kqn_credits);
}
- CDEBUG (D_MALLOC, "start kmem %d\n",
cfs_
atomic_read(&libcfs_kmemory));
+ CDEBUG (D_MALLOC, "start kmem %d\n", atomic_read(&libcfs_kmemory));
/* ensure all pointers NULL etc */
memset (&kqswnal_data, 0, sizeof (kqswnal_data));
/* ensure all pointers NULL etc */
memset (&kqswnal_data, 0, sizeof (kqswnal_data));