Mercurial > pidgin.yaz

comparison src/stun.c @ 11336:7d7dd22215ec

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
[gaim-migrate @ 13549] STUN NAT discovery from gaim_network_get_public_ip committer: Tailor Script <tailor@pidgin.im>
author Thomas Butter <tbutter>
date Wed, 24 Aug 2005 20:45:20 +0000
parents dd1a5969b2e5
children 97028c1c69e9
comparison
equal deleted inserted replaced
11335:59aa7080eb2d 11336:7d7dd22215ec
1 /** 1 /**
2 * @file stun.c STUN (RFC3489) Implementation 2 * @file stun.c STUN (RFC3489) Implementation
3 * @ingroup core 3 * @ingroup core
4 * 4 *
5 * gaim 5 * gaim
6 *
7 * STUN implementation inspired by jstun [http://jstun.javawi.de/]
6 * 8 *
7 * Gaim is the legal property of its developers, whose names are too numerous 9 * Gaim is the legal property of its developers, whose names are too numerous
8 * to list here. Please refer to the COPYRIGHT file distributed with this 10 * to list here. Please refer to the COPYRIGHT file distributed with this
9 * source distribution. 11 * source distribution.
10 * 12 *
43 static gint transid[4]; 45 static gint transid[4];
44 46
45 static GSList *callbacks = 0; 47 static GSList *callbacks = 0;
46 static int fd = -1; 48 static int fd = -1;
47 gint incb = -1; 49 gint incb = -1;
50 gint timeout = -1;
48 51
49 static void do_callbacks() { 52 static void do_callbacks() {
50 while(callbacks) { 53 while(callbacks) {
51 StunCallback cb = callbacks->data; 54 StunCallback cb = callbacks->data;
52 cb(&nattype); 55 if(cb)
56 cb(&nattype);
53 callbacks = g_slist_remove(callbacks, cb); 57 callbacks = g_slist_remove(callbacks, cb);
54 } 58 }
55 } 59 }
56 60
57 static void reply_cb(gpointer data, gint source, GaimInputCondition cond) { 61 static void reply_cb(gpointer data, gint source, GaimInputCondition cond) {
58 char buffer[10240]; 62 char buffer[1024];
59 char *tmp; 63 char *tmp;
60 int len; 64 int len;
61 struct in_addr in; 65 struct in_addr in;
62 struct stun_attrib *attrib; 66 struct stun_attrib *attrib;
63 struct stun_header *hdr; 67 struct stun_header *hdr;
64 struct ifconf ifc; 68 struct ifconf ifc;
65 struct ifreq *ifr; 69 struct ifreq *ifr;
66 struct sockaddr_in *sinptr; 70 struct sockaddr_in *sinptr;
67 71
68 len = recv(source, buffer, 10240, 0); 72 len = recv(source, buffer, 1024, 0);
69 73
70 hdr = (struct stun_header*)buffer; 74 hdr = (struct stun_header*)buffer;
71 if(hdr->transid[0]!=transid[0] || hdr->transid[1]!=transid[1] || hdr->transid[2]!=transid[2] || hdr->transid[3]!=transid[3]) { // wrong transaction 75 if(hdr->transid[0]!=transid[0] || hdr->transid[1]!=transid[1] || hdr->transid[2]!=transid[2] || hdr->transid[3]!=transid[3]) { // wrong transaction
72 gaim_debug_info("simple", "got wrong transid\n"); 76 gaim_debug_info("simple", "got wrong transid\n");
73 return; 77 return;
110 } 114 }
111 } 115 }
112 } 116 }
113 117
114 do_callbacks(); 118 do_callbacks();
119 gaim_timeout_remove(timeout);
115 gaim_input_remove(incb); 120 gaim_input_remove(incb);
116 } 121 }
117 122
123 static gboolean timeoutfunc(void *blah) {
124 /* remove input */
125 gaim_input_remove(incb);
126
127 /* set unknown */
128 nattype.status = 0;
129
130 /* callbacks */
131 do_callbacks();
132
133 return FALSE;
134 }
135
136
118 struct stun_nattype *gaim_stun_discover(StunCallback cb) { 137 struct stun_nattype *gaim_stun_discover(StunCallback cb) {
119 struct sockaddr_in addr; 138 struct sockaddr_in addr;
120 struct stun_header data; 139 struct stun_header data;
121 int ret = 0; 140 int ret = 0;
122 const char *ip = gaim_prefs_get_string("/core/network/stun_ip"); 141 const char *ip = gaim_prefs_get_string("/core/network/stun_ip");
123 int port = gaim_prefs_get_int("/core/network/stun_port"); 142 int port = gaim_prefs_get_int("/core/network/stun_port");
143
144 if(!ip || !port) {
145 nattype.status = 0;
146 if(cb) cb(&nattype);
147 return &nattype;
148 }
124 149
125 if(nattype.status == 1) { // currently discovering 150 if(nattype.status == 1) { // currently discovering
126 callbacks = g_slist_append(callbacks, cb); 151 if(cb) callbacks = g_slist_append(callbacks, cb);
127 return NULL; 152 return NULL;
128 } 153 }
129 if(nattype.status == 2 || nattype.status == 0) { // already discovered 154 if(nattype.status != -1) { // already discovered
130 cb(&nattype); 155 if(cb) cb(&nattype);
131 return &nattype; 156 return &nattype;
132 } 157 }
133
134 if((fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { 158 if((fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
135 nattype.status = 0; 159 nattype.status = 0;
136 cb(&nattype); 160 if(cb) cb(&nattype);
137 return &nattype; 161 return &nattype;
138 } 162 }
139 163
140 addr.sin_family = AF_INET; 164 addr.sin_family = AF_INET;
141 addr.sin_port = htons(12108); 165 addr.sin_port = htons(12108);
143 while( ((ret = bind(fd, (struct sockaddr *)&addr, sizeof(struct sockaddr_in))) < 0 ) && ntohs(addr.sin_port) < 12208) { 167 while( ((ret = bind(fd, (struct sockaddr *)&addr, sizeof(struct sockaddr_in))) < 0 ) && ntohs(addr.sin_port) < 12208) {
144 addr.sin_port = htons(ntohs(addr.sin_port)+1); 168 addr.sin_port = htons(ntohs(addr.sin_port)+1);
145 } 169 }
146 if( ret < 0 ) { 170 if( ret < 0 ) {
147 nattype.status = 0; 171 nattype.status = 0;
148 cb(&nattype); 172 if(cb) cb(&nattype);
149 return &nattype; 173 return &nattype;
150 } 174 }
151 incb = gaim_input_add(fd, GAIM_INPUT_READ, reply_cb, NULL); 175 incb = gaim_input_add(fd, GAIM_INPUT_READ, reply_cb, NULL);
152 176
153 if(port == 0 || ip == NULL || ip[0] == '\0') return NULL; 177 if(port == 0 || ip == NULL || ip[0] == '\0') return NULL;
163 transid[2] = data.transid[2] = rand(); 187 transid[2] = data.transid[2] = rand();
164 transid[3] = data.transid[3] = rand(); 188 transid[3] = data.transid[3] = rand();
165 189
166 if( sendto(fd, &data, sizeof(struct stun_header), 0, (struct sockaddr *)&addr, sizeof(struct sockaddr_in)) < sizeof(struct stun_header)) { 190 if( sendto(fd, &data, sizeof(struct stun_header), 0, (struct sockaddr *)&addr, sizeof(struct sockaddr_in)) < sizeof(struct stun_header)) {
167 nattype.status = 0; 191 nattype.status = 0;
168 cb(&nattype); 192 if(cb) cb(&nattype);
169 return &nattype; 193 return &nattype;
170 } 194 }
195 if(cb) callbacks = g_slist_append(callbacks, cb);
196 timeout = gaim_timeout_add(2000, (GSourceFunc)timeoutfunc, NULL);
171 return NULL; 197 return NULL;
172 } 198 }