@@ -2841,7 +2841,7 @@ static void kiblnd_base_shutdown(void)
!atomic_read(&kiblnd_data.kib_nthreads),
"Waiting for %d threads to terminate\n",
atomic_read(&kiblnd_data.kib_nthreads));
- /* fall through */
+ fallthrough;
case IBLND_INIT_NOTHING:
break;
@@ -2898,7 +2898,7 @@ static void kiblnd_shutdown(struct lnet_ni *ni)
"%s: waiting for %d conns to clean\n",
libcfs_nidstr(&ni->ni_nid),
atomic_read(&net->ibn_nconns));
- /* fall through */
+ fallthrough;
case IBLND_INIT_NOTHING:
LASSERT(!atomic_read(&net->ibn_nconns));
@@ -1821,9 +1821,8 @@ static int kiblnd_map_tx(struct lnet_ni *ni, struct kib_tx *tx,
switch (rxmsg->ibm_type) {
default:
LBUG();
-
+ fallthrough;
case IBLND_MSG_IMMEDIATE:
- /* fallthrough */
nob = offsetof(struct kib_msg, ibm_u.immediate.ibim_payload[rlen]);
if (nob > rx->rx_nob) {
CERROR("Immediate message from %s too big: %d(%d)\n",
@@ -2918,7 +2917,7 @@ static int kiblnd_map_tx(struct lnet_ni *ni, struct kib_tx *tx,
}
break;
}
- /* fall through */
+ fallthrough;
default:
CNETERR("%s rejected: reason %d, size %d\n",
libcfs_nid2str(peer_ni->ibp_nid), reason, priv_nob);
@@ -2135,7 +2135,8 @@ static int ksocknal_inetaddr_event(struct notifier_block *unused,
switch (ksocknal_data.ksnd_init) {
default:
LASSERT(0);
- /* fall through */
+ fallthrough;
+
case SOCKNAL_INIT_ALL:
case SOCKNAL_INIT_DATA:
hash_for_each(ksocknal_data.ksnd_peers, i, peer_ni, ksnp_list)
@@ -1254,7 +1254,7 @@ struct ksock_conn_cb *
ksocknal_close_conn_and_siblings(conn, rc);
return -EPROTO;
}
- /* Fall through */
+ fallthrough;
case SOCKNAL_RX_SLOP:
/* starting new packet? */
@@ -3804,7 +3804,7 @@ struct lnet_mt_event_info {
case LNET_EVENT_UNLINK:
CDEBUG(D_NET, "%s recovery ping unlinked\n",
libcfs_nidstr(&ev_info->mt_nid));
- /* fall-through */
+ fallthrough;
case LNET_EVENT_REPLY:
lnet_handle_recovery_reply(ev_info, event->status, false,
event->type == LNET_EVENT_UNLINK);
@@ -4012,7 +4012,7 @@ void lnet_monitor_thr_stop(void)
ready_delay = true;
goto again;
}
- /* fall through */
+ fallthrough;
case LNET_MATCHMD_DROP:
CNETERR("Dropping PUT from %s portal %d match %llu offset %d length %d: %d\n",
@@ -721,7 +721,7 @@ struct delay_daemon_data {
case LNET_CREDIT_OK:
lnet_ni_recv(ni, msg->msg_private, msg, 0,
0, msg->msg_len, msg->msg_len);
- /* fall through */
+ fallthrough;
case LNET_CREDIT_WAIT:
continue;
default: /* failures */
@@ -136,7 +136,7 @@
case LST_OPC_BATCHSRV:
client = 0;
- /* fall through */
+ fallthrough;
case LST_OPC_BATCHCLI:
if (!args->lstio_dbg_namep)
goto out;
@@ -57,13 +57,13 @@ enum {
switch (lst_init_step) {
case LST_INIT_CONSOLE:
lstcon_console_fini();
- /* fall through */
+ fallthrough;
case LST_INIT_FW:
sfw_shutdown();
- /* fall through */
+ fallthrough;
case LST_INIT_RPC:
srpc_shutdown();
- /* fall through */
+ fallthrough;
case LST_INIT_WI_TEST:
for (i = 0;
i < cfs_cpt_number(lnet_cpt_table()); i++) {
@@ -73,7 +73,7 @@ enum {
}
kvfree(lst_test_wq);
lst_test_wq = NULL;
- /* fall through */
+ fallthrough;
case LST_INIT_WI_SERIAL:
destroy_workqueue(lst_serial_wq);
lst_serial_wq = NULL;
@@ -1018,6 +1018,7 @@ struct srpc_bulk *
switch (wi->swi_state) {
default:
LBUG();
+ fallthrough;
case SWI_STATE_NEWBORN: {
struct srpc_msg *msg;
struct srpc_generic_reply *reply;
@@ -1059,7 +1060,7 @@ struct srpc_bulk *
ev->ev_status = rc;
}
}
- /* fall through */
+ fallthrough;
case SWI_STATE_BULK_STARTED:
LASSERT(!rpc->srpc_bulk || ev->ev_fired);
@@ -1255,8 +1256,7 @@ struct srpc_bulk *
break;
wi->swi_state = SWI_STATE_REQUEST_SENT;
- /* perhaps more events */
- /* fall through */
+ fallthrough;
case SWI_STATE_REQUEST_SENT: {
enum srpc_msg_type type = srpc_service2reply(rpc->crpc_service);
@@ -1288,7 +1288,7 @@ struct srpc_bulk *
wi->swi_state = SWI_STATE_REPLY_RECEIVED;
}
- /* fall through */
+ fallthrough;
case SWI_STATE_REPLY_RECEIVED:
if (do_bulk && !rpc->crpc_bulkev.ev_fired)
break;
@@ -1462,11 +1462,11 @@ struct srpc_client_rpc *
CERROR("Unknown event: status %d, type %d, lnet %d\n",
rpcev->ev_status, rpcev->ev_type, rpcev->ev_lnet);
LBUG();
+ fallthrough;
case SRPC_REQUEST_SENT:
if (!ev->status && ev->type != LNET_EVENT_UNLINK)
atomic_inc(&RPC_STAT32(SRPC_RPC_SENT));
-
- /* fall through */
+ fallthrough;
case SRPC_REPLY_RCVD:
case SRPC_BULK_REQ_RCVD:
crpc = rpcev->ev_data;
@@ -1588,7 +1588,7 @@ struct srpc_client_rpc *
if (!ev->unlinked)
break; /* wait for final event */
- /* fall through */
+ fallthrough;
case SRPC_BULK_PUT_SENT:
if (!ev->status && ev->type != LNET_EVENT_UNLINK) {
atomic64_t *data;
@@ -1600,7 +1600,7 @@ struct srpc_client_rpc *
atomic64_add(ev->mlength, data);
}
- /* fall through */
+ fallthrough;
case SRPC_REPLY_SENT:
srpc = rpcev->ev_data;
scd = srpc->srpc_scd;
@@ -1673,6 +1673,7 @@ struct srpc_client_rpc *
switch (state) {
default:
LBUG();
+ fallthrough;
case SRPC_STATE_RUNNING:
spin_lock(&srpc_data.rpc_glock);
@@ -1686,13 +1687,13 @@ struct srpc_client_rpc *
spin_unlock(&srpc_data.rpc_glock);
stt_shutdown();
- /* fall through */
+ fallthrough;
case SRPC_STATE_EQ_INIT:
rc = LNetClearLazyPortal(SRPC_FRAMEWORK_REQUEST_PORTAL);
rc = LNetClearLazyPortal(SRPC_REQUEST_PORTAL);
LASSERT(!rc);
lnet_assert_handler_unused(srpc_data.rpc_lnet_handler);
- /* fall through */
+ fallthrough;
case SRPC_STATE_NI_INIT:
LNetNIFini();
}