X-Git-Url: https://git.lyx.org/gitweb/?a=blobdiff_plain;f=src%2Flyxsocket.C;h=0de947676401945c424931c139dfea79178b6e3b;hb=35204f8f33d7400a5fefeffea533fb4cb4097211;hp=4af70e10b22c66843a39c08d009995862c1e72d2;hpb=a6444784dca48da8b1f7723be12069b2e1dbb4c5;p=lyx.git diff --git a/src/lyxsocket.C b/src/lyxsocket.C index 4af70e10b2..0de9476764 100644 --- a/src/lyxsocket.C +++ b/src/lyxsocket.C @@ -21,7 +21,7 @@ #include "LyXAction.h" #include "lyxfunc.h" -#include "frontends/lyx_gui.h" +#include "frontends/Application.h" #include "support/environment.h" #include "support/lyxlib.h" @@ -42,12 +42,14 @@ using std::endl; using std::string; +namespace lyx { + // Address is the unix address for the socket. // MAX_CLIENTS is the maximum number of clients // that can connect at the same time. LyXServerSocket::LyXServerSocket(LyXFunc * f, string const & addr) : func(f), - fd_(lyx::support::socktools::listen(addr, 3)), + fd_(support::socktools::listen(addr, 3)), address_(addr) { if (fd_ == -1) { @@ -57,11 +59,11 @@ LyXServerSocket::LyXServerSocket(LyXFunc * f, string const & addr) // These env vars are used by DVI inverse search // Needed by xdvi - lyx::support::setEnv("XEDITOR", "lyxclient -g %f %l"); + support::setEnv("XEDITOR", "lyxclient -g %f %l"); // Needed by lyxclient - lyx::support::setEnv("LYXSOCKET", address_); + support::setEnv("LYXSOCKET", address_); - lyx_gui::register_socket_callback( + theApp->registerSocketCallback( fd_, boost::bind(&LyXServerSocket::serverCallback, this) ); @@ -75,12 +77,12 @@ LyXServerSocket::LyXServerSocket(LyXFunc * f, string const & addr) LyXServerSocket::~LyXServerSocket() { if (fd_ != -1) { - lyx_gui::unregister_socket_callback(fd_); + theApp->unregisterSocketCallback(fd_); if (::close(fd_) != 0) lyxerr << "lyx: Server socket " << fd_ << " IO error on closing: " << strerror(errno); } - lyx::support::unlink(address_); + support::unlink(address_); lyxerr[Debug::LYXSERVER] << "lyx: Server socket quitting" << endl; } @@ -95,7 +97,7 @@ string const & LyXServerSocket::address() const // is OK and if the number of clients does not exceed MAX_CLIENTS void LyXServerSocket::serverCallback() { - int const client_fd = lyx::support::socktools::accept(fd_); + int const client_fd = support::socktools::accept(fd_); if (fd_ == -1) { lyxerr[Debug::LYXSERVER] << "lyx: Failed to accept new client" @@ -111,7 +113,7 @@ void LyXServerSocket::serverCallback() // Register the new client. clients[client_fd] = shared_ptr(new LyXDataSocket(client_fd)); - lyx_gui::register_socket_callback( + theApp->registerSocketCallback( client_fd, boost::bind(&LyXServerSocket::dataCallback, this, client_fd) @@ -140,7 +142,7 @@ void LyXServerSocket::dataCallback(int fd) if (key == "LYXCMD") { string const cmd = line.substr(pos + 1); func->dispatch(lyxaction.lookupFunc(cmd)); - string const rval = lyx::to_utf8(func->getMessage()); + string const rval = to_utf8(func->getMessage()); if (func->errorStat()) { client->writeln("ERROR:" + cmd + ':' + rval); } else { @@ -209,7 +211,7 @@ LyXDataSocket::~LyXDataSocket() lyxerr << "lyx: Data socket " << fd_ << " IO error on closing: " << strerror(errno); - lyx_gui::unregister_socket_callback(fd_); + theApp->unregisterSocketCallback(fd_); lyxerr[Debug::LYXSERVER] << "lyx: Data socket " << fd_ << " quitting." << endl; } @@ -280,3 +282,6 @@ void LyXDataSocket::writeln(string const & line) connected_ = false; } } + + +} // namespace lyx