/* terminate network context */
+void _closesocket (socket_t sock)
+{
+ if (sock != INVALID_SOCKET) {
+ int rc = closesocket (sock);
+ if (rc == SOCKET_ERROR) {
+ VERBOSE (ERROR, PERROR ("error: close %d\n", ERRNO));
+ }
+ }
+}
+
void terminate_network_context (void)
{
- closesocket (sock);
- closesocket (conn);
+ _closesocket (sock);
+ _closesocket (conn);
#ifdef _WIN32 /* Windows */
WSACleanup ();
#endif
VERBOSE (DEBUG, PRINT ("Opening socket\n"));
//socket_t sock = socket (PF_INET, SOCK_STREAM, IPPROTO_TCP);
- if (sock != INVALID_SOCKET) {
- int rc = closesocket (sock);
- if (rc == SOCKET_ERROR) {
- VERBOSE (ERROR, PERROR ("error: close %d\n", ERRNO));
- }
- sock = INVALID_SOCKET;
- }
+ _closesocket (sock);
sock = socket (AF_INET, SOCK_STREAM, 0);
if (sock == INVALID_SOCKET) {
return 0;
int rc = bind (sock, (struct sockaddr *)&addr, sizeof (addr));
if (rc == SOCKET_ERROR) {
VERBOSE (ERROR, PERROR ("error: bind %d\n", ERRNO));
- rc = closesocket (sock);
- if (rc == SOCKET_ERROR) {
- VERBOSE (ERROR, PERROR ("error: close %d\n", ERRNO));
- }
+ _closesocket (sock);
sock = INVALID_SOCKET;
return 0;
}
rc = setsockopt (sock, IPPROTO_TCP, TCP_NODELAY, (char *)&val, sizeof (val));
if (rc < 0) {
VERBOSE (ERROR, PERROR ("error: %s\n", "setsockopt/TCP_NODELAY"));
- closesocket (sock);
- if (rc == SOCKET_ERROR) {
- VERBOSE (ERROR, PERROR ("error: close %d\n", ERRNO));
- }
+ _closesocket (sock);
sock = INVALID_SOCKET;
return 0;
}
rc = listen (sock, BACKLOG);
if (rc < 0) {
VERBOSE (ERROR, PERROR ("error: %s\n", "listen"));
- closesocket (sock);
- if (rc == SOCKET_ERROR) {
- VERBOSE (ERROR, PERROR ("error: close %d\n", ERRNO));
- }
+ _closesocket (sock);
sock = INVALID_SOCKET;
return 0;
}
}
if (conn != INVALID_SOCKET) {
- int rc = closesocket (conn);
- if (rc == SOCKET_ERROR) {
- VERBOSE (ERROR, PERROR ("error: close %d\n", ERRNO));
- }
+ _closesocket (conn);
conn = INVALID_SOCKET;
}
conn = accept (sock, NULL, 0);
int rc = setsockopt (conn, IPPROTO_TCP, TCP_NODELAY, (char *)&val, sizeof (val));
if (rc < 0) {
VERBOSE (ERROR, PERROR ("error: %s\n", "setsockopt/TCP_NODELAY"));
- closesocket (conn);
- if (rc == SOCKET_ERROR) {
- VERBOSE (ERROR, PERROR ("error: close %d\n", ERRNO));
- }
+ _closesocket (conn);
conn = INVALID_SOCKET;
return 0;
}
void close_connection (void)
{
- int rc = closesocket (conn);
- if (rc == SOCKET_ERROR) {
- VERBOSE (ERROR, PERROR ("error: %d\n", ERRNO));
- }
+ _closesocket (conn);
conn = INVALID_SOCKET;
}
int rc = recv (conn, buffer, BUFFER_SIZE, 0);
VERBOSE (DEBUG, PRINT ("rc: %d\nerrno: %d\n", rc, ERRNO));
- if (rc == 0) { /* sock closed */
- if (data) {
- free (data);
- data = NULL;
- len = 0;
- }
- break;
-
- } else if ((rc < 0) && (ERRNO != EAGAIN)) { /* error */
+ if (rc == 0) { /* sock closed or error */
if (data) {
free (data);
data = NULL;
}
- len = -1;
+ len = (rc < 0) ? -1 : 0;
break;
} else if (rc > 0) {
while (index < len) {
int rc = send (conn, data + index, len - index, 0);
- if (rc == 0) { /* sock closed */
- index = 0;
- break;
- } else if ((rc < 0) && (ERRNO != EAGAIN)) { /* error */
- index = -1;
+ if (rc <= 0) { /* sock closed or error */
+ index = (rc < 0) ? -1 : 0;
break;
} else if (rc > 0) {
index += rc;