res_pktccops.c File Reference

PacketCable COPS. More...

#include "asterisk.h"
#include <sys/types.h>
#include <sys/socket.h>
#include <fcntl.h>
#include <netdb.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <time.h>
#include <errno.h>
#include <arpa/inet.h>
#include <signal.h>
#include "asterisk/file.h"
#include "asterisk/logger.h"
#include "asterisk/channel.h"
#include "asterisk/config.h"
#include "asterisk/options.h"
#include "asterisk/pbx.h"
#include "asterisk/module.h"
#include "asterisk/cli.h"
#include "asterisk/lock.h"
#include "asterisk/pktccops.h"

Include dependency graph for res_pktccops.c:

Go to the source code of this file.

Data Structures
struct	cmts_list
struct	cops_cmts
struct	cops_ippool
struct	copsmsg
struct	gate_list
struct	gatespec
struct	ippool_list
struct	pktcobj

Macros
#define	AST_API_MODULE
#define	COPS_HEADER_SIZE   8
#define	COPS_OBJECT_HEADER_SIZE   4
#define	DEFAULT_COPS_PORT   "2126"
#define	GATE_INFO_OBJ_SIZE   24
#define	GATE_SET_OBJ_SIZE   144
#define	GATEID_OBJ_SIZE   8
#define	PKTCCOPS_DESTROY_CURRENT_GATE
#define	PKTCCOPS_SCOMMAND_GATE_ALLOC   1
#define	PKTCCOPS_SCOMMAND_GATE_ALLOC_ACK   2
#define	PKTCCOPS_SCOMMAND_GATE_ALLOC_ERR   3
#define	PKTCCOPS_SCOMMAND_GATE_CLOSE   14
#define	PKTCCOPS_SCOMMAND_GATE_DELETE   10
#define	PKTCCOPS_SCOMMAND_GATE_DELETE_ACK   11
#define	PKTCCOPS_SCOMMAND_GATE_DELETE_ERR   12
#define	PKTCCOPS_SCOMMAND_GATE_INFO   7
#define	PKTCCOPS_SCOMMAND_GATE_INFO_ACK   8
#define	PKTCCOPS_SCOMMAND_GATE_INFO_ERR   9
#define	PKTCCOPS_SCOMMAND_GATE_OPEN   13
#define	PKTCCOPS_SCOMMAND_GATE_SET   4
#define	PKTCCOPS_SCOMMAND_GATE_SET_ACK   5
#define	PKTCCOPS_SCOMMAND_GATE_SET_ERR   6
#define	SENDFLAGS   MSG_NOSIGNAL | MSG_DONTWAIT

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
struct ast_module *	AST_MODULE_SELF_SYM (void)
struct cops_gate *AST_OPTIONAL_API_NAME()	ast_pktccops_gate_alloc (int cmd, struct cops_gate *gate, uint32_t mta, uint32_t actcount, float bitrate, uint32_t psize, uint32_t ssip, uint16_t ssport, int(*const got_dq_gi)(struct cops_gate *gate), int(*const gate_remove)(struct cops_gate *gate))
static int	cops_connect (char *host, char *port)
static uint16_t	cops_construct_gate (int cmd, char *p, uint16_t trid, uint32_t mtahost, uint32_t actcount, float rate, uint32_t psizegateid, uint32_t ssip, uint16_t ssport, uint32_t gateid, struct cops_cmts *cmts)
static uint16_t	cops_constructgatespec (struct gatespec *gs, char *res)
static void	cops_freemsg (struct copsmsg *p)
static struct cops_gate *	cops_gate_cmd (int cmd, struct cops_cmts *cmts, uint16_t trid, uint32_t mta, uint32_t actcount, float bitrate, uint32_t psize, uint32_t ssip, uint16_t ssport, struct cops_gate *gate)
static int	cops_getmsg (int sfd, struct copsmsg *recmsg)
static int	cops_sendmsg (int sfd, struct copsmsg *sendmsg)
static void *	do_pktccops (void *data)
static uint32_t	ftoieeef (float n)
static int	load_module (void)
static int	load_pktccops_config (void)
static int	pktccops_add_ippool (struct cops_ippool *ippool)
static char *	pktccops_debug (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	pktccops_gatedel (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	pktccops_gateset (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	pktccops_show_cmtses (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	pktccops_show_gates (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	pktccops_show_pools (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static void	pktccops_unregister_cmtses (void)
static void	pktccops_unregister_ippools (void)
static int	reload_module (void)
static int	restart_pktc_thread (void)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_GLOBAL_SYMBOLS , .description = "PktcCOPS manager for MGCP" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload_module, }
static const struct ast_module_info *	ast_module_info = &__mod_info
static struct ast_cli_entry	cli_pktccops []
struct cmts_list	cmts_list = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }
static uint16_t	cops_trid = 0
struct gate_list	gate_list = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }
static int	gateinfoperiod = 60
static int	gatetimeout = 150
struct ippool_list	ippool_list = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }
static uint32_t	keepalive = 60
static ast_mutex_t	pktccops_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }
static pthread_t	pktccops_thread = AST_PTHREADT_NULL
static int	pktccopsdebug = 0
static int	pktcreload = 0
static uint16_t	t1 = 250
static uint16_t	t7 = 200
static uint16_t	t8 = 300

Detailed Description

PacketCable COPS.

Author

Attila Domjan attil.nosp@m.a.do.nosp@m.mjan..nosp@m.hu@g.nosp@m.mail..nosp@m.com

Note

This module is an add-on to chan_mgcp. It adds support for the PacketCable MGCP variation called NCS. Res_pktccops implements COPS (RFC 2748), a protocol used to manage dynamic bandwith allocation in CMTS's (HFC gateways). When you use NCS, you need to talk COPS with the CMTS to complete the calls.

Definition in file res_pktccops.c.

Macro Definition Documentation

AST_API_MODULE

#define AST_API_MODULE

Definition at line 62 of file res_pktccops.c.

COPS_HEADER_SIZE

#define COPS_HEADER_SIZE   8

Definition at line 67 of file res_pktccops.c.

Referenced by cops_gate_cmd(), cops_getmsg(), cops_sendmsg(), and do_pktccops().

COPS_OBJECT_HEADER_SIZE

#define COPS_OBJECT_HEADER_SIZE   4

Definition at line 68 of file res_pktccops.c.

Referenced by cops_gate_cmd(), cops_getmsg(), and do_pktccops().

DEFAULT_COPS_PORT

#define DEFAULT_COPS_PORT   "2126"

Definition at line 65 of file res_pktccops.c.

Referenced by load_pktccops_config().

GATE_INFO_OBJ_SIZE

#define GATE_INFO_OBJ_SIZE   24

Definition at line 71 of file res_pktccops.c.

Referenced by cops_gate_cmd().

GATE_SET_OBJ_SIZE

#define GATE_SET_OBJ_SIZE   144

Definition at line 69 of file res_pktccops.c.

Referenced by cops_gate_cmd().

GATEID_OBJ_SIZE

#define GATEID_OBJ_SIZE   8

Definition at line 70 of file res_pktccops.c.

Referenced by cops_gate_cmd().

PKTCCOPS_DESTROY_CURRENT_GATE

#define PKTCCOPS_DESTROY_CURRENT_GATE

Value:

AST_LIST_REMOVE_CURRENT(list);  \
      if (gate->gate_remove) {        \
         gate->gate_remove(gate);    \
      }                               \
      ast_free(gate);

Definition at line 692 of file res_pktccops.c.

Referenced by do_pktccops().

PKTCCOPS_SCOMMAND_GATE_ALLOC

#define PKTCCOPS_SCOMMAND_GATE_ALLOC   1

Definition at line 73 of file res_pktccops.c.

PKTCCOPS_SCOMMAND_GATE_ALLOC_ACK

#define PKTCCOPS_SCOMMAND_GATE_ALLOC_ACK   2

Definition at line 74 of file res_pktccops.c.

PKTCCOPS_SCOMMAND_GATE_ALLOC_ERR

#define PKTCCOPS_SCOMMAND_GATE_ALLOC_ERR   3

Definition at line 75 of file res_pktccops.c.

PKTCCOPS_SCOMMAND_GATE_CLOSE

#define PKTCCOPS_SCOMMAND_GATE_CLOSE   14

Definition at line 86 of file res_pktccops.c.

Referenced by do_pktccops().

PKTCCOPS_SCOMMAND_GATE_DELETE

#define PKTCCOPS_SCOMMAND_GATE_DELETE   10

Definition at line 82 of file res_pktccops.c.

Referenced by cops_construct_gate().

PKTCCOPS_SCOMMAND_GATE_DELETE_ACK

#define PKTCCOPS_SCOMMAND_GATE_DELETE_ACK   11

Definition at line 83 of file res_pktccops.c.

Referenced by do_pktccops().

PKTCCOPS_SCOMMAND_GATE_DELETE_ERR

#define PKTCCOPS_SCOMMAND_GATE_DELETE_ERR   12

Definition at line 84 of file res_pktccops.c.

PKTCCOPS_SCOMMAND_GATE_INFO

#define PKTCCOPS_SCOMMAND_GATE_INFO   7

Definition at line 79 of file res_pktccops.c.

Referenced by cops_construct_gate().

PKTCCOPS_SCOMMAND_GATE_INFO_ACK

#define PKTCCOPS_SCOMMAND_GATE_INFO_ACK   8

Definition at line 80 of file res_pktccops.c.

Referenced by do_pktccops().

PKTCCOPS_SCOMMAND_GATE_INFO_ERR

#define PKTCCOPS_SCOMMAND_GATE_INFO_ERR   9

Definition at line 81 of file res_pktccops.c.

Referenced by do_pktccops().

PKTCCOPS_SCOMMAND_GATE_OPEN

#define PKTCCOPS_SCOMMAND_GATE_OPEN   13

Definition at line 85 of file res_pktccops.c.

Referenced by do_pktccops().

PKTCCOPS_SCOMMAND_GATE_SET

#define PKTCCOPS_SCOMMAND_GATE_SET   4

Definition at line 76 of file res_pktccops.c.

Referenced by cops_construct_gate().

PKTCCOPS_SCOMMAND_GATE_SET_ACK

#define PKTCCOPS_SCOMMAND_GATE_SET_ACK   5

Definition at line 77 of file res_pktccops.c.

Referenced by do_pktccops().

PKTCCOPS_SCOMMAND_GATE_SET_ERR

#define PKTCCOPS_SCOMMAND_GATE_SET_ERR   6

Definition at line 78 of file res_pktccops.c.

Referenced by do_pktccops().

SENDFLAGS

#define SENDFLAGS   MSG_NOSIGNAL | MSG_DONTWAIT

Referenced by cops_sendmsg().

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 1516 of file res_pktccops.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 1516 of file res_pktccops.c.

AST_MODULE_SELF_SYM()

struct ast_module* AST_MODULE_SELF_SYM

(

void

)

Definition at line 1516 of file res_pktccops.c.

ast_pktccops_gate_alloc()

struct cops_gate* AST_OPTIONAL_API_NAME() ast_pktccops_gate_alloc	(	int	cmd,
		struct cops_gate *	gate,
		uint32_t	mta,
		uint32_t	actcount,
		float	bitrate,
		uint32_t	psize,
		uint32_t	ssip,
		uint16_t	ssport,
		int(*)(struct cops_gate *gate)	got_dq_gi,
		int(*)(struct cops_gate *gate)	gate_remove
	)

Definition at line 468 of file res_pktccops.c.

References ast_debug, ast_log, cops_gate_cmd(), cops_trid, cops_gate::gate_remove, GATE_SET_HAVE_GATEID, cops_gate::gateid, cops_gate::got_dq_gi, LOG_WARNING, cops_gate::mta, NULL, and pktcreload.

Referenced by mgcp_alloc_pktcgate(), and mgcp_hangup().

{
   while (pktcreload) {
      sched_yield();
   }

   if (cmd == GATE_SET_HAVE_GATEID && gate) {
      ast_debug(3, "------- gate modify gateid 0x%x ssip: 0x%x\n", gate->gateid, ssip);
      /* TODO implement it */
      ast_log(LOG_WARNING, "Modify GateID not implemented\n");
   }

   if ((gate = cops_gate_cmd(cmd, NULL, cops_trid++, mta, actcount, bitrate, psize, ssip, ssport, gate))) {
      ast_debug(3, "COPS: Allocating gate for mta: 0x%x\n", mta);
      gate->got_dq_gi = got_dq_gi;
      gate->gate_remove = gate_remove;
      return(gate);
   } else {
      ast_debug(3, "COPS: Couldn't allocate gate for mta: 0x%x\n", mta);
      return NULL;
   }
}

cops_connect()

static int cops_connect ( char *  host, char *  port  )

static

Definition at line 649 of file res_pktccops.c.

References ast_debug, ast_fd_set_flags, ast_log, LOG_WARNING, NULL, and result.

Referenced by do_pktccops().

{
   int s, sfd = -1;
   struct addrinfo hints;
   struct addrinfo *rp;
   struct addrinfo *result;
#ifdef HAVE_SO_NOSIGPIPE
   int trueval = 1;
#endif

   memset(&hints, 0, sizeof(struct addrinfo));

   hints.ai_family = AF_UNSPEC;
   hints.ai_socktype = SOCK_STREAM;
   hints.ai_flags = 0;
   hints.ai_protocol = 0;

   s = getaddrinfo(host, port, &hints, &result);
   if (s != 0) {
      ast_log(LOG_WARNING, "COPS: getaddrinfo: %s\n", gai_strerror(s));
      return -1;
   }

   for (rp = result; rp != NULL; rp = rp->ai_next) {
      sfd = socket(rp->ai_family, rp->ai_socktype, rp->ai_protocol);
      if (sfd == -1) {
         ast_log(LOG_WARNING, "Failed socket\n");
      }
      ast_fd_set_flags(sfd, O_NONBLOCK);
#ifdef HAVE_SO_NOSIGPIPE
      setsockopt(sfd, SOL_SOCKET, SO_NOSIGPIPE, &trueval, sizeof(trueval));
#endif
      connect(sfd, rp->ai_addr, rp->ai_addrlen);
      if (sfd == -1) {
         ast_log(LOG_WARNING, "Failed connect\n");
      }
   }
   freeaddrinfo(result);

   ast_debug(3, "Connecting to cmts:  %s:%s\n", host, port);
   return(sfd);
}

cops_construct_gate()

static uint16_t cops_construct_gate ( int  cmd, char *  p, uint16_t  trid, uint32_t  mtahost, uint32_t  actcount, float  rate, uint32_t  psizegateid, uint32_t  ssip, uint16_t  ssport, uint32_t  gateid, struct cops_cmts *  cmts  )

static

Definition at line 221 of file res_pktccops.c.

References ast_debug, gatespec::b, cops_constructgatespec(), gatespec::diffserv, gatespec::direction, gatespec::dstip, gatespec::dstp, gatespec::flags, ftoieeef(), GATE_DEL, GATE_INFO, GATE_SET_HAVE_GATEID, gatespec::m, gatespec::mm, gatespec::p, PKTCCOPS_SCOMMAND_GATE_DELETE, PKTCCOPS_SCOMMAND_GATE_INFO, PKTCCOPS_SCOMMAND_GATE_SET, gatespec::protocolid, gatespec::r, gatespec::rate, gatespec::s, gatespec::sessionclass, gatespec::srcip, gatespec::srcp, gatespec::t1, cops_cmts::t1, gatespec::t7, cops_cmts::t7, gatespec::t8, and cops_cmts::t8.

Referenced by cops_gate_cmd().

{
   struct gatespec gs;
   int offset = 0;

   ast_debug(3, "CMD: %d\n", cmd);

   /* Transaction Identifier 8 octets */
   *(p + offset++) = 0;
   *(p + offset++) = 8; /* length */
   *(p + offset++) = 1; /* snum */
   *(p + offset++) = 1; /* stype */
   *((uint16_t *) (p + offset)) = htons(trid);
   offset += 2;
   *(p + offset++) = 0;
   *(p + offset++) = (cmd == GATE_DEL) ? PKTCCOPS_SCOMMAND_GATE_DELETE : (cmd != GATE_INFO) ? PKTCCOPS_SCOMMAND_GATE_SET : PKTCCOPS_SCOMMAND_GATE_INFO; /* 4: GATE-SET, 7: GATE-INFO */

   /*Subscriper Identifier 8 octets */
   *(p + offset++) = 0;
   *(p + offset++) = 8; /* length */
   *(p + offset++) = 2; /* snum */
   *(p + offset++) = 1; /* stype */
   *((uint32_t *) (p + offset)) = htonl(mtahost);
   offset += 4;

   if (cmd == GATE_INFO || cmd == GATE_SET_HAVE_GATEID || cmd == GATE_DEL) {
      /* Gate ID 8 Octets */
      *(p + offset++) = 0;
      *(p + offset++) = 8; /* length */
      *(p + offset++) = 3; /* snum */
      *(p + offset++) = 1; /* stype */
      *((uint32_t *) (p + offset)) = htonl(gateid);
      offset += 4;
      if (cmd == GATE_INFO || cmd == GATE_DEL) {
         return offset;
      }

   }

   /* Activity Count 8 octets */
   *(p + offset++) = 0;
   *(p + offset++) = 8; /* length */
   *(p + offset++) = 4; /* snum */
   *(p + offset++) = 1; /* stype */
   *((uint32_t *) (p + offset)) = htonl(actcount);
   offset += 4;


   /* Gate Spec 2*60 Octets */
   gs.direction = 0; /* DS */
   gs.protocolid = 17; /* UDP */
   gs.flags = 0;
   gs.sessionclass = 1;
   gs.srcip = htonl(ssip);
   gs.dstip = htonl(mtahost);
   gs.srcp = htons(ssport);
   gs.dstp = 0;
/* gs.diffserv = 0xa0;*/
   gs.diffserv = 0;
   gs.t1 = htons(cmts->t1);
   gs.t7 = htons(cmts->t7);
   gs.t8 = htons(cmts->t8);
   gs.r = ftoieeef(rate);
   gs.b = ftoieeef(psizegateid);
   gs.p = ftoieeef(rate);
   gs.m = htonl((uint32_t) psizegateid);
   gs.mm = htonl((uint32_t) psizegateid);
   gs.rate = ftoieeef(rate);
   gs.s = htonl(800);


   *(p + offset) = 0;
   offset++;
   *(p + offset) = 60; /* length */
   offset++;
   *(p + offset) = 5; /* snum */
   offset++;
   *(p + offset) = 1; /* stype */
   offset++;
   offset += cops_constructgatespec(&gs, p + offset);


   gs.direction = 1; /* US */
   gs.srcip = htonl(mtahost);
   gs.dstip = htonl(ssip);
   gs.srcp = 0;
   gs.dstp = htons(ssport);
   *(p + offset) = 0;
   offset++;
   *(p + offset) = 60; /* length */
   offset++;
   *(p + offset) = 5; /* snum */
   offset++;
   *(p + offset) = 1; /* stype */
   offset++;
   offset += cops_constructgatespec(&gs, p + offset);

   return(offset);
}

cops_constructgatespec()

static uint16_t cops_constructgatespec ( struct gatespec *  gs, char *  res  )

static

Definition at line 182 of file res_pktccops.c.

References gatespec::b, gatespec::diffserv, gatespec::direction, gatespec::dstip, gatespec::dstp, gatespec::flags, gatespec::m, gatespec::mm, NULL, gatespec::p, gatespec::protocolid, gatespec::r, gatespec::rate, gatespec::s, gatespec::sessionclass, gatespec::srcip, gatespec::srcp, gatespec::t1, gatespec::t7, and gatespec::t8.

Referenced by cops_construct_gate().

{
   if (res == NULL) {
      return 0;
   }

   *res = (char) gs->direction;
   *(res + 1) = (char) gs->protocolid;
   *(res + 2) = (char) gs->flags;
   *(res + 3) = (char) gs->sessionclass;

   *((uint32_t *) (res + 4)) = gs->srcip;
   *((uint32_t *) (res + 8)) = gs->dstip;

   *((uint16_t *) (res + 12)) = gs->srcp;
   *((uint16_t *) (res + 14)) = gs->dstp;

   *(res + 16) = (char) gs->diffserv;
   *(res + 17) = 0; /* reserved */
   *(res + 18) = 0; /* reserved */
   *(res + 19) = 0; /* reserved */

   *((uint16_t *) (res + 20)) = gs->t1;
   *(res + 22) = 0; /* reserved */
   *(res + 23) = 0; /* reserved */

   *((uint16_t *) (res + 24)) = gs->t7;
   *((uint16_t *) (res + 26)) = gs->t8;

   *((uint32_t *) (res + 28)) = gs->r;
   *((uint32_t *) (res + 32)) = gs->b;
   *((uint32_t *) (res + 36)) = gs->p;
   *((uint32_t *) (res + 40)) = gs->m;
   *((uint32_t *) (res + 44)) = gs->mm;
   *((uint32_t *) (res + 48)) = gs->rate;
   *((uint32_t *) (res + 52)) = gs->s;
   return 56; /* length */
};

cops_freemsg()

static void cops_freemsg ( struct copsmsg *  p )

static

Definition at line 453 of file res_pktccops.c.

References ast_free, pktcobj::contents, copsmsg::msg, pktcobj::next, NULL, and copsmsg::object.

Referenced by cops_gate_cmd(), and do_pktccops().

{
   struct pktcobj *pnext;
   ast_free(p->msg);
   p->msg = NULL;
   while (p->object != NULL) {
         pnext = p->object->next;
         ast_free(p->object->contents);
         p->object->contents = NULL;
         ast_free(p->object);
         p->object = pnext;
   }
   p->object = NULL;
}

cops_gate_cmd()

static struct cops_gate * cops_gate_cmd ( int  cmd, struct cops_cmts *  cmts, uint16_t  trid, uint32_t  mta, uint32_t  actcount, float  bitrate, uint32_t  psize, uint32_t  ssip, uint16_t  ssport, struct cops_gate *  gate  )

static

Definition at line 495 of file res_pktccops.c.

References ast_calloc, ast_debug, ast_free, AST_LIST_INSERT_HEAD, AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_log, ast_malloc, copsmsg::clienttype, cops_gate::cmts, cops_ippool::cmts, pktcobj::cnum, pktcobj::contents, cops_construct_gate(), cops_freemsg(), COPS_HEADER_SIZE, COPS_OBJECT_HEADER_SIZE, cops_sendmsg(), pktcobj::ctype, GATE_ALLOC_PROGRESS, GATE_DEL, GATE_INFO, GATE_INFO_OBJ_SIZE, GATE_SET, GATE_SET_HAVE_GATEID, GATE_SET_OBJ_SIZE, cops_gate::gateid, GATEID_OBJ_SIZE, cops_cmts::handle, cops_gate::in_transaction, pktcobj::length, copsmsg::length, cops_ippool::list, LOG_WARNING, copsmsg::msg, cops_cmts::name, pktcobj::next, NULL, copsmsg::object, copsmsg::opcode, pktccopsdebug, cops_cmts::sfd, cops_ippool::start, stop, cops_gate::trid, and copsmsg::verflag.

Referenced by ast_pktccops_gate_alloc(), do_pktccops(), pktccops_gatedel(), and pktccops_gateset().

{
   struct copsmsg *gateset;
   struct cops_gate *new;
   struct cops_ippool *ippool;

   if (cmd == GATE_DEL) {
      if (gate == NULL) {
         return NULL;
      } else {
         cmts = gate->cmts;
      }
   }

   if (!cmts) {
      AST_LIST_LOCK(&ippool_list);
      AST_LIST_TRAVERSE(&ippool_list, ippool, list) {
         if (mta >= ippool->start && mta <= ippool->stop) {
            cmts = ippool->cmts;
            break;
         }
      }
      AST_LIST_UNLOCK(&ippool_list);
      if (!cmts) {
         ast_log(LOG_WARNING, "COPS: couldn't find cmts for mta: 0x%x\n", mta);
         return NULL;
      }
      if (cmts->sfd < 0) {
         ast_log(LOG_WARNING, "CMTS: %s not connected\n", cmts->name);
         return NULL;
      }
   }

   if (cmd == GATE_SET) {
      new = ast_calloc(1, sizeof(*new));
      new->gateid = 0;
      new->trid = trid;
      new->mta = mta;
      new->state = GATE_ALLOC_PROGRESS;
      new->checked = time(NULL);
      new->allocated = time(NULL);
      new->cmts = cmts;
      new->got_dq_gi = NULL;
      new->gate_remove = NULL;
      new->gate_open = NULL;
      new->tech_pvt = NULL;
      new->deltimer = 0;
      AST_LIST_LOCK(&gate_list);
      AST_LIST_INSERT_HEAD(&gate_list, new, list);
      AST_LIST_UNLOCK(&gate_list);
      gate = new;
   } else {
      if (gate) {
         gate->trid = trid;
      }
   }

   gate->in_transaction = time(NULL);

   if (!(gateset = ast_malloc(sizeof(struct copsmsg)))) {
      ast_free(gateset);
      return NULL;
   }
   gateset->msg = NULL;
   gateset->verflag = 0x10;
   gateset->opcode = 2; /* Decision */
   gateset->clienttype = 0x8008; /* =PacketCable */

   /* Handle object */
   gateset->object = ast_malloc(sizeof(struct pktcobj));
   if (!gateset->object) {
      cops_freemsg(gateset);
      ast_free(gateset);
      return NULL;
   }
   gateset->object->length = COPS_OBJECT_HEADER_SIZE + 4;
   gateset->object->cnum = 1; /* Handle */
   gateset->object->ctype = 1; /* client */
   if (!(gateset->object->contents = ast_malloc(sizeof(uint32_t)))) {
      cops_freemsg(gateset);
      ast_free(gateset);
      return NULL;
   }
   *((uint32_t *) gateset->object->contents) = htonl(cmts->handle);

   /* Context Object */
   if (!(gateset->object->next = ast_malloc(sizeof(struct pktcobj)))) {
      cops_freemsg(gateset);
      ast_free(gateset);
      return NULL;
   }
   gateset->object->next->length = COPS_OBJECT_HEADER_SIZE + 4;
   gateset->object->next->cnum = 2; /* Context */
   gateset->object->next->ctype = 1; /* Context */
   if (!(gateset->object->next->contents = ast_malloc(sizeof(uint32_t)))) {
      cops_freemsg(gateset);
      ast_free(gateset);
      return NULL;
   }
   *((uint32_t *) gateset->object->next->contents) = htonl(0x00080000); /* R-Type = 8 configuration request, M-Type = 0 */

   /* Decision Object: Flags */
   if (!(gateset->object->next->next = ast_malloc(sizeof(struct pktcobj)))) {
      cops_freemsg(gateset);
      ast_free(gateset);
      return NULL;
   }
   gateset->object->next->next->length = COPS_OBJECT_HEADER_SIZE + 4;
   gateset->object->next->next->cnum = 6; /* Decision */
   gateset->object->next->next->ctype = 1; /* Flags */
   if (!(gateset->object->next->next->contents = ast_malloc(sizeof(uint32_t)))) {
      cops_freemsg(gateset);
      ast_free(gateset);
      return NULL;
   }
   *((uint32_t *) gateset->object->next->next->contents) = htonl(0x00010001); /* Install, Trigger Error */

   /* Decision Object: Data */
   if (!(gateset->object->next->next->next = ast_malloc(sizeof(struct pktcobj)))) {
      cops_freemsg(gateset);
      ast_free(gateset);
      return NULL;
   }
   gateset->object->next->next->next->length = COPS_OBJECT_HEADER_SIZE + ((cmd != GATE_INFO && cmd != GATE_DEL) ? GATE_SET_OBJ_SIZE : GATE_INFO_OBJ_SIZE) + ((cmd == GATE_SET_HAVE_GATEID) ? GATEID_OBJ_SIZE : 0);
   gateset->object->next->next->next->cnum = 6; /* Decision */
   gateset->object->next->next->next->ctype = 4; /* Decision Data */
   gateset->object->next->next->next->contents = ast_malloc(((cmd != GATE_INFO && cmd != GATE_DEL) ? GATE_SET_OBJ_SIZE : GATE_INFO_OBJ_SIZE) + ((cmd == GATE_SET_HAVE_GATEID) ? GATEID_OBJ_SIZE : 0));
   if (!gateset->object->next->next->next->contents) {
      cops_freemsg(gateset);
      ast_free(gateset);
      return NULL;
   }
   gateset->object->next->next->next->next = NULL;

   gateset->length = COPS_HEADER_SIZE + gateset->object->length + gateset->object->next->length + gateset->object->next->next->length + gateset->object->next->next->next->length;

   if ((cmd == GATE_INFO || cmd == GATE_SET_HAVE_GATEID || cmd == GATE_DEL) && gate) {
      ast_debug(1, "Construct gate with gateid: 0x%x\n", gate->gateid);
      cops_construct_gate(cmd, gateset->object->next->next->next->contents, trid, mta, actcount, bitrate, psize, ssip, ssport, gate->gateid, cmts);
   } else {
      ast_debug(1, "Construct new gate\n");
      cops_construct_gate(cmd, gateset->object->next->next->next->contents, trid, mta, actcount, bitrate, psize, ssip, ssport, 0, cmts);
   }
   if (pktccopsdebug) {
      ast_debug(3, "send cmd\n");
   }
   cops_sendmsg(cmts->sfd, gateset);
   cops_freemsg(gateset);
   ast_free(gateset);
   return gate;
}

cops_getmsg()

static int cops_getmsg ( int  sfd, struct copsmsg *  recmsg  )

static

Definition at line 323 of file res_pktccops.c.

References ast_debug, ast_malloc, buf, copsmsg::clienttype, pktcobj::cnum, pktcobj::contents, COPS_HEADER_SIZE, COPS_OBJECT_HEADER_SIZE, pktcobj::ctype, len(), pktcobj::length, copsmsg::length, copsmsg::msg, pktcobj::next, NULL, copsmsg::object, copsmsg::opcode, and copsmsg::verflag.

Referenced by do_pktccops().

{
   int len, lent;
   char buf[COPS_HEADER_SIZE];
   struct pktcobj *pobject = NULL;
   uint16_t *ubuf = (uint16_t *) buf;
   recmsg->msg = NULL;
   recmsg->object = NULL;
   len = recv(sfd, buf, COPS_HEADER_SIZE, MSG_DONTWAIT);
   if (len < COPS_HEADER_SIZE) {
      return len;
   }
   recmsg->verflag = *buf;
   recmsg->opcode = *(buf + 1);
   recmsg->clienttype = ntohs(*((uint16_t *) (buf + 2)));
   recmsg->length = ntohl(*((uint32_t *) (buf + 4)));
   /* Eg KA msg*/
   if (recmsg->clienttype != 0x8008 ) {
      if (!(recmsg->msg = ast_malloc(recmsg->length - COPS_HEADER_SIZE))) {
         return -1;
      }
      lent = recv(sfd, recmsg->msg, recmsg->length - COPS_HEADER_SIZE, MSG_DONTWAIT);
      if (lent < recmsg->length - COPS_HEADER_SIZE) {
         return lent;
      }
      len += len;
   } else {
      /* PacketCable Objects */
      while (len < recmsg->length) {
         if (len == COPS_HEADER_SIZE) {
            /* 1st round */
            if (!(recmsg->object = ast_malloc(sizeof(struct pktcobj)))) {
               return -1;
            }
            pobject = recmsg->object;
         } else {
            if (!(pobject->next = ast_malloc(sizeof(struct pktcobj)))) {
               return -1;
            }
            pobject = pobject->next;
         }
         pobject->next = NULL;
         lent = recv(sfd, buf, COPS_OBJECT_HEADER_SIZE, MSG_DONTWAIT);
         if (lent < COPS_OBJECT_HEADER_SIZE) {
            ast_debug(3, "Too short object header len: %i\n", lent);
            return lent;
         }
         len += lent;
         pobject->length = ntohs(*ubuf);
         pobject->cnum = *(buf + 2);
         pobject->ctype = *(buf + 3);
         if (!(pobject->contents = ast_malloc(pobject->length - COPS_OBJECT_HEADER_SIZE))) {
            return -1;
         }
         lent = recv(sfd, pobject->contents, pobject->length - COPS_OBJECT_HEADER_SIZE, MSG_DONTWAIT);
         if (lent < pobject->length - COPS_OBJECT_HEADER_SIZE) {
            ast_debug(3, "Too short object content len: %i\n", lent);
            return lent;
         }
         len += lent;
      }
   }
   return len;
}

cops_sendmsg()

static int cops_sendmsg ( int  sfd, struct copsmsg *  sendmsg  )

static

Definition at line 388 of file res_pktccops.c.

References ast_debug, ast_free, ast_log, ast_malloc, buf, copsmsg::clienttype, pktcobj::cnum, pktcobj::contents, COPS_HEADER_SIZE, pktcobj::ctype, errno, pktcobj::length, copsmsg::length, LOG_WARNING, copsmsg::msg, pktcobj::next, NULL, copsmsg::object, copsmsg::opcode, SENDFLAGS, and copsmsg::verflag.

Referenced by cops_gate_cmd(), and do_pktccops().

{
   char *buf;
   int bufpos;
   struct pktcobj *pobject;

   if (sfd < 0) {
      return -1;
   }

   ast_debug(3, "COPS: sending opcode: %i len: %u\n", sendmsg->opcode, sendmsg->length);
   if (sendmsg->length < COPS_HEADER_SIZE) {
      ast_log(LOG_WARNING, "COPS: invalid msg size!!!\n");
      return -1;
   }
   if (!(buf = ast_malloc((size_t) sendmsg->length))) {
      return -1;
   }
   *buf = sendmsg->verflag ;
   *(buf + 1) = sendmsg->opcode;
   *((uint16_t *)(buf + 2)) = htons(sendmsg->clienttype);
   *((uint32_t *)(buf + 4)) = htonl(sendmsg->length);

   if (sendmsg->msg != NULL) {
      memcpy(buf + COPS_HEADER_SIZE, sendmsg->msg, sendmsg->length - COPS_HEADER_SIZE);
   } else if (sendmsg->object != NULL) {
      bufpos = 8;
      pobject = sendmsg->object;
      while(pobject != NULL) {
         ast_debug(3, "COPS: Sending Object : cnum: %i ctype %i len: %i\n", pobject->cnum, pobject->ctype, pobject->length);
         if (sendmsg->length < bufpos + pobject->length) {
            ast_log(LOG_WARNING, "COPS: Invalid msg size len: %u objectlen: %i\n", sendmsg->length, pobject->length);
            ast_free(buf);
            return -1;
         }
         *(uint16_t *) (buf + bufpos) = htons(pobject->length);
         *(buf + bufpos + 2) = pobject->cnum;
         *(buf + bufpos + 3) = pobject->ctype;
         if (sendmsg->length < pobject->length + bufpos) {
            ast_log(LOG_WARNING, "COPS: Error sum of object len more the msg len %u < %i\n", sendmsg->length, pobject->length + bufpos);
            ast_free(buf);
            return -1;
         }
         memcpy((buf + bufpos + 4), pobject->contents, pobject->length - 4);
         bufpos += pobject->length;
         pobject = pobject->next;
      }
   }

   errno = 0;
#ifdef HAVE_MSG_NOSIGNAL
#define  SENDFLAGS   MSG_NOSIGNAL | MSG_DONTWAIT
#else
#define  SENDFLAGS   MSG_DONTWAIT
#endif
   if (send(sfd, buf, sendmsg->length, SENDFLAGS) == -1) {
      ast_log(LOG_WARNING, "COPS: Send failed errno=%i\n", errno);
      ast_free(buf);
      return -2;
   }
#undef SENDFLAGS
   ast_free(buf);
   return 0;
}

do_pktccops()

static void* do_pktccops ( void *  data )

static

Definition at line 699 of file res_pktccops.c.

References ast_debug, ast_free, AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_log, ast_malloc, ast_poll, ast_poll_fd_index(), ast_realloc, cops_gate::checked, copsmsg::clienttype, cops_gate::cmts, pktcobj::cnum, pktcobj::contents, cops_connect(), cops_freemsg(), cops_gate_cmd(), cops_getmsg(), COPS_HEADER_SIZE, COPS_OBJECT_HEADER_SIZE, cops_sendmsg(), cops_trid, pktcobj::ctype, cops_gate::deltimer, GATE_ALLOC_FAILED, GATE_ALLOCATED, GATE_CLOSED, GATE_CLOSED_ERR, GATE_DEL, GATE_DELETED, GATE_INFO, GATE_OPEN, cops_gate::gate_open, GATE_TIMEOUT, cops_gate::gateid, gateinfoperiod, gatetimeout, cops_gate::got_dq_gi, cops_cmts::handle, cops_cmts::host, cops_gate::in_transaction, cops_cmts::katimer, cops_cmts::keepalive, len(), pktcobj::length, copsmsg::length, load_pktccops_config(), LOG_WARNING, copsmsg::msg, cops_gate::mta, cops_cmts::name, cops_cmts::need_delete, pktcobj::next, NULL, copsmsg::object, copsmsg::opcode, PKTCCOPS_DESTROY_CURRENT_GATE, PKTCCOPS_SCOMMAND_GATE_CLOSE, PKTCCOPS_SCOMMAND_GATE_DELETE_ACK, PKTCCOPS_SCOMMAND_GATE_INFO_ACK, PKTCCOPS_SCOMMAND_GATE_INFO_ERR, PKTCCOPS_SCOMMAND_GATE_OPEN, PKTCCOPS_SCOMMAND_GATE_SET_ACK, PKTCCOPS_SCOMMAND_GATE_SET_ERR, pktccops_unregister_ippools(), pktcreload, cops_cmts::port, cops_cmts::sfd, cops_gate::state, cops_cmts::state, tmp(), cops_gate::trid, and copsmsg::verflag.

Referenced by restart_pktc_thread().

{
   int res, nfds, len;
   struct copsmsg *recmsg, *sendmsg;
   struct copsmsg recmsgb, sendmsgb;
   struct pollfd *pfds = NULL, *tmp;
   struct pktcobj *pobject;
   struct cops_cmts *cmts;
   struct cops_gate *gate;
   char *sobjp;
   uint16_t snst, sobjlen, scommand, recvtrid, actcount, reason, subreason;
   uint32_t gateid, subscrid, pktcerror;
   time_t last_exec = 0;

   recmsg = &recmsgb;
   sendmsg = &sendmsgb;

   ast_debug(3, "COPS: thread started\n");

   for (;;) {
      ast_free(pfds);
      pfds = NULL;
      nfds = 0;
      AST_LIST_LOCK(&cmts_list);
      AST_LIST_TRAVERSE(&cmts_list, cmts, list) {
         if (last_exec != time(NULL)) {
            if (cmts->state == 2 && cmts->katimer + cmts->keepalive < time(NULL)) {
               ast_log(LOG_WARNING, "KA timer (%us) expired cmts: %s\n",  cmts->keepalive, cmts->name);
               cmts->state = 0;
               cmts->katimer = -1;
               close(cmts->sfd);
               cmts->sfd = -1;
            }
         }
         if (cmts->sfd > 0) {
            if (!(tmp = ast_realloc(pfds, (nfds + 1) * sizeof(*pfds)))) {
               continue;
            }
            pfds = tmp;
            pfds[nfds].fd = cmts->sfd;
            pfds[nfds].events = POLLIN;
            pfds[nfds].revents = 0;
            nfds++;
         } else {
            cmts->sfd = cops_connect(cmts->host, cmts->port);
            if (cmts->sfd > 0) {
               cmts->state = 1;
               if (cmts->sfd > 0) {
                  if (!(tmp = ast_realloc(pfds, (nfds + 1) * sizeof(*pfds)))) {
                     continue;
                  }
                  pfds = tmp;
                  pfds[nfds].fd = cmts->sfd;
                  pfds[nfds].events = POLLIN;
                  pfds[nfds].revents = 0;
                  nfds++;
               }
            }
         }
      }
      AST_LIST_UNLOCK(&cmts_list);

      if (last_exec != time(NULL)) {
         last_exec = time(NULL);
         AST_LIST_LOCK(&gate_list);
         AST_LIST_TRAVERSE_SAFE_BEGIN(&gate_list, gate, list) {
            if (gate) {
               if (gate->deltimer && gate->deltimer < time(NULL)) {
                  gate->deltimer = time(NULL) + 5;
                  gate->trid = cops_trid++;
                  cops_gate_cmd(GATE_DEL, gate->cmts, gate->trid, 0, 0, 0, 0, 0, 0, gate);
                  ast_debug(3, "COPS: requested Gate-Del: CMTS: %s gateid: 0x%x\n", (gate->cmts) ? gate->cmts->name : "null", gate->gateid);
               }
               if (time(NULL) - gate->checked > gatetimeout) {
                  ast_debug(3, "COPS: remove from list GATE, CMTS: %s gateid: 0x%x\n", (gate->cmts) ? gate->cmts->name : "null", gate->gateid);
                  gate->state = GATE_TIMEOUT;
                  PKTCCOPS_DESTROY_CURRENT_GATE;
               } else if (time(NULL) - gate->checked > gateinfoperiod && (gate->state == GATE_ALLOCATED || gate->state == GATE_OPEN)) {
                  if (gate->cmts && (!gate->in_transaction || ( gate->in_transaction + 5 ) < time(NULL))) {
                     gate->trid = cops_trid++;
                     ast_debug(3, "COPS: Gate-Info send to CMTS: %s gateid: 0x%x\n", gate->cmts->name, gate->gateid);
                     cops_gate_cmd(GATE_INFO, gate->cmts, gate->trid, gate->mta, 0, 0, 0, 0, 0, gate);
                  }
               }
            }
         }
         AST_LIST_TRAVERSE_SAFE_END;
         AST_LIST_UNLOCK(&gate_list);
      }

      if (pktcreload == 2) {
         pktcreload = 0;
      }
      if ((res = ast_poll(pfds, nfds, 1000))) {
         AST_LIST_LOCK(&cmts_list);
         AST_LIST_TRAVERSE(&cmts_list, cmts, list) {
            int idx;
            if ((idx = ast_poll_fd_index(pfds, nfds, cmts->sfd)) > -1 && (pfds[idx].revents & POLLIN)) {
               len = cops_getmsg(cmts->sfd, recmsg);
               if (len > 0) {
                  ast_debug(3, "COPS: got from %s:\n Header: versflag=0x%02hhx opcode=%i clienttype=0x%04hx msglength=%u\n",
                     cmts->name, recmsg->verflag,
                     recmsg->opcode, recmsg->clienttype, recmsg->length);
                  if (recmsg->object != NULL) {
                     pobject = recmsg->object;
                     while (pobject != NULL) {
                        ast_debug(3, " OBJECT: length=%i cnum=%i ctype=%i\n", pobject->length, pobject->cnum, pobject->ctype);
                        if (recmsg->opcode == 1 && pobject->cnum == 1 && pobject->ctype == 1 ) {
                           cmts->handle = ntohl(*((uint32_t *) pobject->contents));
                           ast_debug(3, "    REQ client handle: %u\n", cmts->handle);
                           cmts->state = 2;
                           cmts->katimer = time(NULL);
                        } else if (pobject->cnum == 9 && pobject->ctype == 1) {
                           sobjp = pobject->contents;
                           subscrid = 0;
                           recvtrid = 0;
                           scommand = 0;
                           pktcerror = 0;
                           actcount = 0;
                           gateid = 0;
                           reason = 0;
                           subreason = 0;
                           while (sobjp < (pobject->contents + pobject->length - 4)) {
                              sobjlen = ntohs(*((uint16_t *) sobjp));
                              snst = ntohs(*((uint16_t *) (sobjp + 2)));
                              ast_debug(3, "   S-Num S-type: 0x%.4x len: %i\n", (unsigned)snst, sobjlen);
                              if (snst == 0x0101 ) {
                                 recvtrid = ntohs(*((uint16_t *) (sobjp + 4)));
                                 scommand = ntohs(*((uint16_t *) (sobjp + 6)));
                                 ast_debug(3, "     Transaction Identifier command: %i trid %i\n", scommand, recvtrid);
                              } else if (snst == 0x0201) {
                                 subscrid = ntohl(*((uint32_t *) (sobjp + 4)));
                                 ast_debug(3, "     Subscriber ID: 0x%.8x\n", subscrid);
                              } else if (snst == 0x0301) {
                                 gateid = ntohl(*((uint32_t *) (sobjp + 4)));
                                 ast_debug(3, "      Gate ID: 0x%x 0x%.8x\n", gateid, gateid);
                              } else if (snst == 0x0401) {
                                 actcount = ntohs(*((uint16_t *) (sobjp + 6)));
                                 ast_debug(3, "      Activity Count: %i\n", actcount);
                              } else if (snst == 0x0901) {
                                 pktcerror = ntohl(*((uint32_t *) (sobjp + 4)));
                                 ast_debug(3, "      PKTC Error: 0x%.8x\n", pktcerror);
                              } else if (snst == 0x0d01) {
                                 reason = ntohs(*((uint16_t *) (sobjp + 4)));
                                 subreason = ntohs(*((uint16_t *) (sobjp + 6)));
                                 ast_debug(3, "      Reason: %d Subreason: %d\n", reason, subreason);
                              }
                              sobjp += sobjlen;
                              if (!sobjlen)
                                 break;
                           }
                           if (scommand == PKTCCOPS_SCOMMAND_GATE_CLOSE || scommand == PKTCCOPS_SCOMMAND_GATE_OPEN) {
                              AST_LIST_LOCK(&gate_list);
                              AST_LIST_TRAVERSE_SAFE_BEGIN(&gate_list, gate, list) {
                                 if (gate->cmts == cmts && gate->gateid == gateid) {
                                    if (scommand == PKTCCOPS_SCOMMAND_GATE_CLOSE && gate->state != GATE_CLOSED && gate->state != GATE_CLOSED_ERR ) {
                                       ast_debug(3, "COPS Gate Close Gate ID: 0x%x TrId: %i CMTS: %s\n", gateid, recvtrid, cmts->name);
                                       if (subreason) {
                                          gate->state = GATE_CLOSED_ERR;
                                          PKTCCOPS_DESTROY_CURRENT_GATE;
                                       } else {
                                          gate->state = GATE_CLOSED;
                                          PKTCCOPS_DESTROY_CURRENT_GATE;
                                       }
                                       break;
                                    } else if (scommand == PKTCCOPS_SCOMMAND_GATE_OPEN && gate->state == GATE_ALLOCATED) {
                                       ast_debug(3, "COPS Gate Open Gate ID: 0x%x TrId: %i CMTS: %s\n", gateid, recvtrid, cmts->name);
                                       gate->state = GATE_OPEN;
                                       if (gate->gate_open) {
                                          ast_debug(3, "Calling GATE-OPEN callback function\n");
                                          gate->gate_open(gate);
                                          gate->gate_open = NULL;
                                       }
                                       break;
                                    }
                                 }
                              }
                              AST_LIST_TRAVERSE_SAFE_END;
                              AST_LIST_UNLOCK(&gate_list);
                           } else if (scommand == PKTCCOPS_SCOMMAND_GATE_SET_ACK || scommand == PKTCCOPS_SCOMMAND_GATE_SET_ERR || scommand == PKTCCOPS_SCOMMAND_GATE_INFO_ACK || scommand == PKTCCOPS_SCOMMAND_GATE_INFO_ERR || scommand == PKTCCOPS_SCOMMAND_GATE_DELETE_ACK) {
                              AST_LIST_LOCK(&gate_list);
                              AST_LIST_TRAVERSE_SAFE_BEGIN(&gate_list, gate, list) {
                                 if (gate->cmts == cmts && gate->trid == recvtrid) {
                                    gate->gateid = gateid;
                                    gate->checked = time(NULL);
                                    if (scommand == PKTCCOPS_SCOMMAND_GATE_SET_ACK) {
                                       ast_debug(3, "COPS Gate Set Ack Gate ID: 0x%x TrId: %i CMTS: %s\n", gateid, recvtrid, cmts->name);
                                       gate->state = GATE_ALLOCATED;
                                       if (gate->got_dq_gi) {
                                          gate->got_dq_gi(gate);
                                          gate->got_dq_gi = NULL;
                                       }
                                    } else if (scommand == PKTCCOPS_SCOMMAND_GATE_SET_ERR) {
                                       ast_debug(3, "COPS Gate Set Error TrId: %i ErrorCode: 0x%.8x CMTS: %s\n ", recvtrid, pktcerror, cmts->name);
                                       gate->state = GATE_ALLOC_FAILED;
                                       if (gate->got_dq_gi) {
                                          gate->got_dq_gi(gate);
                                          gate->got_dq_gi = NULL;
                                       }
                                       PKTCCOPS_DESTROY_CURRENT_GATE;
                                    } else if (scommand == PKTCCOPS_SCOMMAND_GATE_INFO_ACK) {
                                       ast_debug(3, "COPS Gate Info Ack Gate ID: 0x%x TrId: %i CMTS: %s\n", gateid, recvtrid, cmts->name);
                                    } else if (scommand == PKTCCOPS_SCOMMAND_GATE_INFO_ERR) {
                                       ast_debug(3, "COPS Gate Info Error Gate ID: 0x%x TrId: %i CMTS: %s\n", gateid, recvtrid, cmts->name);
                                       gate->state = GATE_ALLOC_FAILED;
                                       PKTCCOPS_DESTROY_CURRENT_GATE;
                                    } else if (scommand == PKTCCOPS_SCOMMAND_GATE_DELETE_ACK) {
                                       ast_debug(3, "COPS Gate Deleted Gate ID: 0x%x TrId: %i CMTS: %s\n", gateid, recvtrid, cmts->name);
                                       gate->state = GATE_DELETED;
                                       PKTCCOPS_DESTROY_CURRENT_GATE;
                                    }
                                    gate->in_transaction = 0;
                                    break;
                                 }
                              }
                              AST_LIST_TRAVERSE_SAFE_END;
                              AST_LIST_UNLOCK(&gate_list);
                           }
                        }
                        pobject = pobject->next;
                     }
                  }

                  if (recmsg->opcode == 6 && recmsg->object && recmsg->object->cnum == 11 && recmsg->object->ctype == 1) {
                     ast_debug(3, "COPS: Client open %s\n", cmts->name);
                     sendmsg->msg = NULL;
                     sendmsg->verflag = 0x10;
                     sendmsg->opcode = 7; /* Client Accept */
                     sendmsg->clienttype = 0x8008; /* =PacketCable */
                     sendmsg->length = COPS_HEADER_SIZE + COPS_OBJECT_HEADER_SIZE + 4;
                     sendmsg->object = ast_malloc(sizeof(struct pktcobj));
                     sendmsg->object->length = 4 + COPS_OBJECT_HEADER_SIZE;
                     sendmsg->object->cnum = 10; /* keppalive timer*/
                     sendmsg->object->ctype = 1;
                     sendmsg->object->contents = ast_malloc(sizeof(uint32_t));
                     *((uint32_t *) sendmsg->object->contents) = htonl(cmts->keepalive & 0x0000ffff);
                     sendmsg->object->next = NULL;
                     cops_sendmsg(cmts->sfd, sendmsg);
                     cops_freemsg(sendmsg);
                  } else if (recmsg->opcode == 9) {
                     ast_debug(3, "COPS: Keepalive Request got echoing back %s\n", cmts->name);
                     cops_sendmsg(cmts->sfd, recmsg);
                     cmts->state = 2;
                     cmts->katimer = time(NULL);
                  }
               }
               if (len <= 0) {
                  ast_debug(3, "COPS: lost connection to %s\n", cmts->name);
                  close(cmts->sfd);
                  cmts->sfd = -1;
                  cmts->state = 0;
               }
               cops_freemsg(recmsg);
            }
         }
         AST_LIST_UNLOCK(&cmts_list);
      }
      if (pktcreload) {
         ast_debug(3, "Reloading pktccops...\n");
         AST_LIST_LOCK(&gate_list);
         AST_LIST_LOCK(&cmts_list);
         pktccops_unregister_ippools();
         AST_LIST_TRAVERSE(&cmts_list, cmts, list) {
            cmts->need_delete = 1;
         }
         load_pktccops_config();
         AST_LIST_TRAVERSE_SAFE_BEGIN(&cmts_list, cmts, list) {
            if (cmts && cmts->need_delete) {
               AST_LIST_TRAVERSE(&gate_list, gate, list) {
                  if (gate->cmts == cmts) {
                     ast_debug(3, "Null gate %s\n", gate->cmts->name);
                     gate->cmts = NULL;
                  }
                  gate->in_transaction = 0;
               }
               AST_LIST_UNLOCK(&gate_list);
               ast_debug(3, "removing cmts: %s\n", cmts->name);
               if (cmts->sfd > 0) {
                  close(cmts->sfd);
               }
               AST_LIST_REMOVE_CURRENT(list);
               ast_free(cmts);
            }
         }
         AST_LIST_TRAVERSE_SAFE_END;
         AST_LIST_UNLOCK(&cmts_list);
         AST_LIST_UNLOCK(&gate_list);
         pktcreload = 2;
      }
      pthread_testcancel();
   }
   return NULL;
}

ftoieeef()

static uint32_t ftoieeef ( float  n )

static

Definition at line 175 of file res_pktccops.c.

Referenced by cops_construct_gate().

{
   uint32_t res;
   memcpy(&res, &n, 4);
   return htonl(res);
}

load_module()

static int load_module ( void  )

static

Definition at line 1463 of file res_pktccops.c.

References ast_cli_register_multiple, AST_LIST_LOCK, AST_LIST_UNLOCK, AST_MODULE_LOAD_DECLINE, load_pktccops_config(), and restart_pktc_thread().

Referenced by reload_module().

{
   int res;
   AST_LIST_LOCK(&cmts_list);
   res = load_pktccops_config();
   AST_LIST_UNLOCK(&cmts_list);
   if (res == -1) {
      return AST_MODULE_LOAD_DECLINE;
   }
   ast_cli_register_multiple(cli_pktccops, sizeof(cli_pktccops) / sizeof(struct ast_cli_entry));
   restart_pktc_thread();

   return 0;
}

load_pktccops_config()

static int load_pktccops_config ( void  )

static

Definition at line 1022 of file res_pktccops.c.

References a, ast_calloc, ast_category_browse(), ast_config_destroy(), ast_config_load, ast_copy_string(), AST_LIST_INSERT_HEAD, AST_LIST_TRAVERSE, ast_log, ast_variable_browse(), b, c, cops_ippool::cmts, config, d, DEFAULT_COPS_PORT, gateinfoperiod, gatetimeout, host, cops_cmts::host, cops_cmts::keepalive, keepalive, LOG_WARNING, ast_variable::name, cops_cmts::name, cops_cmts::need_delete, ast_variable::next, NULL, pktccops_add_ippool(), cops_cmts::port, cops_cmts::sfd, cops_ippool::start, cops_cmts::state, cops_ippool::stop, cops_cmts::t1, t1, cops_cmts::t7, t7, cops_cmts::t8, t8, update(), and ast_variable::value.

Referenced by do_pktccops(), and load_module().

{
   static char *cfg = "res_pktccops.conf";
   struct ast_config *config;
   struct ast_variable *v;
   struct cops_cmts *cmts;
   struct cops_ippool *new_ippool;
   const char *host, *cat, *port;
   int update;
   int res = 0;
   uint16_t t1_temp, t7_temp, t8_temp;
   uint32_t keepalive_temp;
   unsigned int a,b,c,d,e,f,g,h;
   struct ast_flags config_flags = {0};

   if (!(config = ast_config_load(cfg, config_flags))) {
      ast_log(LOG_WARNING, "Unable to load config file res_pktccops.conf\n");
      return -1;
   }
   for (cat = ast_category_browse(config, NULL); cat; cat = ast_category_browse(config, cat)) {
      if (!strcmp(cat, "general")) {
         for (v = ast_variable_browse(config, cat); v; v = v->next) {
            if (!strcasecmp(v->name, "t1")) {
               t1 = atoi(v->value);
            } else if (!strcasecmp(v->name, "t7")) {
               t7 = atoi(v->value);
            } else if (!strcasecmp(v->name, "t8")) {
               t8 = atoi(v->value);
            } else if (!strcasecmp(v->name, "keepalive")) {
               keepalive = atoi(v->value);
            } else if (!strcasecmp(v->name, "gateinfoperiod")) {
               gateinfoperiod = atoi(v->value);
            } else if (!strcasecmp(v->name, "gatetimeout")) {
               gatetimeout = atoi(v->value);
            } else {
               ast_log(LOG_WARNING, "Unkown option %s in general section of res_ptkccops.conf\n", v->name);
            }
         }
      } else {
         /* Defaults */
         host = NULL;
         port = NULL;
         t1_temp = t1;
         t7_temp = t7;
         t8_temp = t8;
         keepalive_temp = keepalive;

         for (v = ast_variable_browse(config, cat); v; v = v->next) {
            if (!strcasecmp(v->name, "host")) {
               host = v->value;
            } else if (!strcasecmp(v->name, "port")) {
               port = v->value;
            } else if (!strcasecmp(v->name, "t1")) {
               t1_temp = atoi(v->value);
            } else if (!strcasecmp(v->name, "t7")) {
               t7_temp = atoi(v->value);
            } else if (!strcasecmp(v->name, "t8")) {
               t8_temp = atoi(v->value);
            } else if (!strcasecmp(v->name, "keepalive")) {
               keepalive_temp = atoi(v->value);
            } else if (!strcasecmp(v->name, "pool")) {
               /* we weill parse it in 2nd round */
            } else {
               ast_log(LOG_WARNING, "Unkown option %s in res_ptkccops.conf\n", v->name);
            }
         }

         update = 0;
         AST_LIST_TRAVERSE(&cmts_list, cmts, list) {
            if (!strcmp(cmts->name, cat)) {
               update = 1;
               break;
            }

         }
         if (!update) {
            cmts = ast_calloc(1, sizeof(*cmts));
            if (!cmts) {
               res = -1;
               break;
            }
            AST_LIST_INSERT_HEAD(&cmts_list, cmts, list);
         }
         if (cat) {
            ast_copy_string(cmts->name, cat, sizeof(cmts->name));
         }
         if (host) {
            ast_copy_string(cmts->host, host, sizeof(cmts->host));
         }
         if (port) {
            ast_copy_string(cmts->port, port, sizeof(cmts->port));
         } else {
            ast_copy_string(cmts->port, DEFAULT_COPS_PORT, sizeof(cmts->port));
         }

         cmts->t1 = t1_temp;
         cmts->t7 = t7_temp;
         cmts->t8 = t8_temp;
         cmts->keepalive = keepalive_temp;
         if (!update) {
            cmts->state = 0;
            cmts->sfd = -1;
         }
         cmts->need_delete = 0;
         for (v = ast_variable_browse(config, cat); v; v = v->next) {
            /* parse ipppol when we have cmts ptr */
            if (!strcasecmp(v->name, "pool")) {
               if (sscanf(v->value, "%3u.%3u.%3u.%3u %3u.%3u.%3u.%3u", &a, &b, &c, &d, &e, &f, &g, &h) == 8) {
                  new_ippool = ast_calloc(1, sizeof(*new_ippool));
                  if (!new_ippool) {
                     res = -1;
                     break;
                  }
                  new_ippool->start = a << 24 | b << 16 | c << 8 | d;
                  new_ippool->stop = e << 24 | f << 16 | g << 8 | h;
                  new_ippool->cmts = cmts;
                  pktccops_add_ippool(new_ippool);
               } else {
                  ast_log(LOG_WARNING, "Invalid ip pool format in res_pktccops.conf\n");
               }
            }
         }
      }
   }
   ast_config_destroy(config);
   return res;
}

pktccops_add_ippool()

static int pktccops_add_ippool ( struct cops_ippool *  ippool )

static

Definition at line 1420 of file res_pktccops.c.

References AST_LIST_INSERT_HEAD, AST_LIST_LOCK, AST_LIST_UNLOCK, ast_log, ast_cli_entry::list, and LOG_WARNING.

Referenced by load_pktccops_config().

{
   if (ippool) {
      AST_LIST_LOCK(&ippool_list);
      AST_LIST_INSERT_HEAD(&ippool_list, ippool, list);
      AST_LIST_UNLOCK(&ippool_list);
      return 0;
   } else {
      ast_log(LOG_WARNING, "Attempted to register NULL ippool?\n");
      return -1;
   }
}

pktccops_debug()

static char* pktccops_debug ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 1383 of file res_pktccops.c.

References ast_cli_args::argc, ast_cli_entry::args, ast_cli_args::argv, ast_cli(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, ast_cli_args::fd, NULL, pktccopsdebug, and ast_cli_entry::usage.

{
   switch (cmd) {
   case CLI_INIT:
      e->command = "pktccops set debug {on|off}";
      e->usage =
         "Usage: pktccops set debug {on|off}\n"
         "  Turn on/off debuging\n";
      return NULL;
   case CLI_GENERATE:
      return NULL;
   }

   if (a->argc != e->args)
      return CLI_SHOWUSAGE;
   if (!strncasecmp(a->argv[e->args - 1], "on", 2)) {
      pktccopsdebug = 1;
      ast_cli(a->fd, "PktcCOPS Debugging Enabled\n");
   } else if (!strncasecmp(a->argv[e->args - 1], "off", 2)) {
      pktccopsdebug = 0;
      ast_cli(a->fd, "PktcCOPS Debugging Disabled\n");
   } else {
      return CLI_SHOWUSAGE;
   }
   return CLI_SUCCESS;

}

pktccops_gatedel()

static char* pktccops_gatedel ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 1266 of file res_pktccops.c.

References ast_cli_args::argc, ast_cli_args::argv, ast_cli(), AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, cops_gate::cmts, ast_cli_entry::command, cops_gate_cmd(), cops_trid, ast_cli_args::fd, GATE_DEL, cops_gate::gateid, cops_cmts::list, cops_cmts::name, NULL, and ast_cli_entry::usage.

{
   int found = 0;
   int trid;
   uint32_t gateid;
   struct cops_gate *gate;
   struct cops_cmts *cmts;

   switch (cmd) {
   case CLI_INIT:
      e->command = "pktccops gatedel";
      e->usage =
         "Usage: pktccops gatedel <cmts> <gateid>\n"
         "       Send Gate-Del to cmts.\n";
      return NULL;
   case CLI_GENERATE:
      return NULL;
   }

   if (a->argc < 4)
      return CLI_SHOWUSAGE;

   AST_LIST_LOCK(&cmts_list);
   AST_LIST_TRAVERSE(&cmts_list, cmts, list) {
      if (!strcmp(cmts->name, a->argv[2])) {
         ast_cli(a->fd, "Found cmts: %s\n", cmts->name);
         found = 1;
         break;
      }
   }
   AST_LIST_UNLOCK(&cmts_list);

   if (!found)
      return CLI_SHOWUSAGE;

   trid = cops_trid++;
   if (!sscanf(a->argv[3], "%x", &gateid)) {
      ast_cli(a->fd, "bad gate specification (%s)\n", a->argv[3]);
      return CLI_SHOWUSAGE;
   }

   found = 0;
   AST_LIST_LOCK(&gate_list);
   AST_LIST_TRAVERSE(&gate_list, gate, list) {
      if (gate->gateid == gateid && gate->cmts == cmts) {
         found = 1;
         break;
      }
   }

   if (!found) {
      ast_cli(a->fd, "gate not found: %s\n", a->argv[3]);
      return CLI_SHOWUSAGE;
   }

   AST_LIST_UNLOCK(&gate_list);
   cops_gate_cmd(GATE_DEL, cmts, trid, 0, 0, 0, 0, 0, 0, gate);
   return CLI_SUCCESS;
}

pktccops_gateset()

static char* pktccops_gateset ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 1326 of file res_pktccops.c.

References ast_cli_args::argc, ast_cli_args::argv, ast_cli(), AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, cops_gate_cmd(), cops_trid, ast_cli_args::fd, GATE_SET, cops_cmts::list, cops_cmts::name, NULL, and ast_cli_entry::usage.

{
   int foundcmts = 0;
   int trid;
   unsigned int an,bn,cn,dn;
   uint32_t mta, ssip;
   struct cops_cmts *cmts;

   switch (cmd) {
   case CLI_INIT:
      e->command = "pktccops gateset";
      e->usage =
         "Usage: pktccops gateset <cmts> <mta> <acctcount> <bitrate> <packet size> <switch ip> <switch port>\n"
         "       Send Gate-Set to cmts.\n";
      return NULL;
   case CLI_GENERATE:
      return NULL;
   }

   if (a->argc < 9)
      return CLI_SHOWUSAGE;

   if (!strcmp(a->argv[2], "null")) {
      cmts = NULL;
   } else {
      AST_LIST_LOCK(&cmts_list);
      AST_LIST_TRAVERSE(&cmts_list, cmts, list) {
         if (!strcmp(cmts->name, a->argv[2])) {
            ast_cli(a->fd, "Found cmts: %s\n", cmts->name);
            foundcmts = 1;
            break;
         }
      }
      AST_LIST_UNLOCK(&cmts_list);
      if (!foundcmts) {
         ast_cli(a->fd, "CMTS not found: %s\n", a->argv[2]);
         return CLI_SHOWUSAGE;
      }
   }

   trid = cops_trid++;
   if (sscanf(a->argv[3], "%3u.%3u.%3u.%3u", &an, &bn, &cn, &dn) != 4) {
      ast_cli(a->fd, "MTA specification (%s) does not look like an ipaddr\n", a->argv[3]);
      return CLI_SHOWUSAGE;
   }
   mta = an << 24 | bn << 16 | cn << 8 | dn;

   if (sscanf(a->argv[7], "%3u.%3u.%3u.%3u", &an, &bn, &cn, &dn) != 4) {
      ast_cli(a->fd, "SSIP specification (%s) does not look like an ipaddr\n", a->argv[7]);
      return CLI_SHOWUSAGE;
   }
   ssip = an << 24 | bn << 16 | cn << 8 | dn;

   cops_gate_cmd(GATE_SET, cmts, trid, mta, atoi(a->argv[4]), atof(a->argv[5]), atoi(a->argv[6]), ssip, atoi(a->argv[8]), NULL);
   return CLI_SUCCESS;
}

pktccops_show_cmtses()

static char* pktccops_show_cmtses ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 1150 of file res_pktccops.c.

References ast_cli(), ast_copy_string(), AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, CLI_GENERATE, CLI_INIT, CLI_SUCCESS, ast_cli_entry::command, ast_cli_args::fd, cops_cmts::host, cops_cmts::katimer, cops_cmts::list, cops_cmts::name, NULL, cops_cmts::port, cops_cmts::state, and ast_cli_entry::usage.

{
   struct cops_cmts *cmts;
   char statedesc[16];
   int katimer;

   switch(cmd) {
   case CLI_INIT:
      e->command = "pktccops show cmtses";
      e->usage =
         "Usage: pktccops show cmtses\n"
         "       List PacketCable COPS CMTSes.\n";

      return NULL;
   case CLI_GENERATE:
      return NULL;
   }

   ast_cli(a->fd, "%-16s %-24s %-12s %7s\n", "Name        ", "Host                ", "Status    ", "KA timer  ");
   ast_cli(a->fd, "%-16s %-24s %-12s %7s\n", "------------", "--------------------", "----------", "-----------");
   AST_LIST_LOCK(&cmts_list);
   AST_LIST_TRAVERSE(&cmts_list, cmts, list) {
      katimer = -1;
      if (cmts->state == 2) {
         ast_copy_string(statedesc, "Connected", sizeof(statedesc));
         katimer = (int) (time(NULL) - cmts->katimer);
      } else if (cmts->state == 1) {
         ast_copy_string(statedesc, "Connecting", sizeof(statedesc));
      } else {
         ast_copy_string(statedesc, "N/A", sizeof(statedesc));
      }
      ast_cli(a->fd, "%-16s %-15s:%-8s %-12s %-7d\n", cmts->name, cmts->host, cmts->port, statedesc, katimer);
   }
   AST_LIST_UNLOCK(&cmts_list);
   return CLI_SUCCESS;
}

pktccops_show_gates()

static char* pktccops_show_gates ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 1187 of file res_pktccops.c.

References cops_gate::allocated, ast_cli(), ast_copy_string(), AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, cops_gate::checked, CLI_GENERATE, CLI_INIT, CLI_SUCCESS, cops_gate::cmts, ast_cli_entry::command, ast_cli_args::fd, GATE_ALLOC_FAILED, GATE_ALLOC_PROGRESS, GATE_ALLOCATED, GATE_CLOSED, GATE_CLOSED_ERR, GATE_DELETED, GATE_OPEN, cops_gate::gateid, cops_gate::in_transaction, cops_gate::mta, cops_cmts::name, NULL, cops_gate::state, and ast_cli_entry::usage.

{
   struct cops_gate *gate;
   char state_desc[16];

   switch(cmd) {
   case CLI_INIT:
      e->command = "pktccops show gates";
      e->usage =
         "Usage: pktccops show gates\n"
         "       List PacketCable COPS GATEs.\n";

      return NULL;
   case CLI_GENERATE:
      return NULL;
   }

   ast_cli(a->fd, "%-16s %-12s %-12s %-10s %-10s %-10s\n" ,"CMTS", "Gate-Id","MTA", "Status", "AllocTime", "CheckTime");
   ast_cli(a->fd, "%-16s %-12s %-12s %-10s %-10s %-10s\n" ,"--------------" ,"----------", "----------", "--------", "--------", "--------\n");
   AST_LIST_LOCK(&cmts_list);
   AST_LIST_LOCK(&gate_list);
   AST_LIST_TRAVERSE(&gate_list, gate, list) {
      if (gate->state == GATE_ALLOC_FAILED) {
         ast_copy_string(state_desc, "Failed", sizeof(state_desc));
      } else if (gate->state == GATE_ALLOC_PROGRESS) {
         ast_copy_string(state_desc, "In Progress", sizeof(state_desc));
      } else if (gate->state == GATE_ALLOCATED) {
         ast_copy_string(state_desc, "Allocated", sizeof(state_desc));
      } else if (gate->state == GATE_CLOSED) {
         ast_copy_string(state_desc, "Closed", sizeof(state_desc));
      } else if (gate->state == GATE_CLOSED_ERR) {
         ast_copy_string(state_desc, "ClosedErr", sizeof(state_desc));
      } else if (gate->state == GATE_OPEN) {
         ast_copy_string(state_desc, "Open", sizeof(state_desc));
      } else if (gate->state == GATE_DELETED) {
         ast_copy_string(state_desc, "Deleted", sizeof(state_desc));
      } else {
         ast_copy_string(state_desc, "N/A", sizeof(state_desc));
      }

      ast_cli(a->fd, "%-16s 0x%.8x   0x%08x   %-10s %10i %10i %u\n", (gate->cmts) ? gate->cmts->name : "null" , gate->gateid, gate->mta,
         state_desc, (int) (time(NULL) - gate->allocated), (gate->checked) ? (int) (time(NULL) - gate->checked) : 0, (unsigned int) gate->in_transaction);
   }
   AST_LIST_UNLOCK(&cmts_list);
   AST_LIST_UNLOCK(&gate_list);
   return CLI_SUCCESS;
}

pktccops_show_pools()

static char* pktccops_show_pools ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 1235 of file res_pktccops.c.

References ast_cli(), AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, CLI_GENERATE, CLI_INIT, CLI_SUCCESS, cops_ippool::cmts, ast_cli_entry::command, ast_cli_args::fd, cops_ippool::list, cops_cmts::name, NULL, cops_ippool::start, cops_ippool::stop, stop, and ast_cli_entry::usage.

{
   struct cops_ippool *ippool;
   char start[32];
   char stop[32];

   switch(cmd) {
   case CLI_INIT:
      e->command = "pktccops show pools";
      e->usage =
         "Usage: pktccops show pools\n"
         "       List PacketCable COPS ip pools of MTAs.\n";

      return NULL;
   case CLI_GENERATE:
      return NULL;
   }

   ast_cli(a->fd, "%-16s %-18s %-7s\n", "Start     ", "Stop      ", "CMTS    ");
   ast_cli(a->fd, "%-16s %-18s %-7s\n", "----------", "----------", "--------");
   AST_LIST_LOCK(&ippool_list);
   AST_LIST_TRAVERSE(&ippool_list, ippool, list) {
      snprintf(start, sizeof(start), "%3u.%3u.%3u.%3u", ippool->start >> 24, (ippool->start >> 16) & 0x000000ff, (ippool->start >> 8) & 0x000000ff, ippool->start & 0x000000ff);

      snprintf(stop, sizeof(stop), "%3u.%3u.%3u.%3u", ippool->stop >> 24, (ippool->stop >> 16) & 0x000000ff, (ippool->stop >> 8) & 0x000000ff, ippool->stop & 0x000000ff);
      ast_cli(a->fd, "%-16s %-18s %-16s\n", start, stop, ippool->cmts->name);
   }
   AST_LIST_UNLOCK(&ippool_list);
   return CLI_SUCCESS;
}

pktccops_unregister_cmtses()

static void pktccops_unregister_cmtses ( void  )

static

Definition at line 1433 of file res_pktccops.c.

References ast_free, AST_LIST_LOCK, AST_LIST_REMOVE_HEAD, AST_LIST_UNLOCK, and cops_cmts::sfd.

Referenced by unload_module().

{
   struct cops_cmts *cmts;
   struct cops_gate *gate;
   AST_LIST_LOCK(&cmts_list);
   while ((cmts = AST_LIST_REMOVE_HEAD(&cmts_list, list))) {
      if (cmts->sfd > 0) {
         close(cmts->sfd);
      }
      ast_free(cmts);
   }
   AST_LIST_UNLOCK(&cmts_list);

   AST_LIST_LOCK(&gate_list);
   while ((gate = AST_LIST_REMOVE_HEAD(&gate_list, list))) {
      ast_free(gate);
   }
   AST_LIST_UNLOCK(&gate_list);
}

pktccops_unregister_ippools()

static void pktccops_unregister_ippools ( void  )

static

Definition at line 1453 of file res_pktccops.c.

References ast_free, AST_LIST_LOCK, AST_LIST_REMOVE_HEAD, AST_LIST_UNLOCK, and cops_ippool::list.

Referenced by do_pktccops(), and unload_module().

{
   struct cops_ippool *ippool;
   AST_LIST_LOCK(&ippool_list);
   while ((ippool = AST_LIST_REMOVE_HEAD(&ippool_list, list))) {
      ast_free(ippool);
   }
   AST_LIST_UNLOCK(&ippool_list);
}

reload_module()

static int reload_module ( void  )

static

Definition at line 1500 of file res_pktccops.c.

References ast_log, AST_MODFLAG_GLOBAL_SYMBOLS, AST_MODULE_INFO(), AST_MODULE_SUPPORT_EXTENDED, ASTERISK_GPL_KEY, load_module(), LOG_NOTICE, pktcreload, reload(), and unload_module().

{
   /* Prohibit unloading */
   if (pktcreload) {
      ast_log(LOG_NOTICE, "Previous reload in progress, please wait!\n");
      return -1;
   }
   pktcreload = 1;
   return 0;
}

restart_pktc_thread()

static int restart_pktc_thread ( void  )

static

Definition at line 993 of file res_pktccops.c.

References ast_log, ast_mutex_lock, ast_mutex_unlock, ast_pthread_create_background, AST_PTHREADT_NULL, AST_PTHREADT_STOP, do_pktccops(), LOG_ERROR, LOG_WARNING, NULL, pktccops_lock, and pktccops_thread.

Referenced by load_module().

{
   if (pktccops_thread == AST_PTHREADT_STOP) {
      return 0;
   }
   if (ast_mutex_lock(&pktccops_lock)) {
      ast_log(LOG_WARNING, "Unable to lock pktccops\n");
      return -1;
   }
   if (pktccops_thread == pthread_self()) {
      ast_mutex_unlock(&pktccops_lock);
      ast_log(LOG_WARNING, "Cannot kill myself\n");
      return -1;
   }
   if (pktccops_thread != AST_PTHREADT_NULL) {
      /* Wake up the thread */
      pthread_kill(pktccops_thread, SIGURG);
   } else {
      /* Start a new monitor */
      if (ast_pthread_create_background(&pktccops_thread, NULL, do_pktccops, NULL) < 0) {
         ast_mutex_unlock(&pktccops_lock);
         ast_log(LOG_ERROR, "Unable to start monitor thread.\n");
         return -1;
      }
   }
   ast_mutex_unlock(&pktccops_lock);
   return 0;
}

unload_module()

static int unload_module ( void  )

static

Definition at line 1478 of file res_pktccops.c.

References ast_cli_unregister_multiple(), ast_log, ast_mutex_lock, ast_mutex_unlock, AST_PTHREADT_NULL, AST_PTHREADT_STOP, LOG_ERROR, NULL, pktccops_lock, pktccops_thread, pktccops_unregister_cmtses(), and pktccops_unregister_ippools().

Referenced by reload_module().

{
   if (!ast_mutex_lock(&pktccops_lock)) {
      if ((pktccops_thread != AST_PTHREADT_NULL) && (pktccops_thread != AST_PTHREADT_STOP)) {
         pthread_cancel(pktccops_thread);
         pthread_kill(pktccops_thread, SIGURG);
         pthread_join(pktccops_thread, NULL);
      }
      pktccops_thread = AST_PTHREADT_STOP;
      ast_mutex_unlock(&pktccops_lock);
   } else {
      ast_log(LOG_ERROR, "Unable to lock the pktccops_thread\n");
      return -1;
   }

   ast_cli_unregister_multiple(cli_pktccops, sizeof(cli_pktccops) / sizeof(struct ast_cli_entry));
   pktccops_unregister_cmtses();
   pktccops_unregister_ippools();
   pktccops_thread = AST_PTHREADT_NULL;
   return 0;
}

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_GLOBAL_SYMBOLS , .description = "PktcCOPS manager for MGCP" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload_module, }

static

Definition at line 1516 of file res_pktccops.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 1516 of file res_pktccops.c.

cli_pktccops

struct ast_cli_entry cli_pktccops[]

static

Definition at line 1411 of file res_pktccops.c.

cmts_list

struct cmts_list cmts_list = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }

cops_trid

uint16_t cops_trid = 0

static

Definition at line 90 of file res_pktccops.c.

Referenced by ast_pktccops_gate_alloc(), do_pktccops(), pktccops_gatedel(), and pktccops_gateset().

gate_list

struct gate_list gate_list = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }

gateinfoperiod

int gateinfoperiod = 60

static

Definition at line 163 of file res_pktccops.c.

Referenced by do_pktccops(), and load_pktccops_config().

gatetimeout

int gatetimeout = 150

static

Definition at line 164 of file res_pktccops.c.

Referenced by do_pktccops(), and load_pktccops_config().

ippool_list

struct ippool_list ippool_list = { .first = NULL, .last = NULL, .lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} } , }

keepalive

uint32_t keepalive = 60

static

Definition at line 160 of file res_pktccops.c.

Referenced by check_rtp_timeout(), load_pktccops_config(), send_keepalive(), and sip_send_keepalive().

pktccops_lock

ast_mutex_t pktccops_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static

Definition at line 88 of file res_pktccops.c.

Referenced by restart_pktc_thread(), and unload_module().

pktccops_thread

pthread_t pktccops_thread = AST_PTHREADT_NULL

static

Definition at line 89 of file res_pktccops.c.

Referenced by restart_pktc_thread(), and unload_module().

pktccopsdebug

int pktccopsdebug = 0

static

Definition at line 161 of file res_pktccops.c.

Referenced by cops_gate_cmd(), and pktccops_debug().

pktcreload

int pktcreload = 0

static

Definition at line 162 of file res_pktccops.c.

Referenced by ast_pktccops_gate_alloc(), do_pktccops(), and reload_module().

t1

uint16_t t1 = 250

static

Definition at line 157 of file res_pktccops.c.

Referenced by create_match_char_tree(), destroy_test_container(), differ_by_repeat(), is_prefix(), load_pktccops_config(), make_test1(), print_list(), and print_list_backwards().

t7

uint16_t t7 = 200

static

Definition at line 158 of file res_pktccops.c.

Referenced by load_pktccops_config().

t8

uint16_t t8 = 300

static

Definition at line 159 of file res_pktccops.c.

Referenced by load_pktccops_config().