diff options
Diffstat (limited to 'src/net/ipc.cpp')
| -rw-r--r-- | src/net/ipc.cpp | 226 |
1 files changed, 0 insertions, 226 deletions
diff --git a/src/net/ipc.cpp b/src/net/ipc.cpp deleted file mode 100644 index 2f910eaed..000000000 --- a/src/net/ipc.cpp +++ /dev/null @@ -1,226 +0,0 @@ -/* - * The ManaPlus Client - * Copyright (C) 2014-2017 The ManaPlus Developers - * - * This file is part of The ManaPlus Client. - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program. If not, see <http://www.gnu.org/licenses/>. - */ - -#include "net/ipc.h" - -#include "gui/windows/chatwindow.h" - -#ifndef DYECMD -#include "input/inputmanager.h" -#endif // DYECMD - -#include "utils/delete2.h" -#include "utils/foreach.h" -#include "utils/sdlhelper.h" -#include "utils/stringutils.h" - -#include "debug.h" - -IPC *ipc = nullptr; - -IPC::IPC() : - mNumReqs(0), - mSocket(nullptr), - mDelayedCommands(), - mThread(nullptr), - mMutex(SDL_CreateMutex()), - mPort(44007U), - mThreadLocked(false), - mListen(false) -{ -} - -IPC::~IPC() -{ - mListen = false; - if (mSocket != nullptr) - { - TcpNet::closeSocket(mSocket); - mSocket = nullptr; - } - SDL_DestroyMutex(mMutex); - mMutex = nullptr; - SDL::WaitThread(mThread); - mThread = nullptr; -} - -bool IPC::init() -{ - IPaddress ip; - - if (TcpNet::resolveHost(&ip, nullptr, mPort) == -1) - { - logger->log("IPC: resolveHost error: %s\n", TcpNet::getError()); - return false; - } - - mSocket = TcpNet::open(&ip); - if (mSocket == nullptr) - { - logger->log("IPC: open error: %s", TcpNet::getError()); - return false; - } - - mThread = SDL::createThread(&acceptLoop, "ipc", this); - if (mThread == nullptr) - { - logger->log("IPC: unable to create acceptLoop thread"); - return false; - } - return true; -} - -int IPC::acceptLoop(void *ptr) -{ - if (ptr == nullptr) - return 1; - - IPC *const ipc1 = reinterpret_cast<IPC*>(ptr); - const int max_length = 1024; - const TcpNet::SocketSet set = TcpNet::allocSocketSet(1); - TcpNet::addSocket(set, ipc1->mSocket); - ipc1->mListen = true; - while (ipc1->mListen) - { - TcpNet::checkSockets(set, 250); - if (TcpNet::socketReady(ipc1->mSocket) == 0) - continue; - - const TcpNet::Socket sock = TcpNet::accept(ipc1->mSocket); - if (sock == nullptr) - { - logger->log_r("IPC: unable to accept connection"); - continue; - } - char data[max_length] = {0}; - int result = TcpNet::recv(sock, data, max_length); - if (result <= 0) - { - logger->log_r("IPC: unable to accept connection"); - TcpNet::closeSocket(sock); - continue; - } - - std::string req(data); - trim(req); - logger->log_r("IPC command: %s", req.c_str()); - - ipc1->mThreadLocked = true; - SDL_mutexP(ipc1->mMutex); - ipc1->mDelayedCommands.push_back(req); - SDL_mutexV(ipc1->mMutex); - ipc1->mThreadLocked = false; - - ipc1->mNumReqs ++; - const std::string resp = strprintf("[%u] %s\n", - ipc1->mNumReqs, req.c_str()); - - const char *const respc = resp.c_str(); - const int len = CAST_S32(strlen(respc)) + 1; - result = TcpNet::send(sock, respc, len); - if (result < len) - { - logger->log_r("IPC: send error: %s\n", TcpNet::getError()); - TcpNet::closeSocket(sock); - continue; - } - TcpNet::closeSocket(sock); - } - TcpNet::closeSocket(ipc1->mSocket); - TcpNet::freeSocketSet(set); - ipc1->mSocket = nullptr; - ipc1->mThread = nullptr; - return 0; -} - -void IPC::stop() -{ - if (ipc == nullptr) - return; - - logger->log("Stopping IPC..."); - delete2(ipc); -} - -void IPC::start() -{ - if (ipc != nullptr) - return; - - unsigned short port(44007); - const char *const portStr = getenv("IPC_PORT"); - if (portStr != nullptr) - port = static_cast<unsigned short>(atoi(portStr)); - - logger->log("Starting IPC..."); - ipc = new IPC; - for (int f = port; f < 65535; f ++) - { - ipc->setPort(static_cast<unsigned short>(f)); - logger->log(" -> trying port %d...", f); - if (ipc->init()) - { - logger->log(" -> Port %d selected", f); - return; - } - - port ++; - } - delete2(ipc); -} - -void IPC::flush() -{ - if (!mThreadLocked) - { - SDL_mutexP(mMutex); -#ifndef DYECMD -// probably need enable only commands in tool - if (chatWindow != nullptr) - { - FOR_EACH (STD_VECTOR<std::string>::const_iterator, it, - mDelayedCommands) - { - chatWindow->chatInput(*it); - } - } - else - { - FOR_EACH (STD_VECTOR<std::string>::const_iterator, it, - mDelayedCommands) - { - std::string msg = *it; - if (msg.empty() || msg[0] != '/') - continue; - msg = msg.substr(1); - const size_t pos = msg.find(' '); - const std::string type(msg, 0, pos); - std::string args(msg, - pos == std::string::npos ? msg.size() : pos + 1); - args = trim(args); - inputManager.executeChatCommand(type, args, nullptr); - } - } -#endif // DYECMD - - mDelayedCommands.clear(); - SDL_mutexV(mMutex); - } -} |