Re: [SR-Users] 200 OK re transmission only on re-SUBSCRIBE

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 &lt;miconda(a)gmail.com&gt; Sent: 26 January 2022 16:37 To: Kamailio (SER) - Users Mailing List &lt;sr-users(a)lists.kamailio.org&gt;rg>; Lewis Hutchinson &lt;lewis.hutchinson(a)missionlabs.co.uk&gt; 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@lists.kamailio.org<mailto:sr-users@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://eur… -- Daniel-Constantin Mierla -- www.asipto.com<https://eur03.safelinks.protection.outlook.com/?url=http%… www.twitter.com/miconda<https://eur03.safelinks.protection.outlook.com/?… -- www.linkedin.com/in/miconda<https://eur03.safelinks.protection.outlook.c… Kamailio Advanced Training - Online Feb 21-24, 2022 (America Timezone) * https://www.asipto.com/sw/kamailio-advanced-training-online/<https://eur…