changed "IP" to "host"

This commit is contained in:
badaix 2015-10-25 13:08:59 +01:00
parent b99cf2f2fc
commit a46b7c6106
6 changed files with 15 additions and 16 deletions

View file

@ -29,7 +29,7 @@
using namespace std; using namespace std;
ClientConnection::ClientConnection(MessageReceiver* receiver, const std::string& ip, size_t port) : active_(false), connected_(false), messageReceiver_(receiver), reqId_(1), ip_(ip), port_(port), readerThread_(NULL), sumTimeout_(chronos::msec(0)) ClientConnection::ClientConnection(MessageReceiver* receiver, const std::string& host, size_t port) : active_(false), connected_(false), messageReceiver_(receiver), reqId_(1), host_(host), port_(port), readerThread_(NULL), sumTimeout_(chronos::msec(0))
{ {
} }
@ -59,7 +59,7 @@ void ClientConnection::socketRead(void* _to, size_t _bytes)
void ClientConnection::start() void ClientConnection::start()
{ {
tcp::resolver resolver(io_service_); tcp::resolver resolver(io_service_);
tcp::resolver::query query(tcp::v4(), ip_, boost::lexical_cast<string>(port_), boost::asio::ip::resolver_query_base::numeric_service); tcp::resolver::query query(tcp::v4(), host_, boost::lexical_cast<string>(port_), boost::asio::ip::resolver_query_base::numeric_service);
auto iterator = resolver.resolve(query); auto iterator = resolver.resolve(query);
logO << "Connecting\n"; logO << "Connecting\n";
socket_.reset(new tcp::socket(io_service_)); socket_.reset(new tcp::socket(io_service_));

View file

@ -67,7 +67,7 @@ class ClientConnection
{ {
public: public:
/// ctor. Received message from the server are passed to MessageReceiver /// ctor. Received message from the server are passed to MessageReceiver
ClientConnection(MessageReceiver* receiver, const std::string& ip, size_t port); ClientConnection(MessageReceiver* receiver, const std::string& host, size_t port);
virtual ~ClientConnection(); virtual ~ClientConnection();
virtual void start(); virtual void start();
virtual void stop(); virtual void stop();
@ -114,7 +114,7 @@ protected:
mutable std::mutex requestMutex_; mutable std::mutex requestMutex_;
std::set<std::shared_ptr<PendingRequest>> pendingRequests_; std::set<std::shared_ptr<PendingRequest>> pendingRequests_;
uint16_t reqId_; uint16_t reqId_;
std::string ip_; std::string host_;
size_t port_; size_t port_;
std::thread* readerThread_; std::thread* readerThread_;
chronos::msec sumTimeout_; chronos::msec sumTimeout_;

View file

@ -110,12 +110,11 @@ bool Controller::sendTimeSyncMessage(long after)
} }
void Controller::start(const PcmDevice& pcmDevice, const std::string& ip, size_t port, size_t latency) void Controller::start(const PcmDevice& pcmDevice, const std::string& host, size_t port, size_t latency)
{ {
ip_ = ip;
pcmDevice_ = pcmDevice; pcmDevice_ = pcmDevice;
latency_ = latency; latency_ = latency;
clientConnection_ = new ClientConnection(this, ip, port); clientConnection_ = new ClientConnection(this, host, port);
controllerThread_ = new thread(&Controller::worker, this); controllerThread_ = new thread(&Controller::worker, this);
} }

View file

@ -39,7 +39,7 @@ class Controller : public MessageReceiver
{ {
public: public:
Controller(); Controller();
void start(const PcmDevice& pcmDevice, const std::string& ip, size_t port, size_t latency); void start(const PcmDevice& pcmDevice, const std::string& host, size_t port, size_t latency);
void stop(); void stop();
/// Implementation of MessageReceiver. /// Implementation of MessageReceiver.

View file

@ -64,7 +64,7 @@ int main (int argc, char *argv[])
try try
{ {
string soundcard; string soundcard;
string ip; string host;
// int bufferMs; // int bufferMs;
size_t port; size_t port;
size_t latency; size_t latency;
@ -73,10 +73,10 @@ int main (int argc, char *argv[])
po::options_description desc("Allowed options"); po::options_description desc("Allowed options");
desc.add_options() desc.add_options()
("help,h", "produce help message") ("help", "produce help message")
("version,v", "show version number") ("version,v", "show version number")
("list,l", po::bool_switch(&listPcmDevices)->default_value(false), "list pcm devices") ("list,l", po::bool_switch(&listPcmDevices)->default_value(false), "list pcm devices")
("ip,i", po::value<string>(&ip), "server IP") ("host,h", po::value<string>(&host), "server hostname or ip address")
("port,p", po::value<size_t>(&port)->default_value(1704), "server port") ("port,p", po::value<size_t>(&port)->default_value(1704), "server port")
("soundcard,s", po::value<string>(&soundcard)->default_value("default"), "index or name of the soundcard") ("soundcard,s", po::value<string>(&soundcard)->default_value("default"), "index or name of the soundcard")
("daemon,d", po::value<int>(&runAsDaemon)->implicit_value(-3), "daemonize, optional process priority [-20..19]") ("daemon,d", po::value<int>(&runAsDaemon)->implicit_value(-3), "daemonize, optional process priority [-20..19]")
@ -139,7 +139,7 @@ int main (int argc, char *argv[])
return 1; return 1;
} }
if (!vm.count("ip")) if (!vm.count("host"))
{ {
BrowseAvahi browseAvahi; BrowseAvahi browseAvahi;
AvahiResult avahiResult; AvahiResult avahiResult;
@ -149,9 +149,9 @@ int main (int argc, char *argv[])
{ {
if (browseAvahi.browse("_snapcast._tcp", AVAHI_PROTO_INET, avahiResult, 5000)) if (browseAvahi.browse("_snapcast._tcp", AVAHI_PROTO_INET, avahiResult, 5000))
{ {
ip = avahiResult.ip_; host = avahiResult.ip_;
port = avahiResult.port_; port = avahiResult.port_;
logO << "Found server " << ip << ":" << port << "\n"; logO << "Found server " << host << ":" << port << "\n";
break; break;
} }
} }
@ -166,7 +166,7 @@ int main (int argc, char *argv[])
std::unique_ptr<Controller> controller(new Controller()); std::unique_ptr<Controller> controller(new Controller());
if (!g_terminated) if (!g_terminated)
{ {
controller->start(pcmDevice, ip, port, latency); controller->start(pcmDevice, host, port, latency);
while(!g_terminated) while(!g_terminated)
usleep(100*1000); usleep(100*1000);
controller->stop(); controller->stop();

View file

@ -45,7 +45,7 @@ public:
/// Reads and decodes PCM data from a named pipe /// Reads and decodes PCM data from a named pipe
/** /**
* Reads PCM from a named pipe and passed the data to an encoder. * Reads PCM from a named pipe and passes the data to an encoder.
* Implements EncoderListener to get the encoded data. * Implements EncoderListener to get the encoded data.
* Data is passed to the PipeListener * Data is passed to the PipeListener
*/ */