misc config defaults and comments

This commit is contained in:
Peter Thorson
2011-12-13 09:54:36 -06:00
parent ebf0fa614c
commit b67f1c41b6
4 changed files with 52 additions and 8 deletions

View File

@@ -10,10 +10,7 @@
<body>
<script type="text/javascript">
var options = {"console_enabled": false};
var options = {"console_enabled": true};
var ws;
var url;

View File

@@ -149,13 +149,13 @@ public:
// close frame get written before the acknowledgement close frame.
// The async option will probably reduce latency
// See Autobahn test 7.1.3
write_message(msg);
//write_message(msg);
/*m_endpoint.endpoint_base::m_io_service.post(
m_endpoint.endpoint_base::m_io_service.post(
boost::bind(
&type::write_message,
type::shared_from_this(),
msg)); */
msg));
}
void send(const binary_string& data) {
binary_string_ptr msg(m_processor->prepare_frame(frame::opcode::BINARY,

View File

@@ -136,7 +136,7 @@ private:
unsigned char m_masking_key[4];
int m_masking_index;
// Message payload
// Message buffers
std::string m_payload;
};

View File

@@ -48,6 +48,53 @@ namespace hybi_state {
};
}
/*
client case
end user asks connection for next message
- connection returns the next avaliable message or throws if none are ready
- connection resets the message and fills in a new masking key
end user calls set payload with const ref string to final payload
- set opcode... argument to set payload?
- set payload checks utf8 if copies from source, masks, and stores in payload.
prepare (hybi):
- writes header (writes opcode, payload length, masking key, fin bit, mask bit)
server case
end user asks connection for next message
- connection returns the next avaliable message or throws if none are ready
- connection resets the message and sets masking to off.
end user calls set payload with const ref string to final payload
- std::copy msg to payload
prepare
- writes header (writes opcode, payload length, fin bit, mask bit)
int reference_count
std::list< std::pair< std::string,std::string > >
*/
/*class hybi_message {
public:
hybi_message(frame::opcode::value opcode) : m_processed(false) {
}
void reset() {
}
private:
bool m_processed;
std::string m_header;
std::string m_payload;
};*/
// connection must provide:
// int32_t get_rng();
// message::data_ptr get_data_message();