include/l7vs_lsock.h

   1 /*!
   2  * @file  l7vs_lsock.h
   3  * @brief The listening socket is managed.
   4  *
   5  *
   6  * L7VSD: Linux Virtual Server for Layer7 Load Balancing
   7  * Copyright (C) 2005  NTT COMWARE Corporation.
   8  *
   9  * This program is free software; you can redistribute it and/or
  10  * modify it under the terms of the GNU Lesser General Public
  11  * License as published by the Free Software Foundation; either
  12  * version 2.1 of the License, or (at your option) any later version.
  13  *
  14  * This program is distributed in the hope that it will be useful,
  15  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  17  * Lesser General Public License for more details.
  18  *
  19  * You should have received a copy of the GNU Lesser General Public
  20  * License along with this library; if not, write to the Free Software
  21  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
  22  * 02110-1301 USA
  23  *
  24  **********************************************************************/
  25 #ifndef L7VS_LSOCK_H
  26 #define L7VS_LSOCK_H
  27
  28 #include <netinet/in.h>
  29 #include <glib.h>
  30 #include <stdint.h>
  31 #include "l7vs_iom.h"
  32
  33 // listen socket datatype. accepts client connections.
  34 struct  l7vs_lsock{
  35         struct  sockaddr_in     addr;
  36         uint8_t                 proto;
  37         struct  l7vs_iomux*     iom;
  38         int                     refcnt;
  39         int                     fast_schedule;
  40         GList*                  srv_list;
  41 };
  42
  43 struct  l7vs_service;
  44 struct  l7vs_conn;
  45 struct  l7vs_dest;
  46
  47 //
  48 // functions
  49 //
  50 extern  int                     l7vs_lsock_init();
  51 extern  void                    l7vs_lsock_fini();
  52 extern  struct l7vs_lsock*      l7vs_lsock_get( struct sockaddr_in*, uint8_t, int );
  53 extern  void                    l7vs_lsock_put( struct l7vs_lsock* );
  54 extern  struct l7vs_lsock*      l7vs_lsock_table_lookup( struct sockaddr_in*, uint8_t );
  55 extern  void                    l7vs_lsock_add_service( struct l7vs_lsock*, struct l7vs_service* );
  56 extern  void                    l7vs_lsock_remove_service( struct l7vs_lsock*, struct l7vs_service* );
  57
  58 extern  int             l7vs_lsock_select_service(
  59                                 struct l7vs_lsock*,
  60                                 struct l7vs_conn*,
  61                                 char*,
  62                                 size_t,
  63                                 struct l7vs_service**,
  64                                 struct l7vs_dest**);
  65 /*!
  66  * serialize struct sockaddr_in
  67  *
  68  * @param[out]  ret     serialized string
  69  * @param[in]   dest    source sockaddr_in
  70  * @return      void
  71  */
  72 inline  void l7vs_lsock_sockaddr_in_c_str(char* ret, const struct sockaddr_in* addr)
  73 {
  74         if (!addr) {
  75                 snprintf(ret, DEBUG_STR_LEN, "(nil)");
  76                 return;
  77         }
  78
  79         snprintf(ret, DEBUG_STR_LEN,
  80                 "sockaddr_in="
  81                 "{sin_addr=%s: "
  82                 "sin_port=%d}"
  83                 , inet_ntoa(addr->sin_addr)
  84                 , ntohs(addr->sin_port));
  85 }
  86
  87 /*!
  88  * serialize struct l7vs_lsock
  89  *
  90  * @param[out]  ret     serialized string
  91  * @param[in]   lsock    source l7vs_lsock
  92  * @return      void
  93  */
  94 inline  void l7vs_lsock_c_str(char* ret, const struct l7vs_lsock* lsock)
  95 {
  96         char addr_str[DEBUG_STR_LEN];
  97         char iomux_str[DEBUG_STR_LEN];
  98
  99         if(!lsock){
 100                 snprintf(ret, DEBUG_STR_LEN, "(nil)");
 101                 return;
 102         }
 103
 104         l7vs_lsock_sockaddr_in_c_str(addr_str,&(lsock->addr));
 105         l7vs_iomux_c_str(iomux_str,lsock->iom);
 106         snprintf(ret, DEBUG_STR_LEN,
 107                 "lsock = %p"
 108                 "addr = %s: "
 109                 "proto= %d: "
 110                 "iom= %s: "
 111                 "refcnt= %d: "
 112                 "srv_list= %p: ",
 113                 lsock,
 114                 addr_str,
 115                 lsock->proto,
 116                 iomux_str,
 117                 lsock->refcnt,
 118                 lsock->srv_list);
 119 }
 120
 121 #endif  //L7VS_LSOCK_H
 122