Home page | Mailing list | Docs

Last updated: Sat Feb 3 05:01:52 2007

Asterisk developer's documentation :: Codename Pineapple

---

sip3_pokedevice.c File Reference

---

Detailed Description

SIP qualification subsystem - poking around on the network Version 3 of chan_sip.

Author:

Mark Spencer <markster@digium.com>

Olle E. Johansson <oej@edvina.net> (all the chan_sip3 changes)

See Also:

• CREDITS

Definition in file sip3_pokedevice.c.

#include "asterisk.h"
#include <stdio.h>
#include <ctype.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/ioctl.h>
#include <net/if.h>
#include <errno.h>
#include <stdlib.h>
#include <fcntl.h>
#include <netdb.h>
#include <signal.h>
#include <sys/signal.h>
#include <netinet/in.h>
#include <netinet/in_systm.h>
#include <arpa/inet.h>
#include <netinet/ip.h>
#include <regex.h>
#include "asterisk/lock.h"
#include "asterisk/channel.h"
#include "asterisk/config.h"
#include "asterisk/logger.h"
#include "asterisk/module.h"
#include "asterisk/pbx.h"
#include "asterisk/options.h"
#include "asterisk/sched.h"
#include "asterisk/io.h"
#include "asterisk/rtp.h"
#include "asterisk/udptl.h"
#include "asterisk/acl.h"
#include "asterisk/manager.h"
#include "asterisk/callerid.h"
#include "asterisk/cli.h"
#include "asterisk/app.h"
#include "asterisk/musiconhold.h"
#include "asterisk/dsp.h"
#include "asterisk/features.h"
#include "asterisk/srv.h"
#include "asterisk/astdb.h"
#include "asterisk/causes.h"
#include "asterisk/utils.h"
#include "asterisk/file.h"
#include "asterisk/astobj.h"
#include "asterisk/dnsmgr.h"
#include "asterisk/devicestate.h"
#include "asterisk/linkedlists.h"
#include "asterisk/stringfields.h"
#include "asterisk/monitor.h"
#include "asterisk/localtime.h"
#include "asterisk/abstract_jb.h"
#include "asterisk/compiler.h"
#include "sip3.h"
#include "sip3funcs.h"

Include dependency graph for sip3_pokedevice.c:

Go to the source code of this file.

Functions
void	handle_response_peerpoke (struct sip_dialog *p, int resp, struct sip_request *req)
	Handle qualification responses (OPTIONS).
void	sip_poke_all_peers (void)
	Send a poke to all known peers Space them out 100 ms apart XXX We might have a cool algorithm for this or use random - any suggestions?
int	sip_poke_noanswer (void *data)
	React to lack of answer to Qualify poke.
int	sip_poke_peer (struct sip_device *peer)
	Check availability of peer, also keep NAT open.
int	sip_poke_peer_s (void *data)
	Poke peer (send qualify to check if peer is alive and well).

---

Function Documentation

void handle_response_peerpoke (  struct sip_dialog *  p, int  resp, struct sip_request *  req )

Handle qualification responses (OPTIONS). Definition at line 103 of file sip3_pokedevice.c. References ast_device_state_changed(), ast_log(), ast_sched_add(), ast_sched_del(), ast_set_flag, sip_device::call, sip_globals::default_qualifycheck_notok, sip_globals::default_qualifycheck_ok, DIALOG_STATE_TERMINATED, dialogstatechange(), EVENT_FLAG_SYSTEM, sip_dialog::flags, global, sip_device::lastms, LOG_NOTICE, manager_event, sip_device::maxms, sip_device::pokeexpire, sip_device::ps, sip_dialog::relatedpeer, s, SIP_NEEDDESTROY, and sip_poke_peer_s(). { struct sip_device *peer = p->relatedpeer; int statechanged, is_reachable, was_reachable; int pingtime = ast_tvdiff_ms(ast_tvnow(), peer->ps); if (!peer) return; /* * Compute the response time to a ping (goes in peer->lastms.) * -1 means did not respond, 0 means unknown, * 1..maxms is a valid response, >maxms means late response. */ if (pingtime < 1) /* zero = unknown, so round up to 1 */ pingtime = 1; /* Now determine new state and whether it has changed. * Use some helper variables to simplify the writing * of the expressions. */ was_reachable = peer->lastms > 0 && peer->lastms <= peer->maxms; is_reachable = pingtime <= peer->maxms; statechanged = peer->lastms == 0 /* yes, unknown before */ || was_reachable != is_reachable; peer->lastms = pingtime; peer->call = NULL; if (statechanged) { const char *s = is_reachable ? "Reachable" : "Lagged"; ast_log(LOG_NOTICE, "Peer '%s' is now %s. (%dms / %dms)\n", peer->name, s, pingtime, peer->maxms); ast_device_state_changed("SIP/%s", peer->name); manager_event(EVENT_FLAG_SYSTEM, "PeerStatus", "Peer: SIP/%s\r\nPeerStatus: %s\r\nTime: %d\r\n", peer->name, s, pingtime); } if (peer->pokeexpire > -1) ast_sched_del(sched, peer->pokeexpire); /* Try again eventually */ peer->pokeexpire = ast_sched_add(sched, is_reachable ? global.default_qualifycheck_ok: global.default_qualifycheck_notok, sip_poke_peer_s, peer); dialogstatechange(p, DIALOG_STATE_TERMINATED); ast_set_flag(&p->flags[0], SIP_NEEDDESTROY); }

void sip_poke_all_peers (  void   )

Send a poke to all known peers Space them out 100 ms apart XXX We might have a cool algorithm for this or use random - any suggestions? Definition at line 239 of file sip3_pokedevice.c. References ast_sched_add(), ast_sched_del(), ASTOBJ_CONTAINER_TRAVERSE, ASTOBJ_UNLOCK, ASTOBJ_WRLOCK, devicelist, sip_poke_peer_s(), sipcounters, and channel_counters::static_peers. { int ms = 0; if (!sipcounters.static_peers) /* No peers, just give up */ return; ASTOBJ_CONTAINER_TRAVERSE(&devicelist, 1, do { ASTOBJ_WRLOCK(iterator); if (iterator->pokeexpire > -1) ast_sched_del(sched, iterator->pokeexpire); ms += 100; iterator->pokeexpire = ast_sched_add(sched, ms, sip_poke_peer_s, iterator); ASTOBJ_UNLOCK(iterator); } while (0) ); }

int sip_poke_noanswer (  void *  data  )

React to lack of answer to Qualify poke. Definition at line 155 of file sip3_pokedevice.c. References ast_device_state_changed(), ast_log(), ast_sched_add(), sip_device::call, sip_globals::default_qualifycheck_notok, EVENT_FLAG_SYSTEM, global, sip_device::lastms, LOG_NOTICE, manager_event, sip_device::pokeexpire, sip_destroy(), and sip_poke_peer_s(). { struct sip_device *peer = data; peer->pokeexpire = -1; if (peer->lastms > -1) { ast_log(LOG_NOTICE, "Peer '%s' is now UNREACHABLE! Last qualify: %d\n", peer->name, peer->lastms); manager_event(EVENT_FLAG_SYSTEM, "PeerStatus", "Peer: SIP/%s\r\nPeerStatus: Unreachable\r\nTime: %d\r\n", peer->name, -1); } if (peer->call) sip_destroy(peer->call); peer->call = NULL; peer->lastms = -1; ast_device_state_changed("SIP/%s", peer->name); /* Try again quickly */ peer->pokeexpire = ast_sched_add(sched, global.default_qualifycheck_notok, sip_poke_peer_s, peer); return 0; }

int sip_poke_peer (  struct sip_device *  peer  )

Check availability of peer, also keep NAT open. Note: This is done with the interval in qualify= configuration option Default is 2 seconds Definition at line 177 of file sip3_pokedevice.c. References sip_network::__ourip, sip_device::addr, ast_copy_flags, ast_inet_ntoa(), ast_log(), ast_sched_add(), ast_sched_del(), ast_set_flag, ast_string_field_set, ast_strlen_zero(), build_callid_pvt(), build_via(), sip_device::call, DEFAULT_QUALIFY_MAXMS, sip_device::extra, FALSE, sip_dialog::flags, sip_device::flags, sip_device::lastms, LOG_NOTICE, sip_device::maxms, sip_dialog::ourip, sip_device::pokeexpire, sip_device::ps, sip_dialog::recv, sip_dialog::relatedpeer, sip_dialog::sa, sip_alloc(), sip_destroy(), SIP_FLAGS_TO_COPY, SIP_INVITE, SIP_OPTIONS, sip_ouraddrfor(), SIP_OUTGOING, SIP_PAGE2_FLAGS_TO_COPY, sip_poke_noanswer(), sipdebug, sipnet, sip_device_extra::tohost, and transmit_invite(). { struct sip_dialog *p; if (!peer->maxms || !peer->addr.sin_addr.s_addr) { /* IF we have no IP, or this isn't to be monitored, return imeediately after clearing things out */ if (peer->pokeexpire > -1) ast_sched_del(sched, peer->pokeexpire); peer->lastms = 0; peer->pokeexpire = -1; peer->call = NULL; return 0; } if (peer->call > 0) { if (sipdebug) ast_log(LOG_NOTICE, "Still have a QUALIFY dialog active, deleting\n"); sip_destroy(peer->call); } if (!(p = peer->call = sip_alloc(NULL, NULL, FALSE, SIP_OPTIONS))) return -1; p->sa = peer->addr; p->recv = peer->addr; ast_copy_flags(&p->flags[0], &peer->flags[0], SIP_FLAGS_TO_COPY); ast_copy_flags(&p->flags[1], &peer->flags[1], SIP_PAGE2_FLAGS_TO_COPY); /* Send OPTIONs to peer's fullcontact */ if (!ast_strlen_zero(peer->fullcontact)) ast_string_field_set(p, fullcontact, peer->fullcontact); if (!ast_strlen_zero(peer->extra.tohost)) ast_string_field_set(p, tohost, peer->extra.tohost); else ast_string_field_set(p, tohost, ast_inet_ntoa(peer->addr.sin_addr)); /* Recalculate our side, and recalculate Call ID */ if (sip_ouraddrfor(&p->sa.sin_addr, &p->ourip)) p->ourip = sipnet.__ourip; build_via(p, FALSE); build_callid_pvt(p); if (peer->pokeexpire > -1) ast_sched_del(sched, peer->pokeexpire); p->relatedpeer = peer; ast_set_flag(&p->flags[0], SIP_OUTGOING); #ifdef VOCAL_DATA_HACK ast_copy_string(p->peername, "__VOCAL_DATA_SHOULD_READ_THE_SIP_SPEC__", sizeof(p->peername)); transmit_invite(p, SIP_INVITE, FALSE, 2); #else transmit_invite(p, SIP_OPTIONS, FALSE, 2); #endif gettimeofday(&peer->ps, NULL); peer->pokeexpire = ast_sched_add(sched, DEFAULT_QUALIFY_MAXMS * 2, sip_poke_noanswer, peer); return 0; }

int sip_poke_peer_s (  void *  data  )

Poke peer (send qualify to check if peer is alive and well). Definition at line 93 of file sip3_pokedevice.c. References sip_device::pokeexpire, and sip_poke_peer(). { struct sip_device *peer = data; peer->pokeexpire = -1; sip_poke_peer(peer); return 0; }

---

Asterisk is a trademark for Digium, inc.. | Edvina.net | Asterisk.org | This documentation was generated with Doxygen