23[[nodiscard]]
static std::string getUserName()
28 struct passwd* pw = getpwuid(getuid());
29 return pw->pw_name ? pw->pw_name : std::string{};
33[[nodiscard]]
static bool checkSocketDir(
zstring_view dir)
46 if ((st->st_mode & 0777) != 0700) {
50 if (st->st_uid != getuid()) {
58[[nodiscard]]
static bool checkSocket(
zstring_view socket)
61 if (!name.starts_with(
"socket.")) {
76 if (!S_ISSOCK(st->st_mode)) {
83 if ((st->st_mode & 0777) != 0600) {
88 if (st->st_uid != getuid()) {
98[[nodiscard]]
static int openPort(
SOCKET listenSock)
100 const int BASE = 9938;
101 const int RANGE = 64;
105 for (
auto n :
xrange(RANGE)) {
106 int port = BASE + ((first + n) % RANGE);
107 sockaddr_in server_address;
108 memset(&server_address, 0,
sizeof(server_address));
109 server_address.sin_family = AF_INET;
110 server_address.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
111 server_address.sin_port = htons(port);
112 if (bind(listenSock,
reinterpret_cast<sockaddr*
>(&server_address),
113 sizeof(server_address)) != -1) {
117 throw MSXException(
"Couldn't open socket.");
121SOCKET CliServer::createSocket()
125 if (!checkSocketDir(dir)) {
126 throw MSXException(
"Couldn't create socket directory.");
128 socketName =
strCat(dir,
"/socket.",
int(getpid()));
131 SOCKET sd = socket(AF_INET, SOCK_STREAM, 0);
135 int portNumber = openPort(sd);
141 out << portNumber <<
'\n';
144 throw MSXException(
"Couldn't write socket port file.");
148 SOCKET sd = socket(AF_UNIX, SOCK_STREAM, 0);
156 strncpy(addr.sun_path, socketName.c_str(),
sizeof(addr.sun_path) - 1);
157 addr.sun_path[
sizeof(addr.sun_path) - 1] =
'\0';
158 addr.sun_family = AF_UNIX;
160 if (bind(sd,
reinterpret_cast<sockaddr*
>(&addr),
sizeof(addr)) == -1) {
162 throw MSXException(
"Couldn't bind socket.");
164 if (chmod(socketName.c_str(), 0600) == -1) {
166 throw MSXException(
"Couldn't set socket permissions.");
170 if (!checkSocket(socketName)) {
172 throw MSXException(
"Opened socket fails sanity check.");
176 throw MSXException(
"Couldn't listen to socket: ",
sock_error());
181void CliServer::exitAcceptLoop()
187static void deleteSocket(
const std::string& socket)
190 auto dir = socket.
substr(0, socket.find_last_of(
'/'));
198 : commandController(commandController_)
199 , eventDistributor(eventDistributor_)
205 listenSock = createSocket();
206 thread = std::thread([
this]() { mainLoop(); });
219 deleteSocket(socketName);
223void CliServer::mainLoop()
228 fcntl(listenSock, F_SETFL, O_NONBLOCK);
235 if (poller.
poll(listenSock)) {
239 SOCKET sd = accept(listenSock,
nullptr,
nullptr);
247 if (errno ==
one_of(EAGAIN, EWOULDBLOCK)) {
256 fcntl(sd, F_SETFL, 0);
258 cliComm.
addListener(std::make_unique<SocketConnection>(
259 commandController, eventDistributor, sd));
void printWarning(std::string_view message)
CliServer(CommandController &commandController, EventDistributor &eventDistributor, GlobalCliComm &cliComm)
CliListener * addListener(std::unique_ptr< CliListener > listener)
bool poll(int fd)
Waits for an event to occur on the given file descriptor.
bool aborted()
Returns true iff abort() was called.
void abort()
Aborts a poll in progress and any future poll attempts.
Like std::string_view, but with the extra guarantee that it refers to a zero-terminated string.
constexpr zstring_view substr(size_type pos) const
void mkdir(zstring_view path, mode_t mode)
Create the specified directory.
bool isRegularFile(const Stat &st)
int rmdir(zstring_view path)
Call rmdir() in a platform-independent manner.
string getTempDir()
Get the name of the temp directory on the system.
bool isDirectory(const Stat &st)
void openOfStream(std::ofstream &stream, zstring_view filename)
Open an ofstream in a platform-independent manner.
string_view getFilename(string_view path)
Returns the file portion of a path name.
std::optional< Stat > getStat(zstring_view filename)
Call stat() and return the stat structure.
int unlink(zstring_view path)
Call unlink() in a platform-independent manner.
This file implemented 3 utility functions:
constexpr int OPENMSX_INVALID_SOCKET
constexpr int SOCKET_ERROR
void sock_close(SOCKET sd)
int random_int(int from, int thru)
Return a random integer in the range [from, thru] (note: closed interval).
TemporaryString tmpStrCat(Ts &&... ts)
std::string strCat(Ts &&...ts)
constexpr auto xrange(T e)