Skip to content

L
libzmq
Commit c6d74e0a authored by Steven McCoy's avatar Steven McCoy Committed by Martin Sustrik
Browse files
Options

Drop PGM parameters to 100mb friendly range. 

Signed-off-by: 's avatarSteven McCoy <steven.mccoy@miru.hk>
parent 5b8af52e
Hide whitespace changes
Inline Side-by-side
Showing with 13 additions and 17 deletions
src/pgm_socket.cpp
View file @ c6d74e0a
...@@ -187,13 +187,13 @@ int zmq::pgm_socket_t::init (bool udp_encapsulation_, const char *network_) ...@@ -187,13 +187,13 @@ int zmq::pgm_socket_t::init (bool udp_encapsulation_, const char *network_)
const int recv_only = 1, const int recv_only = 1,
rxw_max_rte = options.rate * 1000 / 8, rxw_max_rte = options.rate * 1000 / 8,
rxw_secs = options.recovery_ivl, rxw_secs = options.recovery_ivl,
peer_expiry = 5 * pgm_msecs (8192), peer_expiry = pgm_secs (300),
spmr_expiry = pgm_msecs (25), spmr_expiry = pgm_msecs (25),
nak_bo_ivl = pgm_msecs (50), nak_bo_ivl = pgm_msecs (50),
nak_rpt_ivl = pgm_msecs (200), nak_rpt_ivl = pgm_msecs (200),
nak_rdata_ivl = pgm_msecs (200), nak_rdata_ivl = pgm_msecs (200),
nak_data_retries = 5, nak_data_retries = 50,
nak_ncf_retries = 2; nak_ncf_retries = 50;
if (!pgm_setsockopt (sock, IPPROTO_PGM, PGM_RECV_ONLY, &recv_only, sizeof (recv_only)) || if (!pgm_setsockopt (sock, IPPROTO_PGM, PGM_RECV_ONLY, &recv_only, sizeof (recv_only)) ||
!pgm_setsockopt (sock, IPPROTO_PGM, PGM_RXW_MAX_RTE, &rxw_max_rte, sizeof (rxw_max_rte)) || !pgm_setsockopt (sock, IPPROTO_PGM, PGM_RXW_MAX_RTE, &rxw_max_rte, sizeof (rxw_max_rte)) ||
...@@ -210,20 +210,16 @@ int zmq::pgm_socket_t::init (bool udp_encapsulation_, const char *network_) ...@@ -210,20 +210,16 @@ int zmq::pgm_socket_t::init (bool udp_encapsulation_, const char *network_)
const int send_only = 1, const int send_only = 1,
txw_max_rte = options.rate * 1000 / 8, txw_max_rte = options.rate * 1000 / 8,
txw_secs = options.recovery_ivl, txw_secs = options.recovery_ivl,
ambient_spm = pgm_msecs (8192), ambient_spm = pgm_secs (30),
heartbeat_spm[] = { pgm_msecs (4), heartbeat_spm[] = { pgm_msecs (100),
pgm_msecs (4), pgm_msecs (100),
pgm_msecs (8), pgm_msecs (100),
pgm_msecs (16), pgm_msecs (100),
pgm_msecs (32), pgm_msecs (1300),
pgm_msecs (64), pgm_secs (7),
pgm_msecs (128), pgm_secs (16),
pgm_msecs (256), pgm_secs (25),
pgm_msecs (512), pgm_secs (30) };
pgm_msecs (1024),
pgm_msecs (2048),
pgm_msecs (4096),
pgm_msecs (8192) };
if (!pgm_setsockopt (sock, IPPROTO_PGM, PGM_SEND_ONLY, &send_only, sizeof (send_only)) || if (!pgm_setsockopt (sock, IPPROTO_PGM, PGM_SEND_ONLY, &send_only, sizeof (send_only)) ||
!pgm_setsockopt (sock, IPPROTO_PGM, PGM_TXW_MAX_RTE, &txw_max_rte, sizeof (txw_max_rte)) || !pgm_setsockopt (sock, IPPROTO_PGM, PGM_TXW_MAX_RTE, &txw_max_rte, sizeof (txw_max_rte)) ||
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment