diff options
| author | Matthias Schiffer <mschiffer@universe-factory.net> | 2012-04-14 16:59:54 +0200 |
|---|---|---|
| committer | Matthias Schiffer <mschiffer@universe-factory.net> | 2012-04-14 16:59:54 +0200 |
| commit | b9054051b9bf232968dc52b4732a65381c6a0e5f (patch) | |
| tree | 9c9eaf61dbde5a48f09e097ab8ee4ecad37e06e0 /src/protocol_ec25519_fhmqvc.c | |
| parent | 74f2d0357f87a231e3782d3d8bd21853fb3524b2 (diff) | |
| download | fastd-b9054051b9bf232968dc52b4732a65381c6a0e5f.tar fastd-b9054051b9bf232968dc52b4732a65381c6a0e5f.zip | |
Reduce task queue usage
Diffstat (limited to 'src/protocol_ec25519_fhmqvc.c')
| -rw-r--r-- | src/protocol_ec25519_fhmqvc.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/protocol_ec25519_fhmqvc.c b/src/protocol_ec25519_fhmqvc.c index 3168d03..b4dab07 100644 --- a/src/protocol_ec25519_fhmqvc.c +++ b/src/protocol_ec25519_fhmqvc.c @@ -242,7 +242,7 @@ static void protocol_handshake_init(fastd_context *ctx, fastd_peer *peer) { fastd_handshake_add(ctx, &buffer, RECORD_SENDER_HANDSHAKE_KEY, PUBLICKEYBYTES, handshake->public_key.p); - fastd_task_put_send_handshake(ctx, peer, buffer); + fastd_send_handshake(ctx, peer, buffer); } static inline bool has_field(const fastd_handshake *handshake, uint8_t type, size_t length) { @@ -303,7 +303,7 @@ static void respond_handshake(fastd_context *ctx, fastd_peer *peer, const fastd_ fastd_handshake_add(ctx, &buffer, RECORD_RECEIPIENT_HANDSHAKE_KEY, PUBLICKEYBYTES, peer->protocol_state->accepting_handshake->peer_key.p); fastd_handshake_add(ctx, &buffer, RECORD_T, HMACBYTES, hmacbuf); - fastd_task_put_send_handshake(ctx, peer, buffer); + fastd_send_handshake(ctx, peer, buffer); peer->protocol_state->accepting_handshake->state = HANDSHAKE_STATE_RESPONSE; } @@ -423,7 +423,7 @@ static void finish_handshake(fastd_context *ctx, fastd_peer *peer, const fastd_h fastd_handshake_add(ctx, &buffer, RECORD_RECEIPIENT_HANDSHAKE_KEY, PUBLICKEYBYTES, peer->protocol_state->initiating_handshake->peer_key.p); fastd_handshake_add(ctx, &buffer, RECORD_T, HMACBYTES, hmacbuf); - fastd_task_put_send_handshake(ctx, peer, buffer); + fastd_send_handshake(ctx, peer, buffer); establish(ctx, peer, peer->protocol_state->initiating_handshake->peer_config, true, &peer->protocol_state->initiating_handshake->public_key, @@ -650,7 +650,7 @@ static void protocol_handle_recv(fastd_context *ctx, fastd_peer *peer, fastd_buf fastd_peer_seen(ctx, peer); if (recv_buffer.len) - fastd_task_put_handle_recv(ctx, peer, recv_buffer); + fastd_handle_receive(ctx, peer, recv_buffer); else fastd_buffer_free(recv_buffer); @@ -679,7 +679,7 @@ static void protocol_send(fastd_context *ctx, fastd_peer *peer, fastd_buffer buf if (!ctx->conf->method->encrypt(ctx, session->method_state, &send_buffer, buffer)) goto fail; - fastd_task_put_send(ctx, peer, send_buffer); + fastd_send(ctx, peer, send_buffer); fastd_task_delete_peer_keepalives(ctx, peer); fastd_task_schedule_keepalive(ctx, peer, ctx->conf->keepalive_interval*1000); |