LU-5396: o2ib: make local functions static

[fs/lustre-release.git] / lnet / klnds / o2iblnd / o2iblnd_cb.c

diff --git a/lnet/klnds/o2iblnd/o2iblnd_cb.c b/lnet/klnds/o2iblnd/o2iblnd_cb.c
index 484fe8c..c52ff41 100644 (file)
--- a/lnet/klnds/o2iblnd/o2iblnd_cb.c
+++ b/lnet/klnds/o2iblnd/o2iblnd_cb.c
@@ -40,7 +40,17 @@
 
 #include "o2iblnd.h"
 
 
 #include "o2iblnd.h"
 

-void
+static void kiblnd_peer_alive(kib_peer_t *peer);
+static void kiblnd_peer_connect_failed(kib_peer_t *peer, int active, int error);
+static void kiblnd_check_sends(kib_conn_t *conn);
+static void kiblnd_init_tx_msg(lnet_ni_t *ni, kib_tx_t *tx,
+                              int type, int body_nob);
+static int kiblnd_init_rdma(kib_conn_t *conn, kib_tx_t *tx, int type,
+                           int resid, kib_rdma_desc_t *dstrd, __u64 dstcookie);
+static void kiblnd_queue_tx_locked(kib_tx_t *tx, kib_conn_t *conn);
+static void kiblnd_queue_tx(kib_tx_t *tx, kib_conn_t *conn);
+
+static void

 kiblnd_tx_done (lnet_ni_t *ni, kib_tx_t *tx)
 {
        lnet_msg_t *lntmsg[2];
 kiblnd_tx_done (lnet_ni_t *ni, kib_tx_t *tx)
 {
        lnet_msg_t *lntmsg[2];


@@ -99,7 +109,7 @@ kiblnd_txlist_done(lnet_ni_t *ni, struct list_head *txlist, int status)
        }
 }
 
        }
 }
 

-kib_tx_t *
+static kib_tx_t *

 kiblnd_get_idle_tx(lnet_ni_t *ni, lnet_nid_t target)
 {
        kib_net_t               *net = (kib_net_t *)ni->ni_data;
 kiblnd_get_idle_tx(lnet_ni_t *ni, lnet_nid_t target)
 {
        kib_net_t               *net = (kib_net_t *)ni->ni_data;


@@ -127,7 +137,7 @@ kiblnd_get_idle_tx(lnet_ni_t *ni, lnet_nid_t target)
         return tx;
 }
 
         return tx;
 }
 

-void
+static void

 kiblnd_drop_rx(kib_rx_t *rx)
 {
        kib_conn_t              *conn   = rx->rx_conn;
 kiblnd_drop_rx(kib_rx_t *rx)
 {
        kib_conn_t              *conn   = rx->rx_conn;


@@ -209,7 +219,7 @@ kiblnd_post_rx (kib_rx_t *rx, int credit)
        return 0;
 }
 
        return 0;
 }
 

-kib_tx_t *
+static kib_tx_t *

 kiblnd_find_waiting_tx_locked(kib_conn_t *conn, int txtype, __u64 cookie)
 {
        struct list_head *tmp;
 kiblnd_find_waiting_tx_locked(kib_conn_t *conn, int txtype, __u64 cookie)
 {
        struct list_head *tmp;


@@ -234,7 +244,7 @@ kiblnd_find_waiting_tx_locked(kib_conn_t *conn, int txtype, __u64 cookie)
        return NULL;
 }
 
        return NULL;
 }
 

-void
+static void

 kiblnd_handle_completion(kib_conn_t *conn, int txtype, int status, __u64 cookie)
 {
        kib_tx_t    *tx;
 kiblnd_handle_completion(kib_conn_t *conn, int txtype, int status, __u64 cookie)
 {
        kib_tx_t    *tx;


@@ -273,7 +283,7 @@ kiblnd_handle_completion(kib_conn_t *conn, int txtype, int status, __u64 cookie)
                kiblnd_tx_done(ni, tx);
 }
 
                kiblnd_tx_done(ni, tx);
 }
 

-void
+static void

 kiblnd_send_completion(kib_conn_t *conn, int type, int status, __u64 cookie)
 {
        lnet_ni_t   *ni = conn->ibc_peer->ibp_ni;
 kiblnd_send_completion(kib_conn_t *conn, int type, int status, __u64 cookie)
 {
        lnet_ni_t   *ni = conn->ibc_peer->ibp_ni;


@@ -292,7 +302,7 @@ kiblnd_send_completion(kib_conn_t *conn, int type, int status, __u64 cookie)
         kiblnd_queue_tx(tx, conn);
 }
 
         kiblnd_queue_tx(tx, conn);
 }
 

-void
+static void

 kiblnd_handle_rx (kib_rx_t *rx)
 {
         kib_msg_t    *msg = rx->rx_msg;
 kiblnd_handle_rx (kib_rx_t *rx)
 {
         kib_msg_t    *msg = rx->rx_msg;


@@ -453,7 +463,7 @@ kiblnd_handle_rx (kib_rx_t *rx)
                 kiblnd_post_rx(rx, post_credit);
 }
 
                 kiblnd_post_rx(rx, post_credit);
 }
 

-void
+static void

 kiblnd_rx_complete (kib_rx_t *rx, int status, int nob)
 {
         kib_msg_t    *msg = rx->rx_msg;
 kiblnd_rx_complete (kib_rx_t *rx, int status, int nob)
 {
         kib_msg_t    *msg = rx->rx_msg;


@@ -524,7 +534,7 @@ kiblnd_rx_complete (kib_rx_t *rx, int status, int nob)
         kiblnd_drop_rx(rx);                     /* Don't re-post rx. */
 }
 
         kiblnd_drop_rx(rx);                     /* Don't re-post rx. */
 }
 

-struct page *
+static struct page *

 kiblnd_kvaddr_to_page (unsigned long vaddr)
 {
         struct page *page;
 kiblnd_kvaddr_to_page (unsigned long vaddr)
 {
         struct page *page;


@@ -695,7 +705,7 @@ kiblnd_map_tx(lnet_ni_t *ni, kib_tx_t *tx,
 }
 
 
 }
 
 

-int
+static int

 kiblnd_setup_rd_iov(lnet_ni_t *ni, kib_tx_t *tx, kib_rdma_desc_t *rd,
                     unsigned int niov, struct iovec *iov, int offset, int nob)
 {
 kiblnd_setup_rd_iov(lnet_ni_t *ni, kib_tx_t *tx, kib_rdma_desc_t *rd,
                     unsigned int niov, struct iovec *iov, int offset, int nob)
 {


@@ -748,7 +758,7 @@ kiblnd_setup_rd_iov(lnet_ni_t *ni, kib_tx_t *tx, kib_rdma_desc_t *rd,
         return kiblnd_map_tx(ni, tx, rd, sg - tx->tx_frags);
 }
 
         return kiblnd_map_tx(ni, tx, rd, sg - tx->tx_frags);
 }
 

-int
+static int

 kiblnd_setup_rd_kiov (lnet_ni_t *ni, kib_tx_t *tx, kib_rdma_desc_t *rd,
                       int nkiov, lnet_kiov_t *kiov, int offset, int nob)
 {
 kiblnd_setup_rd_kiov (lnet_ni_t *ni, kib_tx_t *tx, kib_rdma_desc_t *rd,
                       int nkiov, lnet_kiov_t *kiov, int offset, int nob)
 {


@@ -788,7 +798,7 @@ kiblnd_setup_rd_kiov (lnet_ni_t *ni, kib_tx_t *tx, kib_rdma_desc_t *rd,
         return kiblnd_map_tx(ni, tx, rd, sg - tx->tx_frags);
 }
 
         return kiblnd_map_tx(ni, tx, rd, sg - tx->tx_frags);
 }
 

-int
+static int

 kiblnd_post_tx_locked (kib_conn_t *conn, kib_tx_t *tx, int credit)
 {
         kib_msg_t         *msg = tx->tx_msg;
 kiblnd_post_tx_locked (kib_conn_t *conn, kib_tx_t *tx, int credit)
 {
         kib_msg_t         *msg = tx->tx_msg;


@@ -920,7 +930,7 @@ kiblnd_post_tx_locked (kib_conn_t *conn, kib_tx_t *tx, int credit)
        return -EIO;
 }
 
        return -EIO;
 }
 

-void
+static void

 kiblnd_check_sends (kib_conn_t *conn)
 {
         int        ver = conn->ibc_version;
 kiblnd_check_sends (kib_conn_t *conn)
 {
         int        ver = conn->ibc_version;


@@ -992,7 +1002,7 @@ kiblnd_check_sends (kib_conn_t *conn)
        kiblnd_conn_decref(conn); /* ...until here */
 }
 
        kiblnd_conn_decref(conn); /* ...until here */
 }
 

-void
+static void

 kiblnd_tx_complete (kib_tx_t *tx, int status)
 {
         int           failed = (status != IB_WC_SUCCESS);
 kiblnd_tx_complete (kib_tx_t *tx, int status)
 {
         int           failed = (status != IB_WC_SUCCESS);


@@ -1047,7 +1057,7 @@ kiblnd_tx_complete (kib_tx_t *tx, int status)
         kiblnd_conn_decref(conn);               /* ...until here */
 }
 
         kiblnd_conn_decref(conn);               /* ...until here */
 }
 

-void
+static void

 kiblnd_init_tx_msg (lnet_ni_t *ni, kib_tx_t *tx, int type, int body_nob)
 {
         kib_hca_dev_t     *hdev = tx->tx_pool->tpo_hdev;
 kiblnd_init_tx_msg (lnet_ni_t *ni, kib_tx_t *tx, int type, int body_nob)
 {
         kib_hca_dev_t     *hdev = tx->tx_pool->tpo_hdev;


@@ -1081,9 +1091,9 @@ kiblnd_init_tx_msg (lnet_ni_t *ni, kib_tx_t *tx, int type, int body_nob)
         tx->tx_nwrq++;
 }
 
         tx->tx_nwrq++;
 }
 

-int
-kiblnd_init_rdma (kib_conn_t *conn, kib_tx_t *tx, int type,
-                 int resid, kib_rdma_desc_t *dstrd, __u64 dstcookie)
+static int
+kiblnd_init_rdma(kib_conn_t *conn, kib_tx_t *tx, int type,
+                int resid, kib_rdma_desc_t *dstrd, __u64 dstcookie)

 {
        kib_msg_t         *ibmsg = tx->tx_msg;
        kib_rdma_desc_t   *srcrd = tx->tx_rd;
 {
        kib_msg_t         *ibmsg = tx->tx_msg;
        kib_rdma_desc_t   *srcrd = tx->tx_rd;


@@ -1166,8 +1176,8 @@ kiblnd_init_rdma (kib_conn_t *conn, kib_tx_t *tx, int type,
         return rc;
 }
 
         return rc;
 }
 

-void
-kiblnd_queue_tx_locked (kib_tx_t *tx, kib_conn_t *conn)
+static void
+kiblnd_queue_tx_locked(kib_tx_t *tx, kib_conn_t *conn)

 {
        struct list_head *q;
 
 {
        struct list_head *q;
 


@@ -1219,7 +1229,7 @@ kiblnd_queue_tx_locked (kib_tx_t *tx, kib_conn_t *conn)
        list_add_tail(&tx->tx_list, q);
 }
 
        list_add_tail(&tx->tx_list, q);
 }
 

-void
+static void

 kiblnd_queue_tx (kib_tx_t *tx, kib_conn_t *conn)
 {
        spin_lock(&conn->ibc_lock);
 kiblnd_queue_tx (kib_tx_t *tx, kib_conn_t *conn)
 {
        spin_lock(&conn->ibc_lock);


@@ -1271,7 +1281,7 @@ static int kiblnd_resolve_addr(struct rdma_cm_id *cmid,
         return rc;
 }
 
         return rc;
 }
 

-void
+static void

 kiblnd_connect_peer (kib_peer_t *peer)
 {
         struct rdma_cm_id *cmid;
 kiblnd_connect_peer (kib_peer_t *peer)
 {
         struct rdma_cm_id *cmid;


@@ -1628,7 +1638,7 @@ kiblnd_send (lnet_ni_t *ni, void *private, lnet_msg_t *lntmsg)
         return 0;
 }
 
         return 0;
 }
 

-void
+static void

 kiblnd_reply (lnet_ni_t *ni, kib_rx_t *rx, lnet_msg_t *lntmsg)
 {
         lnet_process_id_t target = lntmsg->msg_target;
 kiblnd_reply (lnet_ni_t *ni, kib_rx_t *rx, lnet_msg_t *lntmsg)
 {
         lnet_process_id_t target = lntmsg->msg_target;


@@ -1815,13 +1825,13 @@ kiblnd_thread_start(int (*fn)(void *arg), void *arg, char *name)
        return 0;
 }
 
        return 0;
 }
 

-void
+static void

 kiblnd_thread_fini (void)
 {
        atomic_dec (&kiblnd_data.kib_nthreads);
 }
 
 kiblnd_thread_fini (void)
 {
        atomic_dec (&kiblnd_data.kib_nthreads);
 }
 

-void
+static void

 kiblnd_peer_alive (kib_peer_t *peer)
 {
        /* This is racy, but everyone's only writing cfs_time_current() */
 kiblnd_peer_alive (kib_peer_t *peer)
 {
        /* This is racy, but everyone's only writing cfs_time_current() */


@@ -1829,7 +1839,7 @@ kiblnd_peer_alive (kib_peer_t *peer)
        smp_mb();
 }
 
        smp_mb();
 }
 

-void
+static void

 kiblnd_peer_notify (kib_peer_t *peer)
 {
         int           error = 0;
 kiblnd_peer_notify (kib_peer_t *peer)
 {
         int           error = 0;


@@ -1937,7 +1947,7 @@ kiblnd_close_conn(kib_conn_t *conn, int error)
        write_unlock_irqrestore(&kiblnd_data.kib_global_lock, flags);
 }
 
        write_unlock_irqrestore(&kiblnd_data.kib_global_lock, flags);
 }
 

-void
+static void

 kiblnd_handle_early_rxs(kib_conn_t *conn)
 {
        unsigned long    flags;
 kiblnd_handle_early_rxs(kib_conn_t *conn)
 {
        unsigned long    flags;


@@ -1960,7 +1970,7 @@ kiblnd_handle_early_rxs(kib_conn_t *conn)
        write_unlock_irqrestore(&kiblnd_data.kib_global_lock, flags);
 }
 
        write_unlock_irqrestore(&kiblnd_data.kib_global_lock, flags);
 }
 

-void
+static void

 kiblnd_abort_txs(kib_conn_t *conn, struct list_head *txs)
 {
        struct list_head         zombies = LIST_HEAD_INIT(zombies);
 kiblnd_abort_txs(kib_conn_t *conn, struct list_head *txs)
 {
        struct list_head         zombies = LIST_HEAD_INIT(zombies);


@@ -1996,7 +2006,7 @@ kiblnd_abort_txs(kib_conn_t *conn, struct list_head *txs)
        kiblnd_txlist_done(conn->ibc_peer->ibp_ni, &zombies, -ECONNABORTED);
 }
 
        kiblnd_txlist_done(conn->ibc_peer->ibp_ni, &zombies, -ECONNABORTED);
 }
 

-void
+static void

 kiblnd_finalise_conn (kib_conn_t *conn)
 {
        LASSERT (!in_interrupt());
 kiblnd_finalise_conn (kib_conn_t *conn)
 {
        LASSERT (!in_interrupt());


@@ -2021,8 +2031,8 @@ kiblnd_finalise_conn (kib_conn_t *conn)
        kiblnd_handle_early_rxs(conn);
 }
 
        kiblnd_handle_early_rxs(conn);
 }
 

-void
-kiblnd_peer_connect_failed (kib_peer_t *peer, int active, int error)
+static void
+kiblnd_peer_connect_failed(kib_peer_t *peer, int active, int error)

 {
        struct list_head zombies = LIST_HEAD_INIT(zombies);
        unsigned long   flags;
 {
        struct list_head zombies = LIST_HEAD_INIT(zombies);
        unsigned long   flags;


@@ -2075,7 +2085,7 @@ kiblnd_peer_connect_failed (kib_peer_t *peer, int active, int error)
        kiblnd_txlist_done(peer->ibp_ni, &zombies, -EHOSTUNREACH);
 }
 
        kiblnd_txlist_done(peer->ibp_ni, &zombies, -EHOSTUNREACH);
 }
 

-void
+static void

 kiblnd_connreq_done(kib_conn_t *conn, int status)
 {
        kib_peer_t       *peer = conn->ibc_peer;
 kiblnd_connreq_done(kib_conn_t *conn, int status)
 {
        kib_peer_t       *peer = conn->ibc_peer;


@@ -2170,7 +2180,7 @@ kiblnd_connreq_done(kib_conn_t *conn, int status)
        kiblnd_handle_early_rxs(conn);
 }
 
        kiblnd_handle_early_rxs(conn);
 }
 

-void
+static void

 kiblnd_reject(struct rdma_cm_id *cmid, kib_rej_t *rej)
 {
         int          rc;
 kiblnd_reject(struct rdma_cm_id *cmid, kib_rej_t *rej)
 {
         int          rc;


@@ -2181,7 +2191,7 @@ kiblnd_reject(struct rdma_cm_id *cmid, kib_rej_t *rej)
                 CWARN("Error %d sending reject\n", rc);
 }
 
                 CWARN("Error %d sending reject\n", rc);
 }
 

-int
+static int

 kiblnd_passive_connect (struct rdma_cm_id *cmid, void *priv, int priv_nob)
 {
        rwlock_t                *g_lock = &kiblnd_data.kib_global_lock;
 kiblnd_passive_connect (struct rdma_cm_id *cmid, void *priv, int priv_nob)
 {
        rwlock_t                *g_lock = &kiblnd_data.kib_global_lock;


@@ -2455,7 +2465,7 @@ kiblnd_passive_connect (struct rdma_cm_id *cmid, void *priv, int priv_nob)
         return -ECONNREFUSED;
 }
 
         return -ECONNREFUSED;
 }
 

-void
+static void

 kiblnd_reconnect (kib_conn_t *conn, int version,
                   __u64 incarnation, int why, kib_connparams_t *cp)
 {
 kiblnd_reconnect (kib_conn_t *conn, int version,
                   __u64 incarnation, int why, kib_connparams_t *cp)
 {


@@ -2519,7 +2529,7 @@ kiblnd_reconnect (kib_conn_t *conn, int version,
         kiblnd_connect_peer(peer);
 }
 
         kiblnd_connect_peer(peer);
 }
 

-void
+static void

 kiblnd_rejected (kib_conn_t *conn, int reason, void *priv, int priv_nob)
 {
        kib_peer_t    *peer = conn->ibc_peer;
 kiblnd_rejected (kib_conn_t *conn, int reason, void *priv, int priv_nob)
 {
        kib_peer_t    *peer = conn->ibc_peer;


@@ -2658,7 +2668,7 @@ kiblnd_rejected (kib_conn_t *conn, int reason, void *priv, int priv_nob)
         kiblnd_connreq_done(conn, -ECONNREFUSED);
 }
 
         kiblnd_connreq_done(conn, -ECONNREFUSED);
 }
 

-void
+static void

 kiblnd_check_connreply (kib_conn_t *conn, void *priv, int priv_nob)
 {
         kib_peer_t    *peer = conn->ibc_peer;
 kiblnd_check_connreply (kib_conn_t *conn, void *priv, int priv_nob)
 {
         kib_peer_t    *peer = conn->ibc_peer;


@@ -2757,7 +2767,7 @@ kiblnd_check_connreply (kib_conn_t *conn, void *priv, int priv_nob)
         kiblnd_connreq_done(conn, 0);
 }
 
         kiblnd_connreq_done(conn, 0);
 }
 

-int
+static int

 kiblnd_active_connect (struct rdma_cm_id *cmid)
 {
         kib_peer_t              *peer = (kib_peer_t *)cmid->context;
 kiblnd_active_connect (struct rdma_cm_id *cmid)
 {
         kib_peer_t              *peer = (kib_peer_t *)cmid->context;


@@ -3032,7 +3042,7 @@ kiblnd_conn_timed_out_locked(kib_conn_t *conn)
                 kiblnd_check_txs_locked(conn, &conn->ibc_active_txs);
 }
 
                 kiblnd_check_txs_locked(conn, &conn->ibc_active_txs);
 }
 

-void
+static void

 kiblnd_check_conns (int idx)
 {
        struct list_head  closes = LIST_HEAD_INIT(closes);
 kiblnd_check_conns (int idx)
 {
        struct list_head  closes = LIST_HEAD_INIT(closes);


@@ -3114,7 +3124,7 @@ kiblnd_check_conns (int idx)
        }
 }
 
        }
 }
 

-void
+static void

 kiblnd_disconnect_conn (kib_conn_t *conn)
 {
        LASSERT (!in_interrupt());
 kiblnd_disconnect_conn (kib_conn_t *conn)
 {
        LASSERT (!in_interrupt());


@@ -3253,7 +3263,7 @@ kiblnd_qp_event(struct ib_event *event, void *arg)
         }
 }
 
         }
 }
 

-void
+static void

 kiblnd_complete (struct ib_wc *wc)
 {
         switch (kiblnd_wreqid2type(wc->wr_id)) {
 kiblnd_complete (struct ib_wc *wc)
 {
         switch (kiblnd_wreqid2type(wc->wr_id)) {