[prev in list] [next in list] [prev in thread] [next in thread]
List: openser-devel
Subject: [sr-dev] git:5.0:aa9db3e6: kazoo: free envelope only on normal response
From: Luis Azedo <luis () 2600hz ! com>
Date: 2018-02-28 16:40:18
Message-ID: E1er4mA-0000K1-Nu () www ! kamailio ! org
[Download RAW message or body]
Module: kamailio
Branch: 5.0
Commit: aa9db3e667b2a0029cc2dab4f74d226ae30f53c7
URL: https://github.com/kamailio/kamailio/commit/aa9db3e667b2a0029cc2dab4f74d226ae30f53c7
Author: lazedo <luis.azedo@factorlusitano.com>
Committer: Luis Azedo <luis@2600hz.com>
Date: 2018-02-28T16:39:56Z
kazoo: free envelope only on normal response
(cherry picked from commit 6c40983bf04a23bd7394c247980f21c5f2d6d817)
---
Modified: src/modules/kazoo/kz_amqp.c
---
Diff: https://github.com/kamailio/kamailio/commit/aa9db3e667b2a0029cc2dab4f74d226ae30f53c7.diff
Patch: https://github.com/kamailio/kamailio/commit/aa9db3e667b2a0029cc2dab4f74d226ae30f53c7.patch
---
diff --git a/src/modules/kazoo/kz_amqp.c b/src/modules/kazoo/kz_amqp.c
index e04bdd3179..f0b73a0cc6 100644
--- a/src/modules/kazoo/kz_amqp.c
+++ b/src/modules/kazoo/kz_amqp.c
@@ -3115,7 +3115,6 @@ int kz_amqp_consumer_proc(kz_amqp_server_ptr server_ptr)
LM_DBG("CONSUMER INIT DONE\n");
while(OK) {
-// payload = NULL;
amqp_envelope_t envelope;
amqp_maybe_release_buffers(consumer->conn);
amqp_rpc_reply_t reply = amqp_consume_message(consumer->conn, &envelope, NULL, 0);
@@ -3153,6 +3152,7 @@ int kz_amqp_consumer_proc(kz_amqp_server_ptr server_ptr)
if(OK)
kz_amqp_send_worker_event(server_ptr, &envelope, consumer_channels[idx].consumer);
}
+ amqp_destroy_envelope(&envelope);
break;
case AMQP_RESPONSE_SERVER_EXCEPTION:
LM_ERR("AMQP_RESPONSE_SERVER_EXCEPTION in consume\n");
@@ -3164,7 +3164,6 @@ int kz_amqp_consumer_proc(kz_amqp_server_ptr server_ptr)
OK = 0;
break;
};
- amqp_destroy_envelope(&envelope);
}
kz_amqp_connection_close(consumer);
_______________________________________________
Kamailio (SER) - Development Mailing List
sr-dev@lists.kamailio.org
https://lists.kamailio.org/cgi-bin/mailman/listinfo/sr-dev
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic