epics/pvxs
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

expose wrappers for some evutil as expert API

Browse Source
This commit is contained in:
Michael Davidsaver
2023-04-02 11:58:50 -07:00
parent a012b9ffe0
commit 9449059d8b
2 changed files with 43 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/util.cpp
+33 -8
View File
@@ -4,6 +4,15 @@
* in file LICENSE that is included with this distribution.
*/
#include <osiSock.h>
#ifdef __has_include
# if defined(_WIN32) && __has_include(<afunix.h>)
# include <afunix.h>
# define WIN_HAS_AFUNIX
# endif
#endif
// for signal handling
#include <signal.h>
@@ -228,15 +237,9 @@ void SigInt_handler(int signum);
namespace {
struct SocketPair {
evutil_socket_t s[2];
SOCKET s[2];
SocketPair() {
#ifdef _WIN32
auto err = evutil_socketpair(AF_INET, SOCK_STREAM, 0, s);
#else
auto err = evutil_socketpair(AF_UNIX, SOCK_STREAM, 0, s);
#endif
if(err)
throw BAD_ALLOC();
compat_socketpair(s);
}
~SocketPair() {
epicsSocketDestroy(s[0]);
@@ -663,6 +666,28 @@ GetAddrInfo::~GetAddrInfo()
evutil_freeaddrinfo(info);
}
void compat_socketpair(SOCKET sock[2])
{
evutil_socket_t s[2];
int err = -1;
#if !defined(_WIN32) || defined(WIN_HAS_AFUNIX)
err = evutil_socketpair(AF_UNIX, SOCK_STREAM, 0, s);
#endif
if(err)
err = evutil_socketpair(AF_INET, SOCK_STREAM, 0, s);
if(err)
throw std::runtime_error(SB()<<"ERROR: "<<__func__<<" "<<SOCKERRNO);
sock[0] = (SOCKET)s[0];
sock[1] = (SOCKET)s[1];
}
void compat_make_socket_nonblocking(SOCKET sock)
{
if(evutil_make_socket_nonblocking(sock))
throw std::runtime_error(SB()<<"ERROR: "<<__func__<<" "<<SOCKERRNO);
}
} // namespace pvxs
namespace pvxs {namespace impl {