diff options
| author | Masaq- <tilt@techie.com> | 2019-01-28 02:34:32 +0000 |
|---|---|---|
| committer | Masaq- <tilt@techie.com> | 2019-01-28 02:34:32 +0000 |
| commit | 0c249d89747d613ebe3d39a2467c08137349f668 (patch) | |
| tree | 87e98da359f4e76517c34176f5ac39e715769498 /src/pdesc.h | |
| parent | 8a7a9a83ae7b15755cf7c459872670abca4cbd14 (diff) | |
extend the protocol to load options from the data section
Diffstat (limited to 'src/pdesc.h')
| -rw-r--r-- | src/pdesc.h | 11 |
1 files changed, 7 insertions, 4 deletions
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 |