summaryrefslogtreecommitdiff
path: root/src/pgm_socket.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_socket.hpp
parentaebff623f36efddc0de7a3192832b61802f8cec8 (diff)
PGM code cleanup
Diffstat (limited to 'src/pgm_socket.hpp')
-rw-r--r--src/pgm_socket.hpp37
1 files changed, 6 insertions, 31 deletions
diff --git a/src/pgm_socket.hpp b/src/pgm_socket.hpp
index b1d0718..3b2740c 100644
--- a/src/pgm_socket.hpp
+++ b/src/pgm_socket.hpp
@@ -30,7 +30,6 @@
#include <pgm/pgm.h>
-#include "stdint.hpp"
#include "options.hpp"
namespace zmq
@@ -62,11 +61,8 @@ namespace zmq
// Send data as one APDU, transmit window owned memory.
size_t send (unsigned char *data_, size_t data_len_);
- // Allocates one slice for packet in tx window.
- void *get_buffer (size_t *size_);
-
- // Fees memory allocated by get_buffer.
- void free_buffer (void *data_);
+ // Returns max tsdu size without fragmentation.
+ size_t get_max_tsdu_size ();
// Receive data from pgm socket.
ssize_t receive (void **data_, const pgm_tsi_t **tsi_);
@@ -76,21 +72,9 @@ namespace zmq
void process_upstream ();
private:
-
- // Open PGM transport.
- int open_transport ();
-
- // Close transport.
- void close_transport ();
// OpenPGM transport
pgm_transport_t* transport;
-
- // Returns max tsdu size without fragmentation.
- size_t get_max_tsdu_size ();
-
- // Returns maximum count of apdus which fills readbuf_size_
- size_t get_max_apdu_at_once (size_t readbuf_size_);
// Associated socket options.
options_t options;
@@ -98,19 +82,13 @@ namespace zmq
// true when pgm_socket should create receiving side.
bool receiver;
- // TIBCO Rendezvous format network info.
- char network [256];
-
- // PGM transport port number.
- uint16_t port_number;
-
- // If we are using UDP encapsulation.
- bool udp_encapsulation;
-
- // Array of pgm_msgv_t structures to store received data
+ // Array of pgm_msgv_t structures to store received data
// from the socket (pgm_transport_recvmsgv).
pgm_msgv_t *pgm_msgv;
+ // Size of pgm_msgv array.
+ size_t pgm_msgv_len;
+
// How many bytes were read from pgm socket.
size_t nbytes_rec;
@@ -119,9 +97,6 @@ namespace zmq
// How many messages from pgm_msgv were already sent up.
size_t pgm_msgv_processed;
-
- // Size of pgm_msgv array.
- size_t pgm_msgv_len;
};
}
#endif