diff options
| author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-13 09:11:08 +0100 |
|---|---|---|
| committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-13 09:11:08 +0100 |
| commit | 73b765e4b497f6a505cbf88c524085fa0e58e59c (patch) | |
| tree | e5168937f98cbb2d85ad3cc93e842ef29d14b276 /src/zmq_engine.cpp | |
| parent | d5670f34baa0751a5b4567a28caea4e4fa208727 (diff) | |
PGM transport fixed
Diffstat (limited to 'src/zmq_engine.cpp')
| -rw-r--r-- | src/zmq_engine.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/zmq_engine.cpp b/src/zmq_engine.cpp index d474f4e..c04f29b 100644 --- a/src/zmq_engine.cpp +++ b/src/zmq_engine.cpp @@ -106,7 +106,9 @@ void zmq::zmq_engine_t::out_event () { // If write buffer is empty, try to read new data from the encoder. if (!outsize) { - encoder.get_buffer (&outpos, &outsize); + + outpos = NULL; + encoder.get_data (&outpos, &outsize); // If there is no data to send, stop polling for output. if (outsize == 0) { |