ReactOS  0.4.15-dev-1070-ge1a01de
tcp_helper.h File Reference
#include "../lwip_check.h"
#include "lwip/arch.h"
#include "lwip/tcp.h"
#include "lwip/netif.h"
Include dependency graph for tcp_helper.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes

struct  test_tcp_counters
 
struct  test_tcp_txcounters
 

Functions

void tcp_remove_all (void)
 
struct pbuftcp_create_segment (ip_addr_t *src_ip, ip_addr_t *dst_ip, u16_t src_port, u16_t dst_port, void *data, size_t data_len, u32_t seqno, u32_t ackno, u8_t headerflags)
 
struct pbuftcp_create_rx_segment (struct tcp_pcb *pcb, void *data, size_t data_len, u32_t seqno_offset, u32_t ackno_offset, u8_t headerflags)
 
struct pbuftcp_create_rx_segment_wnd (struct tcp_pcb *pcb, void *data, size_t data_len, u32_t seqno_offset, u32_t ackno_offset, u8_t headerflags, u16_t wnd)
 
void tcp_set_state (struct tcp_pcb *pcb, enum tcp_state state, ip_addr_t *local_ip, ip_addr_t *remote_ip, u16_t local_port, u16_t remote_port)
 
void test_tcp_counters_err (void *arg, err_t err)
 
err_t test_tcp_counters_recv (void *arg, struct tcp_pcb *pcb, struct pbuf *p, err_t err)
 
struct tcp_pcb * test_tcp_new_counters_pcb (struct test_tcp_counters *counters)
 
void test_tcp_input (struct pbuf *p, struct netif *inp)
 
void test_tcp_init_netif (struct netif *netif, struct test_tcp_txcounters *txcounters, ip_addr_t *ip_addr, ip_addr_t *netmask)
 

Function Documentation

◆ tcp_create_rx_segment()

struct pbuf* tcp_create_rx_segment ( struct tcp_pcb *  pcb,
void data,
size_t  data_len,
u32_t  seqno_offset,
u32_t  ackno_offset,
u8_t  headerflags 
)

Create a TCP segment usable for passing to tcp_input

  • IP-addresses, ports, seqno and ackno are taken from pcb
  • seqno and ackno can be altered with an offset

Definition at line 118 of file tcp_helper.c.

120 {
121  return tcp_create_segment(&pcb->remote_ip, &pcb->local_ip, pcb->remote_port, pcb->local_port,
122  data, data_len, pcb->rcv_nxt + seqno_offset, pcb->lastack + ackno_offset, headerflags);
123 }
struct pbuf * tcp_create_segment(ip_addr_t *src_ip, ip_addr_t *dst_ip, u16_t src_port, u16_t dst_port, void *data, size_t data_len, u32_t seqno, u32_t ackno, u8_t headerflags)
Definition: tcp_helper.c:105
GLint GLenum GLsizei GLsizei GLsizei GLint GLsizei const GLvoid * data
Definition: gl.h:1950

Referenced by START_TEST(), test_tcp_recv_ooseq_double_FINs(), and test_tcp_tx_full_window_lost().

◆ tcp_create_rx_segment_wnd()

struct pbuf* tcp_create_rx_segment_wnd ( struct tcp_pcb *  pcb,
void data,
size_t  data_len,
u32_t  seqno_offset,
u32_t  ackno_offset,
u8_t  headerflags,
u16_t  wnd 
)

Create a TCP segment usable for passing to tcp_input

  • IP-addresses, ports, seqno and ackno are taken from pcb
  • seqno and ackno can be altered with an offset
  • TCP window can be adjusted

Definition at line 130 of file tcp_helper.c.

132 {
133  return tcp_create_segment_wnd(&pcb->remote_ip, &pcb->local_ip, pcb->remote_port, pcb->local_port,
134  data, data_len, pcb->rcv_nxt + seqno_offset, pcb->lastack + ackno_offset, headerflags, wnd);
135 }
GLint GLenum GLsizei GLsizei GLsizei GLint GLsizei const GLvoid * data
Definition: gl.h:1950
static struct pbuf * tcp_create_segment_wnd(ip_addr_t *src_ip, ip_addr_t *dst_ip, u16_t src_port, u16_t dst_port, void *data, size_t data_len, u32_t seqno, u32_t ackno, u8_t headerflags, u16_t wnd)
Definition: tcp_helper.c:41

Referenced by test_tcp_tx_full_window_lost().

◆ tcp_create_segment()

struct pbuf* tcp_create_segment ( ip_addr_t src_ip,
ip_addr_t dst_ip,
u16_t  src_port,
u16_t  dst_port,
void data,
size_t  data_len,
u32_t  seqno,
u32_t  ackno,
u8_t  headerflags 
)

Create a TCP segment usable for passing to tcp_input

Definition at line 105 of file tcp_helper.c.

108 {
109  return tcp_create_segment_wnd(src_ip, dst_ip, src_port, dst_port, data,
110  data_len, seqno, ackno, headerflags, TCP_WND);
111 }
#define TCP_WND
Definition: opt.h:923
GLint GLenum GLsizei GLsizei GLsizei GLint GLsizei const GLvoid * data
Definition: gl.h:1950
static struct pbuf * tcp_create_segment_wnd(ip_addr_t *src_ip, ip_addr_t *dst_ip, u16_t src_port, u16_t dst_port, void *data, size_t data_len, u32_t seqno, u32_t ackno, u8_t headerflags, u16_t wnd)
Definition: tcp_helper.c:41

Referenced by tcp_create_rx_segment().

◆ tcp_remove_all()

void tcp_remove_all ( void  )

Remove all pcbs on listen-, active- and time-wait-list (bound- isn't exported).

Definition at line 28 of file tcp_helper.c.

29 {
30  tcp_remove(tcp_listen_pcbs.pcbs);
31  tcp_remove(tcp_active_pcbs);
32  tcp_remove(tcp_tw_pcbs);
33  fail_unless(lwip_stats.memp[MEMP_TCP_PCB].used == 0);
34  fail_unless(lwip_stats.memp[MEMP_TCP_PCB_LISTEN].used == 0);
35  fail_unless(lwip_stats.memp[MEMP_TCP_SEG].used == 0);
36  fail_unless(lwip_stats.memp[MEMP_PBUF_POOL].used == 0);
37 }
static void tcp_remove(struct tcp_pcb *pcb_list)
Definition: tcp_helper.c:14

Referenced by tcp_oos_setup(), tcp_oos_teardown(), tcp_setup(), and tcp_teardown().

◆ tcp_set_state()

void tcp_set_state ( struct tcp_pcb *  pcb,
enum tcp_state  state,
ip_addr_t local_ip,
ip_addr_t remote_ip,
u16_t  local_port,
u16_t  remote_port 
)

Safely bring a tcp_pcb into the requested state

Definition at line 139 of file tcp_helper.c.

141 {
142  /* @todo: are these all states? */
143  /* @todo: remove from previous list */
144  pcb->state = state;
145  if (state == ESTABLISHED) {
146  TCP_REG(&tcp_active_pcbs, pcb);
147  pcb->local_ip.addr = local_ip->addr;
148  pcb->local_port = local_port;
149  pcb->remote_ip.addr = remote_ip->addr;
150  pcb->remote_port = remote_port;
151  } else if(state == LISTEN) {
152  TCP_REG(&tcp_listen_pcbs.pcbs, pcb);
153  pcb->local_ip.addr = local_ip->addr;
154  pcb->local_port = local_port;
155  } else if(state == TIME_WAIT) {
156  TCP_REG(&tcp_tw_pcbs, pcb);
157  pcb->local_ip.addr = local_ip->addr;
158  pcb->local_port = local_port;
159  pcb->remote_ip.addr = remote_ip->addr;
160  pcb->remote_port = remote_port;
161  } else {
162  fail();
163  }
164 }
static int state
Definition: maze.c:121

◆ test_tcp_counters_err()

void test_tcp_counters_err ( void arg,
err_t  err 
)

Definition at line 167 of file tcp_helper.c.

168 {
169  struct test_tcp_counters* counters = arg;
170  EXPECT_RET(arg != NULL);
171  counters->err_calls++;
172  counters->last_err = err;
173 }
GLint GLint GLsizei GLuint * counters
Definition: glext.h:11114
void * arg
Definition: msvc.h:10
#define EXPECT_RET(x)
Definition: lwip_check.h:12
smooth NULL
Definition: ftsmooth.c:416
#define err(...)

Referenced by test_tcp_new_counters_pcb().

◆ test_tcp_counters_recv()

err_t test_tcp_counters_recv ( void arg,
struct tcp_pcb *  pcb,
struct pbuf p,
err_t  err 
)

Definition at line 197 of file tcp_helper.c.

198 {
199  struct test_tcp_counters* counters = arg;
200  EXPECT_RETX(arg != NULL, ERR_OK);
201  EXPECT_RETX(pcb != NULL, ERR_OK);
203 
204  if (p != NULL) {
205  if (counters->close_calls == 0) {
206  counters->recv_calls++;
208  counters->recved_bytes += p->tot_len;
209  } else {
210  counters->recv_calls_after_close++;
211  counters->recved_bytes_after_close += p->tot_len;
212  }
213  pbuf_free(p);
214  } else {
215  counters->close_calls++;
216  }
217  EXPECT(counters->recv_calls_after_close == 0 && counters->recved_bytes_after_close == 0);
218  return ERR_OK;
219 }
GLint GLint GLsizei GLuint * counters
Definition: glext.h:11114
void * arg
Definition: msvc.h:10
smooth NULL
Definition: ftsmooth.c:416
u8_t pbuf_free(struct pbuf *p)
Definition: pbuf.c:618
#define ERR_OK
Definition: err.h:52
#define err(...)
static void test_tcp_counters_check_rxdata(struct test_tcp_counters *counters, struct pbuf *p)
Definition: tcp_helper.c:176
#define EXPECT(a, b, c, d, e, f)
Definition: vartest.c:1303
GLfloat GLfloat p
Definition: glext.h:8902
#define EXPECT_RETX(x, y)
Definition: lwip_check.h:13

Referenced by test_tcp_new_counters_pcb().

◆ test_tcp_init_netif()

void test_tcp_init_netif ( struct netif netif,
struct test_tcp_txcounters txcounters,
ip_addr_t ip_addr,
ip_addr_t netmask 
)

Definition at line 283 of file tcp_helper.c.

285 {
286  struct netif *n;
287  memset(netif, 0, sizeof(struct netif));
288  if (txcounters != NULL) {
289  memset(txcounters, 0, sizeof(struct test_tcp_txcounters));
290  netif->state = txcounters;
291  }
296  for (n = netif_list; n != NULL; n = n->next) {
297  if (n == netif) {
298  return;
299  }
300  }
301  netif->next = NULL;
302  netif_list = netif;
303 }
struct netif * netif_list
Definition: netif.c:75
#define ip_addr_copy(dest, src)
Definition: ip_addr.h:162
#define NETIF_FLAG_UP
Definition: netif.h:69
GLdouble n
Definition: glext.h:7729
netif_output_fn output
Definition: netif.h:151
static err_t test_tcp_netif_output(struct netif *netif, struct pbuf *p, ip_addr_t *ipaddr)
Definition: tcp_helper.c:258
smooth NULL
Definition: ftsmooth.c:416
struct netif * next
Definition: netif.h:138
u8_t flags
Definition: netif.h:192
Definition: netif.h:136
ip_addr_t ip_addr
Definition: netif.h:141
void * state
Definition: netif.h:172
ip_addr_t netmask
Definition: netif.h:142
#define memset(x, y, z)
Definition: compat.h:39

Referenced by START_TEST(), test_tcp_recv_ooseq_double_FINs(), and test_tcp_tx_full_window_lost().

◆ test_tcp_input()

void test_tcp_input ( struct pbuf p,
struct netif inp 
)

Calls tcp_input() after adjusting current_iphdr_dest

Definition at line 238 of file tcp_helper.c.

239 {
240  struct ip_hdr *iphdr = (struct ip_hdr*)p->payload;
241  /* these lines are a hack, don't use them as an example :-) */
242  ip_addr_copy(*ipX_current_dest_addr(), iphdr->dest);
243  ip_addr_copy(*ipX_current_src_addr(), iphdr->src);
244  ip_current_netif() = inp;
245  ip_current_header() = iphdr;
246 
247  /* since adding IPv6, p->payload must point to tcp header, not ip header */
248  pbuf_header(p, -(s16_t)sizeof(struct ip_hdr));
249 
250  tcp_input(p, inp);
251 
252  ipX_current_dest_addr()->addr = 0;
253  ipX_current_src_addr()->addr = 0;
256 }
#define ip_addr_copy(dest, src)
Definition: ip_addr.h:162
#define ip_current_netif()
Definition: ip.h:194
u8_t pbuf_header(struct pbuf *p, s16_t header_size_increment)
Definition: pbuf.c:511
smooth NULL
Definition: ftsmooth.c:416
#define ip_current_header()
Definition: ip.h:198
struct ip_addr src dest
Definition: ip.h:96
Definition: ip.h:116
GLfloat GLfloat p
Definition: glext.h:8902
signed short s16_t
Definition: cc.h:29

Referenced by START_TEST(), test_tcp_recv_ooseq_double_FINs(), and test_tcp_tx_full_window_lost().

◆ test_tcp_new_counters_pcb()

struct tcp_pcb* test_tcp_new_counters_pcb ( struct test_tcp_counters counters)

Allocate a pcb and set up the test_tcp_counters_* callbacks

Definition at line 223 of file tcp_helper.c.

224 {
225  struct tcp_pcb* pcb = tcp_new();
226  if (pcb != NULL) {
227  /* set up args and callbacks */
228  tcp_arg(pcb, counters);
230  tcp_err(pcb, test_tcp_counters_err);
231  pcb->snd_wnd = TCP_WND;
232  pcb->snd_wnd_max = TCP_WND;
233  }
234  return pcb;
235 }
STREAM tcp_recv(STREAM s, uint32 length)
Definition: tcp.c:344
void test_tcp_counters_err(void *arg, err_t err)
Definition: tcp_helper.c:167
GLint GLint GLsizei GLuint * counters
Definition: glext.h:11114
#define TCP_WND
Definition: opt.h:923
smooth NULL
Definition: ftsmooth.c:416
err_t test_tcp_counters_recv(void *arg, struct tcp_pcb *pcb, struct pbuf *p, err_t err)
Definition: tcp_helper.c:197

Referenced by START_TEST(), test_tcp_recv_ooseq_double_FINs(), and test_tcp_tx_full_window_lost().