summaryrefslogtreecommitdiffstats
path: root/src/receive.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/receive.c')
-rw-r--r--src/receive.c66
1 files changed, 33 insertions, 33 deletions
diff --git a/src/receive.c b/src/receive.c
index 49f05fe..a8ec1ce 100644
--- a/src/receive.c
+++ b/src/receive.c
@@ -77,57 +77,57 @@ static inline void handle_socket_control(struct msghdr *message, const fastd_soc
}
}
-static bool backoff_unknown(fastd_context_t *ctx, const fastd_peer_address_t *addr) {
+static bool backoff_unknown(const fastd_peer_address_t *addr) {
size_t i;
- for (i = 0; i < array_size(ctx->unknown_handshakes); i++) {
- const fastd_handshake_timeout_t *t = &ctx->unknown_handshakes[(ctx->unknown_handshake_pos + i) % array_size(ctx->unknown_handshakes)];
+ for (i = 0; i < array_size(ctx.unknown_handshakes); i++) {
+ const fastd_handshake_timeout_t *t = &ctx.unknown_handshakes[(ctx.unknown_handshake_pos + i) % array_size(ctx.unknown_handshakes)];
- if (fastd_timed_out(ctx, &t->timeout))
+ if (fastd_timed_out(&t->timeout))
break;
if (fastd_peer_address_equal(addr, &t->address)) {
- pr_debug2(ctx, "sent a handshake to unknown address %I a short time ago, not sending again", addr);
+ pr_debug2("sent a handshake to unknown address %I a short time ago, not sending again", addr);
return true;
}
}
- if (ctx->unknown_handshake_pos == 0)
- ctx->unknown_handshake_pos = array_size(ctx->unknown_handshakes)-1;
+ if (ctx.unknown_handshake_pos == 0)
+ ctx.unknown_handshake_pos = array_size(ctx.unknown_handshakes)-1;
else
- ctx->unknown_handshake_pos--;
+ ctx.unknown_handshake_pos--;
- fastd_handshake_timeout_t *t = &ctx->unknown_handshakes[ctx->unknown_handshake_pos];
+ fastd_handshake_timeout_t *t = &ctx.unknown_handshakes[ctx.unknown_handshake_pos];
t->address = *addr;
- t->timeout = fastd_in_seconds(ctx, conf.min_handshake_interval);
+ t->timeout = fastd_in_seconds(conf.min_handshake_interval);
return false;
}
-static inline void handle_socket_receive_known(fastd_context_t *ctx, fastd_socket_t *sock, const fastd_peer_address_t *local_addr, const fastd_peer_address_t *remote_addr, fastd_peer_t *peer, fastd_buffer_t buffer) {
- if (!fastd_peer_may_connect(ctx, peer)) {
+static inline void handle_socket_receive_known(fastd_socket_t *sock, const fastd_peer_address_t *local_addr, const fastd_peer_address_t *remote_addr, fastd_peer_t *peer, fastd_buffer_t buffer) {
+ if (!fastd_peer_may_connect(peer)) {
fastd_buffer_free(buffer);
return;
}
const uint8_t *packet_type = buffer.data;
- fastd_buffer_push_head(ctx, &buffer, 1);
+ fastd_buffer_push_head(&buffer, 1);
switch (*packet_type) {
case PACKET_DATA:
if (!fastd_peer_is_established(peer) || !fastd_peer_address_equal(&peer->local_address, local_addr)) {
fastd_buffer_free(buffer);
- if (!backoff_unknown(ctx, remote_addr))
- conf.protocol->handshake_init(ctx, sock, local_addr, remote_addr, NULL);
+ if (!backoff_unknown(remote_addr))
+ conf.protocol->handshake_init(sock, local_addr, remote_addr, NULL);
return;
}
- conf.protocol->handle_recv(ctx, peer, buffer);
+ conf.protocol->handle_recv(peer, buffer);
break;
case PACKET_HANDSHAKE:
- fastd_handshake_handle(ctx, sock, local_addr, remote_addr, peer, buffer);
+ fastd_handshake_handle(sock, local_addr, remote_addr, peer, buffer);
}
}
@@ -135,24 +135,24 @@ static inline bool allow_unknown_peers(void) {
return conf.has_floating || fastd_shell_command_isset(&conf.on_verify);
}
-static inline void handle_socket_receive_unknown(fastd_context_t *ctx, fastd_socket_t *sock, const fastd_peer_address_t *local_addr, const fastd_peer_address_t *remote_addr, fastd_buffer_t buffer) {
+static inline void handle_socket_receive_unknown(fastd_socket_t *sock, const fastd_peer_address_t *local_addr, const fastd_peer_address_t *remote_addr, fastd_buffer_t buffer) {
const uint8_t *packet_type = buffer.data;
- fastd_buffer_push_head(ctx, &buffer, 1);
+ fastd_buffer_push_head(&buffer, 1);
switch (*packet_type) {
case PACKET_DATA:
fastd_buffer_free(buffer);
- if (!backoff_unknown(ctx, remote_addr))
- conf.protocol->handshake_init(ctx, sock, local_addr, remote_addr, NULL);
+ if (!backoff_unknown(remote_addr))
+ conf.protocol->handshake_init(sock, local_addr, remote_addr, NULL);
break;
case PACKET_HANDSHAKE:
- fastd_handshake_handle(ctx, sock, local_addr, remote_addr, NULL, buffer);
+ fastd_handshake_handle(sock, local_addr, remote_addr, NULL, buffer);
}
}
-static inline void handle_socket_receive(fastd_context_t *ctx, fastd_socket_t *sock, const fastd_peer_address_t *local_addr, const fastd_peer_address_t *remote_addr, fastd_buffer_t buffer) {
+static inline void handle_socket_receive(fastd_socket_t *sock, const fastd_peer_address_t *local_addr, const fastd_peer_address_t *remote_addr, fastd_buffer_t buffer) {
fastd_peer_t *peer = NULL;
if (sock->peer) {
@@ -164,24 +164,24 @@ static inline void handle_socket_receive(fastd_context_t *ctx, fastd_socket_t *s
peer = sock->peer;
}
else {
- peer = fastd_peer_hashtable_lookup(ctx, remote_addr);
+ peer = fastd_peer_hashtable_lookup(remote_addr);
}
if (peer) {
- handle_socket_receive_known(ctx, sock, local_addr, remote_addr, peer, buffer);
+ handle_socket_receive_known(sock, local_addr, remote_addr, peer, buffer);
}
else if (allow_unknown_peers()) {
- handle_socket_receive_unknown(ctx, sock, local_addr, remote_addr, buffer);
+ handle_socket_receive_unknown(sock, local_addr, remote_addr, buffer);
}
else {
- pr_debug(ctx, "received packet from unknown peer %I", remote_addr);
+ pr_debug("received packet from unknown peer %I", remote_addr);
fastd_buffer_free(buffer);
}
}
-void fastd_receive(fastd_context_t *ctx, fastd_socket_t *sock) {
- size_t max_len = fastd_max_outer_packet(ctx);
- fastd_buffer_t buffer = fastd_buffer_alloc(ctx, max_len, conf.min_decrypt_head_space, conf.min_decrypt_tail_space);
+void fastd_receive(fastd_socket_t *sock) {
+ size_t max_len = fastd_max_outer_packet();
+ fastd_buffer_t buffer = fastd_buffer_alloc(max_len, conf.min_decrypt_head_space, conf.min_decrypt_tail_space);
fastd_peer_address_t local_addr;
fastd_peer_address_t recvaddr;
struct iovec buffer_vec = { .iov_base = buffer.data, .iov_len = buffer.len };
@@ -199,7 +199,7 @@ void fastd_receive(fastd_context_t *ctx, fastd_socket_t *sock) {
ssize_t len = recvmsg(sock->fd, &message, 0);
if (len <= 0) {
if (len < 0 && errno != EINTR)
- pr_warn_errno(ctx, "recvmsg");
+ pr_warn_errno("recvmsg");
fastd_buffer_free(buffer);
return;
@@ -211,7 +211,7 @@ void fastd_receive(fastd_context_t *ctx, fastd_socket_t *sock) {
#ifdef USE_PKTINFO
if (!local_addr.sa.sa_family) {
- pr_error(ctx, "received packet without packet info");
+ pr_error("received packet without packet info");
fastd_buffer_free(buffer);
return;
}
@@ -219,5 +219,5 @@ void fastd_receive(fastd_context_t *ctx, fastd_socket_t *sock) {
fastd_peer_address_simplify(&recvaddr);
- handle_socket_receive(ctx, sock, &local_addr, &recvaddr, buffer);
+ handle_socket_receive(sock, &local_addr, &recvaddr, buffer);
}