libcfs/include/libcfs/darwin/darwin-tcpip.h

   1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
   2  * vim:expandtab:shiftwidth=8:tabstop=8:
   3  *
   4  * GPL HEADER START
   5  *
   6  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   7  *
   8  * This program is free software; you can redistribute it and/or modify
   9  * it under the terms of the GNU General Public License version 2 only,
  10  * as published by the Free Software Foundation.
  11  *
  12  * This program is distributed in the hope that it will be useful, but
  13  * WITHOUT ANY WARRANTY; without even the implied warranty of
  14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  15  * General Public License version 2 for more details (a copy is included
  16  * in the LICENSE file that accompanied this code).
  17  *
  18  * You should have received a copy of the GNU General Public License
  19  * version 2 along with this program; If not, see [sun.com URL with a
  20  * copy of GPLv2].
  21  *
  22  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
  23  * CA 95054 USA or visit www.sun.com if you need additional information or
  24  * have any questions.
  25  *
  26  * GPL HEADER END
  27  */
  28 /*
  29  * Copyright  2008 Sun Microsystems, Inc. All rights reserved
  30  * Use is subject to license terms.
  31  */
  32 /*
  33  * This file is part of Lustre, http://www.lustre.org/
  34  * Lustre is a trademark of Sun Microsystems, Inc.
  35  *
  36  * libcfs/include/libcfs/darwin/darwin-tcpip.h
  37  *
  38  * Basic library routines.
  39  */
  40
  41 #ifndef __LIBCFS_DARWIN_TCPIP_H__
  42 #define __LIBCFS_DARWIN_TCPIP_H__
  43
  44 #ifdef __KERNEL__
  45 #include <sys/socket.h>
  46
  47 #ifdef __DARWIN8__
  48
  49 struct socket;
  50
  51 typedef void    (*so_upcall)(socket_t sock, void* arg, int waitf);
  52
  53 #define CFS_SOCK_UPCALL         0x1
  54 #define CFS_SOCK_DOWN           0x2
  55
  56 #define CFS_SOCK_MAGIC          0xbabeface
  57
  58 typedef struct cfs_socket {
  59         socket_t        s_so;
  60         int             s_magic;
  61         int             s_flags;
  62         so_upcall       s_upcall;
  63         void           *s_upcallarg;
  64 } cfs_socket_t;
  65
  66
  67 /* cfs_socket_t to bsd socket */
  68 #define C2B_SOCK(s)             ((s)->s_so)
  69
  70 static inline int get_sock_intopt(socket_t so, int opt)
  71 {
  72         int     val, len;
  73         int     rc;
  74
  75         /*
  76          * sock_getsockopt will take a lock(mutex) for socket,
  77          * so it can be blocked. So be careful while using
  78          * them.
  79          */
  80         len = sizeof(val);
  81         rc = sock_getsockopt(so, SOL_SOCKET, opt, &val, &len);
  82         assert(rc == 0);
  83         return val;
  84 }
  85
  86 #define SOCK_ERROR(s)           get_sock_intopt(C2B_SOCK(s), SO_ERROR)
  87 /* #define SOCK_WMEM_QUEUED(s)     (0) */
  88 #define SOCK_WMEM_QUEUED(s)     get_sock_intopt(C2B_SOCK(s), SO_NWRITE)
  89 /* XXX Liang: no reliable way to get it in Darwin8.x */
  90 #define SOCK_TEST_NOSPACE(s)    (0)
  91
  92 void libcfs_sock_set_cb(cfs_socket_t *sock, so_upcall callback, void *arg);
  93 void libcfs_sock_reset_cb(cfs_socket_t *sock);
  94
  95 #else /* !__DARWIN8__ */
  96
  97 #define SOCK_WMEM_QUEUED(so)    ((so)->so_snd.sb_cc)
  98 #define SOCK_ERROR(so)          ((so)->so_error)
  99
 100 #define SOCK_TEST_NOSPACE(so)   (sbspace(&(so)->so_snd) < (so)->so_snd.sb_lowat)
 101
 102 #endif /* !__DARWIN8__ */
 103
 104 #endif  /* __KERNEL END */
 105
 106 #endif  /* __XNU_CFS_TYPES_H__ */