sr-dev March 2017

sr-dev@lists.kamailio.org

31 participants
269 discussions

git:master:3fe09fe2: rabbitmq: don't declare reply_to queue on rabbitmq_publish()

by Stefan Mititelu

Module: kamailio Branch: master Commit: 3fe09fe2e18049d3983f7395ca7bae2bef90d198 URL: https://github.com/kamailio/kamailio/commit/3fe09fe2e18049d3983f7395ca7bae2… Author: Stefan Mititelu <stefan.mititelu(a)onem.com> Committer: Stefan Mititelu <stefan.mititelu(a)onem.com> Date: 2017-03-07T16:56:05+02:00 rabbitmq: don't declare reply_to queue on rabbitmq_publish() There is no need to declare a reply-to queue on simple rabbitmq_publish(). The consume will never happen, thus one queue remained spawned, for each rabbitmq_publish() call. --- Modified: src/modules/rabbitmq/rabbitmq.c --- Diff: https://github.com/kamailio/kamailio/commit/3fe09fe2e18049d3983f7395ca7bae2… Patch: https://github.com/kamailio/kamailio/commit/3fe09fe2e18049d3983f7395ca7bae2… --- diff --git a/src/modules/rabbitmq/rabbitmq.c b/src/modules/rabbitmq/rabbitmq.c index 4cd69c9..05fa750 100644 --- a/src/modules/rabbitmq/rabbitmq.c +++ b/src/modules/rabbitmq/rabbitmq.c @@ -175,7 +175,6 @@ static int rabbitmq_publish(struct sip_msg* msg, char* in_exchange, char* in_rou int reconnect_attempts = 0; int log_ret; str exchange, routingkey, messagebody, contenttype; - amqp_bytes_t reply_to_queue; // sanity checks if (get_str_fparam(&exchange, msg, (fparam_t*)in_exchange) < 0) { @@ -231,44 +230,13 @@ static int rabbitmq_publish(struct sip_msg* msg, char* in_exchange, char* in_rou return RABBITMQ_ERR_CHANNEL; } - // alloc queue - amqp_queue_declare_ok_t *r = amqp_queue_declare(conn, 1, amqp_empty_bytes, 0, 0, 0, 1, amqp_empty_table); - if (log_on_amqp_error(amqp_get_rpc_reply(conn), "amqp_queue_declare()") != AMQP_RESPONSE_NORMAL) { - LM_ERR("FAIL: amqp_queue_declare()\n"); - amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS); - return RABBITMQ_ERR_QUEUE; - } - - // alloc bytes - reply_to_queue = amqp_bytes_malloc_dup(r->queue); - LM_DBG("%.*s\n", (int)reply_to_queue.len, (char*)reply_to_queue.bytes); - if (reply_to_queue.bytes == NULL) { - amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS); - amqp_bytes_free(reply_to_queue); - LM_ERR("Out of memory while copying queue name"); - return -1; - } - // alloc properties amqp_basic_properties_t props; props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG | AMQP_BASIC_DELIVERY_MODE_FLAG | - AMQP_BASIC_REPLY_TO_FLAG | AMQP_BASIC_CORRELATION_ID_FLAG; props.content_type = amqp_cstring_bytes(contenttype.s); props.delivery_mode = 2; /* persistent delivery mode */ - props.reply_to = amqp_bytes_malloc_dup(reply_to_queue); - if (props.reply_to.bytes == NULL) { - // debug - LM_ERR("Out of memory while copying queue name"); - - // cleanup - amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS); - amqp_bytes_free(reply_to_queue); - - // error - return -1; - } props.correlation_id = amqp_cstring_bytes("1"); // publish @@ -285,7 +253,6 @@ static int rabbitmq_publish(struct sip_msg* msg, char* in_exchange, char* in_rou // cleanup amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS); - amqp_bytes_free(reply_to_queue); // error return RABBITMQ_ERR_PUBLISH; @@ -295,8 +262,6 @@ static int rabbitmq_publish(struct sip_msg* msg, char* in_exchange, char* in_rou LM_DBG("SUCCESS: amqp_basic_publish()\n"); // cleanup - amqp_bytes_free(props.reply_to); - amqp_bytes_free(reply_to_queue); amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS); // success

7 years, 9 months

git:5.0:c58952c4: db_oracle: fix NULL values binding

by Ovidiu Sas

Module: kamailio Branch: 5.0 Commit: c58952c4d744750a49f51c284f3069342c67409b URL: https://github.com/kamailio/kamailio/commit/c58952c4d744750a49f51c284f30693… Author: Ovidiu Sas <osas(a)voipembedded.com> Committer: Ovidiu Sas <osas(a)voipembedded.com> Date: 2017-03-07T09:46:46-05:00 db_oracle: fix NULL values binding (cherry picked from commit af18ebc1b580c8d236ed6d65ab9e8e8c528adbd2) --- Modified: src/modules/db_oracle/val.c --- Diff: https://github.com/kamailio/kamailio/commit/c58952c4d744750a49f51c284f30693… Patch: https://github.com/kamailio/kamailio/commit/c58952c4d744750a49f51c284f30693… --- diff --git a/src/modules/db_oracle/val.c b/src/modules/db_oracle/val.c index f032734..3b41bbc 100644 --- a/src/modules/db_oracle/val.c +++ b/src/modules/db_oracle/val.c @@ -58,7 +58,35 @@ int db_oracle_val2bind(bmap_t* _m, const db_val_t* _v, OCIDate* _o) if (VAL_NULL(_v)) { _m->addr = NULL; _m->size = 0; - _m->type = SQLT_NON; + switch (VAL_TYPE(_v)) { + case DB1_INT: + _m->type = SQLT_INT; + break; + case DB1_BIGINT: + LM_ERR("BIGINT not supported"); + return -1; + case DB1_BITMAP: + _m->type = SQLT_UIN; + break; + case DB1_DOUBLE: + _m->type = SQLT_FLT; + break; + case DB1_STRING: + _m->type = SQLT_STR; + break; + case DB1_STR: + _m->type = SQLT_CHR; + break; + case DB1_DATETIME: + _m->type = SQLT_ODT; + break; + case DB1_BLOB: + _m->type = SQLT_CLOB; + break; + default: + LM_ERR("unknown data type\n"); + return -1; + } return 0; } @@ -130,8 +158,8 @@ int db_oracle_val2bind(bmap_t* _m, const db_val_t* _v, OCIDate* _o) break; default: - LM_ERR("unknown data type\n"); - return -1; + LM_ERR("unknown data type\n"); + return -1; } return 0; }

7 years, 9 months

git:master:af18ebc1: db_oracle: fix NULL values binding

by Ovidiu Sas

Module: kamailio Branch: master Commit: af18ebc1b580c8d236ed6d65ab9e8e8c528adbd2 URL: https://github.com/kamailio/kamailio/commit/af18ebc1b580c8d236ed6d65ab9e8e8… Author: Ovidiu Sas <osas(a)voipembedded.com> Committer: Ovidiu Sas <osas(a)voipembedded.com> Date: 2017-03-07T09:42:48-05:00 db_oracle: fix NULL values binding --- Modified: src/modules/db_oracle/val.c --- Diff: https://github.com/kamailio/kamailio/commit/af18ebc1b580c8d236ed6d65ab9e8e8… Patch: https://github.com/kamailio/kamailio/commit/af18ebc1b580c8d236ed6d65ab9e8e8… --- diff --git a/src/modules/db_oracle/val.c b/src/modules/db_oracle/val.c index f032734..3b41bbc 100644 --- a/src/modules/db_oracle/val.c +++ b/src/modules/db_oracle/val.c @@ -58,7 +58,35 @@ int db_oracle_val2bind(bmap_t* _m, const db_val_t* _v, OCIDate* _o) if (VAL_NULL(_v)) { _m->addr = NULL; _m->size = 0; - _m->type = SQLT_NON; + switch (VAL_TYPE(_v)) { + case DB1_INT: + _m->type = SQLT_INT; + break; + case DB1_BIGINT: + LM_ERR("BIGINT not supported"); + return -1; + case DB1_BITMAP: + _m->type = SQLT_UIN; + break; + case DB1_DOUBLE: + _m->type = SQLT_FLT; + break; + case DB1_STRING: + _m->type = SQLT_STR; + break; + case DB1_STR: + _m->type = SQLT_CHR; + break; + case DB1_DATETIME: + _m->type = SQLT_ODT; + break; + case DB1_BLOB: + _m->type = SQLT_CLOB; + break; + default: + LM_ERR("unknown data type\n"); + return -1; + } return 0; } @@ -130,8 +158,8 @@ int db_oracle_val2bind(bmap_t* _m, const db_val_t* _v, OCIDate* _o) break; default: - LM_ERR("unknown data type\n"); - return -1; + LM_ERR("unknown data type\n"); + return -1; } return 0; }

7 years, 9 months

git:master:501c41dd: db_mongodb: re-init iterator and search again if fails to find from crt position

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: 501c41dd35fb9f15fdf96f4f3778860395e37a84 URL: https://github.com/kamailio/kamailio/commit/501c41dd35fb9f15fdf96f4f3778860… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2017-03-07T08:56:37+01:00 db_mongodb: re-init iterator and search again if fails to find from crt position --- Modified: src/modules/db_mongodb/mongodb_dbase.c --- Diff: https://github.com/kamailio/kamailio/commit/501c41dd35fb9f15fdf96f4f3778860… Patch: https://github.com/kamailio/kamailio/commit/501c41dd35fb9f15fdf96f4f3778860… --- diff --git a/src/modules/db_mongodb/mongodb_dbase.c b/src/modules/db_mongodb/mongodb_dbase.c index f4316ae..759b1c6 100644 --- a/src/modules/db_mongodb/mongodb_dbase.c +++ b/src/modules/db_mongodb/mongodb_dbase.c @@ -377,9 +377,16 @@ int db_mongodb_get_columns(const db1_con_t* _h, db1_res_t* _r) LM_DBG("Found a field[%d] named: %s\n", col, colname); if(mgres->colsdoc) { if(!bson_iter_find(&riter, colname)) { - LM_ERR("field [%s] not found in result iterator\n", - colname); - return -4; + /* re-init the iterator */ + if (!bson_iter_init (&riter, mgres->rdoc)) { + LM_ERR("failed to initialize result iterator\n"); + return -3; + } + if(!bson_iter_find(&riter, colname)) { + LM_ERR("field [%s] not found in result iterator\n", + colname); + return -4; + } } coltype = bson_iter_type(&riter); } else {

7 years, 9 months

git:master:f1f0dbbb: kazoo : add consistent worker binding option

by Luis Azedo

Module: kamailio Branch: master Commit: f1f0dbbbde0bfbe1162deca4f70c3c3969bf99d0 URL: https://github.com/kamailio/kamailio/commit/f1f0dbbbde0bfbe1162deca4f70c3c3… Author: Luis Azedo <luis(a)2600hz.com> Committer: Luis Azedo <luis(a)2600hz.com> Date: 2017-03-06T12:06:48Z kazoo : add consistent worker binding option --- Modified: src/modules/kazoo/kz_amqp.c Modified: src/modules/kazoo/kz_amqp.h --- Diff: https://github.com/kamailio/kamailio/commit/f1f0dbbbde0bfbe1162deca4f70c3c3… Patch: https://github.com/kamailio/kamailio/commit/f1f0dbbbde0bfbe1162deca4f70c3c3… --- diff --git a/src/modules/kazoo/kz_amqp.c b/src/modules/kazoo/kz_amqp.c index a962d99..05e8407 100644 --- a/src/modules/kazoo/kz_amqp.c +++ b/src/modules/kazoo/kz_amqp.c @@ -1551,6 +1551,7 @@ int kz_amqp_subscribe(struct sip_msg* msg, char* payload) int no_ack = 1; int federate = 0; int wait_for_consumer_ack = 1; + int consistent_worker = 0; json_obj_ptr json_obj = NULL; struct json_object* tmpObj = NULL; @@ -1607,6 +1608,11 @@ int kz_amqp_subscribe(struct sip_msg* msg, char* payload) federate = json_object_get_int(tmpObj); } + tmpObj = kz_json_get_object(json_obj, "consistent-worker"); + if(tmpObj != NULL) { + consistent_worker = json_object_get_int(tmpObj); + } + kz_amqp_bind_ptr bind = kz_amqp_bind_alloc(&exchange_s, &exchange_type_s, &queue_s, &routing_key_s); if(bind == NULL) { LM_ERR("Could not allocate bind struct\n"); @@ -1620,6 +1626,7 @@ int kz_amqp_subscribe(struct sip_msg* msg, char* payload) bind->no_ack = no_ack; bind->wait_for_consumer_ack = wait_for_consumer_ack; bind->federate = federate; + bind->consistent_worker = consistent_worker; kz_amqp_binding_ptr binding = shm_malloc(sizeof(kz_amqp_binding)); @@ -2571,6 +2578,7 @@ void kz_amqp_send_worker_event(int _kz_server_id, amqp_envelope_t* envelope, kz_ kz_amqp_consumer_delivery_ptr ptr = NULL; str* message_id = NULL; int idx = envelope->channel-1; + int worker = 0; json_obj_ptr json_obj = kz_json_parse((char*)envelope->message.body.bytes); if (json_obj == NULL) { @@ -2617,12 +2625,21 @@ void kz_amqp_send_worker_event(int _kz_server_id, amqp_envelope_t* envelope, kz_ ptr->event_subkey = kz_amqp_bytes_dup(bind->event_subkey); } - consumer++; - if(consumer >= dbk_consumer_workers) { - consumer = 0; - } + if(bind && bind->consistent_worker) { + str rk; + rk.s = (char*)envelope->routing_key.bytes; + rk.len = (int)envelope->routing_key.len; + worker = core_hash(&rk, NULL, dbk_consumer_workers); + LM_DBG("computed worker for %.*s is %d\n", rk.len, rk.s, worker); + } else { + consumer++; + if(consumer >= dbk_consumer_workers) { + consumer = 0; + } + worker = consumer; + } - if (write(kz_worker_pipes[consumer], &ptr, sizeof(ptr)) != sizeof(ptr)) { + if (write(kz_worker_pipes[worker], &ptr, sizeof(ptr)) != sizeof(ptr)) { LM_ERR("failed to send payload to consumer %d : %s\nPayload %s\n", consumer, strerror(errno), ptr->payload); goto error; } diff --git a/src/modules/kazoo/kz_amqp.h b/src/modules/kazoo/kz_amqp.h index 6aa36b8..7c5e6e8 100644 --- a/src/modules/kazoo/kz_amqp.h +++ b/src/modules/kazoo/kz_amqp.h @@ -183,6 +183,7 @@ typedef struct { amqp_boolean_t no_ack; amqp_boolean_t wait_for_consumer_ack; amqp_boolean_t federate; + amqp_boolean_t consistent_worker; } kz_amqp_bind, *kz_amqp_bind_ptr; typedef struct {

7 years, 9 months

Re: [sr-dev] [kamailio/kamailio] siputils: added is_alphanumex(tval, eset) function (76c5da5)

by Daniel-Constantin Mierla

The functions was removed accidentally. I reintroduced it. Thanks! -- You are receiving this because you are subscribed to this thread. Reply to this email directly or view it on GitHub: https://github.com/kamailio/kamailio/commit/76c5da5ec048cd62c0f3cab6bf38aef…

7 years, 9 months

git:master:2d0a0d8d: siputils: reintroduced the c function for is_alphanum()

by Daniel-Constantin Mierla

Module: kamailio Branch: master Commit: 2d0a0d8decbad9cea3d603a5067b6656d659cbf6 URL: https://github.com/kamailio/kamailio/commit/2d0a0d8decbad9cea3d603a5067b665… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2017-03-06T09:16:12+01:00 siputils: reintroduced the c function for is_alphanum() - accidentaly stripped when adding is_alphanumex() - reported by Carsten Bock --- Modified: src/modules/siputils/checks.c Modified: src/modules/siputils/checks.h Modified: src/modules/siputils/siputils.c --- Diff: https://github.com/kamailio/kamailio/commit/2d0a0d8decbad9cea3d603a5067b665… Patch: https://github.com/kamailio/kamailio/commit/2d0a0d8decbad9cea3d603a5067b665… --- diff --git a/src/modules/siputils/checks.c b/src/modules/siputils/checks.c index cfddfda..ca6991f 100644 --- a/src/modules/siputils/checks.c +++ b/src/modules/siputils/checks.c @@ -807,11 +807,38 @@ int is_numeric(sip_msg_t *msg, char *_sp, char* _s2) return 1; } + +/* + * Check if the parameter contains alphanumeric characters + */ +int ksr_is_alphanum(sip_msg_t *msg, char *_sp, char* _s2) +{ + str tval = {0, 0}; + int i; + + if(fixup_get_svalue(msg, (gparam_t*)_sp, &tval)!=0) { + LM_ERR("cannot get parameter value\n"); + return -1; + } + if(tval.len<=0) + return -2; + + i = 0; + for(; i<tval.len; i++) { + if( !((tval.s[i]>='0' && tval.s[i]<='9') + || (tval.s[i]>='A' && tval.s[i]<='Z') + || (tval.s[i]>='z' && tval.s[i]<='z')) ) + return -3; + } + + return 1; +} + /* * Check if the parameter contains alphanumeric characters or are part of * the second parameter */ -int is_alphanumex(sip_msg_t *msg, char *_sp, char* _se) +int ksr_is_alphanumex(sip_msg_t *msg, char *_sp, char* _se) { str tval = {0, 0}; str eset = {0, 0}; diff --git a/src/modules/siputils/checks.h b/src/modules/siputils/checks.h index f071e24..39a575d 100644 --- a/src/modules/siputils/checks.h +++ b/src/modules/siputils/checks.h @@ -127,12 +127,12 @@ int is_numeric(sip_msg_t *msg, char *_sp, char* _s2); /* * Check if the parameter contains alphanumeric characters */ -int is_alphanum(sip_msg_t *msg, char *_sp, char* _s2); +int ksr_is_alphanum(sip_msg_t *msg, char *_sp, char* _s2); /* * Check if the parameter contains alphanumeric characters or are part of * the second parameter */ -int is_alphanumex(sip_msg_t *msg, char *_sp, char* _se); +int ksr_is_alphanumex(sip_msg_t *msg, char *_sp, char* _se); #endif /* CHECKS_H */ diff --git a/src/modules/siputils/siputils.c b/src/modules/siputils/siputils.c index f01bf6f..519e82b 100644 --- a/src/modules/siputils/siputils.c +++ b/src/modules/siputils/siputils.c @@ -179,9 +179,9 @@ static cmd_export_t cmds[]={ 0, ANY_ROUTE}, {"is_numeric", (cmd_function)is_numeric, 1, fixup_spve_null, 0, ANY_ROUTE}, - {"is_alphanum", (cmd_function)is_alphanum, 1, fixup_spve_null, + {"is_alphanum", (cmd_function)ksr_is_alphanum, 1, fixup_spve_null, 0, ANY_ROUTE}, - {"is_alphanumex", (cmd_function)is_alphanumex, 2, fixup_spve_spve, + {"is_alphanumex", (cmd_function)ksr_is_alphanumex, 2, fixup_spve_spve, 0, ANY_ROUTE}, {"sip_p_charging_vector", (cmd_function)sip_handle_pcv, 1, fixup_spve_null, fixup_free_spve_null, ANY_ROUTE},

7 years, 9 months

Re: [sr-dev] [kamailio/kamailio] siputils: added is_alphanumex(tval, eset) function (76c5da5)

by ng-voice GmbH

Hi, this currently breaks the SIP-Utils module: * 0(32154) ERROR: <core> [core/sr_module.c:582]: load_module(): could not open module </usr/lib/x86_64-linux-gnu/kamailio/modules/siputils.so>: /usr/lib/x86_64-linux-gnu/kamailio/modules/siputils.so: undefined symbol: is_alphanum 0(32154) CRITICAL: <core> [core/cfg.y:3401]: yyerror_at(): parse error in config file /etc/kamailio/kamailio.cfg, line 128, column 12-21: failed to load module is_alphanum is linked, but no longer defined. Maybe, some wrapper for the old "is_alphanum" is needed? Thanks, Carsten -- You are receiving this because you are subscribed to this thread. Reply to this email directly or view it on GitHub: https://github.com/kamailio/kamailio/commit/76c5da5ec048cd62c0f3cab6bf38aef…

7 years, 9 months

[kamailio/kamailio] ipops is_in_subnet failure with IPv6 after upgrade to 5.0.0 (#1018)

by Anthony Messina

After upgrading to 5.0.0, I've found that using an IPv6 range such as ``` is_in_subnet("$si", "2001:db8::/32")) ``` no longer works. In fact, the script just terminates without error or response: ``` ERROR: *** cfgtrace:request_route=[REGISTRAR] c=[/etc/kamailio/kamailio.cfg] l=1150 a=16 n=if ERROR: *** cfgtrace:request_route=[REGISTRAR] c=[/etc/kamailio/kamailio.cfg] l=1148 a=25 n=is_method ERROR: *** cfgtrace:request_route=[REGISTRAR] c=[/etc/kamailio/kamailio.cfg] l=1160 a=16 n=if ERROR: *** cfgtrace:request_route=[REGISTRAR] c=[/etc/kamailio/kamailio.cfg] l=1150 a=41 n=isflagset ERROR: *** cfgtrace:request_route=[REGISTRAR] c=[/etc/kamailio/kamailio.cfg] l=1151 a=25 n=setbflag ERROR: *** cfgtrace:request_route=[REGISTRAR] c=[/etc/kamailio/kamailio.cfg] l=1164 a=16 n=if ERROR: *** cfgtrace:request_route=[REGISTRAR] c=[/etc/kamailio/kamailio.cfg] l=1160 a=26 n=is_in_subnet DEBUG: <core> [core/receive.c:275]: receive_msg(): request-route executed in: 1240 usec DEBUG: <core> [core/usr_avp.c:631]: destroy_avp_list(): destroying list 0x7f5860b8e778 DEBUG: <core> [core/usr_avp.c:631]: destroy_avp_list(): destroying list (nil) DEBUG: <core> [core/usr_avp.c:631]: destroy_avp_list(): destroying list (nil) DEBUG: <core> [core/usr_avp.c:631]: destroy_avp_list(): destroying list (nil) DEBUG: <core> [core/usr_avp.c:631]: destroy_avp_list(): destroying list (nil) DEBUG: <core> [core/usr_avp.c:631]: destroy_avp_list(): destroying list (nil) DEBUG: <core> [core/xavp.c:446]: xavp_destroy_list(): destroying xavp list (nil) DEBUG: <core> [core/receive.c:368]: receive_msg(): cleaning up ``` If I remove the IPv6 range from the `is_in_subnet` function, things work normally. Prior to today's upgrade, I was using 4.4.5 with updates from the 4.4 branch applied to the build (up to an including 4180f5b). -- You are receiving this because you are subscribed to this thread. Reply to this email directly or view it on GitHub: https://github.com/kamailio/kamailio/issues/1018

7 years, 9 months

git:4.4:9812a49f: http_async_client: fix memory leak in pkg memory in case of error

by Federico Cabiddu

Module: kamailio Branch: 4.4 Commit: 9812a49fb7fa58b9d9f2b29ac963011d4d684bcb URL: https://github.com/kamailio/kamailio/commit/9812a49fb7fa58b9d9f2b29ac963011… Author: Federico Cabiddu <federico.cabiddu(a)gmail.com> Committer: Federico Cabiddu <federico.cabiddu(a)gmail.com> Date: 2017-03-05T10:15:17+01:00 http_async_client: fix memory leak in pkg memory in case of error (cherry picked from commit bd35608f1799f27c725815637c2c8e99b32d53a2) --- Modified: modules/http_async_client/http_multi.c --- Diff: https://github.com/kamailio/kamailio/commit/9812a49fb7fa58b9d9f2b29ac963011… Patch: https://github.com/kamailio/kamailio/commit/9812a49fb7fa58b9d9f2b29ac963011… --- diff --git a/modules/http_async_client/http_multi.c b/modules/http_async_client/http_multi.c index a5df0ab..4f0f1a2 100644 --- a/modules/http_async_client/http_multi.c +++ b/modules/http_async_client/http_multi.c @@ -316,6 +316,8 @@ void reply_error(struct http_m_cell *cell) cell->cb(reply, cell->param); + pkg_free(reply); + return; }

7 years, 9 months

← Newer
1
...
20
21
22
23
24
25
26
27
Older →

Jump to page:

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

sr-dev March 2017