summaryrefslogtreecommitdiff
path: root/code/test/stress.c
diff options
context:
space:
mode:
authorUros Majstorovic <majstor@majstor.org>2017-09-06 18:19:00 +0200
committerUros Majstorovic <majstor@majstor.org>2017-09-06 18:19:00 +0200
commitc129b10bf7c851d94002767aa09e06c526cacb7d (patch)
treea0ca2c8d603a233c43c888dddb4ee541d4ba34e5 /code/test/stress.c
parentb83e58e21ea7dda57ddfda47bd1539d15abe687f (diff)
frad/defrag implemented
Diffstat (limited to 'code/test/stress.c')
-rw-r--r--code/test/stress.c6
1 files changed, 3 insertions, 3 deletions
diff --git a/code/test/stress.c b/code/test/stress.c
index d1ead1d..0e46f84 100644
--- a/code/test/stress.c
+++ b/code/test/stress.c
@@ -86,7 +86,7 @@ void *sender(ECPConnection *c) {
usleep(rnd % (2000000/msg_rate));
ecp_pld_set_type(payload, MTYPE_MSG);
- ssize_t _rv = ecp_send(c, payload, sizeof(payload));
+ ssize_t _rv = ecp_pld_send(c, payload, sizeof(payload));
if (c_start && (_rv > 0)) {
pthread_mutex_lock(&t_mtx[idx]);
t_sent[idx]++;
@@ -121,14 +121,14 @@ ssize_t handle_msg_c(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigne
}
// ecp_pld_set_type(payload, MTYPE_MSG);
- // ssize_t _rv = ecp_send(c, payload, sizeof(payload));
+ // ssize_t _rv = ecp_pld_send(c, payload, sizeof(payload));
return s;
}
ssize_t handle_msg_s(ECPConnection *conn, ecp_seq_t sq, unsigned char t, unsigned char *p, ssize_t s) {
unsigned char payload[ECP_SIZE_PLD(1000, 0)];
ecp_pld_set_type(payload, MTYPE_MSG);
- ssize_t _rv = ecp_send(conn, payload, sizeof(payload));
+ ssize_t _rv = ecp_pld_send(conn, payload, sizeof(payload));
return s;
}