drivers/staging/lustre/lnet/lnet/lo.c

   1 /*
   2  * GPL HEADER START
   3  *
   4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   5  *
   6  * This program is free software; you can redistribute it and/or modify
   7  * it under the terms of the GNU General Public License version 2 only,
   8  * as published by the Free Software Foundation.
   9  *
  10  * This program is distributed in the hope that it will be useful, but
  11  * WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * General Public License version 2 for more details (a copy is included
  14  * in the LICENSE file that accompanied this code).
  15  *
  16  * You should have received a copy of the GNU General Public License
  17  * version 2 along with this program; If not, see
  18  * http://www.gnu.org/licenses/gpl-2.0.html
  19  *
  20  * GPL HEADER END
  21  */
  22 /*
  23  * Copyright (c) 2007, 2010, Oracle and/or its affiliates. All rights reserved.
  24  * Use is subject to license terms.
  25  */
  26 /*
  27  * This file is part of Lustre, http://www.lustre.org/
  28  * Lustre is a trademark of Sun Microsystems, Inc.
  29  */
  30
  31 #define DEBUG_SUBSYSTEM S_LNET
  32
  33 #include <linux/lnet/lib-lnet.h>
  34
  35 static int
  36 lolnd_send(struct lnet_ni *ni, void *private, struct lnet_msg *lntmsg)
  37 {
  38         LASSERT(!lntmsg->msg_routing);
  39         LASSERT(!lntmsg->msg_target_is_router);
  40
  41         return lnet_parse(ni, &lntmsg->msg_hdr, ni->ni_nid, lntmsg, 0);
  42 }
  43
  44 static int
  45 lolnd_recv(struct lnet_ni *ni, void *private, struct lnet_msg *lntmsg,
  46            int delayed, struct iov_iter *to, unsigned int rlen)
  47 {
  48         struct lnet_msg *sendmsg = private;
  49
  50         if (lntmsg) {              /* not discarding */
  51                 if (sendmsg->msg_iov)
  52                         lnet_copy_iov2iter(to,
  53                                            sendmsg->msg_niov,
  54                                            sendmsg->msg_iov,
  55                                            sendmsg->msg_offset,
  56                                            iov_iter_count(to));
  57                 else
  58                         lnet_copy_kiov2iter(to,
  59                                             sendmsg->msg_niov,
  60                                             sendmsg->msg_kiov,
  61                                             sendmsg->msg_offset,
  62                                             iov_iter_count(to));
  63
  64                 lnet_finalize(ni, lntmsg, 0);
  65         }
  66
  67         lnet_finalize(ni, sendmsg, 0);
  68         return 0;
  69 }
  70
  71 static int lolnd_instanced;
  72
  73 static void
  74 lolnd_shutdown(struct lnet_ni *ni)
  75 {
  76         CDEBUG(D_NET, "shutdown\n");
  77         LASSERT(lolnd_instanced);
  78
  79         lolnd_instanced = 0;
  80 }
  81
  82 static int
  83 lolnd_startup(struct lnet_ni *ni)
  84 {
  85         LASSERT(ni->ni_lnd == &the_lolnd);
  86         LASSERT(!lolnd_instanced);
  87         lolnd_instanced = 1;
  88
  89         return 0;
  90 }
  91
  92 struct lnet_lnd the_lolnd = {
  93         /* .lnd_list       = */ {&the_lolnd.lnd_list, &the_lolnd.lnd_list},
  94         /* .lnd_refcount   = */ 0,
  95         /* .lnd_type       = */ LOLND,
  96         /* .lnd_startup    = */ lolnd_startup,
  97         /* .lnd_shutdown   = */ lolnd_shutdown,
  98         /* .lnt_ctl        = */ NULL,
  99         /* .lnd_send       = */ lolnd_send,
 100         /* .lnd_recv       = */ lolnd_recv,
 101         /* .lnd_eager_recv = */ NULL,
 102         /* .lnd_notify     = */ NULL,
 103         /* .lnd_accept     = */ NULL
 104 };