Module: kamailio Branch: master Commit: c291dc1a0e965b664aacb994ac08fbc7f20bcaec URL: https://github.com/kamailio/kamailio/commit/c291dc1a0e965b664aacb994ac08fbc… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2017-12-12T09:58:44+01:00 pua_rpc: added pua.send_publish rpc command - send a PUBLISH request without waiting for response --- Modified: src/modules/pua_rpc/pua_rpc.c --- Diff: https://github.com/kamailio/kamailio/commit/c291dc1a0e965b664aacb994ac08fbc… Patch: https://github.com/kamailio/kamailio/commit/c291dc1a0e965b664aacb994ac08fbc… --- diff --git a/src/modules/pua_rpc/pua_rpc.c b/src/modules/pua_rpc/pua_rpc.c index 0687b9d127..86bb231b4f 100644 --- a/src/modules/pua_rpc/pua_rpc.c +++ b/src/modules/pua_rpc/pua_rpc.c @@ -57,6 +57,14 @@ static const char* pua_rpc_publish_doc[2] = { 0 }; +static const char* pua_rpc_send_publish_doc[2] = { + "Send publish request without waiting for the final reply, using a list " + "of string parameters: presentity uri, expires, event package, " + "content type, id, etag, outbound proxy, extra headers, " + " and body (optional)", + 0 +}; + static int pua_rpc_publish_callback(ua_pres_t* hentity, sip_msg_t* reply) { @@ -130,11 +138,11 @@ static int pua_rpc_publish_callback(ua_pres_t* hentity, sip_msg_t* reply) } -static void pua_rpc_publish(rpc_t* rpc, void* c) +static void pua_rpc_publish_mode(rpc_t* rpc, void* c, int mode) { str pres_uri, expires, event, content_type, id, etag, outbound_proxy, extra_headers, body; - rpc_delayed_ctx_t* dctx; + rpc_delayed_ctx_t* dctx = NULL; int exp, sign, ret, err_ret, sip_error; char err_buf[MAX_REASON_LEN]; struct sip_uri uri; @@ -242,24 +250,30 @@ static void pua_rpc_publish(rpc_t* rpc, void* c) publ.body= &body; } - dctx = rpc->delayed_ctx_new(c); - if (dctx == 0) { - LM_ERR("internal error: failed to create context\n"); - rpc->fault(c, 500, "Internal error: failed to create context"); - return; + if(mode==1) { + dctx = rpc->delayed_ctx_new(c); + if (dctx == 0) { + LM_ERR("internal error: failed to create context\n"); + rpc->fault(c, 500, "Internal error: failed to create context"); + return; + } + publ.cb_param = dctx; + publ.source_flag = RPC_ASYN_PUBLISH; + } else { + publ.source_flag = RPC_PUBLISH; } - publ.cb_param = dctx; - publ.source_flag = RPC_ASYN_PUBLISH; ret = pua_rpc_api.send_publish(&publ); LM_DBG("pua send_publish returned %d\n", ret); - if (dctx->reply_ctx != 0) { - /* callback was not executed or its execution failed */ - rpc = &dctx->rpc; - c = dctx->reply_ctx; - } else { - return; + if(mode==1) { + if (dctx->reply_ctx != 0) { + /* callback was not executed or its execution failed */ + rpc = &dctx->rpc; + c = dctx->reply_ctx; + } else { + return; + } } if (ret < 0) { @@ -271,18 +285,36 @@ static void pua_rpc_publish(rpc_t* rpc, void* c) } else { rpc->fault(c, 500, "RPC/PUBLISH error"); } - rpc->delayed_ctx_close(dctx); + if(mode==1) { + rpc->delayed_ctx_close(dctx); + } } if (ret == 418) { rpc->fault(c, 500, "Wrong ETag"); - rpc->delayed_ctx_close(dctx); + if(mode==1) { + rpc->delayed_ctx_close(dctx); + } } - return; } +/** + * + */ +static void pua_rpc_publish(rpc_t* rpc, void* c) +{ + pua_rpc_publish_mode(rpc, c, 1); +} + +/** + * + */ +static void pua_rpc_send_publish(rpc_t* rpc, void* c) +{ + pua_rpc_publish_mode(rpc, c, 0); +} /** * rpc pua.subscribe @@ -348,6 +380,7 @@ static const char* pua_rpc_subscribe_doc[2] = { rpc_export_t pua_rpc_ex[] = { {"pua.publish", pua_rpc_publish, pua_rpc_publish_doc, 0}, + {"pua.send_publish", pua_rpc_send_publish, pua_rpc_send_publish_doc, 0}, {"pua.subscribe", pua_rpc_subscribe, pua_rpc_subscribe_doc, 0}, {0, 0, 0, 0} };