[SR-Users] dmq_replicate deserializing?

Charles Chance charles.chance at sipcentric.com
Thu Jul 2 08:57:04 CEST 2015 

Hello,

As with your other thread, I suspect dmq_usrloc is at fault here. I've not
looked at this module before, but can take a look over the next day or so
if no one else gets to it first.

Cheers,
On 1 Jul 2015 22:13, "Asgaroth" <00asgaroth00 at gmail.com> wrote:

>  Hi,
>
> Sorry, the previous sample, was the incorrect timestamp, this one is the
> corresponding message sent:
>
> U 2015/07/01 20:40:52.446646 10.6.0.173:5060 -> 10.6.0.174:5060
>
> KDMQ sip:usrloc at 10.6.0.174:5060 SIP/2.0.
> Via: SIP/2.0/UDP
> 10.6.0.173;branch=z9hG4bK9b3c.fe993716000000000000000000000000.0.
> To: <sip:usrloc at 10.6.0.174:5060> <sip:usrloc at 10.6.0.174:5060>.
> From: <sip:usrloc at 10.6.0.173:5060> <sip:usrloc at 10.6.0.173:5060>
> ;tag=390c95c339281829d3cea6f43c8512cb-7e62.
> CSeq: 10 KDMQ.
> Call-ID: 3c502b38465e8d94-8433 at 10.6.0.173.
> Content-Length: 471.
> User-Agent: kamailio (bfievkrl01).
> Max-Forwards: 1.
> Content-Type: application/json.
> .
> {"action":1,"aor":"subscriber_name at subscriber_domain
> ","ruid":"uloc-55941474-20f1-1","c":
> "sip:subscriber_name at 212.2.160.202:61270;rinstance=7b7c543d11c12134;transport=UDP"
> <sip:subscriber_name at 212.2.160.202:61270;rinstance=7b7c543d11c12134;transport=UDP>
> ,"received":"sip:212.2.160.202:61270
> ","path":"<sip:10.7.0.109;lr;received=sip:212.2.160.202:61270>","callid":"rvOjXlyhAGK1aokNbR859w..","user_agent":"Z
> 3.7.30891
> r30851","instance":"","expires":1435779765,"cseq":6,"flags":0,"cflags":64,"q":-1,"last_modified":1435779652,"methods":5087,"reg_id":0}
>
>
>
> On 01/07/2015 21:30, Charles Chance wrote:
>
> Hello,
>
> Should be no need to load any additional deserializer. The docs simply
> mean if you wish to send/receive your own messages from within a module or
> script, it's up to you to choose the best payload type and method of
> (de)serialization.
>
> Can you post an example KDMQ message here to look at?
>
> Cheers,
> Charles
> On 1 Jul 2015 20:49, "Asgaroth" <00asgaroth00 at gmail.com> wrote:
>
>> Hi All,
>>
>> I am playing with the new dmq_replicate module and am banging my head
>> against an issue I have come accross. I can see the kamailio registrars
>> sending the replication messages to the other node(s) in the dmq bus, and
>> the payload looks to be of type json. However, on the recieving nodes, when
>> I try to issue a kamctl ul show --brief, the output of the AOR's are
>> garbled.
>>
>> I had a look at the dmq/dmq_ursloc moduled, and the dmq module docs
>> mention that we may need to load our own deserializers, is this the case
>> when using the dmq_usrloc module as well? I am only using dmq to replicate
>> registration messages.
>>
>> Here is a sample of the dmq workers on a recieving node applying the
>> update, and you can see that it thinks the contact to add is 'p÷#031#002',
>> is was expecting the actual AOR of the subriber to show up here.
>>
>> Am I missing something simple here or is there something more sinister at
>> play.
>>
>> Any pointers would be greatly appreciated.
>>
>> Kamailio Version:
>>
>> version: kamailio 4.3.0 (x86_64/linux) c6aa95
>> 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: c6aa95
>> compiled on 16:14:27 Jun 23 2015 with gcc 4.4.7
>>
>> Debug log below:
>>
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/msg_parser.c:606]: parse_msg(): SIP Request:
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/msg_parser.c:608]: parse_msg():  method: <KDMQ>
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/msg_parser.c:610]: parse_msg():  uri: <sip:usrloc at 10.6.0.174:5060
>> >
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/msg_parser.c:612]: parse_msg():  version: <SIP/2.0>
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/parse_via.c:1254]: parse_via_param(): Found param type 232,
>> <branch> = <z9hG4bK9b3c.fe993716000000000000000000000000.0>; state=16
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/parse_via.c:2642]: parse_via(): end of header reached, state=5
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/msg_parser.c:496]: parse_headers(): parse_headers: Via found,
>> flags=2
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/msg_parser.c:498]: parse_headers(): parse_headers: this is the
>> first via
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [receive.c:134]: receive_msg(): After parse_msg...
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [receive.c:177]: receive_msg(): preparing to run routing scripts...
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: tm
>> [t_lookup.c:1011]: t_check_msg(): DEBUG: t_check_msg: msg id=450 global
>> id=449 T start=0xffffffffffffffff
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/parse_addr_spec.c:894]: parse_addr_spec(): end of header reached,
>> state=10
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/msg_parser.c:173]: get_hdr_field(): DEBUG: get_hdr_field: <To>
>> [30]; uri=[sip:usrloc at 10.6.0.174:5060]
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/msg_parser.c:175]: get_hdr_field(): DEBUG: to body [<
>> sip:usrloc at 10.6.0.174:5060>#015#012]
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/msg_parser.c:153]: get_hdr_field(): get_hdr_field: cseq <CSeq>:
>> <10> <KDMQ>
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/msg_parser.c:187]: get_hdr_field(): DEBUG: get_hdr_body :
>> content_length=471
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [parser/msg_parser.c:89]: get_hdr_field(): found end of header
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: tm
>> [t_lookup.c:466]: t_lookup_request(): t_lookup_request: start searching:
>> hash=50105, isACK=0
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: tm
>> [t_lookup.c:424]: matching_3261(): DEBUG: RFC3261 transaction matching
>> failed
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: tm
>> [t_lookup.c:648]: t_lookup_request(): DEBUG: t_lookup_request: no
>> transaction found
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: tm
>> [t_lookup.c:1080]: t_check_msg(): DEBUG: t_check_msg: msg id=450 global
>> id=450 T end=(nil)
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: dmq
>> [message.c:53]: dmq_handle_message(): dmq_handle_message [KDMQ
>> sip:usrloc at 10.6.0.174:5060] [ ]
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: dmq
>> [message.c:65]: dmq_handle_message(): dmq_handle_message peer found: usrloc
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [usr_avp.c:631]: destroy_avp_list(): destroying list (nil)
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [usr_avp.c:631]: destroy_avp_list(): destroying list (nil)
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: dmq
>> [worker.c:84]: worker_loop(): dmq_worker [0 23014] lock acquired
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [usr_avp.c:631]: destroy_avp_list(): destroying list (nil)
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: <core>
>> [parser/parse_addr_spec.c:172]: parse_to_param(): DEBUG: add_param:
>> tag=390c95c339281829d3cea6f43c8512cb-7e62
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: <core>
>> [parser/parse_addr_spec.c:894]: parse_addr_spec(): end of header reached,
>> state=29
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: dmq_usrloc
>> [usrloc_sync.c:250]: usrloc_dmq_handle_msg(): dmq message received from
>> sip:usrloc at 10.6.0.173:5060
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: dmq_usrloc
>> [usrloc_sync.c:353]: usrloc_dmq_handle_msg(): Received DMQ_UPDATE. Update
>> contact info...
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: dmq_usrloc
>> [usrloc_sync.c:60]: add_contact(): 'p÷#031#002' found in usrloc
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: dmq_usrloc
>> [usrloc_sync.c:62]: add_contact(): get_ucontact = 0
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: dmq_usrloc
>> [usrloc_sync.c:72]: add_contact(): Found contact
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: usrloc
>> [ucontact.c:1688]: update_ucontact(): exists callback for type=
>> UL_CONTACT_UPDATE
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: usrloc
>> [ul_callback.h:84]: run_ul_callbacks(): contact=0x7ffe86eabad8, callback
>> type 2/15, id 0 entered
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: dmq_usrloc
>> [usrloc_sync.c:494]: dmq_ul_cb_contact(): Callback from usrloc with type=2
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: dmq_usrloc
>> [usrloc_sync.c:517]: dmq_ul_cb_contact(): Contact recieved from DMQ... skip
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: dmq_usrloc
>> [usrloc_sync.c:85]: add_contact(): Release record
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: dmq_usrloc
>> [usrloc_sync.c:87]: add_contact(): Unlock udomain
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: sl
>> [sl.c:280]: send_reply(): reply in stateless mode (sl)
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [usr_avp.c:631]: destroy_avp_list(): destroying list (nil)
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: <core>
>> [msg_translator.c:158]: check_via_address(): (10.6.0.173, 10.6.0.173, 0)
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [usr_avp.c:631]: destroy_avp_list(): destroying list (nil)
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [usr_avp.c:631]: destroy_avp_list(): destroying list (nil)
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [xavp.c:446]: xavp_destroy_list(): destroying xavp list (nil)
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23007]: DEBUG: <core>
>> [receive.c:278]: receive_msg(): cleaning up
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: dmq
>> [worker.c:134]: worker_loop(): sent reply
>> Jul  1 20:40:52 bfievkrl02 /usr/sbin/kamailio[23014]: DEBUG: dmq
>> [worker.c:82]: worker_loop(): dmq_worker [0 23014] getting lock
>>
>>
>>
>> _______________________________________________
>> SIP Express Router (SER) and Kamailio (OpenSER) - sr-users mailing list
>> sr-users at lists.sip-router.org
>> http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-users
>>
>
> www.sipcentric.com
>
> Follow us on twitter @sipcentric <http://twitter.com/sipcentric>
>
> Sipcentric Ltd. Company registered in England & Wales no. 7365592. Registered
> office: Faraday Wharf, Innovation Birmingham Campus, Holt Street,
> Birmingham Science Park, Birmingham B7 4BB.
>
> _______________________________________________
> SIP Express Router (SER) and Kamailio (OpenSER) - sr-users mailing listsr-users at lists.sip-router.orghttp://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-users
>
>
>
> _______________________________________________
> SIP Express Router (SER) and Kamailio (OpenSER) - sr-users mailing list
> sr-users at lists.sip-router.org
> http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-users
>
>

-- 
www.sipcentric.com

Follow us on twitter @sipcentric <http://twitter.com/sipcentric>

Sipcentric Ltd. Company registered in England & Wales no. 7365592. Registered 
office: Faraday Wharf, Innovation Birmingham Campus, Holt Street, 
Birmingham Science Park, Birmingham B7 4BB.
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.sip-router.org/pipermail/sr-users/attachments/20150702/e639a474/attachment.html>

More information about the sr-users mailing list