diff options
author | LRN <lrn1986@gmail.com> | 2013-03-20 19:15:55 +0000 |
---|---|---|
committer | LRN <lrn1986@gmail.com> | 2013-03-20 19:15:55 +0000 |
commit | 9f0ab5f654c9d5bc1a04c3728ff65f74b5c1f741 (patch) | |
tree | cf648afb4f31458a1fe524049fdc9da5cdca39a4 /src/util | |
parent | 346748a3a55e197fe206e87b0520cef85ab9fda3 (diff) | |
download | gnunet-9f0ab5f654c9d5bc1a04c3728ff65f74b5c1f741.tar.gz gnunet-9f0ab5f654c9d5bc1a04c3728ff65f74b5c1f741.zip |
Fix warnings and fix/improve logging in network.c
Diffstat (limited to 'src/util')
-rw-r--r-- | src/util/network.c | 16 |
1 files changed, 11 insertions, 5 deletions
diff --git a/src/util/network.c b/src/util/network.c index bea6bfbb2..659b89c0c 100644 --- a/src/util/network.c +++ b/src/util/network.c | |||
@@ -215,7 +215,7 @@ socket_set_inheritable (const struct GNUNET_NETWORK_Handle *h) | |||
215 | #else | 215 | #else |
216 | BOOL b; | 216 | BOOL b; |
217 | SetLastError (0); | 217 | SetLastError (0); |
218 | b = SetHandleInformation (h->fd, HANDLE_FLAG_INHERIT, 0); | 218 | b = SetHandleInformation ((HANDLE) h->fd, HANDLE_FLAG_INHERIT, 0); |
219 | if (!b) | 219 | if (!b) |
220 | { | 220 | { |
221 | SetErrnoFromWinsockError (WSAGetLastError ()); | 221 | SetErrnoFromWinsockError (WSAGetLastError ()); |
@@ -1196,7 +1196,7 @@ static DWORD WINAPI | |||
1196 | _selector (LPVOID p) | 1196 | _selector (LPVOID p) |
1197 | { | 1197 | { |
1198 | struct _select_params *sp = p; | 1198 | struct _select_params *sp = p; |
1199 | int i; | 1199 | |
1200 | while (1) | 1200 | while (1) |
1201 | { | 1201 | { |
1202 | WaitForSingleObject (sp->standby, INFINITE); | 1202 | WaitForSingleObject (sp->standby, INFINITE); |
@@ -1380,6 +1380,7 @@ GNUNET_NETWORK_socket_select (struct GNUNET_NETWORK_FDSet *rfds, | |||
1380 | 1380 | ||
1381 | p = 1; | 1381 | p = 1; |
1382 | res = ioctlsocket (select_wakeup_socket, FIONBIO, &p); | 1382 | res = ioctlsocket (select_wakeup_socket, FIONBIO, &p); |
1383 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Select thread initialization: ioctlsocket() returns %d\n", res); | ||
1383 | 1384 | ||
1384 | alen = sizeof (s_in); | 1385 | alen = sizeof (s_in); |
1385 | s_in.sin_family = AF_INET; | 1386 | s_in.sin_family = AF_INET; |
@@ -1389,12 +1390,16 @@ GNUNET_NETWORK_socket_select (struct GNUNET_NETWORK_FDSet *rfds, | |||
1389 | s_in.sin_addr.S_un.S_un_b.s_b3 = 0; | 1390 | s_in.sin_addr.S_un.S_un_b.s_b3 = 0; |
1390 | s_in.sin_addr.S_un.S_un_b.s_b4 = 1; | 1391 | s_in.sin_addr.S_un.S_un_b.s_b4 = 1; |
1391 | res = bind (select_listening_socket, (const struct sockaddr *) &s_in, sizeof (s_in)); | 1392 | res = bind (select_listening_socket, (const struct sockaddr *) &s_in, sizeof (s_in)); |
1393 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Select thread initialization: bind() returns %d\n", res); | ||
1392 | 1394 | ||
1393 | res = getsockname (select_listening_socket, (struct sockaddr *) &s_in, &alen); | 1395 | res = getsockname (select_listening_socket, (struct sockaddr *) &s_in, &alen); |
1396 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Select thread initialization: getsockname() returns %d\n", res); | ||
1394 | 1397 | ||
1395 | res = listen (select_listening_socket, SOMAXCONN); | 1398 | res = listen (select_listening_socket, SOMAXCONN); |
1399 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Select thread initialization: listen() returns %d\n", res); | ||
1396 | 1400 | ||
1397 | res = connect (select_wakeup_socket, (const struct sockaddr *) &s_in, sizeof (s_in)); | 1401 | res = connect (select_wakeup_socket, (const struct sockaddr *) &s_in, sizeof (s_in)); |
1402 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Select thread initialization: connect() returns %d\n", res); | ||
1398 | 1403 | ||
1399 | select_send_socket = accept (select_listening_socket, (struct sockaddr *) &s_in, &alen); | 1404 | select_send_socket = accept (select_listening_socket, (struct sockaddr *) &s_in, &alen); |
1400 | 1405 | ||
@@ -1480,10 +1485,11 @@ GNUNET_NETWORK_socket_select (struct GNUNET_NETWORK_FDSet *rfds, | |||
1480 | if (rfds && read_handles) | 1485 | if (rfds && read_handles) |
1481 | { | 1486 | { |
1482 | struct GNUNET_CONTAINER_SList_Iterator i; | 1487 | struct GNUNET_CONTAINER_SList_Iterator i; |
1488 | int c; | ||
1483 | 1489 | ||
1484 | for (i = GNUNET_CONTAINER_slist_begin (rfds->handles); | 1490 | for (c = 0, i = GNUNET_CONTAINER_slist_begin (rfds->handles); |
1485 | GNUNET_CONTAINER_slist_end (&i) != GNUNET_YES; | 1491 | GNUNET_CONTAINER_slist_end (&i) != GNUNET_YES; |
1486 | GNUNET_CONTAINER_slist_next (&i)) | 1492 | GNUNET_CONTAINER_slist_next (&i), c++) |
1487 | { | 1493 | { |
1488 | struct GNUNET_DISK_FileHandle *fh; | 1494 | struct GNUNET_DISK_FileHandle *fh; |
1489 | 1495 | ||
@@ -1498,7 +1504,7 @@ GNUNET_NETWORK_socket_select (struct GNUNET_NETWORK_FDSet *rfds, | |||
1498 | bret = PeekNamedPipe (fh->h, NULL, 0, NULL, &waitstatus, NULL); | 1504 | bret = PeekNamedPipe (fh->h, NULL, 0, NULL, &waitstatus, NULL); |
1499 | error = GetLastError (); | 1505 | error = GetLastError (); |
1500 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Peek at read pipe %d (0x%x) returned %d (%d bytes available) GLE %u\n", | 1506 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Peek at read pipe %d (0x%x) returned %d (%d bytes available) GLE %u\n", |
1501 | i, fh->h, bret, waitstatus, error); | 1507 | c, fh->h, bret, waitstatus, error); |
1502 | if (bret == 0) | 1508 | if (bret == 0) |
1503 | { | 1509 | { |
1504 | /* TODO: either add more errors to this condition, or eliminate it | 1510 | /* TODO: either add more errors to this condition, or eliminate it |