3pp-mirror/snapcast
1
0
Fork 0
mirror of https://github.com/badaix/snapcast.git synced 2025-07-27 21:38:48 +02:00
Code Issues Projects Releases Packages Wiki Activity

x

Browse source 
git-svn-id: svn://elaine/murooma/trunk@143 d8a302eb-03bc-478d-80e4-98257eca68ef
This commit is contained in:
(no author) 2014-08-06 06:21:09 +00:00
parent ec2fd4d930
commit 342bc79770
2 changed files with 34 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

36
blocking_tcp_echo_server.cpp
View file

@ -14,12 +14,32 @@
#include <boost/smart_ptr.hpp> #include <boost/smart_ptr.hpp>
#include <boost/asio.hpp> #include <boost/asio.hpp>
#include <boost/thread/thread.hpp> #include <boost/thread/thread.hpp>
#include <chrono>
#include <ctime> // localtime
#include <sstream> // stringstream
#include <iomanip>
using boost::asio::ip::tcp; using boost::asio::ip::tcp;
const int max_length = 1024; const int max_length = 1024;
typedef boost::shared_ptr<tcp::socket> socket_ptr; typedef boost::shared_ptr<tcp::socket> socket_ptr;
using namespace std;
using namespace std::chrono;
std::string return_current_time_and_date()
{
auto now = system_clock::now();
auto in_time_t = system_clock::to_time_t(now);
system_clock::duration ms = now.time_since_epoch();
char buff[20];
strftime(buff, 20, "%Y-%m-%d %H:%M:%S", localtime(&in_time_t));
stringstream ss;
ss << buff << "." << std::setw(3) << std::setfill('0') << ((ms / milliseconds(1)) % 1000);
return ss.str();
}
void session(socket_ptr sock) void session(socket_ptr sock)
{ {
@ -27,7 +47,7 @@ void session(socket_ptr sock)
{ {
for (;;) for (;;)
{ {
char data[max_length]; /* char data[max_length];
boost::system::error_code error; boost::system::error_code error;
size_t length = sock->read_some(boost::asio::buffer(data), error); size_t length = sock->read_some(boost::asio::buffer(data), error);
@ -35,8 +55,17 @@ void session(socket_ptr sock)
break; // Connection closed cleanly by peer. break; // Connection closed cleanly by peer.
else if (error) else if (error)
throw boost::system::system_error(error); // Some other error. throw boost::system::system_error(error); // Some other error.
*/
boost::asio::write(*sock, boost::asio::buffer(data, length)); string response(return_current_time_and_date() + "\tHallo\n");
boost::system::error_code error;
cout << response << "\n";
boost::asio::write(*sock, boost::asio::buffer(response), boost::asio::transfer_all(), error);
if (error == boost::asio::error::eof)
break; // Connection closed cleanly by peer.
else if (error)
throw boost::system::system_error(error); // Some other error.
sleep(1);
//std::cout << return_current_time_and_date() << "\n";
} }
} }
catch (std::exception& e) catch (std::exception& e)
@ -52,6 +81,7 @@ void server(boost::asio::io_service& io_service, unsigned short port)
{ {
socket_ptr sock(new tcp::socket(io_service)); socket_ptr sock(new tcp::socket(io_service));
a.accept(*sock); a.accept(*sock);
cout << "New connection: " << sock->remote_endpoint().address().to_string() << "\n";
boost::thread t(boost::bind(session, sock)); boost::thread t(boost::bind(session, sock));
} }
} }

2
client.cpp
View file

@ -133,7 +133,7 @@ int initAudio()
outputParameters.sampleFormat = paInt16; /* 32 bit floating point output */ outputParameters.sampleFormat = paInt16; /* 32 bit floating point output */
outputParameters.suggestedLatency = Pa_GetDeviceInfo( outputParameters.device )->defaultHighOutputLatency; outputParameters.suggestedLatency = Pa_GetDeviceInfo( outputParameters.device )->defaultHighOutputLatency;
outputParameters.hostApiSpecificStreamInfo = NULL; outputParameters.hostApiSpecificStreamInfo = NULL;
std::cerr << "HighLatency: " << outputParameters.suggestedLatency << "\t LowLatency: " << Pa_GetDeviceInfo( outputParameters.device )->defaultLowOutputLatency << "\n";
err = Pa_OpenStream( err = Pa_OpenStream(
&paStream, &paStream,
NULL, /* no input */ NULL, /* no input */