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                                 int* );
  66 /*!
  67  * serialize struct sockaddr_in
  68  *
  69  * @param[out]  ret     serialized string
  70  * @param[in]   dest    source sockaddr_in
  71  * @return      void
  72  */
  73 inline  void l7vs_lsock_sockaddr_in_c_str(char* ret, const struct sockaddr_in* addr)
  74 {
  75         if (!addr) {
  76                 snprintf(ret, DEBUG_STR_LEN, "(nil)");
  77                 return;
  78         }
  79
  80         snprintf(ret, DEBUG_STR_LEN,
  81                 "sockaddr_in="
  82                 "{sin_addr=%s: "
  83                 "sin_port=%d}"
  84                 , inet_ntoa(addr->sin_addr)
  85                 , ntohs(addr->sin_port));
  86 }
  87
  88 /*!
  89  * serialize struct l7vs_lsock
  90  *
  91  * @param[out]  ret     serialized string
  92  * @param[in]   lsock    source l7vs_lsock
  93  * @return      void
  94  */
  95 inline  void l7vs_lsock_c_str(char* ret, const struct l7vs_lsock* lsock)
  96 {
  97         char addr_str[DEBUG_STR_LEN];
  98         char iomux_str[DEBUG_STR_LEN];
  99
 100         if(!lsock){
 101                 snprintf(ret, DEBUG_STR_LEN, "(nil)");
 102                 return;
 103         }
 104
 105         l7vs_lsock_sockaddr_in_c_str(addr_str,&(lsock->addr));
 106         l7vs_iomux_c_str(iomux_str,lsock->iom);
 107         snprintf(ret, DEBUG_STR_LEN,
 108                 "lsock = %p"
 109                 "addr = %s: "
 110                 "proto= %d: "
 111                 "iom= %s: "
 112                 "refcnt= %d: "
 113                 "srv_list= %p: ",
 114                 lsock,
 115                 addr_str,
 116                 lsock->proto,
 117                 iomux_str,
 118                 lsock->refcnt,
 119                 lsock->srv_list);
 120 }
 121
 122 #endif  //L7VS_LSOCK_H
 123