Skip to content

P
paho.mqtt.c
Commit 372ef9e8 authored by Ian Craggs's avatar Ian Craggs
Browse files
Options

Allocate storage for thread parms

parent b07dee3b
Hide whitespace changes
Inline Side-by-side
Showing with 11 additions and 6 deletions
src/MQTTClient.c
View file @ 372ef9e8
...@@ -653,6 +653,8 @@ static thread_return_type WINAPI call_disconnected(void* context) ...@@ -653,6 +653,8 @@ static thread_return_type WINAPI call_disconnected(void* context)
(*(pr->m->disconnected))(pr->m->disconnected_context, pr->properties, pr->reasonCode); (*(pr->m->disconnected))(pr->m->disconnected_context, pr->properties, pr->reasonCode);
MQTTProperties_free(pr->properties); MQTTProperties_free(pr->properties);
free(pr->properties);
free(pr);
return 0; return 0;
} }
...@@ -803,15 +805,18 @@ static thread_return_type WINAPI MQTTClient_run(void* n) ...@@ -803,15 +805,18 @@ static thread_return_type WINAPI MQTTClient_run(void* n)
{ {
if (pack->header.bits.type == DISCONNECT && m->disconnected) if (pack->header.bits.type == DISCONNECT && m->disconnected)
{ {
struct props_rc_parms dp; struct props_rc_parms* dp;
Ack* disc = (Ack*)pack; Ack* disc = (Ack*)pack;
dp.m = m; dp = malloc(sizeof(struct props_rc_parms));
dp.properties = &disc->properties; dp->m = m;
dp.reasonCode = disc->rc; dp->reasonCode = disc->rc;
free(pack); dp->properties = malloc(sizeof(MQTTProperties));
*(dp->properties) = disc->properties;
free(disc);
MQTTClient_disconnect1(m, 10, 0, 1, SUCCESS, NULL);
Log(TRACE_MIN, -1, "Calling disconnected for client %s", m->c->clientID); Log(TRACE_MIN, -1, "Calling disconnected for client %s", m->c->clientID);
Thread_start(call_disconnected, &dp); Thread_start(call_disconnected, dp);
} }
if (pack->header.bits.type == AUTH && m->auth_handle) if (pack->header.bits.type == AUTH && m->auth_handle)
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment