[SR-Users] 200 OK re transmission only on re-SUBSCRIBE
Lewis Hutchinson
lewis.hutchinson at missionlabs.co.uk
Wed Jan 26 18:22:41 CET 2022
Hi Daniel
Many thanks, this is in the early stages and to undergo extensive testing which I suspect will see a lot efforts to improve and refine. This was previously written in native kamailio but for other reasons moved to python. Any feedback always welcome
"looks like after sending the response execution continues somewhere else hitting t_check_trans() which detect the transaction exists and re-sends the last last reply (as it is supposed to behave)." can you think why this only occur on a re SUBSCRIBE
There is no intelligence in the reply needed just an accurate response from the API transformed into a reply 200, 500 etc etc
Lewis
From: Daniel-Constantin Mierla <miconda at gmail.com>
Sent: 26 January 2022 16:37
To: Kamailio (SER) - Users Mailing List <sr-users at lists.kamailio.org>; Lewis Hutchinson <lewis.hutchinson at missionlabs.co.uk>
Subject: Re: [SR-Users] 200 OK re transmission only on re-SUBSCRIBE
Hello,
looks like after sending the response execution continues somewhere else hitting t_check_trans() which detect the transaction exists and re-sends the last last reply (as it is supposed to behave).
Be also careful with async processing in python, I am not familiar with it at all, just be aware that kamailio has a multi-process design and uses per-process global variables. if you do multi-threading async processing in python, be sure you ensure consistency of globals and avoid races to read+change them.
Cheers,
Daniel
On 26.01.22 16:53, Lewis Hutchinson wrote:
First of all I should start by saying this is my first post so go easy on me!! : ) and thank for everyone's efforts to share knowledge it has been invaluable for my kamailio learning.
Build Details
Version: kamailio 5.5.3 (x86_64/linux)
Kamailio kemi python
Scenario
Relevant config
def ksr_route_api_query(self, msg):
KSR.log("info", "SUBSCRIBE API Query Starts")
# Create new Transaction
KSR.tm.t_newtran()
async def main():
url = 'https://api.hidingtheurl.com/subscribe<https://eur03.safelinks.protection.outlook.com/?url=https%3A%2F%2Fapi.hidingtheurl.com%2Fsubscribe&data=04%7C01%7Clewis.hutchinson%40missionlabs.co.uk%7Cdd21c3bd426b483f046908d9e0ea0e56%7C97c26f550a7a4661bd8f7b43b50d3f2b%7C0%7C0%7C637788119843865974%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C3000&sdata=RUXou2G%2F5kC2rT2VKu%2BJ3YQKvimpUxe4HsyMjfqXAUk%3D&reserved=0>'
payload = {
"ruri": KSR.pv.get("$ru"),
"from": KSR.pv.get("$fu"),
"from_tag": KSR.pv.gete("$ft"),
"to": KSR.pv.get("$tu"),
"callid": KSR.pv.get("$ci"),
"cseq": KSR.pv.get("$cs"),
"contact": KSR.pv.gete("$ct"),
"supported": KSR.pv.get("$hdr(Supported)"),
"event": KSR.pv.get("$hdr(Event)"),
"expires": KSR.pv.get("$hdr(Expires)"),
"diversion": KSR.pv.get("$di"),
"body": KSR.pv.get("$rb")
}
async with aiohttp.ClientSession() as session:
async with session.post(url, json=payload) as response:
if response.status == 0:
KSR.xlog.xinfo(f"SUB Manager Timeout: {response.status}")
KSR.tm.t_reply(408, "SUB Manager Timeout")
elif response.status >= 500:
KSR.xlog.xinfo(f"SUB Manager Down: {response.status}")
KSR.tm.t_reply(500, "SUB Manager Down")
elif response.status >= 400:
KSR.xlog.xinfo(f"SUB Manager Error: {response.status}")
KSR.tm.t_reply(400, "SUB Manager Error")
else:
if response.status == 200:
KSR.xlog.xinfo(f"SUB Manager Success: {response.status}")
KSR.tm.t_reply(200, "OK")
KSR.log("info", "SUBSCRIBE API Query Ends")
asyncio.run(main())
# API Query Ends
Scenario
Initial SUBSCRIBE >>> hits Kamailio >>> send payload in JSON to API get receive 200OK response from API and send a 200OK on to Device
SUBSCRIBE -------->
<------------ 200 OK
After Subscription Expiry
re-SUBSCRIBE >>> hits Kamailio >>> send payload in JSON to API get 200OK response from API and send a 200OK on to Device but also another 200OK a fraction of a second later...
SUBSCRIBE -------->
<------------ 200 OK
<<<--------- 200 OK
This happens for all following re-SUBSCRIBE's
The 200 OK are identical, and it is a re transmission, but I can't work out why..
Relevant DEBUG is below
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: INFO: <script>: SUB Manager Success: 200
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: app_python3 [apy_kemi.c:232]: sr_apy_kemi_exec_func_ex(): execution of method: t_reply
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: app_python3 [apy_kemi.c:287]: sr_apy_kemi_exec_func_ex(): params[2] for: t_reply are int-str: [200] [OK]
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: tm [t_lookup.c:1034]: t_check_msg(): msg (0x7eff0cd4e828) id=2/11234 global id=2/11234 T start=0x7eff0918d7d8
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: tm [t_lookup.c:1108]: t_check_msg(): T (0x7eff0918d7d8) already found for msg (0x7eff0cd4e828)!
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: <core> [core/msg_translator.c:162]: check_via_address(): (80.111.111.111, 80.111.111.111, 0)
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: tm [t_reply.c:1763]: cleanup_uac_timers(): RETR/FR timers reset
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: tm [t_reply.c:637]: _reply_light(): reply sent out - buf=0x7eff0cd50938: SIP/2.0 200 OK#015#012Via:... shmem=0x7eff09190ca8: SIP/2.0 200 OK#015#012Via:
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: tm [t_reply.c:648]: _reply_light(): finished
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: app_python3 [apy_kemi.c:232]: sr_apy_kemi_exec_func_ex(): execution of method: t_precheck_trans
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: app_python3 [apy_kemi.c:232]: sr_apy_kemi_exec_func_ex(): execution of method: t_check_trans
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: tm [t_lookup.c:1034]: t_check_msg(): msg (0x7eff0cd4e828) id=2/11234 global id=2/11234 T start=0x7eff0918d7d8
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: tm [t_lookup.c:1108]: t_check_msg(): T (0x7eff0918d7d8) already found for msg (0x7eff0cd4e828)!
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: tm [t_reply.c:1703]: t_retransmit_reply(): reply retransmitted. buf=0x7eff0cb18220: SIP/2.0 2..., shmem=0x7eff09190ca8: SIP/2.0 2
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: app_python3 [apy_kemi.c:112]: sr_kemi_config_engine_python(): execution of route type 1 with no name returned 1
Jan 26 12:31:17 ip-172-20-46-39 kamailio[11234]: DEBUG: <core> [core/receive.c:514]: receive_msg(): request-route executed in: 38258 usec
Everything works well as is but I want to clean up this issue or at least understand what is causing it.
Lewis
__________________________________________________________
Kamailio - Users Mailing List - Non Commercial Discussions
* sr-users at lists.kamailio.org<mailto:sr-users at lists.kamailio.org>
Important: keep the mailing list in the recipients, do not reply only to the sender!
Edit mailing list options or unsubscribe:
* https://lists.kamailio.org/cgi-bin/mailman/listinfo/sr-users<https://eur03.safelinks.protection.outlook.com/?url=https%3A%2F%2Flists.kamailio.org%2Fcgi-bin%2Fmailman%2Flistinfo%2Fsr-users&data=04%7C01%7Clewis.hutchinson%40missionlabs.co.uk%7Cdd21c3bd426b483f046908d9e0ea0e56%7C97c26f550a7a4661bd8f7b43b50d3f2b%7C0%7C0%7C637788119843875940%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C3000&sdata=ktFWCyiPBcm1lBD%2FufKC29cRDas8w40bz%2B%2FeqlKU4ME%3D&reserved=0>
--
Daniel-Constantin Mierla -- www.asipto.com<https://eur03.safelinks.protection.outlook.com/?url=http%3A%2F%2Fwww.asipto.com%2F&data=04%7C01%7Clewis.hutchinson%40missionlabs.co.uk%7Cdd21c3bd426b483f046908d9e0ea0e56%7C97c26f550a7a4661bd8f7b43b50d3f2b%7C0%7C0%7C637788119843885892%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C3000&sdata=sWTHp6KL5rN4GUE0AE8bjcPZ%2FY15ogA3kXohl8pFPlU%3D&reserved=0>
www.twitter.com/miconda<https://eur03.safelinks.protection.outlook.com/?url=http%3A%2F%2Fwww.twitter.com%2Fmiconda&data=04%7C01%7Clewis.hutchinson%40missionlabs.co.uk%7Cdd21c3bd426b483f046908d9e0ea0e56%7C97c26f550a7a4661bd8f7b43b50d3f2b%7C0%7C0%7C637788119843885892%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C3000&sdata=9aZF1fGLjKeQHQjJh6EtQoM%2FguP78pdwEmec7wRl%2FeY%3D&reserved=0> -- www.linkedin.com/in/miconda<https://eur03.safelinks.protection.outlook.com/?url=http%3A%2F%2Fwww.linkedin.com%2Fin%2Fmiconda&data=04%7C01%7Clewis.hutchinson%40missionlabs.co.uk%7Cdd21c3bd426b483f046908d9e0ea0e56%7C97c26f550a7a4661bd8f7b43b50d3f2b%7C0%7C0%7C637788119843895840%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C3000&sdata=M6Eisb%2FqYQ%2FnBEK8zF2vbhCycOPtGT%2B6rV3coVO6Ebo%3D&reserved=0>
Kamailio Advanced Training - Online
Feb 21-24, 2022 (America Timezone)
* https://www.asipto.com/sw/kamailio-advanced-training-online/<https://eur03.safelinks.protection.outlook.com/?url=https%3A%2F%2Fwww.asipto.com%2Fsw%2Fkamailio-advanced-training-online%2F&data=04%7C01%7Clewis.hutchinson%40missionlabs.co.uk%7Cdd21c3bd426b483f046908d9e0ea0e56%7C97c26f550a7a4661bd8f7b43b50d3f2b%7C0%7C0%7C637788119843905804%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C3000&sdata=O2YyPhALtsIevNfiWMTXdK2GMaeZ91GU%2B1ebo%2BC%2Fx9E%3D&reserved=0>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.kamailio.org/pipermail/sr-users/attachments/20220126/4ec3c608/attachment.htm>
More information about the sr-users
mailing list