3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-09 15:26:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Spelling fixes

Browse Source
This commit is contained in:
Pieter Hintjens 2012-12-23 17:47:44 +01:00
parent af934f85ca
commit ef186fe15b
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/stream_engine.cpp
View File

@ -194,7 +194,7 @@ void zmq::stream_engine_t::terminate ()
void zmq::stream_engine_t::in_event () void zmq::stream_engine_t::in_event ()
{ {
// If still handshaking, receive and prcess the greeting message. // If still handshaking, receive and process the greeting message.
if (unlikely (handshaking)) if (unlikely (handshaking))
if (!handshake ()) if (!handshake ())
return; return;
@ -390,9 +390,8 @@ bool zmq::stream_engine_t::handshake ()
// Position of the version field in the greeting. // Position of the version field in the greeting.
const size_t version_pos = 10; const size_t version_pos = 10;
// Is the peer using the unversioned protocol? // Is the peer using ZMTP/1.0 with no version number?
// If so, we send and receive rests of identity // If so, we send and receive rests of identity messages
// messages.
if (greeting [0] != 0xff || !(greeting [9] & 0x01)) { if (greeting [0] != 0xff || !(greeting [9] & 0x01)) {
encoder = new (std::nothrow) encoder_t (out_batch_size); encoder = new (std::nothrow) encoder_t (out_batch_size);
alloc_assert (encoder); alloc_assert (encoder);
@ -417,8 +416,8 @@ bool zmq::stream_engine_t::handshake ()
insize = greeting_bytes_read; insize = greeting_bytes_read;
// To allow for interoperability with peers that do not forward // To allow for interoperability with peers that do not forward
// their subscriptions, we inject a phony subsription // their subscriptions, we inject a phony subscription
// message into the incomming message stream. To put this // message into the incoming message stream. To put this
// message right after the identity message, we temporarily // message right after the identity message, we temporarily
// divert the message stream from session to ourselves. // divert the message stream from session to ourselves.
if (options.type == ZMQ_PUB || options.type == ZMQ_XPUB) if (options.type == ZMQ_PUB || options.type == ZMQ_XPUB)