ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2026-04-29 15:37:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

updates API version used by broadcast server example

Browse Source
This commit is contained in:
Peter Thorson
2012-01-08 20:16:39 -06:00
parent 14ada3a3a3
commit f6b68fe431
3 changed files with 8 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
examples/broadcast_server_tls/broadcast_admin_handler.hpp
View File

@@ -100,15 +100,8 @@ public:
}
void command_error(connection_ptr connection,const std::string msg) {
websocketpp::message::data_ptr m = connection->get_data_message();
if (m) {
m->reset(frame::opcode::TEXT);
m->set_payload("{\"type\":\"error\",\"value\":\""+msg+"\"}");
connection->send(m);
} else {
// error no avaliable message buffers
}
std::string str = "{\"type\":\"error\",\"value\":\""+msg+"\"}";
connection->send(str);
}
// close: - close this connection

7
examples/broadcast_server_tls/broadcast_handler.hpp
View File

@@ -92,9 +92,10 @@ public:
void on_message(connection_ptr connection,message::data_ptr msg) {
wscmd::cmd command = wscmd::parse(msg->get_payload());
std::cout << "msg: " << msg->get_payload() << std::endl;
if (command.command == "ack") {
handle_ack(connection,command);
//connection->recycle(msg);
} else {
broadcast_message(msg);
}
@@ -160,12 +161,12 @@ public:
// broadcast to clients
for (it = m_connections.begin(); it != m_connections.end(); it++) {
//(*it)->send(msg->get_payload(),(msg->get_opcode() == frame::opcode::BINARY));
for (int i = 0; i < 1; i++) {
for (int i = 0; i < 10; i++) {
(*it)->send(msg);
}
}
new_msg.sent = m_connections.size()*1;
new_msg.sent = m_connections.size()*10;
new_msg.acked = 0;
}

4
examples/broadcast_server_tls/broadcast_server_tls.cpp
View File

@@ -109,9 +109,9 @@ int main(int argc, char* argv[]) {
plain_endpoint_type e(h);
e.alog().unset_level(websocketpp::log::alevel::ALL);
e.elog().unset_level(websocketpp::log::elevel::ALL);
e.elog().set_level(websocketpp::log::elevel::ALL);
e.alog().set_level(websocketpp::log::alevel::DEVEL);
//e.alog().set_level(websocketpp::log::alevel::DEVEL);
std::cout << "Starting WebSocket broadcast server on port " << port << std::endl;
e.listen(port);