Whamcloud - gitweb
LU-13005 lnet: remove 'eq' from names, use 'handler'
[fs/lustre-release.git] / lnet / selftest / selftest.h
index ea1ee06..c14f9e1 100644 (file)
@@ -151,11 +151,11 @@ struct srpc_event {
 
 /* bulk descriptor */
 struct srpc_bulk {
-        int              bk_len;  /* len of bulk data */
-       struct lnet_handle_md bk_mdh;
-        int              bk_sink; /* sink/source */
-        int              bk_niov; /* # iov in bk_iovs */
-        lnet_kiov_t      bk_iovs[0];
+       int                     bk_len;  /* len of bulk data */
+       struct lnet_handle_md   bk_mdh;
+       int                     bk_sink; /* sink/source */
+       int                     bk_niov; /* # iov in bk_iovs */
+       struct bio_vec          bk_iovs[0];
 };
 
 /* message buffer descriptor */
@@ -511,8 +511,6 @@ srpc_destroy_client_rpc(struct srpc_client_rpc *rpc)
        } else {
                (*rpc->crpc_fini) (rpc);
        }
-
-       return;
 }
 
 static inline void
@@ -551,7 +549,6 @@ srpc_init_client_rpc(struct srpc_client_rpc *rpc, struct lnet_process_id peer,
         rpc->crpc_reqstmsg.msg_magic   = SRPC_MSG_MAGIC;
         rpc->crpc_reqstmsg.msg_version = SRPC_MSG_VERSION;
         rpc->crpc_reqstmsg.msg_type    = srpc_service2request(service);
-        return;
 }
 
 static inline const char *
@@ -581,8 +578,8 @@ do {                                                                        \
                       fmt, ## __VA_ARGS__);                            \
                spin_unlock(&(lock));                                   \
                                                                        \
-               set_current_state(TASK_UNINTERRUPTIBLE);                \
-               schedule_timeout(cfs_time_seconds(1) / 10);             \
+               schedule_timeout_uninterruptible(                       \
+                       cfs_time_seconds(1) / 10);                      \
                                                                        \
                spin_lock(&(lock));                                     \
        }                                                               \
@@ -600,8 +597,7 @@ srpc_wait_service_shutdown(struct srpc_service *sv)
                CDEBUG(((i & -i) == i) ? D_WARNING : D_NET,
                       "Waiting for %s service to shutdown...\n",
                       sv->sv_name);
-               set_current_state(TASK_UNINTERRUPTIBLE);
-               schedule_timeout(cfs_time_seconds(1) / 10);
+               schedule_timeout_uninterruptible(cfs_time_seconds(1) / 10);
        }
 }