Merged revisions 42086 via svnmerge from

https://origsvn.digium.com/svn/asterisk/branches/1.2

........
r42086 | file | 2006-09-06 11:55:20 -0400 (Wed, 06 Sep 2006) | 2 lines

Make realtime regseconds work as people expected (0 on registration expiration or release, and actual on normal state) (issue #7684 reported by kshumard)

........


git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@42087 65c4cc65-6c06-0410-ace0-fbb531ad65f3
1.4
Joshua Colp 19 years ago
parent 228d50806c
commit e77c51f5c6

@ -2550,14 +2550,12 @@ static struct iax2_user *realtime_user(const char *username)
return user; return user;
} }
static void realtime_update_peer(const char *peername, struct sockaddr_in *sin) static void realtime_update_peer(const char *peername, struct sockaddr_in *sin, time_t regtime)
{ {
char port[10]; char port[10];
char regseconds[20]; char regseconds[20];
time_t nowtime;
time(&nowtime); snprintf(regseconds, sizeof(regseconds), "%d", (int)regtime);
snprintf(regseconds, sizeof(regseconds), "%d", (int)nowtime);
snprintf(port, sizeof(port), "%d", ntohs(sin->sin_port)); snprintf(port, sizeof(port), "%d", ntohs(sin->sin_port));
ast_update_realtime("iaxpeers", "name", peername, ast_update_realtime("iaxpeers", "name", peername,
"ipaddr", ast_inet_ntoa(sin->sin_addr), "port", port, "ipaddr", ast_inet_ntoa(sin->sin_addr), "port", port,
@ -5487,6 +5485,8 @@ static void __expire_registry(void *data)
return; return;
ast_log(LOG_DEBUG, "Expiring registration for peer '%s'\n", p->name); ast_log(LOG_DEBUG, "Expiring registration for peer '%s'\n", p->name);
if (ast_test_flag((&globalflags), IAX_RTUPDATE) && (ast_test_flag(p, IAX_TEMPONLY|IAX_RTCACHEFRIENDS)))
realtime_update_peer(p->name, &p->addr, 0);
manager_event(EVENT_FLAG_SYSTEM, "PeerStatus", "Peer: IAX2/%s\r\nPeerStatus: Unregistered\r\nCause: Expired\r\n", p->name); manager_event(EVENT_FLAG_SYSTEM, "PeerStatus", "Peer: IAX2/%s\r\nPeerStatus: Unregistered\r\nCause: Expired\r\n", p->name);
/* Reset the address */ /* Reset the address */
memset(&p->addr, 0, sizeof(p->addr)); memset(&p->addr, 0, sizeof(p->addr));
@ -5571,8 +5571,15 @@ static int update_registry(const char *name, struct sockaddr_in *sin, int callno
return -1; return -1;
} }
if (ast_test_flag((&globalflags), IAX_RTUPDATE) && (ast_test_flag(p, IAX_TEMPONLY|IAX_RTCACHEFRIENDS))) if (ast_test_flag((&globalflags), IAX_RTUPDATE) && (ast_test_flag(p, IAX_TEMPONLY|IAX_RTCACHEFRIENDS))) {
realtime_update_peer(name, sin); if (sin->sin_addr.s_addr) {
time_t nowtime;
time(&nowtime);
realtime_update_peer(name, sin, nowtime);
} else {
realtime_update_peer(name, sin, 0);
}
}
if (inaddrcmp(&p->addr, sin)) { if (inaddrcmp(&p->addr, sin)) {
if (iax2_regfunk) if (iax2_regfunk)
iax2_regfunk(p->name, 1); iax2_regfunk(p->name, 1);

Loading…
Cancel
Save