Commit dae0587e authored by James Simmons's avatar James Simmons Committed by Greg Kroah-Hartman

staging: lustre: cleanup comment style for lnet selftest

Apply a consistent style for comments in the lnet selftest
code. Realign some of the comments to make it easier to read.
This also fixes a few checkpatch issues as well.
Signed-off-by: default avatarJames Simmons <jsimmons@infradead.org>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent 0b4427de
...@@ -327,7 +327,7 @@ brw_client_done_rpc(sfw_test_unit_t *tsu, srpc_client_rpc_t *rpc) ...@@ -327,7 +327,7 @@ brw_client_done_rpc(sfw_test_unit_t *tsu, srpc_client_rpc_t *rpc)
if (rpc->crpc_status) { if (rpc->crpc_status) {
CERROR("BRW RPC to %s failed with %d\n", CERROR("BRW RPC to %s failed with %d\n",
libcfs_id2str(rpc->crpc_dest), rpc->crpc_status); libcfs_id2str(rpc->crpc_dest), rpc->crpc_status);
if (!tsi->tsi_stopping) /* rpc could have been aborted */ if (!tsi->tsi_stopping) /* rpc could have been aborted */
atomic_inc(&sn->sn_brw_errors); atomic_inc(&sn->sn_brw_errors);
return; return;
} }
......
...@@ -51,9 +51,9 @@ lst_session_new_ioctl(lstio_session_new_args_t *args) ...@@ -51,9 +51,9 @@ lst_session_new_ioctl(lstio_session_new_args_t *args)
char *name; char *name;
int rc; int rc;
if (!args->lstio_ses_idp || /* address for output sid */ if (!args->lstio_ses_idp || /* address for output sid */
!args->lstio_ses_key || /* no key is specified */ !args->lstio_ses_key || /* no key is specified */
!args->lstio_ses_namep || /* session name */ !args->lstio_ses_namep || /* session name */
args->lstio_ses_nmlen <= 0 || args->lstio_ses_nmlen <= 0 ||
args->lstio_ses_nmlen > LST_NAME_SIZE) args->lstio_ses_nmlen > LST_NAME_SIZE)
return -EINVAL; return -EINVAL;
...@@ -95,11 +95,11 @@ lst_session_info_ioctl(lstio_session_info_args_t *args) ...@@ -95,11 +95,11 @@ lst_session_info_ioctl(lstio_session_info_args_t *args)
{ {
/* no checking of key */ /* no checking of key */
if (!args->lstio_ses_idp || /* address for output sid */ if (!args->lstio_ses_idp || /* address for output sid */
!args->lstio_ses_keyp || /* address for output key */ !args->lstio_ses_keyp || /* address for output key */
!args->lstio_ses_featp || /* address for output features */ !args->lstio_ses_featp || /* address for output features */
!args->lstio_ses_ndinfo || /* address for output ndinfo */ !args->lstio_ses_ndinfo || /* address for output ndinfo */
!args->lstio_ses_namep || /* address for output name */ !args->lstio_ses_namep || /* address for output name */
args->lstio_ses_nmlen <= 0 || args->lstio_ses_nmlen <= 0 ||
args->lstio_ses_nmlen > LST_NAME_SIZE) args->lstio_ses_nmlen > LST_NAME_SIZE)
return -EINVAL; return -EINVAL;
...@@ -125,7 +125,7 @@ lst_debug_ioctl(lstio_debug_args_t *args) ...@@ -125,7 +125,7 @@ lst_debug_ioctl(lstio_debug_args_t *args)
if (!args->lstio_dbg_resultp) if (!args->lstio_dbg_resultp)
return -EINVAL; return -EINVAL;
if (args->lstio_dbg_namep && /* name of batch/group */ if (args->lstio_dbg_namep && /* name of batch/group */
(args->lstio_dbg_nmlen <= 0 || (args->lstio_dbg_nmlen <= 0 ||
args->lstio_dbg_nmlen > LST_NAME_SIZE)) args->lstio_dbg_nmlen > LST_NAME_SIZE))
return -EINVAL; return -EINVAL;
...@@ -326,7 +326,7 @@ lst_nodes_add_ioctl(lstio_group_nodes_args_t *args) ...@@ -326,7 +326,7 @@ lst_nodes_add_ioctl(lstio_group_nodes_args_t *args)
if (args->lstio_grp_key != console_session.ses_key) if (args->lstio_grp_key != console_session.ses_key)
return -EACCES; return -EACCES;
if (!args->lstio_grp_idsp || /* array of ids */ if (!args->lstio_grp_idsp || /* array of ids */
args->lstio_grp_count <= 0 || args->lstio_grp_count <= 0 ||
!args->lstio_grp_resultp || !args->lstio_grp_resultp ||
!args->lstio_grp_featp || !args->lstio_grp_featp ||
...@@ -394,13 +394,13 @@ lst_group_info_ioctl(lstio_group_info_args_t *args) ...@@ -394,13 +394,13 @@ lst_group_info_ioctl(lstio_group_info_args_t *args)
args->lstio_grp_nmlen > LST_NAME_SIZE) args->lstio_grp_nmlen > LST_NAME_SIZE)
return -EINVAL; return -EINVAL;
if (!args->lstio_grp_entp && /* output: group entry */ if (!args->lstio_grp_entp && /* output: group entry */
!args->lstio_grp_dentsp) /* output: node entry */ !args->lstio_grp_dentsp) /* output: node entry */
return -EINVAL; return -EINVAL;
if (args->lstio_grp_dentsp) { /* have node entry */ if (args->lstio_grp_dentsp) { /* have node entry */
if (!args->lstio_grp_idxp || /* node index */ if (!args->lstio_grp_idxp || /* node index */
!args->lstio_grp_ndentp) /* # of node entry */ !args->lstio_grp_ndentp) /* # of node entry */
return -EINVAL; return -EINVAL;
if (copy_from_user(&ndent, args->lstio_grp_ndentp, if (copy_from_user(&ndent, args->lstio_grp_ndentp,
...@@ -612,18 +612,18 @@ lst_batch_info_ioctl(lstio_batch_info_args_t *args) ...@@ -612,18 +612,18 @@ lst_batch_info_ioctl(lstio_batch_info_args_t *args)
if (args->lstio_bat_key != console_session.ses_key) if (args->lstio_bat_key != console_session.ses_key)
return -EACCES; return -EACCES;
if (!args->lstio_bat_namep || /* batch name */ if (!args->lstio_bat_namep || /* batch name */
args->lstio_bat_nmlen <= 0 || args->lstio_bat_nmlen <= 0 ||
args->lstio_bat_nmlen > LST_NAME_SIZE) args->lstio_bat_nmlen > LST_NAME_SIZE)
return -EINVAL; return -EINVAL;
if (!args->lstio_bat_entp && /* output: batch entry */ if (!args->lstio_bat_entp && /* output: batch entry */
!args->lstio_bat_dentsp) /* output: node entry */ !args->lstio_bat_dentsp) /* output: node entry */
return -EINVAL; return -EINVAL;
if (args->lstio_bat_dentsp) { /* have node entry */ if (args->lstio_bat_dentsp) { /* have node entry */
if (!args->lstio_bat_idxp || /* node index */ if (!args->lstio_bat_idxp || /* node index */
!args->lstio_bat_ndentp) /* # of node entry */ !args->lstio_bat_ndentp) /* # of node entry */
return -EINVAL; return -EINVAL;
if (copy_from_user(&index, args->lstio_bat_idxp, if (copy_from_user(&index, args->lstio_bat_idxp,
...@@ -722,18 +722,18 @@ static int lst_test_add_ioctl(lstio_test_args_t *args) ...@@ -722,18 +722,18 @@ static int lst_test_add_ioctl(lstio_test_args_t *args)
if (!args->lstio_tes_resultp || if (!args->lstio_tes_resultp ||
!args->lstio_tes_retp || !args->lstio_tes_retp ||
!args->lstio_tes_bat_name || /* no specified batch */ !args->lstio_tes_bat_name || /* no specified batch */
args->lstio_tes_bat_nmlen <= 0 || args->lstio_tes_bat_nmlen <= 0 ||
args->lstio_tes_bat_nmlen > LST_NAME_SIZE || args->lstio_tes_bat_nmlen > LST_NAME_SIZE ||
!args->lstio_tes_sgrp_name || /* no source group */ !args->lstio_tes_sgrp_name || /* no source group */
args->lstio_tes_sgrp_nmlen <= 0 || args->lstio_tes_sgrp_nmlen <= 0 ||
args->lstio_tes_sgrp_nmlen > LST_NAME_SIZE || args->lstio_tes_sgrp_nmlen > LST_NAME_SIZE ||
!args->lstio_tes_dgrp_name || /* no target group */ !args->lstio_tes_dgrp_name || /* no target group */
args->lstio_tes_dgrp_nmlen <= 0 || args->lstio_tes_dgrp_nmlen <= 0 ||
args->lstio_tes_dgrp_nmlen > LST_NAME_SIZE) args->lstio_tes_dgrp_nmlen > LST_NAME_SIZE)
return -EINVAL; return -EINVAL;
if (!args->lstio_tes_loop || /* negative is infinite */ if (!args->lstio_tes_loop || /* negative is infinite */
args->lstio_tes_concur <= 0 || args->lstio_tes_concur <= 0 ||
args->lstio_tes_dist <= 0 || args->lstio_tes_dist <= 0 ||
args->lstio_tes_span <= 0) args->lstio_tes_span <= 0)
......
...@@ -296,8 +296,8 @@ lstcon_rpc_trans_abort(lstcon_rpc_trans_t *trans, int error) ...@@ -296,8 +296,8 @@ lstcon_rpc_trans_abort(lstcon_rpc_trans_t *trans, int error)
spin_lock(&rpc->crpc_lock); spin_lock(&rpc->crpc_lock);
if (!crpc->crp_posted || /* not posted */ if (!crpc->crp_posted || /* not posted */
crpc->crp_stamp) { /* rpc done or aborted already */ crpc->crp_stamp) { /* rpc done or aborted already */
if (!crpc->crp_stamp) { if (!crpc->crp_stamp) {
crpc->crp_stamp = cfs_time_current(); crpc->crp_stamp = cfs_time_current();
crpc->crp_status = -EINTR; crpc->crp_status = -EINTR;
...@@ -562,10 +562,10 @@ lstcon_rpc_trans_destroy(lstcon_rpc_trans_t *trans) ...@@ -562,10 +562,10 @@ lstcon_rpc_trans_destroy(lstcon_rpc_trans_t *trans)
} }
/* /*
* rpcs can be still not callbacked (even LNetMDUnlink is called) * rpcs can be still not callbacked (even LNetMDUnlink is
* because huge timeout for inaccessible network, don't make * called) because huge timeout for inaccessible network,
* user wait for them, just abandon them, they will be recycled * don't make user wait for them, just abandon them, they
* in callback * will be recycled in callback
*/ */
LASSERT(crpc->crp_status); LASSERT(crpc->crp_status);
...@@ -938,7 +938,7 @@ lstcon_sesnew_stat_reply(lstcon_rpc_trans_t *trans, ...@@ -938,7 +938,7 @@ lstcon_sesnew_stat_reply(lstcon_rpc_trans_t *trans,
if (!trans->tas_feats_updated) { if (!trans->tas_feats_updated) {
spin_lock(&console_session.ses_rpc_lock); spin_lock(&console_session.ses_rpc_lock);
if (!trans->tas_feats_updated) { /* recheck with lock */ if (!trans->tas_feats_updated) { /* recheck with lock */
trans->tas_feats_updated = 1; trans->tas_feats_updated = 1;
trans->tas_features = reply->msg_ses_feats; trans->tas_features = reply->msg_ses_feats;
} }
...@@ -1178,7 +1178,8 @@ lstcon_rpc_pinger(void *arg) ...@@ -1178,7 +1178,8 @@ lstcon_rpc_pinger(void *arg)
int count = 0; int count = 0;
int rc; int rc;
/* RPC pinger is a special case of transaction, /*
* RPC pinger is a special case of transaction,
* it's called by timer at 8 seconds interval. * it's called by timer at 8 seconds interval.
*/ */
mutex_lock(&console_session.ses_mutex); mutex_lock(&console_session.ses_mutex);
......
...@@ -277,7 +277,7 @@ lstcon_group_find(const char *name, lstcon_group_t **grpp) ...@@ -277,7 +277,7 @@ lstcon_group_find(const char *name, lstcon_group_t **grpp)
if (strncmp(grp->grp_name, name, LST_NAME_SIZE)) if (strncmp(grp->grp_name, name, LST_NAME_SIZE))
continue; continue;
lstcon_group_addref(grp); /* +1 ref for caller */ lstcon_group_addref(grp); /* +1 ref for caller */
*grpp = grp; *grpp = grp;
return 0; return 0;
} }
...@@ -1446,7 +1446,8 @@ lstcon_test_batch_query(char *name, int testidx, int client, ...@@ -1446,7 +1446,8 @@ lstcon_test_batch_query(char *name, int testidx, int client,
lstcon_rpc_trans_postwait(trans, timeout); lstcon_rpc_trans_postwait(trans, timeout);
if (!testidx && /* query a batch, not a test */ /* query a batch, not a test */
if (!testidx &&
!lstcon_rpc_stat_failure(lstcon_trans_stat(), 0) && !lstcon_rpc_stat_failure(lstcon_trans_stat(), 0) &&
!lstcon_tsbqry_stat_run(lstcon_trans_stat(), 0)) { !lstcon_tsbqry_stat_run(lstcon_trans_stat(), 0)) {
/* all RPCs finished, and no active test */ /* all RPCs finished, and no active test */
......
...@@ -226,7 +226,7 @@ __must_hold(&sfw_data.fw_lock) ...@@ -226,7 +226,7 @@ __must_hold(&sfw_data.fw_lock)
} }
if (nactive) if (nactive)
return; /* wait for active batches to stop */ return; /* wait for active batches to stop */
list_del_init(&sn->sn_list); list_del_init(&sn->sn_list);
spin_unlock(&sfw_data.fw_lock); spin_unlock(&sfw_data.fw_lock);
...@@ -693,7 +693,7 @@ sfw_unpack_addtest_req(srpc_msg_t *msg) ...@@ -693,7 +693,7 @@ sfw_unpack_addtest_req(srpc_msg_t *msg)
LASSERT(req->tsr_is_client); LASSERT(req->tsr_is_client);
if (msg->msg_magic == SRPC_MSG_MAGIC) if (msg->msg_magic == SRPC_MSG_MAGIC)
return; /* no flipping needed */ return; /* no flipping needed */
LASSERT(msg->msg_magic == __swab32(SRPC_MSG_MAGIC)); LASSERT(msg->msg_magic == __swab32(SRPC_MSG_MAGIC));
...@@ -789,7 +789,7 @@ sfw_add_test_instance(sfw_batch_t *tsb, struct srpc_server_rpc *rpc) ...@@ -789,7 +789,7 @@ sfw_add_test_instance(sfw_batch_t *tsb, struct srpc_server_rpc *rpc)
int j; int j;
dests = page_address(bk->bk_iovs[i / SFW_ID_PER_PAGE].kiov_page); dests = page_address(bk->bk_iovs[i / SFW_ID_PER_PAGE].kiov_page);
LASSERT(dests); /* my pages are within KVM always */ LASSERT(dests); /* my pages are within KVM always */
id = dests[i % SFW_ID_PER_PAGE]; id = dests[i % SFW_ID_PER_PAGE];
if (msg->msg_magic != SRPC_MSG_MAGIC) if (msg->msg_magic != SRPC_MSG_MAGIC)
sfw_unpack_id(id); sfw_unpack_id(id);
...@@ -844,8 +844,8 @@ sfw_test_unit_done(sfw_test_unit_t *tsu) ...@@ -844,8 +844,8 @@ sfw_test_unit_done(sfw_test_unit_t *tsu)
spin_lock(&sfw_data.fw_lock); spin_lock(&sfw_data.fw_lock);
if (!atomic_dec_and_test(&tsb->bat_nactive) ||/* tsb still active */ if (!atomic_dec_and_test(&tsb->bat_nactive) || /* tsb still active */
sn == sfw_data.fw_session) { /* sn also active */ sn == sfw_data.fw_session) { /* sn also active */
spin_unlock(&sfw_data.fw_lock); spin_unlock(&sfw_data.fw_lock);
return; return;
} }
...@@ -1273,7 +1273,7 @@ sfw_handle_server_rpc(struct srpc_server_rpc *rpc) ...@@ -1273,7 +1273,7 @@ sfw_handle_server_rpc(struct srpc_server_rpc *rpc)
} }
} else if (request->msg_ses_feats & ~LST_FEATS_MASK) { } else if (request->msg_ses_feats & ~LST_FEATS_MASK) {
/** /*
* NB: at this point, old version will ignore features and * NB: at this point, old version will ignore features and
* create new session anyway, so console should be able * create new session anyway, so console should be able
* to handle this * to handle this
......
...@@ -129,7 +129,7 @@ ping_client_done_rpc(sfw_test_unit_t *tsu, srpc_client_rpc_t *rpc) ...@@ -129,7 +129,7 @@ ping_client_done_rpc(sfw_test_unit_t *tsu, srpc_client_rpc_t *rpc)
LASSERT(sn); LASSERT(sn);
if (rpc->crpc_status) { if (rpc->crpc_status) {
if (!tsi->tsi_stopping) /* rpc could have been aborted */ if (!tsi->tsi_stopping) /* rpc could have been aborted */
atomic_inc(&sn->sn_ping_errors); atomic_inc(&sn->sn_ping_errors);
CERROR("Unable to ping %s (%d): %d\n", CERROR("Unable to ping %s (%d): %d\n",
libcfs_id2str(rpc->crpc_dest), libcfs_id2str(rpc->crpc_dest),
......
...@@ -1332,8 +1332,8 @@ srpc_abort_rpc(srpc_client_rpc_t *rpc, int why) ...@@ -1332,8 +1332,8 @@ srpc_abort_rpc(srpc_client_rpc_t *rpc, int why)
{ {
LASSERT(why); LASSERT(why);
if (rpc->crpc_aborted || /* already aborted */ if (rpc->crpc_aborted || /* already aborted */
rpc->crpc_closed) /* callback imminent */ rpc->crpc_closed) /* callback imminent */
return; return;
CDEBUG(D_NET, "Aborting RPC: service %d, peer %s, state %s, why %d\n", CDEBUG(D_NET, "Aborting RPC: service %d, peer %s, state %s, why %d\n",
...@@ -1401,7 +1401,7 @@ srpc_send_reply(struct srpc_server_rpc *rpc) ...@@ -1401,7 +1401,7 @@ srpc_send_reply(struct srpc_server_rpc *rpc)
rpc->srpc_peer, rpc->srpc_self, rpc->srpc_peer, rpc->srpc_self,
&rpc->srpc_replymdh, ev); &rpc->srpc_replymdh, ev);
if (rc) if (rc)
ev->ev_fired = 1; /* no more event expected */ ev->ev_fired = 1; /* no more event expected */
return rc; return rc;
} }
...@@ -1509,7 +1509,7 @@ srpc_lnet_ev_handler(lnet_event_t *ev) ...@@ -1509,7 +1509,7 @@ srpc_lnet_ev_handler(lnet_event_t *ev)
scd->scd_buf_err = 0; scd->scd_buf_err = 0;
} }
if (!scd->scd_buf_err && /* adding buffer is enabled */ if (!scd->scd_buf_err && /* adding buffer is enabled */
!scd->scd_buf_adjust && !scd->scd_buf_adjust &&
scd->scd_buf_nposted < scd->scd_buf_low) { scd->scd_buf_nposted < scd->scd_buf_low) {
scd->scd_buf_adjust = max(scd->scd_buf_total / 2, scd->scd_buf_adjust = max(scd->scd_buf_total / 2,
......
...@@ -49,7 +49,7 @@ ...@@ -49,7 +49,7 @@
* sorted by increasing expiry time. The number of slots is 2**7 (128), * sorted by increasing expiry time. The number of slots is 2**7 (128),
* to cover a time period of 1024 seconds into the future before wrapping. * to cover a time period of 1024 seconds into the future before wrapping.
*/ */
#define STTIMER_MINPOLL 3 /* log2 min poll interval (8 s) */ #define STTIMER_MINPOLL 3 /* log2 min poll interval (8 s) */
#define STTIMER_SLOTTIME (1 << STTIMER_MINPOLL) #define STTIMER_SLOTTIME (1 << STTIMER_MINPOLL)
#define STTIMER_SLOTTIMEMASK (~(STTIMER_SLOTTIME - 1)) #define STTIMER_SLOTTIMEMASK (~(STTIMER_SLOTTIME - 1))
#define STTIMER_NSLOTS (1 << 7) #define STTIMER_NSLOTS (1 << 7)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment