status-im
/
miniupnp
mirror of https://github.com/status-im/miniupnp.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

add upnpc_event_unsubscribe()

This commit is contained in:
Thomas Bernard 2016-02-25 13:54:23 +01:00
parent 6f5a5907e5
commit 780f20b75c
3 changed files with 46 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
miniupnpc-libevent/miniupnpc-libevent.c
View File

@ -450,6 +450,17 @@ static void upnpc_subscribe_response(struct evhttp_request * req, void * pvoid)
if(d->parent->subscribe_cb)
d->parent->subscribe_cb(code, d->parent, d, d->parent->cb_data);
}
static void upnpc_unsubscribe_response(struct evhttp_request * req, void * pvoid)
{
upnpc_device_t * d = (upnpc_device_t *)pvoid;
debug_printf("%s\n", __func__);
if(d->parent->http_server) {
evhttp_free(d->parent->http_server);
d->parent->http_server = NULL;
}
}
#endif /* ENABLE_UPNP_EVENTS */
static void upnpc_soap_response(struct evhttp_request * req, void * pvoid)
@ -987,6 +998,36 @@ int upnpc_event_subscribe(upnpc_device_t * p)
p->state |= UPNPC_DEVICE_SOAP_REQ;
return 0;
}
int upnpc_event_unsubscribe(upnpc_device_t * p)
{
char hostname[MAXHOSTNAMELEN+1];
char hostname_port[MAXHOSTNAMELEN+1+6];
unsigned short port;
char * path;
unsigned int scope_id;
struct evhttp_request * req;
struct evkeyvalq * headers;
if(!parseURL(p->event_conn_url, hostname, &port, &path, &scope_id)) {
return -1;
}
if(port != 80)
snprintf(hostname_port, sizeof(hostname_port), "%s:%hu", hostname, port);
else
strncpy(hostname_port, hostname, sizeof(hostname_port));
if(p->soap_conn == NULL) {
p->soap_conn = evhttp_connection_base_new(p->parent->base, NULL, hostname, port);
}
evhttp_connection_set_extended_method_cmp(p->soap_conn, ext_methods_func);
req = evhttp_request_new(upnpc_unsubscribe_response, p);
headers = evhttp_request_get_output_headers(req);
evhttp_add_header(headers, "Host", hostname_port);
evhttp_add_header(headers, "SID", p->event_conn_sid);
evhttp_make_request(p->soap_conn, req, EVHTTP_REQ_SUBSCRIBE, path);
p->state |= UPNPC_DEVICE_SOAP_REQ;
return 0;
}
#endif /* ENABLE_UPNP_EVENTS */
int upnpc_get_external_ip_address(upnpc_device_t * p)

1
miniupnpc-libevent/miniupnpc-libevent.h
View File

@ -108,6 +108,7 @@ int upnpc_finalize(upnpc_t * p);
#ifdef ENABLE_UPNP_EVENTS
int upnpc_event_subscribe(upnpc_device_t * p);
int upnpc_event_unsubscribe(upnpc_device_t * p);
#endif /* ENABLE_UPNP_EVENTS */
int upnpc_get_external_ip_address(upnpc_device_t * p);

4
miniupnpc-libevent/upnpc-libevent.c
View File

@ -135,6 +135,10 @@ static void event_callback(upnpc_t * p, upnpc_device_t * d, void * data,
{
(void)p; (void)d; (void)data;
printf("PROPERTY VALUE CHANGE (service=%s): %s=%s\n", service_id, property_name, property_value);
if(state == EFinished) {
printf("****** EFinished ******\n");
upnpc_event_unsubscribe(d);
}
}
/* subscribe callback */