From 0c249d89747d613ebe3d39a2467c08137349f668 Mon Sep 17 00:00:00 2001
From: Masaq- <tilt@techie.com>
Date: Mon, 28 Jan 2019 02:34:32 +0000
Subject: extend the protocol to load options from the data section

---
 src/pdesc.h | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

(limited to 'src/pdesc.h')

diff --git a/src/pdesc.h b/src/pdesc.h
index d0767aa..e8180fd 100644
--- a/src/pdesc.h
+++ b/src/pdesc.h
@@ -156,8 +156,11 @@ typedef struct proxy_desc_t {
 	double last_ack;
 	/** Time when a packet was last received. */
 	double last_activity;
-    icmp_desc_t send_ring[kPing_window_size];
-    forward_desc_t *recv_ring[kPing_window_size];
+	uint16_t window_size;
+	double ack_interval;
+	double resend_interval;
+    icmp_desc_t *send_ring;
+    forward_desc_t **recv_ring;
     xfer_stats_t xfer;
     struct proxy_desc_t *next;
 } proxy_desc_t;
@@ -176,8 +179,8 @@ int             queue_packet(int icmp_sock, uint8_t type, char *buf, int num_byt
                              uint16_t id_no, uint16_t icmp_id, uint16_t *seq, icmp_desc_t ring[],
                              int *insert_idx, int *await_send, uint32_t ip, uint32_t port,
                              uint32_t state, struct sockaddr_in *dest_addr, uint16_t next_expected_seq,
-                             int *first_ack, uint16_t *ping_seq);
+                             int *first_ack, uint16_t *ping_seq, uint16_t window_size);
 
-uint32_t        send_packets(forward_desc_t *ring[], int *xfer_idx, int *await_send, int *sock);
+uint32_t        send_packets(forward_desc_t *ring[], int *xfer_idx, int *await_send, int *sock, uint16_t window_size);
 
 #endif
-- 
cgit v1.2.3