/*$Id: gflags.c,v 1.5 2004/12/03 19:09:32 andrei Exp $ * * gflags module: global flags; it keeps a bitmap of flags * in shared memory and may be used to change behaviour * of server based on value of the flags. E.g., * if (is_gflag("1")) { t_relay_to_udp("10.0.0.1","5060"); } * else { t_relay_to_udp("10.0.0.2","5060"); } * The benefit of this module is the value of the switch flags * can be manipulated by external applications such as web interface * or command line tools. * * * Copyright (C) 2004 FhG * * This file is part of ser, a free SIP server. * * ser is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version * * For a license to use the ser software under conditions * other than those described here, or to purchase support for this * software, please contact iptel.org by e-mail at the following addresses: * info@iptel.org * * ser is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ /* * History: * -------- * 2004-09-09 initial module created (jiri) * * TODO * - flag range checking * - named flags (takes a protected name list) */ /* flag buffer size for FIFO protocool */ #define MAX_FLAG_LEN 12 /* FIFO action protocol names */ #define FIFO_SET_GFLAG "set_gflag" #define FIFO_IS_GFLAG "is_gflag" #define FIFO_RESET_GFLAG "reset_gflag" #include "../../sr_module.h" #include "../../error.h" #include "../../ut.h" #include "../../mem/mem.h" #include "../../mem/shm_mem.h" #include "../../fifo_server.h" #include MODULE_VERSION static int set_gflag(struct sip_msg*, char *, char *); static int reset_gflag(struct sip_msg*, char *, char *); static int is_gflag(struct sip_msg*, char *, char *); static int fixup_str2int( void** param, int param_no); static int mod_init(void); static int initial=0; static unsigned int *gflags; static cmd_export_t cmds[]={ {"set_gflag", /* action name as in scripts */ set_gflag, /* C function name */ 1, /* number of parameters */ fixup_str2int, /* */ /* can be applied to original/failed requests and replies */ REQUEST_ROUTE|FAILURE_ROUTE|ONREPLY_ROUTE}, {"reset_gflag", reset_gflag, 1, fixup_str2int, REQUEST_ROUTE|FAILURE_ROUTE|ONREPLY_ROUTE}, {"is_gflag", is_gflag, 1, fixup_str2int, REQUEST_ROUTE|FAILURE_ROUTE|ONREPLY_ROUTE}, {0, 0, 0, 0, 0} }; static param_export_t params[]={ {"initial", INT_PARAM, &initial}, {0,0,0} }; struct module_exports exports = { "gflags", cmds, params, mod_init, /* module initialization function */ 0, /* response function*/ 0, /* destroy function */ 0, /* oncancel function */ 0 /* per-child init function */ }; /**************************** fixup functions ******************************/ static int fixup_str2int( void** param, int param_no) { unsigned int *myint; str param_str; /* we only fix the parameter #1 */ if (param_no!=1) return 0; myint=(unsigned int *) pkg_malloc(sizeof(unsigned int)); if (!myint) { LOG(L_ERR, "ERROR: gflags initi: no memory\n"); return -1; } param_str.s=(char*) *param; param_str.len=strlen(param_str.s); if (str2int(¶m_str, myint )<0) { LOG(L_ERR, "ERROR: fixup_str2int: bad number <%s>\n", (char *)(*param)); return E_CFG; } /* success -- change to int */ pkg_free(*param); *param=(void *)myint; return 0; } static unsigned int read_flag(FILE *pipe, char *response_file) { char flag_str[MAX_FLAG_LEN]; int flag_len; unsigned int flag_nr; str fs; if (!read_line(flag_str, MAX_FLAG_LEN, pipe, &flag_len) || flag_len == 0) { fifo_reply(response_file, "400: gflags: invalid flag number\n"); LOG(L_ERR, "ERROR: read_flag: invalid flag number\n"); return 0; } fs.s=flag_str;fs.len=flag_len; if (str2int(&fs, &flag_nr) < 0) { fifo_reply(response_file, "400: gflags: invalid flag format\n"); LOG(L_ERR, "ERROR: read_flag: invalid flag format\n"); return 0; } return flag_nr; } static int fifo_set_gflag( FILE* pipe, char* response_file ) { unsigned int flag; flag=read_flag(pipe, response_file); if (!flag) { LOG(L_ERR, "ERROR: fifo_set_gflag: failed in read_flag\n"); return 1; } (*gflags) |= 1 << flag; fifo_reply (response_file, "200 OK\n"); return 1; } static int fifo_reset_gflag( FILE* pipe, char* response_file ) { unsigned int flag; flag=read_flag(pipe, response_file); if (!flag) { LOG(L_ERR, "ERROR: fifo_reset_gflag: failed in read_flag\n"); return 1; } (*gflags) &= ~ (1 << flag); fifo_reply (response_file, "200 OK\n"); return 1; } static int fifo_is_gflag( FILE* pipe, char* response_file ) { unsigned int flag; flag=read_flag(pipe, response_file); if (!flag) { LOG(L_ERR, "ERROR: fifo_reset_gflag: failed in read_flag\n"); return 1; } fifo_reply (response_file, "200 OK\n%s\n", ((*gflags) & (1<