diff options
| author | Lukáš Ondráček <lukas.ondracek@nic.cz> | 2024-06-10 20:19:10 +0200 |
|---|---|---|
| committer | Lukáš Ondráček <lukas.ondracek@nic.cz> | 2024-06-10 20:19:10 +0200 |
| commit | ca4a97aa6c97e2ae99f320dea56c58a5300da430 (patch) | |
| tree | 7b34b0129e39dfe62ab35319a29f4dbfec1979c4 /daemon/session2.c | |
| parent | defer: extend kru allowing separated reads/updates (diff) | |
| download | knot-resolver-ca4a97aa6c97e2ae99f320dea56c58a5300da430.tar.xz knot-resolver-ca4a97aa6c97e2ae99f320dea56c58a5300da430.zip | |
defer: add new KRU instance and async queues
Diffstat (limited to 'daemon/session2.c')
| -rw-r--r-- | daemon/session2.c | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/daemon/session2.c b/daemon/session2.c index 13f1e52e..39617b0a 100644 --- a/daemon/session2.c +++ b/daemon/session2.c @@ -590,17 +590,13 @@ static int session2_submit( if (!had_comm_param) comm = &session->comm_storage; - // RRL: at this point we might start doing nontrivial work, + // DEFER: at this point we might start doing nontrivial work, // but we may not know the client's IP yet. // Note two cases: incoming session (new request) // vs. outgoing session (resuming work on some request) - if (direction == PROTOLAYER_UNWRAP) { + if (direction == PROTOLAYER_UNWRAP) defer_sample_start(); - // In particular we don't want to miss en/decryption work - // for regular connections from clients. - if (!session->outgoing && session->secure && !proxy_allowed(comm->comm_addr)) - defer_sample_addr((const union kr_sockaddr *)comm->comm_addr); - } + int ret; struct protolayer_iter_ctx *ctx = malloc(session->iter_ctx_size); |