sr-dev March 2015

sr-dev@lists.kamailio.org

34 participants
192 discussions

Redis disconnect when websocket endpoint try to call
by Yuriy Gorlichenko 02 Mar '15

02 Mar '15

Hello. I use this version of kamailio kamailio -v version: kamailio 4.3.0-dev4 (x86_64/linux) a6510b flags: STATS: Off, USE_TCP, USE_TLS, TLS_HOOKS, USE_RAW_SOCKS, DISABLE_NAGLE, USE_MCAST, DNS_IP_HACK, SHM_MEM, SHM_MMAP, PKG_MALLOC, F_MALLOC, DBG_F_MALLOC, USE_FUTEX, FAST_LOCK-ADAPTIVE_WAIT, USE_DNS_CACHE, USE_DNS_FAILOVER, USE_NAPTR, USE_DST_BLACKLIST, HAVE_RESOLV_RES ADAPTIVE_WAIT_LOOPS=1024, MAX_RECV_BUFFER_SIZE 262144, MAX_LISTEN 16, MAX_URI_SIZE 1024, BUF_SIZE 65535, DEFAULT PKG_SIZE 8MB poll method support: poll, epoll_lt, epoll_et, sigio_rt, select. id: a6510b compiled on 05:30:34 Feb 18 2015 with gcc 4.8.2 Now i Have some problems with redis. I try to get some replies from redis. Time after time redis request give me null result. I see this error at log when this reply received redisc_exec(): Redis error: Server closed the connection This happens only with websocket endpoints. My queries is: redis_cmd("srv1", "EXISTS $si", "s"); So at xLOG i see that $si correctly sended, but result is null. At db I keep key IP with value TIMESTAMP Intresting that route, that gives me this result idependend of WS or UDP endpoint. IT does not know about it anything. I try to cach redis-cli: monitor log, but this answered me nothing. I Logging $si before redis replies and it is ok. My exaple of ROUTE that takes this walues from redis is: route[TOASTERISK] { redis_cmd("srv1", "EXISTS $si", "s"); xlog("L_INFO","ASTERISK with ip $si is {$redis(s=>value)}"); } Asterisk sends me option method requests every 10 seconds and I set it to redis with key $si and value $TS IT lives at redis 20 seconds and rewrites with every new request so when invite come to kamailio it just check - does this key exists (ROUTE TOASTERISK) When I catch this error (null) I look at redis and see that key exisit. But it does not mateer. If it not exisit redis myst reply with 0. Now with null.

2 2

git:master:2549f7a6: core: cleaned debug messages and added safety check for bind address
by Daniel-Constantin Mierla 01 Mar '15

01 Mar '15

Module: kamailio Branch: master Commit: 2549f7a6361de36e0dde14de3d5c4c076564871c URL: https://github.com/kamailio/kamailio/commit/2549f7a6361de36e0dde14de3d5c4c0… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2015-03-01T21:17:21+01:00 core: cleaned debug messages and added safety check for bind address --- Modified: tcp_main.c --- Diff: https://github.com/kamailio/kamailio/commit/2549f7a6361de36e0dde14de3d5c4c0… Patch: https://github.com/kamailio/kamailio/commit/2549f7a6361de36e0dde14de3d5c4c0… --- diff --git a/tcp_main.c b/tcp_main.c index f8a7c6d..5553921 100644 --- a/tcp_main.c +++ b/tcp_main.c @@ -3770,17 +3770,17 @@ inline static int send2child(struct tcp_connection* tcpconn) if(tcpconn->rcv.bind_address->workers>0) { wfirst = tcpconn->rcv.bind_address->workers_tcpidx; wlast = wfirst + tcpconn->rcv.bind_address->workers; - LM_DBG("===== checking per-socket specific workers (%d/%d..%d/%d) [%s]\n", + LM_DBG("checking per-socket specific workers (%d/%d..%d/%d) [%s]\n", tcp_children[wfirst].pid, tcp_children[wfirst].proc_no, tcp_children[wlast-1].pid, tcp_children[wlast-1].proc_no, - tcpconn->rcv.bind_address->sock_str.s); + (tcpconn->rcv.bind_address)?tcpconn->rcv.bind_address->sock_str.s:""); } else { wfirst = 0; wlast = tcp_sockets_gworkers - 1; - LM_DBG("+++++ checking per-socket generic workers (%d/%d..%d/%d) [%s]\n", + LM_DBG("checking per-socket generic workers (%d/%d..%d/%d) [%s]\n", tcp_children[wfirst].pid, tcp_children[wfirst].proc_no, tcp_children[wlast-1].pid, tcp_children[wlast-1].proc_no, - tcpconn->rcv.bind_address->sock_str.s); + (tcpconn->rcv.bind_address)?tcpconn->rcv.bind_address->sock_str.s:""); } idx = wfirst; min_busy = tcp_children[idx].busy; @@ -3807,7 +3807,8 @@ inline static int send2child(struct tcp_connection* tcpconn) } LM_DBG("selected tcp worker %d %d(%ld) for activity on [%s], %p\n", idx, tcp_children[idx].proc_no, (long)tcp_children[idx].pid, - tcpconn->rcv.bind_address->sock_str.s, tcpconn); + (tcpconn->rcv.bind_address)?tcpconn->rcv.bind_address->sock_str.s:"", + tcpconn); /* first make sure this child doesn't have pending request for * tcp_main (to avoid a possible deadlock: e.g. child wants to * send a release command, but the master fills its socket buffer

1 0

Jump to page:

2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

sr-dev March 2015