|
|
|
@ -1026,7 +1026,7 @@ static void dispatch_mm7_recv(List *rl)
|
|
|
|
|
|
|
|
|
|
MmsBoxHTTPClientInfo *h;
|
|
|
|
|
|
|
|
|
|
hmon->register_thread( "dispatch_mm7" );
|
|
|
|
|
/* hmon->register_thread( "dispatch_mm7" ); */
|
|
|
|
|
while ((h = gwlist_consume(rl)) != NULL) {
|
|
|
|
|
int ret = -1, has_auth = 0;
|
|
|
|
|
MmscGrp *m = h->m;
|
|
|
|
@ -1060,7 +1060,7 @@ static void dispatch_mm7_recv(List *rl)
|
|
|
|
|
h->m->mo_errors++;
|
|
|
|
|
free_mmsbox_http_clientInfo(h, 1);
|
|
|
|
|
}
|
|
|
|
|
hmon->unregister_thread( "dispatch_mm7" );
|
|
|
|
|
/* hmon->unregister_thread( "dispatch_mm7" ); */
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void mmsc_receive_func(MmscGrp *m)
|
|
|
|
@ -1116,6 +1116,8 @@ void mmsc_receive_func(MmscGrp *m)
|
|
|
|
|
free_mmsbox_http_clientInfo(&h, 0);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
hmon->unregister_thread( "mmsc_receive" );
|
|
|
|
|
|
|
|
|
|
debug("proxy", 0, "MMSBox: MM7 receiver [mmc=%s] Shutting down...", octstr_get_cstr(m->id));
|
|
|
|
|
gwlist_remove_producer(mmsc_incoming_reqs);
|
|
|
|
|
|
|
|
|
@ -1126,7 +1128,6 @@ void mmsc_receive_func(MmscGrp *m)
|
|
|
|
|
gwlist_destroy(mmsc_incoming_reqs, NULL);
|
|
|
|
|
gw_free(thids);
|
|
|
|
|
|
|
|
|
|
hmon->unregister_thread( "mmsc_receive" );
|
|
|
|
|
debug("proxy", 0, "MMSBox: MM7 receiver [mmc=%s] Shutting down complete.", octstr_get_cstr(m->id));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|