summaryrefslogtreecommitdiff
path: root/src/pgm_sender.hpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-12-28 11:51:06 +0100
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-12-28 11:51:06 +0100
commit5852db451a76905336601c5ba3e4f33006f007fb (patch)
treeb881da58001ebd13519b62237acbb84a4a6808e7 /src/pgm_sender.hpp
parentaebff623f36efddc0de7a3192832b61802f8cec8 (diff)
PGM code cleanup
Diffstat (limited to 'src/pgm_sender.hpp')
-rw-r--r--src/pgm_sender.hpp16
1 files changed, 3 insertions, 13 deletions
diff --git a/src/pgm_sender.hpp b/src/pgm_sender.hpp
index 30b545d..e280843 100644
--- a/src/pgm_sender.hpp
+++ b/src/pgm_sender.hpp
@@ -42,6 +42,7 @@ namespace zmq
{
public:
+
pgm_sender_t (class io_thread_t *parent_, const options_t &options_);
~pgm_sender_t ();
@@ -58,12 +59,6 @@ namespace zmq
private:
- // Send one APDU with first message offset information.
- // Note that first 2 bytes in data_ are used to store the offset_
- // and thus user data has to start at data_ + sizeof (uint16_t).
- size_t write_one_pkt_with_offset (unsigned char *data_, size_t size_,
- uint16_t offset_);
-
// Message encoder.
zmq_encoder_t encoder;
@@ -78,20 +73,15 @@ namespace zmq
handle_t uplink_handle;
handle_t rdata_notify_handle;
- // Parent session.
- i_inout *inout;
-
// Output buffer from pgm_socket.
unsigned char *out_buffer;
// Output buffer size.
size_t out_buffer_size;
+ // Number of bytes in the buffer to be written to the socket.
+ // If zero, there are no data to be sent.
size_t write_size;
- size_t write_pos;
-
- // Offset of the first mesage in data chunk taken from encoder.
- int first_message_offset;
pgm_sender_t (const pgm_sender_t&);
void operator = (const pgm_sender_t&);