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

Merge pull request #926 from bebopagogo/master

Browse Source 
added uncommitted norm_engine changes
This commit is contained in:
Richard Newton 2014-03-16 15:55:47 +00:00
commit 0e0c46aedc
3 changed files with 16 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/norm_engine.cpp
View File

@ -267,12 +267,14 @@ void zmq::norm_engine_t::send_data()
// Buffer contained end of message (should we flush?)
//NormStreamMarkEom(norm_tx_stream);
// Note this makes NORM fairly chatty for low duty cycle messaging
// but makes sure content is delivered quickly. Positive acknowledgements
// with flush override would make NORM more succinct here
NormStreamFlush(norm_tx_stream, true, NORM_FLUSH_ACTIVE);
}
tx_index = tx_len = 0; // all buffered data was written
}
// Still norm_tx_ready, so ask for more data from zmq_session
if (!zmq_encoder.has_data())
if (!zmq_encoder.has_data())
{
// Existing message had no more data to encode
if (-1 == zmq_session->pull_msg(&tx_msg))
@ -333,20 +335,19 @@ void zmq::norm_engine_t::in_event()
break;
case NORM_RX_OBJECT_ABORTED:
{
NormRxStreamState* rxState = (NormRxStreamState*)NormObjectGetUserData(event.object);
if (NULL != rxState)
{
NormRxStreamState* rxState = (NormRxStreamState*)NormObjectGetUserData(event.object);
if (NULL != rxState)
{
// Remove the state from the list it's in
// This is now unnecessary since deletion takes care of list removal
// but in the interest of being clear ...
NormRxStreamState::List* list = rxState->AccessList();
if (NULL != list) list->Remove(*rxState);
}
delete rxState;
// Remove the state from the list it's in
// This is now unnecessary since deletion takes care of list removal
// but in the interest of being clear ...
NormRxStreamState::List* list = rxState->AccessList();
if (NULL != list) list->Remove(*rxState);
}
delete rxState;
break;
}
case NORM_REMOTE_SENDER_INACTIVE:
// Here we free resources used for this formerly active sender.
// Note w/ NORM_SYNC_STREAM, if sender reactivates, we may

4
src/norm_engine.hpp
View File

@ -2,8 +2,6 @@
#ifndef __ZMQ_NORM_ENGINE_HPP_INCLUDED__
#define __ZMQ_NORM_ENGINE_HPP_INCLUDED__
#define ZMQ_HAVE_NORM 1
#if defined ZMQ_HAVE_NORM
#include "io_object.hpp"
@ -12,7 +10,7 @@
#include "v2_decoder.hpp"
#include "v2_encoder.hpp"
#include <norm/include/normApi.h>
#include <normApi.h>
namespace zmq
{