Log messages cleanup; one extra message.

git-svn-id: svn://svn.code.sf.net/p/sc2/code/trunk@2677 8092fc87-c524-0410-9efc-e669fe64eaf9
This commit is contained in:
Meep-Eep
2007-01-19 18:44:51 +00:00
parent 5e055e5003
commit dcb277a505
10 changed files with 59 additions and 54 deletions
+1
View File
@@ -1,4 +1,5 @@
Changes towards version 0.7: Changes towards version 0.7:
- No more extra newlines to log_add() calls for libs/network/ code - SvdB
- DUCK videos now play correctly after a video mode change; bug #734 - Alex - DUCK videos now play correctly after a video mode change; bug #734 - Alex
- Cancel key will now quit out of the Manifest Menu (Bug #838) - Michael - Cancel key will now quit out of the Manifest Menu (Bug #838) - Michael
- Added -w and -x commandline options, to counter -f and -o; used these - Added -w and -x commandline options, to counter -f and -o; used these
+14 -10
View File
@@ -78,7 +78,7 @@ ConnectState_incRef(ConnectState *connectState) {
assert(connectState->refCount < REFCOUNT_MAX); assert(connectState->refCount < REFCOUNT_MAX);
connectState->refCount++; connectState->refCount++;
#ifdef DEBUG_CONNECT_REF #ifdef DEBUG_CONNECT_REF
log_add(log_Debug, "ConnectState %08" PRIxPTR ": ref++ (%d)\n", log_add(log_Debug, "ConnectState %08" PRIxPTR ": ref++ (%d)",
(uintptr_t) connectState, connectState->refCount); (uintptr_t) connectState, connectState->refCount);
#endif #endif
} }
@@ -88,7 +88,7 @@ ConnectState_decRef(ConnectState *connectState) {
assert(connectState->refCount > 0); assert(connectState->refCount > 0);
connectState->refCount--; connectState->refCount--;
#ifdef DEBUG_CONNECT_REF #ifdef DEBUG_CONNECT_REF
log_add(log_Debug, "ConnectState %08" PRIxPTR ": ref-- (%d)\n", log_add(log_Debug, "ConnectState %08" PRIxPTR ": ref-- (%d)",
(uintptr_t) connectState, connectState->refCount); (uintptr_t) connectState, connectState->refCount);
#endif #endif
if (connectState->refCount == 0) { if (connectState->refCount == 0) {
@@ -147,20 +147,20 @@ connectCallback(NetDescriptor *nd) {
if (connectState->state == Connect_closed) { if (connectState->state == Connect_closed) {
// The connection attempt has been aborted. // The connection attempt has been aborted.
#ifdef DEBUG #ifdef DEBUG
log_add(log_Debug, "Connection attempt was aborted.\n"); log_add(log_Debug, "Connection attempt was aborted.");
#endif #endif
ConnectState_decRef(connectState); ConnectState_decRef(connectState);
return; return;
} }
if (Socket_getError(NetDescriptor_getSocket(nd), &err) == -1) { if (Socket_getError(NetDescriptor_getSocket(nd), &err) == -1) {
log_add(log_Fatal, "Socket_getError() failed: %s.\n", log_add(log_Fatal, "Socket_getError() failed: %s.",
strerror(errno)); strerror(errno));
explode(); explode();
} }
if (err != 0) { if (err != 0) {
#ifdef DEBUG #ifdef DEBUG
log_add(log_Debug, "connect() failed: %s.\n", strerror(err)); log_add(log_Debug, "connect() failed: %s.", strerror(err));
#endif #endif
NetDescriptor_close(nd); NetDescriptor_close(nd);
connectState->nd = NULL; connectState->nd = NULL;
@@ -169,6 +169,10 @@ connectCallback(NetDescriptor *nd) {
return; return;
} }
#ifdef DEBUG
log_add(log_Debug, "Connection established.");
#endif
// Notify the higher layer. // Notify the higher layer.
connectState->nd = NULL; connectState->nd = NULL;
// The callback function takes over ownership of the // The callback function takes over ownership of the
@@ -224,14 +228,14 @@ tryConnectHostNext(ConnectState *connectState) {
info->ai_protocol); info->ai_protocol);
if (sock == Socket_noSocket) { if (sock == Socket_noSocket) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "socket() failed: %s.\n", strerror(errno)); log_add(log_Error, "socket() failed: %s.", strerror(errno));
errno = savedErrno; errno = savedErrno;
return Socket_noSocket; return Socket_noSocket;
} }
if (Socket_setNonBlocking(sock) == -1) { if (Socket_setNonBlocking(sock) == -1) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "Could not make socket non-blocking: %s.\n", log_add(log_Error, "Could not make socket non-blocking: %s.",
strerror(errno)); strerror(errno));
errno = savedErrno; errno = savedErrno;
return Socket_noSocket; return Socket_noSocket;
@@ -268,7 +272,7 @@ tryConnectHostNext(ConnectState *connectState) {
Socket_close(sock); Socket_close(sock);
#ifdef DEBUG #ifdef DEBUG
log_add(log_Debug, "connect() immediately failed for one address: " log_add(log_Debug, "connect() immediately failed for one address: "
"%s.\n", strerror(errno)); "%s.", strerror(errno));
// TODO: add the address in the status message. // TODO: add the address in the status message.
#endif #endif
errno = savedErrno; errno = savedErrno;
@@ -327,7 +331,7 @@ connectHostNext(ConnectState *connectState) {
ConnectError error; ConnectError error;
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "NetDescriptor_new() failed: %s.\n", log_add(log_Error, "NetDescriptor_new() failed: %s.",
strerror(errno)); strerror(errno));
Socket_close(sock); Socket_close(sock);
freeaddrinfo(connectState->info); freeaddrinfo(connectState->info);
@@ -438,7 +442,7 @@ connectHostByName(const char *host, const char *service, Protocol proto,
connectState = ConnectState_alloc(); connectState = ConnectState_alloc();
connectState->refCount = 1; connectState->refCount = 1;
#ifdef DEBUG_CONNECT_REF #ifdef DEBUG_CONNECT_REF
log_add(log_Debug, "ConnectState %08" PRIxPTR ": ref=1 (%d)\n", log_add(log_Debug, "ConnectState %08" PRIxPTR ": ref=1 (%d)",
(uintptr_t) connectState, connectState->refCount); (uintptr_t) connectState, connectState->refCount);
#endif #endif
connectState->state = Connect_resolving; connectState->state = Connect_resolving;
+15 -15
View File
@@ -74,7 +74,7 @@ ListenState_incRef(ListenState *listenState) {
assert(listenState->refCount < REFCOUNT_MAX); assert(listenState->refCount < REFCOUNT_MAX);
listenState->refCount++; listenState->refCount++;
#ifdef DEBUG_LISTEN_REF #ifdef DEBUG_LISTEN_REF
log_add(log_Debug, "ListenState %08" PRIxPTR ": ref++ (%d)\n", log_add(log_Debug, "ListenState %08" PRIxPTR ": ref++ (%d)",
(uintptr_t) listenState, listenState->refCount); (uintptr_t) listenState, listenState->refCount);
#endif #endif
} }
@@ -84,7 +84,7 @@ ListenState_decRef(ListenState *listenState) {
assert(listenState->refCount > 0); assert(listenState->refCount > 0);
listenState->refCount--; listenState->refCount--;
#ifdef DEBUG_LISTEN_REF #ifdef DEBUG_LISTEN_REF
log_add(log_Debug, "ListenState %08" PRIxPTR ": ref-- (%d)\n", log_add(log_Debug, "ListenState %08" PRIxPTR ": ref-- (%d)",
(uintptr_t) listenState, listenState->refCount); (uintptr_t) listenState, listenState->refCount);
#endif #endif
if (listenState->refCount == 0) { if (listenState->refCount == 0) {
@@ -134,7 +134,7 @@ listenPortSingle(struct ListenState *listenState, struct addrinfo *info) {
info->ai_protocol); info->ai_protocol);
if (sock == Socket_noSocket) { if (sock == Socket_noSocket) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "socket() failed: %s.\n", strerror(errno)); log_add(log_Error, "socket() failed: %s.", strerror(errno));
errno = savedErrno; errno = savedErrno;
return NULL; return NULL;
} }
@@ -154,10 +154,10 @@ listenPortSingle(struct ListenState *listenState, struct addrinfo *info) {
int savedErrno = errno; int savedErrno = errno;
if (errno == EADDRINUSE) { if (errno == EADDRINUSE) {
#ifdef DEBUG #ifdef DEBUG
log_add(log_Warning, "bind() failed: %s.\n", strerror(errno)); log_add(log_Warning, "bind() failed: %s.", strerror(errno));
#endif #endif
} else } else
log_add(log_Error, "bind() failed: %s.\n", strerror(errno)); log_add(log_Error, "bind() failed: %s.", strerror(errno));
Socket_close(sock); Socket_close(sock);
errno = savedErrno; errno = savedErrno;
return NULL; return NULL;
@@ -166,7 +166,7 @@ listenPortSingle(struct ListenState *listenState, struct addrinfo *info) {
listenResult = Socket_listen(sock, listenState->flags.backlog); listenResult = Socket_listen(sock, listenState->flags.backlog);
if (listenResult == -1) { if (listenResult == -1) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "listen() failed: %s.\n", strerror(errno)); log_add(log_Error, "listen() failed: %s.", strerror(errno));
Socket_close(sock); Socket_close(sock);
errno = savedErrno; errno = savedErrno;
return NULL; return NULL;
@@ -175,7 +175,7 @@ listenPortSingle(struct ListenState *listenState, struct addrinfo *info) {
nd = NetDescriptor_new(sock, (void *) listenState); nd = NetDescriptor_new(sock, (void *) listenState);
if (nd == NULL) { if (nd == NULL) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "NetDescriptor_new() failed: %s.\n", log_add(log_Error, "NetDescriptor_new() failed: %s.",
strerror(errno)); strerror(errno));
Socket_close(sock); Socket_close(sock);
errno = savedErrno; errno = savedErrno;
@@ -226,7 +226,7 @@ listenPortMulti(struct ListenState *listenState, struct addrinfo *info) {
// it's a real possibility. // it's a real possibility.
if (errno == EADDRINUSE && addrOkCount == 0) { if (errno == EADDRINUSE && addrOkCount == 0) {
log_add(log_Error, "Error while preparing a network socket " log_add(log_Error, "Error while preparing a network socket "
"for incoming connections: %s\n", strerror(errno)); "for incoming connections: %s", strerror(errno));
} }
continue; continue;
} }
@@ -312,7 +312,7 @@ listenPort(const char *service, Protocol proto, const ListenFlags *flags,
listenState = ListenState_alloc(); listenState = ListenState_alloc();
listenState->refCount = 1; listenState->refCount = 1;
#ifdef DEBUG_LISTEN_REF #ifdef DEBUG_LISTEN_REF
log_add(log_Debug, "ListenState %08" PRIxPTR ": ref=1 (%d)\n", log_add(log_Debug, "ListenState %08" PRIxPTR ": ref=1 (%d)",
(uintptr_t) listenState, listenState->refCount); (uintptr_t) listenState, listenState->refCount);
#endif #endif
listenState->state = Listen_resolving; listenState->state = Listen_resolving;
@@ -382,13 +382,13 @@ acceptSingleConnection(ListenState *listenState, NetDescriptor *nd) {
#endif #endif
// Serious problems, but future connections may still // Serious problems, but future connections may still
// be possible. // be possible.
log_add(log_Warning, "accept() reported '%s'\n", log_add(log_Warning, "accept() reported '%s'",
strerror(errno)); strerror(errno));
return; return;
default: default:
// Should not happen. // Should not happen.
log_add(log_Fatal, "Internal error: accept() reported " log_add(log_Fatal, "Internal error: accept() reported "
"'%s'\n", strerror(errno)); "'%s'", strerror(errno));
explode(); explode();
} }
} }
@@ -397,7 +397,7 @@ acceptSingleConnection(ListenState *listenState, NetDescriptor *nd) {
// Ignore errors; it's not a big deal. // Ignore errors; it's not a big deal.
if (Socket_setNonBlocking(acceptResult) == -1) { if (Socket_setNonBlocking(acceptResult) == -1) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "Could not make socket non-blocking: %s.\n", log_add(log_Error, "Could not make socket non-blocking: %s.",
strerror(errno)); strerror(errno));
Socket_close(acceptResult); Socket_close(acceptResult);
errno = savedErrno; errno = savedErrno;
@@ -418,11 +418,11 @@ acceptSingleConnection(ListenState *listenState, NetDescriptor *nd) {
hostname, sizeof hostname, NULL, 0, 0); hostname, sizeof hostname, NULL, 0, 0);
if (gniRes != 0) { if (gniRes != 0) {
log_add(log_Error, "Error while performing hostname " log_add(log_Error, "Error while performing hostname "
"lookup for incoming connection: %s\n", "lookup for incoming connection: %s",
(gniRes == EAI_SYSTEM) ? strerror(errno) : (gniRes == EAI_SYSTEM) ? strerror(errno) :
gai_strerror(gniRes)); gai_strerror(gniRes));
} else { } else {
log_add(log_Debug, "Accepted incoming connection from '%s'.\n", log_add(log_Debug, "Accepted incoming connection from '%s'.",
hostname); hostname);
} }
} }
@@ -431,7 +431,7 @@ acceptSingleConnection(ListenState *listenState, NetDescriptor *nd) {
newNd = NetDescriptor_new(acceptResult, NULL); newNd = NetDescriptor_new(acceptResult, NULL);
if (newNd == NULL) { if (newNd == NULL) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "NetDescriptor_new() failed: %s.\n", log_add(log_Error, "NetDescriptor_new() failed: %s.",
strerror(errno)); strerror(errno));
Socket_close(acceptResult); Socket_close(acceptResult);
errno = savedErrno; errno = savedErrno;
@@ -51,7 +51,7 @@ ResolveState_incRef(ResolveState *resolveState) {
assert(resolveState->refCount < REFCOUNT_MAX); assert(resolveState->refCount < REFCOUNT_MAX);
resolveState->refCount++; resolveState->refCount++;
#ifdef DEBUG_RESOLVE_REF #ifdef DEBUG_RESOLVE_REF
log_add(log_Debug, "ResolveState %08" PRIxPTR ": ref++ (%d)\n", log_add(log_Debug, "ResolveState %08" PRIxPTR ": ref++ (%d)",
(uintptr_t) resolveState, resolveState->refCount); (uintptr_t) resolveState, resolveState->refCount);
#endif #endif
} }
@@ -61,7 +61,7 @@ ResolveState_decRef(ResolveState *resolveState) {
assert(resolveState->refCount > 0); assert(resolveState->refCount > 0);
resolveState->refCount--; resolveState->refCount--;
#ifdef DEBUG_RESOLVE_REF #ifdef DEBUG_RESOLVE_REF
log_add(log_Debug, "ResolveState %08" PRIxPTR ": ref-- (%d)\n", log_add(log_Debug, "ResolveState %08" PRIxPTR ": ref-- (%d)",
(uintptr_t) resolveState, resolveState->refCount); (uintptr_t) resolveState, resolveState->refCount);
#endif #endif
if (resolveState->refCount == 0) { if (resolveState->refCount == 0) {
@@ -129,7 +129,7 @@ getaddrinfoAsync(const char *node, const char *service,
resolveState = ResolveState_new(); resolveState = ResolveState_new();
resolveState->refCount = 1; resolveState->refCount = 1;
#ifdef DEBUG_RESOLVE_REF #ifdef DEBUG_RESOLVE_REF
log_add(log_Debug, "ResolveState %08" PRIxPTR ": ref=1 (%d)\n", log_add(log_Debug, "ResolveState %08" PRIxPTR ": ref=1 (%d)",
(uintptr_t) resolveState, resolveState->refCount); (uintptr_t) resolveState, resolveState->refCount);
#endif #endif
resolveState->state = Resolve_resolving; resolveState->state = Resolve_resolving;
@@ -51,7 +51,7 @@ NetDescriptor_new(Socket *socket, void *extra) {
nd = NetDescriptor_alloc(); nd = NetDescriptor_alloc();
nd->refCount = 1; nd->refCount = 1;
#ifdef DEBUG_NETDESCRIPTOR_REF #ifdef DEBUG_NETDESCRIPTOR_REF
log_add(log_Debug, "NetDescriptor %08" PRIxPTR ": ref=1 (%d)\n", log_add(log_Debug, "NetDescriptor %08" PRIxPTR ": ref=1 (%d)",
(uintptr_t) nd, nd->refCount); (uintptr_t) nd, nd->refCount);
#endif #endif
@@ -117,7 +117,7 @@ NetDescriptor_incRef(NetDescriptor *nd) {
assert(nd->refCount < REFCOUNT_MAX); assert(nd->refCount < REFCOUNT_MAX);
nd->refCount++; nd->refCount++;
#ifdef DEBUG_NETDESCRIPTOR_REF #ifdef DEBUG_NETDESCRIPTOR_REF
log_add(log_Debug, "NetDescriptor %08" PRIxPTR ": ref++ (%d)\n", log_add(log_Debug, "NetDescriptor %08" PRIxPTR ": ref++ (%d)",
(uintptr_t) nd, nd->refCount); (uintptr_t) nd, nd->refCount);
#endif #endif
} }
@@ -128,7 +128,7 @@ NetDescriptor_decRef(NetDescriptor *nd) {
assert(nd->refCount > 0); assert(nd->refCount > 0);
nd->refCount--; nd->refCount--;
#ifdef DEBUG_NETDESCRIPTOR_REF #ifdef DEBUG_NETDESCRIPTOR_REF
log_add(log_Debug, "NetDescriptor %08" PRIxPTR ": ref-- (%d)\n", log_add(log_Debug, "NetDescriptor %08" PRIxPTR ": ref-- (%d)",
(uintptr_t) nd, nd->refCount); (uintptr_t) nd, nd->refCount);
#endif #endif
if (nd->refCount == 0) { if (nd->refCount == 0) {
@@ -154,7 +154,7 @@ NetManager_process(uint32 *timeoutMs) {
} while (selectResult == -1 && errno == EINTR); } while (selectResult == -1 && errno == EINTR);
if (selectResult == -1) { if (selectResult == -1) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "select() failed: %s.\n", strerror(errno)); log_add(log_Error, "select() failed: %s.", strerror(errno));
errno = savedErrno; errno = savedErrno;
*timeoutMs = (timeout.tv_sec * 1000) + (timeout.tv_usec / 1000); *timeoutMs = (timeout.tv_sec * 1000) + (timeout.tv_usec / 1000);
// XXX: rounding microseconds down. Is that the correct // XXX: rounding microseconds down. Is that the correct
@@ -89,7 +89,7 @@ closeWSAEvent(WSAEVENT event) {
error = WSAGetLastError(); error = WSAGetLastError();
if (error != WSAEINPROGRESS) { if (error != WSAEINPROGRESS) {
log_add(log_Error, log_add(log_Error,
"WSACloseEvent() failed with error code %d.\n", error); "WSACloseEvent() failed with error code %d.", error);
errno = winsockErrorToErrno(error); errno = winsockErrorToErrno(error);
return -1; return -1;
} }
@@ -137,7 +137,7 @@ NetManager_addDesc(NetDescriptor *nd) {
int savedErrno = getWinsockErrno(); int savedErrno = getWinsockErrno();
int closeStatus = closeWSAEvent(event); int closeStatus = closeWSAEvent(event);
if (closeStatus == -1) { if (closeStatus == -1) {
log_add(log_Fatal, "closeWSAEvent() failed: %s.\n", log_add(log_Fatal, "closeWSAEvent() failed: %s.",
strerror(errno)); strerror(errno));
explode(); explode();
} }
@@ -224,7 +224,7 @@ NetManager_updateEvent(NetDescriptor *nd) {
int savedErrno = getWinsockErrno(); int savedErrno = getWinsockErrno();
int closeStatus = closeWSAEvent(events[nd->smd->index]); int closeStatus = closeWSAEvent(events[nd->smd->index]);
if (closeStatus == -1) { if (closeStatus == -1) {
log_add(log_Fatal, "closeWSAEvent() failed: %s.\n", log_add(log_Fatal, "closeWSAEvent() failed: %s.",
strerror(errno)); strerror(errno));
explode(); explode();
} }
@@ -265,7 +265,7 @@ activateSomeCallback(NetDescriptor *nd, long eventMask) {
{ {
int status = NetManager_updateEvent(nd); int status = NetManager_updateEvent(nd);
if (status == -1) { if (status == -1) {
log_add(log_Fatal, "NetManager_updateEvent() failed: %s.\n", log_add(log_Fatal, "NetManager_updateEvent() failed: %s.",
strerror(errno)); strerror(errno));
explode(); explode();
// TODO: better error handling. // TODO: better error handling.
@@ -279,7 +279,7 @@ deactivateSomeCallback(NetDescriptor *nd, long eventMask) {
{ {
int status = NetManager_updateEvent(nd); int status = NetManager_updateEvent(nd);
if (status == -1) { if (status == -1) {
log_add(log_Fatal, "NetManager_updateEvent() failed: %s.\n", log_add(log_Fatal, "NetManager_updateEvent() failed: %s.",
strerror(errno)); strerror(errno));
explode(); explode();
// TODO: better error handling // TODO: better error handling
+5 -5
View File
@@ -35,23 +35,23 @@ Network_init(void) {
startupResult = WSAStartup(requestVersion, &data); startupResult = WSAStartup(requestVersion, &data);
if (startupResult != 0) { if (startupResult != 0) {
int savedErrno = winsockErrorToErrno(startupResult); int savedErrno = winsockErrorToErrno(startupResult);
log_add(log_Fatal, "WSAStartup failed.\n"); log_add(log_Fatal, "WSAStartup failed.");
errno = savedErrno; errno = savedErrno;
explode(); explode();
} }
#ifdef DEBUG #ifdef DEBUG
log_add(log_Debug, "Winsock version %d.%d found: \"%s\".\n", log_add(log_Debug, "Winsock version %d.%d found: \"%s\".",
LOBYTE(data.wHighVersion), HIBYTE(data.wHighVersion), LOBYTE(data.wHighVersion), HIBYTE(data.wHighVersion),
data.szDescription); data.szDescription);
log_add(log_Debug, "Requesting to use Winsock version %d.%d, got " log_add(log_Debug, "Requesting to use Winsock version %d.%d, got "
"version %d.%d.\n", "version %d.%d.",
LOBYTE(requestVersion), HIBYTE(requestVersion), LOBYTE(requestVersion), HIBYTE(requestVersion),
LOBYTE(data.wVersion), HIBYTE(data.wVersion)); LOBYTE(data.wVersion), HIBYTE(data.wVersion));
#endif #endif
if (data.wVersion != requestVersion) { if (data.wVersion != requestVersion) {
log_add(log_Fatal, "Winsock version %d.%d presented, requested " log_add(log_Fatal, "Winsock version %d.%d presented, requested "
"%d.%d.\n", LOBYTE(data.wVersion), HIBYTE(data.wVersion), "%d.%d.", LOBYTE(data.wVersion), HIBYTE(data.wVersion),
LOBYTE(requestVersion), HIBYTE(requestVersion)); LOBYTE(requestVersion), HIBYTE(requestVersion));
(void) WSACleanup(); (void) WSACleanup();
// Ignoring errors; we're going to abort anyhow. // Ignoring errors; we're going to abort anyhow.
@@ -66,7 +66,7 @@ Network_uninit(void) {
cleanupResult = WSACleanup(); cleanupResult = WSACleanup();
if (cleanupResult == SOCKET_ERROR) { if (cleanupResult == SOCKET_ERROR) {
int savedErrno = getWinsockErrno(); int savedErrno = getWinsockErrno();
log_add(log_Fatal, "WSACleanup failed.\n"); log_add(log_Fatal, "WSACleanup failed.");
errno = savedErrno; errno = savedErrno;
explode(); explode();
} }
@@ -142,7 +142,7 @@ Socket_setNonBlocking(Socket *sock) {
if (flags == -1) { if (flags == -1) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "Getting file descriptor flags of socket failed: " log_add(log_Error, "Getting file descriptor flags of socket failed: "
"%s.\n", strerror(errno)); "%s.", strerror(errno));
errno = savedErrno; errno = savedErrno;
return -1; return -1;
} }
@@ -150,7 +150,7 @@ Socket_setNonBlocking(Socket *sock) {
if (fcntl(sock->fd, F_SETFL, flags | O_NONBLOCK) == -1) { if (fcntl(sock->fd, F_SETFL, flags | O_NONBLOCK) == -1) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "Setting non-blocking mode on socket failed: " log_add(log_Error, "Setting non-blocking mode on socket failed: "
"%s.\n", strerror(errno)); "%s.", strerror(errno));
errno = savedErrno; errno = savedErrno;
return -1; return -1;
} }
@@ -165,7 +165,7 @@ Socket_setReuseAddr(Socket *sock) {
if (setsockopt(sock->fd, SOL_SOCKET, SO_REUSEADDR, &flag, sizeof flag) if (setsockopt(sock->fd, SOL_SOCKET, SO_REUSEADDR, &flag, sizeof flag)
== -1) { == -1) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "Setting socket reuse failed: %s.\n", log_add(log_Error, "Setting socket reuse failed: %s.",
strerror(errno)); strerror(errno));
errno = savedErrno; errno = savedErrno;
return -1; return -1;
@@ -183,7 +183,7 @@ Socket_setNodelay(Socket *sock) {
== -1) { == -1) {
#ifdef DEBUG #ifdef DEBUG
int savedErrno = errno; int savedErrno = errno;
log_add(log_Warning, "Disabling Nagle algorithm failed: %s.\n", log_add(log_Warning, "Disabling Nagle algorithm failed: %s.",
strerror(errno)); strerror(errno));
errno = savedErrno; errno = savedErrno;
#endif #endif
@@ -199,7 +199,7 @@ Socket_setTOS(Socket *sock, int tos) {
if (setsockopt(sock->fd, IPPROTO_IP, IP_TOS, &tos, sizeof tos) == -1) { if (setsockopt(sock->fd, IPPROTO_IP, IP_TOS, &tos, sizeof tos) == -1) {
#ifdef DEBUG #ifdef DEBUG
int savedErrno = errno; int savedErrno = errno;
log_add(log_Warning, "Setting socket type-of-service failed: %s.\n", log_add(log_Warning, "Setting socket type-of-service failed: %s.",
strerror(errno)); strerror(errno));
errno = savedErrno; errno = savedErrno;
#endif #endif
@@ -231,7 +231,7 @@ Socket_setInlineOOB(Socket *sock) {
if (setsockopt(sock->fd, SOL_SOCKET, SO_OOBINLINE, &flag, sizeof flag) if (setsockopt(sock->fd, SOL_SOCKET, SO_OOBINLINE, &flag, sizeof flag)
== -1) { == -1) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "Setting inline OOB on socket failed: %s\n", log_add(log_Error, "Setting inline OOB on socket failed: %s",
strerror(errno)); strerror(errno));
errno = savedErrno; errno = savedErrno;
return -1; return -1;
@@ -246,7 +246,7 @@ Socket_setKeepAlive(Socket *sock) {
if (setsockopt(sock->fd, IPPROTO_TCP, SO_KEEPALIVE, &flag, sizeof flag) if (setsockopt(sock->fd, IPPROTO_TCP, SO_KEEPALIVE, &flag, sizeof flag)
== -1) { == -1) {
int savedErrno = errno; int savedErrno = errno;
log_add(log_Error, "Setting keep-alive on socket failed: %s\n", log_add(log_Error, "Setting keep-alive on socket failed: %s",
strerror(errno)); strerror(errno));
errno = savedErrno; errno = savedErrno;
return -1; return -1;
@@ -178,7 +178,7 @@ Socket_setNonBlocking(Socket *sock) {
if (ioctlsocket(sock->sock, FIONBIO, &flag) == SOCKET_ERROR) { if (ioctlsocket(sock->sock, FIONBIO, &flag) == SOCKET_ERROR) {
int savedErrno = getWinsockErrno(); int savedErrno = getWinsockErrno();
log_add(log_Error, "Setting non-block mode on socket failed: %s.\n", log_add(log_Error, "Setting non-block mode on socket failed: %s.",
strerror(errno)); strerror(errno));
errno = savedErrno; errno = savedErrno;
return -1; return -1;
@@ -193,7 +193,7 @@ Socket_setReuseAddr(Socket *sock) {
if (setsockopt(sock->sock, SOL_SOCKET, SO_REUSEADDR, if (setsockopt(sock->sock, SOL_SOCKET, SO_REUSEADDR,
(const char *) &flag, sizeof flag) == SOCKET_ERROR) { (const char *) &flag, sizeof flag) == SOCKET_ERROR) {
int savedErrno = getWinsockErrno(); int savedErrno = getWinsockErrno();
log_add(log_Error, "Setting socket reuse failed: %s.\n", log_add(log_Error, "Setting socket reuse failed: %s.",
strerror(errno)); strerror(errno));
errno = savedErrno; errno = savedErrno;
return -1; return -1;
@@ -211,7 +211,7 @@ Socket_setNodelay(Socket *sock) {
(const char *) &flag, sizeof flag) == SOCKET_ERROR) { (const char *) &flag, sizeof flag) == SOCKET_ERROR) {
#ifdef DEBUG #ifdef DEBUG
int savedErrno = getWinsockErrno(); int savedErrno = getWinsockErrno();
log_add(log_Warning, "Disabling Nagle algorithm failed: %s.\n", log_add(log_Warning, "Disabling Nagle algorithm failed: %s.",
strerror(errno)); strerror(errno));
errno = savedErrno; errno = savedErrno;
#endif #endif
@@ -245,7 +245,7 @@ Socket_setInlineOOB(Socket *sock) {
if (setsockopt(sock->sock, SOL_SOCKET, SO_OOBINLINE, (const char *) &flag, if (setsockopt(sock->sock, SOL_SOCKET, SO_OOBINLINE, (const char *) &flag,
sizeof flag) == SOCKET_ERROR) { sizeof flag) == SOCKET_ERROR) {
int savedErrno = getWinsockErrno(); int savedErrno = getWinsockErrno();
log_add(log_Error, "Setting inline OOB on socket failed: %s\n", log_add(log_Error, "Setting inline OOB on socket failed: %s",
strerror(errno)); strerror(errno));
errno = savedErrno; errno = savedErrno;
return -1; return -1;
@@ -260,7 +260,7 @@ Socket_setKeepAlive(Socket *sock) {
if (setsockopt(sock->sock, IPPROTO_TCP, SO_KEEPALIVE, if (setsockopt(sock->sock, IPPROTO_TCP, SO_KEEPALIVE,
(const char *) &flag, sizeof flag) == SOCKET_ERROR) { (const char *) &flag, sizeof flag) == SOCKET_ERROR) {
int savedErrno = getWinsockErrno(); int savedErrno = getWinsockErrno();
log_add(log_Error, "Setting keep-alive on socket failed: %s\n", log_add(log_Error, "Setting keep-alive on socket failed: %s",
strerror(errno)); strerror(errno));
errno = savedErrno; errno = savedErrno;
return -1; return -1;