summaryrefslogtreecommitdiff
path: root/src/win32/win32_socket.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/win32/win32_socket.c')
-rw-r--r--src/win32/win32_socket.c76
1 files changed, 40 insertions, 36 deletions
diff --git a/src/win32/win32_socket.c b/src/win32/win32_socket.c
index 9138a76..d303888 100644
--- a/src/win32/win32_socket.c
+++ b/src/win32/win32_socket.c
@@ -1,5 +1,7 @@
#if defined(_WIN32)
+#include <stdint.h>
+
#include "win32_socket.h"
#undef socket
@@ -11,11 +13,11 @@
#include <errno.h>
#include <assert.h>
-int win32_poll(struct pollfd *fds, unsigned int nfds, int timo) {
+int32_t win32_poll(struct pollfd *fds, uint32_t nfds, int32_t timo) {
struct timeval timeout, *toptr;
fd_set ifds, ofds, efds, *ip, *op;
- unsigned int i;
- int rc;
+ uint32_t i;
+ int32_t rc;
#ifdef _MSC_VER
#pragma warning(disable: 4548)
@@ -66,11 +68,11 @@ int win32_poll(struct pollfd *fds, unsigned int nfds, int timo) {
printf("Exiting select rc=%d\n", rc);
#endif
- if (rc <= 0) { return(rc); }
+ if (rc <= 0) { return (rc); }
if (rc > 0) {
for ( i = 0; i < nfds; ++i) {
- int fd = fds[i].fd;
+ SOCKET fd = fds[i].fd;
if (fds[i].events & (POLLIN | POLLPRI) && FD_ISSET(fd, &ifds)) {
fds[i].revents |= POLLIN;
@@ -96,10 +98,10 @@ int win32_poll(struct pollfd *fds, unsigned int nfds, int timo) {
}
}
- return(rc);
+ return (rc);
}
-static void set_connect_errno(int winsock_err) {
+static void set_connect_errno(int32_t winsock_err) {
switch (winsock_err) {
case WSAEINVAL:
case WSAEALREADY:
@@ -112,7 +114,7 @@ static void set_connect_errno(int winsock_err) {
}
}
-static void set_socket_errno(int winsock_err) {
+static void set_socket_errno(int32_t winsock_err) {
switch (winsock_err) {
case WSAEWOULDBLOCK:
errno = EAGAIN;
@@ -123,29 +125,31 @@ static void set_socket_errno(int winsock_err) {
}
}
-/* A wrapper around the socket() function.
+/*
+ * A wrapper around the socket() function.
* The purpose of this wrapper is to ensure that the global errno symbol is set if an error occurs,
* even if we are using winsock.
*/
-SOCKET win32_socket(int domain, int type, int protocol) {
+SOCKET win32_socket(int32_t domain, int32_t type, int32_t protocol) {
SOCKET fd = socket(domain, type, protocol);
if (fd == INVALID_SOCKET) { set_socket_errno(WSAGetLastError()); }
- return(fd);
+ return (fd);
}
-/* A wrapper around the connect() function.
+/*
+ * A wrapper around the connect() function.
* The purpose of this wrapper is to ensure that the global errno symbol is set if an error occurs,
* even if we are using winsock.
*/
-int win32_connect(SOCKET fd, struct sockaddr *addr, socklen_t addr_len) {
- int rc = connect(fd, addr, addr_len);
+int32_t win32_connect(SOCKET fd, struct sockaddr *addr, socklen_t addr_len) {
+ int32_t rc = connect(fd, addr, addr_len);
assert(rc == 0 || rc == SOCKET_ERROR);
if (rc == SOCKET_ERROR) { set_connect_errno(WSAGetLastError()); }
- return(rc);
+ return (rc);
}
/* A wrapper around the accept() function.
@@ -160,50 +164,50 @@ SOCKET win32_accept(SOCKET fd, struct sockaddr *addr, socklen_t *addr_len) {
newfd = (SOCKET)-1;
}
- return(newfd);
+ return (newfd);
}
/* A wrapper around the shutdown() function.
* The purpose of this wrapper is to ensure that the global errno symbol is set if an error occurs,
* even if we are using winsock.
*/
-int win32_shutdown(SOCKET fd, int mode) {
- int rc = shutdown(fd, mode);
+int32_t win32_shutdown(SOCKET fd, int32_t mode) {
+ int32_t rc = shutdown(fd, mode);
assert(rc == 0 || rc == SOCKET_ERROR);
if (rc == SOCKET_ERROR) { set_socket_errno(WSAGetLastError()); }
- return(rc);
+ return (rc);
}
-int win32_close_socket(SOCKET fd) {
- int rc = closesocket(fd);
+int32_t win32_close_socket(SOCKET fd) {
+ int32_t rc = closesocket(fd);
if (rc == SOCKET_ERROR) { set_socket_errno(WSAGetLastError()); }
- return(rc);
+ return (rc);
}
-ssize_t win32_write_socket(SOCKET fd, void *buf, int n) {
- int rc = send(fd, buf, n, 0);
+ssize_t win32_write_socket(SOCKET fd, void *buf, int32_t n) {
+ int32_t rc = send(fd, buf, n, 0);
if (rc == SOCKET_ERROR) { set_socket_errno(WSAGetLastError()); }
- return(rc);
+ return (rc);
}
-ssize_t win32_read_socket(SOCKET fd, void *buf, int n) {
- int rc = recv(fd, buf, n, 0);
+ssize_t win32_read_socket(SOCKET fd, void *buf, int32_t n) {
+ int32_t rc = recv(fd, buf, n, 0);
if (rc == SOCKET_ERROR) { set_socket_errno(WSAGetLastError()); }
- return(rc);
+ return (rc);
}
char * win32_strtok_r(char *s, const char *delim, char **lasts) {
register char *spanp;
- register int c, sc;
+ register int32_t c, sc;
char *tok;
@@ -240,7 +244,7 @@ cont:
}
*lasts = s;
- return(tok);
+ return (tok);
}
} while (sc != 0);
@@ -252,11 +256,11 @@ cont:
char *win32_strsep (char **stringp, const char *delim) {
register char *s;
register const char *spanp;
- register int c, sc;
+ register int32_t c, sc;
char *tok;
if ((s = *stringp) == NULL) {
- return(NULL);
+ return (NULL);
}
for (tok = s; ;) {
@@ -272,7 +276,7 @@ char *win32_strsep (char **stringp, const char *delim) {
}
*stringp = s;
- return(tok);
+ return (tok);
}
} while (sc != 0);
@@ -282,7 +286,7 @@ char *win32_strsep (char **stringp, const char *delim) {
}
#ifndef STLINK_HAVE_UNISTD_H
-int usleep(unsigned int waitTime) {
+int32_t usleep(uint32_t waitTime) {
if (waitTime >= 1000) {
/* Don't do long busy-waits.
* However much it seems like the QPC code would be more accurate,
@@ -297,7 +301,7 @@ int usleep(unsigned int waitTime) {
WaitForSingleObject(timer, INFINITE);
CloseHandle(timer);
- return(0);
+ return (0);
}
LARGE_INTEGER perf_cnt, start, now;
@@ -309,7 +313,7 @@ int usleep(unsigned int waitTime) {
QueryPerformanceCounter((LARGE_INTEGER*)&now);
} while ((now.QuadPart - start.QuadPart) / (float)perf_cnt.QuadPart * 1000 * 1000 < waitTime);
- return(0);
+ return (0);
}
#endif
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-03 14:45:51 +0000