mirrors/monado
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/monado/monado.git synced 2025-01-19 13:18:32 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

d/remote: Tidy [NFC]

Browse source
This commit is contained in:
Jakob Bornecrantz 2023-12-01 18:50:50 +00:00
parent 7485975bfb
commit 79a2f3f3d6
1 changed files with 23 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

38
src/xrt/drivers/remote/r_hub.c
View file

@ -71,74 +71,82 @@ DEBUG_GET_ONCE_LOG_OPTION(remote_log, "REMOTE_LOG", U_LOGGING_INFO)
/* /*
* *
* Socket functions. * Platform socket wrapper functions.
* *
*/ */
#if defined(XRT_OS_WINDOWS) #if defined(XRT_OS_WINDOWS)
static void
static inline void
socket_close(SOCKET id) socket_close(SOCKET id)
{ {
closesocket(id); closesocket(id);
} }
static SOCKET static inline SOCKET
socket_create(void) socket_create(void)
{ {
return socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); return socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
} }
static int static inline int
socket_set_opt(SOCKET id, int flag) socket_set_opt(SOCKET id, int flag)
{ {
return setsockopt(id, SOL_SOCKET, SO_REUSEADDR, (const char *)&flag, sizeof(flag)); return setsockopt(id, SOL_SOCKET, SO_REUSEADDR, (const char *)&flag, sizeof(flag));
} }
static ssize_t static inline ssize_t
socket_read(SOCKET id, void *ptr, size_t size, size_t current) socket_read(SOCKET id, void *ptr, size_t size, size_t current)
{ {
return recv(id, (char *)ptr, size - current, 0); return recv(id, (char *)ptr, size - current, 0);
} }
static size_t static inline size_t
socket_write(SOCKET id, void *ptr, size_t size, size_t current) socket_write(SOCKET id, void *ptr, size_t size, size_t current)
{ {
return send(id, (const char *)ptr, size - current, 0); return send(id, (const char *)ptr, size - current, 0);
} }
#else #elif defined(XRT_OS_UNIX)
static void
static inline void
socket_close(SOCKET id) socket_close(SOCKET id)
{ {
close(id); close(id);
} }
static SOCKET static inline SOCKET
socket_create(void) socket_create(void)
{ {
return socket(AF_INET, SOCK_STREAM, 0); return socket(AF_INET, SOCK_STREAM, 0);
} }
static int static inline int
socket_set_opt(SOCKET id, int flag) socket_set_opt(SOCKET id, int flag)
{ {
return setsockopt(id, SOL_SOCKET, SO_REUSEADDR, &flag, sizeof(flag)); return setsockopt(id, SOL_SOCKET, SO_REUSEADDR, &flag, sizeof(flag));
} }
static ssize_t static inline ssize_t
socket_read(SOCKET id, void *ptr, size_t size, size_t current) socket_read(SOCKET id, void *ptr, size_t size, size_t current)
{ {
return read(id, ptr, size - current); return read(id, ptr, size - current);
} }
static ssize_t static inline ssize_t
socket_write(SOCKET id, void *ptr, size_t size, size_t current) socket_write(SOCKET id, void *ptr, size_t size, size_t current)
{ {
return write(id, ptr, size - current); return write(id, ptr, size - current);
} }
#endif
#endif // XRT_OS_UNIX
/*
*
* Helper functions.
*
*/
static int static int
setup_accept_fd(struct r_hub *r) setup_accept_fd(struct r_hub *r)