Annotation of embedaddon/miniupnpd/miniupnpc-libevent/upnpc-libevent.c, revision 1.1
1.1 ! misho 1: /* $Id: upnpc-libevent.c,v 1.11 2014/12/02 13:33:42 nanard Exp $ */
! 2: /* miniupnpc-libevent
! 3: * Copyright (c) 2008-2014, Thomas BERNARD <miniupnp@free.fr>
! 4: * http://miniupnp.free.fr/ or http://miniupnp.tuxfamily.org/
! 5: *
! 6: * Permission to use, copy, modify, and/or distribute this software for any
! 7: * purpose with or without fee is hereby granted, provided that the above
! 8: * copyright notice and this permission notice appear in all copies.
! 9: *
! 10: * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
! 11: * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
! 12: * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
! 13: * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
! 14: * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
! 15: * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
! 16: * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. */
! 17:
! 18: #include <stdio.h>
! 19: #include <string.h>
! 20: #include <signal.h>
! 21: #include <unistd.h>
! 22: #include <sys/socket.h>
! 23: #include <netinet/in.h>
! 24: #include <arpa/inet.h>
! 25:
! 26: #include "miniupnpc-libevent.h"
! 27:
! 28: static struct event_base *base = NULL;
! 29: static char local_address[32];
! 30:
! 31: static void sighandler(int signal)
! 32: {
! 33: (void)signal;
! 34: /*printf("signal %d\n", signal);*/
! 35: if(base != NULL)
! 36: event_base_loopbreak(base);
! 37: }
! 38:
! 39: /* ready callback */
! 40: static void ready(int code, upnpc_t * p, upnpc_device_t * d, void * data)
! 41: {
! 42: (void)data; (void)p;
! 43:
! 44: if(code == 200) {
! 45: printf("READY ! %d\n", code);
! 46: printf(" root_desc_location='%s'\n", d->root_desc_location);
! 47: /* 1st request */
! 48: #ifdef ENABLE_UPNP_EVENTS
! 49: upnpc_event_subscribe(d);
! 50: #else
! 51: upnpc_get_status_info(d);
! 52: #endif /* ENABLE_UPNP_EVENTS */
! 53: } else {
! 54: printf("DISCOVER ERROR : %d\n", code);
! 55: switch(code) {
! 56: case UPNPC_ERR_NO_DEVICE_FOUND:
! 57: printf("UPNPC_ERR_NO_DEVICE_FOUND\n");
! 58: break;
! 59: case UPNPC_ERR_ROOT_DESC_ERROR:
! 60: printf("UPNPC_ERR_ROOT_DESC_ERROR\n");
! 61: break;
! 62: case 404:
! 63: printf("Root desc not found (404)\n");
! 64: break;
! 65: default:
! 66: printf("unknown error\n");
! 67: }
! 68: }
! 69: }
! 70:
! 71: static enum {
! 72: EGetStatusInfo = 0,
! 73: EGetExtIp,
! 74: EGetMaxRate,
! 75: EAddPortMapping,
! 76: EDeletePortMapping,
! 77: EFinished
! 78: } state = EGetStatusInfo;
! 79:
! 80: /* soap callback */
! 81: static void soap(int code, upnpc_t * p, upnpc_device_t * d, void * data)
! 82: {
! 83: (void)data; (void)p;
! 84:
! 85: printf("SOAP ! %d\n", code);
! 86: if(code == 200) {
! 87: switch(state) {
! 88: case EGetStatusInfo:
! 89: printf("ConnectionStatus=%s\n", GetValueFromNameValueList(&d->soap_response_data, "NewConnectionStatus"));
! 90: printf("LastConnectionError=%s\n", GetValueFromNameValueList(&d->soap_response_data, "NewLastConnectionError"));
! 91: printf("Uptime=%s\n", GetValueFromNameValueList(&d->soap_response_data, "NewUptime"));
! 92: upnpc_get_external_ip_address(d);
! 93: state = EGetExtIp;
! 94: break;
! 95: case EGetExtIp:
! 96: printf("ExternalIpAddress=%s\n", GetValueFromNameValueList(&d->soap_response_data, "NewExternalIPAddress"));
! 97: upnpc_get_link_layer_max_rate(d);
! 98: state = EGetMaxRate;
! 99: break;
! 100: case EGetMaxRate:
! 101: printf("DownStream MaxBitRate = %s\t", GetValueFromNameValueList(&d->soap_response_data, "NewLayer1DownstreamMaxBitRate"));
! 102: upnpc_add_port_mapping(d, NULL, 60001, 60002, local_address, "TCP", "test port mapping", 0);
! 103: printf("UpStream MaxBitRate = %s\n", GetValueFromNameValueList(&d->soap_response_data, "NewLayer1UpstreamMaxBitRate"));
! 104: state = EAddPortMapping;
! 105: break;
! 106: case EAddPortMapping:
! 107: printf("AddPortMapping OK!\n");
! 108: upnpc_delete_port_mapping(d, NULL, 60001, "TCP");
! 109: state = EDeletePortMapping;
! 110: break;
! 111: case EDeletePortMapping:
! 112: printf("DeletePortMapping OK!\n");
! 113: state = EFinished;
! 114: break;
! 115: default:
! 116: printf("EFinished : breaking\n");
! 117: event_base_loopbreak(base);
! 118: }
! 119: } else {
! 120: printf("SOAP error :\n");
! 121: printf(" faultcode='%s'\n", GetValueFromNameValueList(&d->soap_response_data, "faultcode"));
! 122: printf(" faultstring='%s'\n", GetValueFromNameValueList(&d->soap_response_data, "faultstring"));
! 123: printf(" errorCode=%s\n", GetValueFromNameValueList(&d->soap_response_data, "errorCode"));
! 124: printf(" errorDescription='%s'\n", GetValueFromNameValueList(&d->soap_response_data, "errorDescription"));
! 125: event_base_loopbreak(base);
! 126: }
! 127: }
! 128:
! 129: #ifdef ENABLE_UPNP_EVENTS
! 130: /* event callback */
! 131: static void event_callback(upnpc_t * p, upnpc_device_t * d, void * data,
! 132: const char * service_id, const char * property_name, const char * property_value)
! 133: {
! 134: (void)p; (void)d; (void)data;
! 135: printf("PROPERTY VALUE CHANGE (service=%s): %s=%s\n", service_id, property_name, property_value);
! 136: }
! 137: #endif /* ENABLE_UPNP_EVENTS */
! 138:
! 139: /* use a UDP "connection" to 8.8.8.8
! 140: * to retrieve local address */
! 141: int find_local_address(void)
! 142: {
! 143: int s;
! 144: struct sockaddr_in local, remote;
! 145: socklen_t len;
! 146:
! 147: s = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
! 148: if(s < 0) {
! 149: perror("socket");
! 150: return -1;
! 151: }
! 152:
! 153: memset(&local, 0, sizeof(local));
! 154: memset(&remote, 0, sizeof(remote));
! 155: /* bind to local port 4567 */
! 156: local.sin_family = AF_INET;
! 157: local.sin_port = htons(4567);
! 158: local.sin_addr.s_addr = htonl(INADDR_ANY);
! 159: if(bind(s, (struct sockaddr *)&local, sizeof(local)) < 0) {
! 160: perror("bind");
! 161: return -1;
! 162: }
! 163: /* "connect" google's DNS server at 8.8.8.8 port 4567 */
! 164: remote.sin_family = AF_INET;
! 165: remote.sin_port = htons(4567);
! 166: remote.sin_addr.s_addr = inet_addr("8.8.8.8");
! 167: if(connect(s, (struct sockaddr *)&remote, sizeof(remote)) < 0) {
! 168: perror("connect");
! 169: return -1;
! 170: }
! 171: len = sizeof(local);
! 172: if(getsockname(s, (struct sockaddr *)&local, &len) < 0) {
! 173: perror("getsockname");
! 174: return -1;
! 175: }
! 176: if(inet_ntop(AF_INET, &(local.sin_addr), local_address, sizeof(local_address)) == NULL) {
! 177: perror("inet_ntop");
! 178: return -1;
! 179: }
! 180: printf("local address : %s\n", local_address);
! 181: close(s);
! 182: return 0;
! 183: }
! 184:
! 185: /* program entry point */
! 186:
! 187: int main(int argc, char * * argv)
! 188: {
! 189: struct sigaction sa;
! 190: upnpc_t upnp;
! 191: char * multicast_if = NULL;
! 192:
! 193: if(argc > 1) {
! 194: multicast_if = argv[1];
! 195: }
! 196:
! 197: memset(&sa, 0, sizeof(struct sigaction));
! 198: sa.sa_handler = sighandler;
! 199: if(sigaction(SIGINT, &sa, NULL) < 0) {
! 200: perror("sigaction");
! 201: }
! 202:
! 203: if(find_local_address() < 0) {
! 204: fprintf(stderr, "failed to get local address\n");
! 205: return 1;
! 206: }
! 207: #ifdef DEBUG
! 208: event_enable_debug_mode();
! 209: #if LIBEVENT_VERSION_NUMBER >= 0x02010100
! 210: event_enable_debug_logging(EVENT_DBG_ALL); /* Libevent 2.1.1 */
! 211: #endif /* LIBEVENT_VERSION_NUMBER >= 0x02010100 */
! 212: #endif /* DEBUG */
! 213: printf("Using libevent %s\n", event_get_version());
! 214: if(LIBEVENT_VERSION_NUMBER != event_get_version_number()) {
! 215: fprintf(stderr, "WARNING build using libevent %s", LIBEVENT_VERSION);
! 216: }
! 217:
! 218: base = event_base_new();
! 219: if(base == NULL) {
! 220: fprintf(stderr, "event_base_new() failed\n");
! 221: return 1;
! 222: }
! 223: #ifdef DEBUG
! 224: printf("Using Libevent with backend method %s.\n",
! 225: event_base_get_method(base));
! 226: #endif /* DEBUG */
! 227:
! 228: if(upnpc_init(&upnp, base, multicast_if, ready, soap, &upnp) != UPNPC_OK) {
! 229: fprintf(stderr, "upnpc_init() failed\n");
! 230: return 1;
! 231: }
! 232: upnpc_set_local_address(&upnp, local_address, 50000);
! 233: #ifdef ENABLE_UPNP_EVENTS
! 234: upnpc_set_event_callback(&upnp, event_callback);
! 235: #endif /* ENABLE_UPNP_EVENTS */
! 236: if(upnpc_start(&upnp) != UPNPC_OK) {
! 237: fprintf(stderr, "upnp_start() failed\n");
! 238: return 1;
! 239: }
! 240:
! 241: event_base_dispatch(base); /* TODO : check return value */
! 242: printf("finishing...\n");
! 243:
! 244: upnpc_finalize(&upnp);
! 245: event_base_free(base);
! 246:
! 247: #if LIBEVENT_VERSION_NUMBER >= 0x02010100
! 248: libevent_global_shutdown(); /* Libevent 2.1.1 */
! 249: #endif
! 250: return 0;
! 251: }
! 252:
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to upnpc-libevent.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / miniupnpd / miniupnpc-libevent