[SR-Users] dmq_replicate deserializing?

Asgaroth 00asgaroth00 at gmail.com
Wed Jul 1 23:12:50 CEST 2015


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>.
From: 
<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","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 
> <mailto: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 <http://sip:usrloc@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
>     <http://sip:usrloc@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
>     <http://sip:usrloc@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 <http://sip:usrloc@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
>     <http://sip:usrloc@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 <mailto:sr-users at lists.sip-router.org>
>     http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-users
>
>
> www.sipcentric.com <http://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 list
> sr-users at lists.sip-router.org
> http://lists.sip-router.org/cgi-bin/mailman/listinfo/sr-users

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.sip-router.org/pipermail/sr-users/attachments/20150701/a1d2995e/attachment.html>


More information about the sr-users mailing list