ManaPlus
Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes
IPC Class Reference

#include <ipc.h>

Public Member Functions

 IPC ()
 
 ~IPC ()
 
bool init ()
 
unsigned short getPort () const
 
void flush ()
 

Static Public Member Functions

static int acceptLoop (void *ptr)
 
static void start ()
 
static void stop ()
 

Private Member Functions

void setPort (const unsigned short port)
 

Private Attributes

unsigned int mNumReqs
 
TcpNet::Socket mSocket
 
std::vector< std::string > mDelayedCommands
 
SDL_Thread * mThread
 
SDL_mutex * mMutex
 
unsigned short mPort
 
volatile bool mThreadLocked
 
bool mListen
 

Detailed Description

Definition at line 36 of file ipc.h.

Constructor & Destructor Documentation

◆ IPC()

IPC::IPC ( )

Constructor.

Definition at line 39 of file ipc.cpp.

39  :
40  mNumReqs(0),
41  mSocket(nullptr),
42  mDelayedCommands(),
43  mThread(nullptr),
44  mMutex(SDL_CreateMutex()),
45  mPort(44007U),
46  mThreadLocked(false),
47  mListen(false)
48 {
49 }
IPC::mPort
unsigned short mPort
Definition: ipc.h:73
IPC::mListen
bool mListen
Definition: ipc.h:75
IPC::mNumReqs
unsigned int mNumReqs
Definition: ipc.h:68
IPC::mThread
SDL_Thread * mThread
Definition: ipc.h:71
IPC::mSocket
TcpNet::Socket mSocket
Definition: ipc.h:69
IPC::mMutex
SDL_mutex * mMutex
Definition: ipc.h:72
IPC::mThreadLocked
volatile bool mThreadLocked
Definition: ipc.h:74
IPC::mDelayedCommands
std::vector< std::string > mDelayedCommands
Definition: ipc.h:70

Referenced by start().

◆ ~IPC()

IPC::~IPC ( )

Destructor.

Definition at line 51 of file ipc.cpp.

52 {
53  mListen = false;
54  if (mSocket != nullptr)
55  {
56  TcpNet::closeSocket(mSocket);
57  mSocket = nullptr;
58  }
59  SDL_DestroyMutex(mMutex);
60  mMutex = nullptr;
61  SDL::WaitThread(mThread);
62  mThread = nullptr;
63 }
SDL::WaitThread
void WaitThread(SDL_Thread *const thread)
Definition: sdlhelper.cpp:195
TcpNet::closeSocket
void closeSocket(const TcpNet::Socket socket)
Definition: sdltcpnet.cpp:88

References TcpNet::closeSocket(), mListen, mMutex, mSocket, mThread, and SDL::WaitThread().

Member Function Documentation

◆ acceptLoop()

int IPC::acceptLoop ( void *  ptr)
static

Definition at line 91 of file ipc.cpp.

92 {
93  if (ptr == nullptr)
94  return 1;
95 
96  IPC *const ipc1 = reinterpret_cast<IPC*>(ptr);
97  const int max_length = 1024;
98  const TcpNet::SocketSet set = TcpNet::allocSocketSet(1);
99  TcpNet::addSocket(set, ipc1->mSocket);
100  ipc1->mListen = true;
101  while (ipc1->mListen)
102  {
103  TcpNet::checkSockets(set, 250);
104  if (TcpNet::socketReady(ipc1->mSocket) == 0)
105  continue;
106 
107  const TcpNet::Socket sock = TcpNet::accept(ipc1->mSocket);
108  if (sock == nullptr)
109  {
110  logger->log_r("IPC: unable to accept connection");
111  continue;
112  }
113  char data[max_length] = {0};
114  int result = TcpNet::recv(sock, data, max_length);
115  if (result <= 0)
116  {
117  logger->log_r("IPC: unable to accept connection");
118  TcpNet::closeSocket(sock);
119  continue;
120  }
121 
122  std::string req(data);
123  trim(req);
124  logger->log_r("IPC command: %s", req.c_str());
125 
126  ipc1->mThreadLocked = true;
127  SDL_mutexP(ipc1->mMutex);
128  ipc1->mDelayedCommands.push_back(req);
129  SDL_mutexV(ipc1->mMutex);
130  ipc1->mThreadLocked = false;
131 
132  ipc1->mNumReqs ++;
133  const std::string resp = strprintf("[%u] %s\n",
134  ipc1->mNumReqs, req.c_str());
135 
136  const char *const respc = resp.c_str();
137  const int len = CAST_S32(strlen(respc)) + 1;
138  result = TcpNet::send(sock, respc, len);
139  if (result < len)
140  {
141  logger->log_r("IPC: send error: %s\n", TcpNet::getError());
142  TcpNet::closeSocket(sock);
143  continue;
144  }
145  TcpNet::closeSocket(sock);
146  }
147  TcpNet::closeSocket(ipc1->mSocket);
148  TcpNet::freeSocketSet(set);
149  ipc1->mSocket = nullptr;
150  ipc1->mThread = nullptr;
151  return 0;
152 }
CAST_S32
#define CAST_S32
Definition: cast.h:30
IPC
Definition: ipc.h:37
Logger::log_r
void log_r(const char *const log_text,...)
Definition: logger.cpp:365
logger
Logger * logger
Definition: logger.cpp:89
data
uint32_t data
Definition: maptypeproperty2.h:1
Catch::trim
std::string trim(std::string const &str)
TcpNet::SocketSet
::SDLNet_SocketSet SocketSet
Definition: sdltcpnet.h:37
TcpNet::send
int send(const TcpNet::Socket sock, const void *const data, const int len)
Definition: sdltcpnet.cpp:93
TcpNet::freeSocketSet
void freeSocketSet(const TcpNet::SocketSet set)
Definition: sdltcpnet.cpp:193
TcpNet::socketReady
int socketReady(const TcpNet::Socket sock)
Definition: sdltcpnet.cpp:164
TcpNet::Socket
::TCPsocket Socket
Definition: sdltcpnet.h:38
TcpNet::addSocket
int addSocket(const TcpNet::SocketSet set, const TcpNet::Socket sock)
Definition: sdltcpnet.cpp:156
TcpNet::allocSocketSet
SocketSet allocSocketSet(const int maxsockets)
Definition: sdltcpnet.cpp:151
TcpNet::getError
const char * getError()
Definition: sdltcpnet.cpp:99
TcpNet::checkSockets
int checkSockets(const TcpNet::SocketSet set, const Uint32 timeout)
Definition: sdltcpnet.cpp:175
TcpNet::recv
int recv(const TcpNet::Socket sock, void *const data, const int maxlen)
Definition: sdltcpnet.cpp:180
TcpNet::accept
TcpNet::Socket accept(const TcpNet::Socket sock)
Definition: sdltcpnet.cpp:198
strprintf
std::string strprintf(const char *const format,...)
Definition: stringutils.cpp:100

References TcpNet::accept(), TcpNet::addSocket(), TcpNet::allocSocketSet(), CAST_S32, TcpNet::checkSockets(), TcpNet::closeSocket(), data, TcpNet::freeSocketSet(), TcpNet::getError(), Logger::log_r(), logger, mDelayedCommands, mListen, mMutex, mNumReqs, mSocket, mThread, mThreadLocked, TcpNet::recv(), TcpNet::send(), TcpNet::socketReady(), strprintf(), and Catch::trim().

Referenced by init().

◆ flush()

void IPC::flush ( )

Definition at line 190 of file ipc.cpp.

191 {
192  if (!mThreadLocked)
193  {
194  SDL_mutexP(mMutex);
195 #ifndef DYECMD
196 // probably need enable only commands in tool
197  if (chatWindow != nullptr)
198  {
199  FOR_EACH (STD_VECTOR<std::string>::const_iterator, it,
200  mDelayedCommands)
201  {
202  chatWindow->chatInput(*it);
203  }
204  }
205  else
206  {
207  FOR_EACH (STD_VECTOR<std::string>::const_iterator, it,
208  mDelayedCommands)
209  {
210  std::string msg = *it;
211  if (msg.empty() || msg[0] != '/')
212  continue;
213  msg = msg.substr(1);
214  const size_t pos = msg.find(' ');
215  const std::string type(msg, 0, pos);
216  std::string args(msg,
217  pos == std::string::npos ? msg.size() : pos + 1);
218  args = trim(args);
219  inputManager.executeChatCommand(type, args, nullptr);
220  }
221  }
222 #endif // DYECMD
223 
224  mDelayedCommands.clear();
225  SDL_mutexV(mMutex);
226  }
227 }
chatWindow
ChatWindow * chatWindow
Definition: chatwindow.cpp:94
ChatWindow::chatInput
void chatInput(const std::string &msg) const
Definition: chatwindow.cpp:665
InputManager::executeChatCommand
bool executeChatCommand(const std::string &cmd, const std::string &args, ChatTab *const tab)
Definition: inputmanager.cpp:898
FOR_EACH
#define FOR_EACH(type, iter, array)
Definition: foreach.h:25
inputManager
InputManager inputManager
Definition: inputmanager.cpp:69
Actions::msg
bool msg(InputEvent &event)
Definition: chat.cpp:39

References ChatWindow::chatInput(), chatWindow, InputManager::executeChatCommand(), FOR_EACH, inputManager, mDelayedCommands, mMutex, Actions::msg(), mThreadLocked, and Catch::trim().

Referenced by Gui::slowLogic().

◆ getPort()

unsigned short IPC::getPort ( ) const
inline

Definition at line 53 of file ipc.h.

54  { return mPort; }

References mPort.

◆ init()

bool IPC::init ( )

Definition at line 65 of file ipc.cpp.

66 {
67  IPaddress ip;
68 
69  if (TcpNet::resolveHost(&ip, nullptr, mPort) == -1)
70  {
71  logger->log("IPC: resolveHost error: %s\n", TcpNet::getError());
72  return false;
73  }
74 
75  mSocket = TcpNet::open(&ip);
76  if (mSocket == nullptr)
77  {
78  logger->log("IPC: open error: %s", TcpNet::getError());
79  return false;
80  }
81 
82  mThread = SDL::createThread(&acceptLoop, "ipc", this);
83  if (mThread == nullptr)
84  {
85  logger->log("IPC: unable to create acceptLoop thread");
86  return false;
87  }
88  return true;
89 }
IPC::acceptLoop
static int acceptLoop(void *ptr)
Definition: ipc.cpp:91
Logger::log
void log(const char *const log_text,...)
Definition: logger.cpp:269
SDL::createThread
SDL_Thread * createThread(int(*fn)(void *), const char *const name, void *const data)
Definition: sdlhelper.cpp:118
TcpNet::resolveHost
int resolveHost(IPaddress *const address, const char *const host, const Uint16 port)
Definition: sdltcpnet.cpp:104
TcpNet::open
TcpNet::Socket open(IPaddress *const ip)
Definition: sdltcpnet.cpp:110

References acceptLoop(), SDL::createThread(), TcpNet::getError(), Logger::log(), logger, mPort, mSocket, mThread, TcpNet::open(), and TcpNet::resolveHost().

Referenced by start().

◆ setPort()

void IPC::setPort ( const unsigned short  port)
inlineprivate

Definition at line 65 of file ipc.h.

66  { mPort = port; }

References mPort.

Referenced by start().

◆ start()

void IPC::start ( )
static

Definition at line 163 of file ipc.cpp.

164 {
165  if (ipc != nullptr)
166  return;
167 
168  unsigned short port(44007);
169  const char *const portStr = getenv("IPC_PORT");
170  if (portStr != nullptr)
171  port = static_cast<unsigned short>(atoi(portStr));
172 
173  logger->log("Starting IPC...");
174  ipc = new IPC;
175  for (int f = port; f < 65535; f ++)
176  {
177  ipc->setPort(static_cast<unsigned short>(f));
178  logger->log(" -> trying port %d...", f);
179  if (ipc->init())
180  {
181  logger->log(" -> Port %d selected", f);
182  return;
183  }
184 
185  port ++;
186  }
187  delete2(ipc)
188 }
IPC::IPC
IPC()
Definition: ipc.cpp:39
IPC::setPort
void setPort(const unsigned short port)
Definition: ipc.h:65
IPC::init
bool init()
Definition: ipc.cpp:65
delete2
#define delete2(var)
Definition: delete2.h:25
ipc
IPC * ipc
Definition: ipc.cpp:37

References delete2, init(), ipc, IPC(), Logger::log(), logger, and setPort().

◆ stop()

void IPC::stop ( )
static

Definition at line 154 of file ipc.cpp.

155 {
156  if (ipc == nullptr)
157  return;
158 
159  logger->log("Stopping IPC...");
160  delete2(ipc)
161 }

References delete2, ipc, Logger::log(), and logger.

Field Documentation

◆ mDelayedCommands

std::vector<std::string> IPC::mDelayedCommands
private

Definition at line 70 of file ipc.h.

Referenced by acceptLoop(), and flush().

◆ mListen

bool IPC::mListen
private

Definition at line 75 of file ipc.h.

Referenced by acceptLoop(), and ~IPC().

◆ mMutex

SDL_mutex* IPC::mMutex
private

Definition at line 72 of file ipc.h.

Referenced by acceptLoop(), flush(), and ~IPC().

◆ mNumReqs

unsigned int IPC::mNumReqs
private

Definition at line 68 of file ipc.h.

Referenced by acceptLoop().

◆ mPort

unsigned short IPC::mPort
private

Definition at line 73 of file ipc.h.

Referenced by getPort(), init(), and setPort().

◆ mSocket

TcpNet::Socket IPC::mSocket
private

Definition at line 69 of file ipc.h.

Referenced by acceptLoop(), init(), and ~IPC().

◆ mThread

SDL_Thread* IPC::mThread
private

Definition at line 71 of file ipc.h.

Referenced by acceptLoop(), init(), and ~IPC().

◆ mThreadLocked

volatile bool IPC::mThreadLocked
private

Definition at line 74 of file ipc.h.

Referenced by acceptLoop(), and flush().

The documentation for this class was generated from the following files:
Generated on Wed Mar 17 2021 19:19:14 for ManaPlus by doxygen 1.9.1