3pp-mirror/snapcast
1
0
Fork 0
mirror of https://github.com/badaix/snapcast.git synced 2025-05-20 20:46:16 +02:00
Code Issues Projects Releases Packages Wiki Activity

x

Browse source 
git-svn-id: svn://elaine/murooma/trunk@156 d8a302eb-03bc-478d-80e4-98257eca68ef
This commit is contained in:
(no author) 2014-08-07 21:17:51 +00:00
parent bdb7eeb522
commit e03a46d8e2
2 changed files with 6 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

2
blocking_tcp_echo_server.cpp
View file

@ -65,7 +65,7 @@ public:
size_t written = 0; size_t written = 0;
do do
{ {
written += boost::asio::write(*socket_, boost::asio::buffer(chunk.get() + written, sizeof(WireChunk) - written), error); written += boost::asio::write(*socket_, boost::asio::buffer(chunk.get() + written, sizeof(WireChunk) - written));//, error);
} }
while (written < sizeof(WireChunk)); while (written < sizeof(WireChunk));

16
client.cpp
View file

@ -48,31 +48,25 @@ void player()
cout << "connect\n"; cout << "connect\n";
tcp::socket s(io_service); tcp::socket s(io_service);
s.connect(*iterator); s.connect(*iterator);
boost::system::error_code error; void* wireChunk = (void*)malloc(sizeof(WireChunk));
WireChunk* wireChunk = new WireChunk();
while (true) while (true)
{ {
size_t toRead = sizeof(WireChunk); size_t toRead = sizeof(WireChunk);
size_t len = 0; size_t len = 0;
do do
{ {
len += s.read_some(boost::asio::buffer(wireChunk + len, toRead), error); len += s.read_some(boost::asio::buffer((char*)wireChunk + len, toRead));
toRead = sizeof(WireChunk) - len; toRead = sizeof(WireChunk) - len;
cout << "len: " << len << "\ttoRead: " << toRead << "\n"; // cout << "len: " << len << "\ttoRead: " << toRead << "\n";
if (error == boost::asio::error::eof)
break;
} }
while (toRead > 0); while (toRead > 0);
stream->addChunk(new Chunk((WireChunk*)wireChunk));
cout << "new chunk\n";
stream->addChunk(new Chunk(wireChunk));
} }
} }
catch (std::exception& e) catch (std::exception& e)
{ {
std::cerr << "Exception: " << e.what() << "\n"; std::cerr << "Exception: " << e.what() << "\n";
usleep(100*1000); usleep(500*1000);
} }
} }
} }