raw_socket_stream.cpp File Reference

#include "llvm/Support/raw_socket_stream.h"
#include "llvm/Config/config.h"
#include "llvm/Support/Error.h"
#include "llvm/Support/FileSystem.h"
#include <atomic>
#include <fcntl.h>
#include <functional>
#include <poll.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <unistd.h>

Go to the source code of this file.

Functions
static std::error_code	getLastSocketErrorCode ()
static Expected< sockaddr_un >	setSocketAddr (StringRef SocketPath)
static Expected< int >	getSocketFD (StringRef SocketPath)
static std::error_code	manageTimeout (const std::chrono::milliseconds &Timeout, const std::function< int()> &getActiveFD, const std::optional< int > &CancelFD=std::nullopt)

Function Documentation

getLastSocketErrorCode()

std::error_code getLastSocketErrorCode ( )

static

Definition at line 56 of file raw_socket_stream.cpp.

References llvm::errnoAsErrorCode().

Referenced by llvm::ListeningSocket::accept(), llvm::ListeningSocket::createUnix(), getSocketFD(), and manageTimeout().

getSocketFD()

Expected< int > getSocketFD ( StringRef SocketPath )

static

Definition at line 78 of file raw_socket_stream.cpp.

References getLastSocketErrorCode(), llvm::make_error(), setSocketAddr(), and llvm::Expected< T >::takeError().

Referenced by llvm::raw_socket_stream::createConnectedUnix(), and llvm::ListeningSocket::createUnix().

manageTimeout()

std::error_code manageTimeout ( const std::chrono::milliseconds & Timeout, const std::function< int()> & getActiveFD, const std::optional< int > & CancelFD = std::nullopt )

static

Definition at line 222 of file raw_socket_stream.cpp.

References getLastSocketErrorCode(), and llvm::Timeout.

Referenced by llvm::ListeningSocket::accept(), and llvm::raw_socket_stream::read().

setSocketAddr()

Expected< sockaddr_un > setSocketAddr ( StringRef SocketPath )

static

Definition at line 64 of file raw_socket_stream.cpp.

References llvm::make_error(), llvm::StringRef::size(), and llvm::StringRef::str().

Referenced by llvm::ListeningSocket::createUnix(), and getSocketFD().