Skip to content
This repository was archived by the owner on Oct 8, 2025. It is now read-only.

Commit 25909c6

Browse files
ac000ac000
committed
** DEBUG DO NOT MERGE **
1 parent d51308f commit 25909c6

File tree

8 files changed

+120
-0
lines changed

8 files changed

+120
-0
lines changed

‎src/nxt_brotli.c‎

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,10 @@
22
*
33
*/
44

5+
#define _GNU_SOURCE
6+
#include <unistd.h>
7+
8+
59
#include <stddef.h>
610
#include <stdint.h>
711
#include <stdbool.h>
@@ -18,6 +22,9 @@ nxt_brotli_init(nxt_http_comp_compressor_ctx_t *ctx)
1822

1923
*brotli = BrotliEncoderCreateInstance(NULL, NULL, NULL);
2024
BrotliEncoderSetParameter(*brotli, BROTLI_PARAM_QUALITY, ctx->level);
25+
26+
printf("%7d %s: brotli compression level [%d]\n", gettid(), __func__,
27+
ctx->level);
2128
}
2229

2330

@@ -36,6 +43,10 @@ nxt_brotli_compress(nxt_http_comp_compressor_ctx_t *ctx, const uint8_t *in_buf,
3643
size_t out_bytes = out_len;
3744
BrotliEncoderState *brotli = ctx->brotli_ctx;
3845

46+
printf("%7d %s: last/%s\n", gettid(), __func__, last ? "true" : "false");
47+
printf("%7d %s: in_len [%lu] out_len [%lu]\n", gettid(), __func__,
48+
in_len, out_len);
49+
3950
ok = BrotliEncoderCompressStream(brotli, BROTLI_OPERATION_PROCESS,
4051
&in_len, &in_buf, &out_bytes, &out_buf,
4152
NULL);
@@ -44,13 +55,18 @@ nxt_brotli_compress(nxt_http_comp_compressor_ctx_t *ctx, const uint8_t *in_buf,
4455
&in_len, &in_buf, &out_bytes, &out_buf,
4556
NULL);
4657

58+
printf("%7d %s: in_len [%lu] out_len [%lu] out_bytes [%lu]\n", gettid(),
59+
__func__, in_len, out_len, out_bytes);
4760
if (last) {
4861
ok = BrotliEncoderCompressStream(brotli, BROTLI_OPERATION_FINISH,
4962
&in_len, &in_buf, &out_bytes,
5063
&out_buf, NULL);
5164
BrotliEncoderDestroyInstance(brotli);
5265
}
5366

67+
printf("%7d %s: in_len [%lu] out_len [%lu] out_bytes [%lu]\n", gettid(),
68+
__func__, in_len, out_len, out_bytes);
69+
5470
return out_len - out_bytes;
5571
}
5672

‎src/nxt_http_compression.c‎

Lines changed: 76 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -136,6 +136,26 @@ static const nxt_http_comp_type_t nxt_http_comp_compressors[] = {
136136
};
137137

138138

139+
static void print_compressor(const nxt_http_comp_compressor_t *c)
140+
{
141+
printf("token : %s\n", c->type->token.start);
142+
printf("scheme : %d\n", c->type->scheme);
143+
printf("level : %d\n", c->opts.level);
144+
printf("min_len : %ld\n", c->opts.min_len);
145+
}
146+
147+
static void print_comp_config(size_t n)
148+
{
149+
for (size_t i = 0; i < n; i++) {
150+
nxt_http_comp_compressor_t *compr =
151+
nxt_http_comp_enabled_compressors + i;
152+
153+
print_compressor(compr);
154+
printf("\n");
155+
}
156+
}
157+
158+
139159
static ssize_t
140160
nxt_http_comp_compress(uint8_t *dst, size_t dst_size, const uint8_t *src,
141161
size_t src_size, bool last)
@@ -175,7 +195,11 @@ nxt_http_comp_compress_app_response(nxt_http_request_t *r, nxt_buf_t **b)
175195
// nxt_buf_t *buf;
176196
nxt_http_comp_ctx_t *ctx = nxt_http_comp_ctx();
177197

198+
printf("%s: \n", __func__);
199+
178200
if (ctx->idx == NXT_HTTP_COMP_SCHEME_IDENTITY) {
201+
printf("%s: NXT_HTTP_COMP_SCHEME_IDENTITY [skipping/identity]\n",
202+
__func__);
179203
return NXT_OK;
180204
}
181205

@@ -188,14 +212,19 @@ nxt_http_comp_compress_app_response(nxt_http_request_t *r, nxt_buf_t **b)
188212
in_len = (*b)->mem.free - (*b)->mem.pos;
189213
buf_len = nxt_http_comp_bound(in_len);
190214

215+
printf("%s: in_len [%lu] buf_len [%lu] last [%s]\n", __func__,
216+
in_len, buf_len, last ? "true" : "false");
217+
191218
#if 1
192219
if (buf_len > (size_t)nxt_buf_mem_size(&(*b)->mem)) {
220+
/* XXX Un-skip Content-Length header, or not... */
193221
return NXT_OK;
194222
}
195223

196224
uint8_t *buf = nxt_malloc(buf_len);
197225

198226
cbytes = nxt_http_comp_compress(buf, buf_len, (*b)->mem.pos, in_len, last);
227+
printf("%s: cbytes = %ld\n", __func__, cbytes);
199228
if (cbytes == -1) {
200229
nxt_free(buf);
201230
return NXT_ERROR;
@@ -310,8 +339,12 @@ nxt_http_comp_compress_static_response(nxt_task_t *task, nxt_file_t **f,
310339

311340
last = n == rest;
312341

342+
printf("%s: out_off [%ld] in_off [%ld] last [%s]\n",
343+
__func__, *out_total, in_size - rest, last ? "true" : "false");
344+
313345
cbytes = nxt_http_comp_compress(out + *out_total, out_size - *out_total,
314346
in + in_size - rest, n, last);
347+
printf("%s: cbytes [%ld]\n", __func__, cbytes);
315348

316349
*out_total += cbytes;
317350
rest -= n;
@@ -342,6 +375,7 @@ nxt_http_comp_wants_compression(void)
342375
{
343376
nxt_http_comp_ctx_t *ctx = nxt_http_comp_ctx();
344377

378+
printf("%s: compression [%s]\n", __func__, ctx->idx > 0 ? "true" : "false");
345379
return ctx->idx;
346380
}
347381

@@ -432,6 +466,9 @@ nxt_http_comp_select_compressor(nxt_http_request_t *r, const nxt_str_t *token)
432466

433467
scheme = nxt_http_comp_enabled_compressors[ecidx].type->scheme;
434468

469+
printf("%s: %.*s [%f] [%d:%d]\n", __func__, (int)enc.length, enc.start,
470+
qval, ecidx, scheme);
471+
435472
if (qval == 0.0 && scheme == NXT_HTTP_COMP_SCHEME_IDENTITY) {
436473
identity_allowed = false;
437474
}
@@ -444,6 +481,12 @@ nxt_http_comp_select_compressor(nxt_http_request_t *r, const nxt_str_t *token)
444481
weight = qval;
445482
}
446483

484+
printf("%s: Selected compressor : %s\n", __func__,
485+
nxt_http_comp_enabled_compressors[idx].type->token.start);
486+
487+
printf("%s: idx [%u], identity_allowed [%s]\n", __func__, idx,
488+
identity_allowed ? "true" : "false");
489+
447490
if (idx == NXT_HTTP_COMP_SCHEME_IDENTITY && !identity_allowed) {
448491
return -1;
449492
}
@@ -461,6 +504,14 @@ nxt_http_comp_set_header(nxt_http_request_t *r, nxt_uint_t comp_idx)
461504
static const nxt_str_t content_encoding_str =
462505
nxt_string("Content-Encoding");
463506

507+
printf("%s: \n", __func__);
508+
509+
#if 0
510+
if (comp_idx == NXT_HTTP_COMP_SCHEME_IDENTITY) {
511+
return NXT_OK;
512+
}
513+
#endif
514+
464515
f = nxt_list_add(r->resp.fields);
465516
if (nxt_slow_path(f == NULL)) {
466517
return NXT_ERROR;
@@ -489,6 +540,8 @@ nxt_http_comp_set_header(nxt_http_request_t *r, nxt_uint_t comp_idx)
489540
if (nxt_strcasecmp(f->name,
490541
(const u_char *)"Content-Length") == 0)
491542
{
543+
printf("%s: Found (%s: %s), marking as 'skip'\n", __func__,
544+
f->name, f->value);
492545
f->skip = true;
493546
break;
494547
}
@@ -504,7 +557,11 @@ nxt_http_comp_is_resp_content_encoded(const nxt_http_request_t *r)
504557
{
505558
nxt_http_field_t *f;
506559

560+
printf("%s: \n", __func__);
561+
507562
nxt_list_each(f, r->resp.fields) {
563+
printf("%s: %.*s: %.*s\n", __func__, f->name_length, f->name,
564+
f->value_length, f->value);
508565
if (nxt_strcasecmp(f->name, (const u_char *)"Content-Encoding") == 0) {
509566
return true;
510567
}
@@ -524,6 +581,8 @@ nxt_http_comp_check_compression(nxt_task_t *task, nxt_http_request_t *r)
524581
nxt_http_comp_ctx_t *ctx = nxt_http_comp_ctx();
525582
nxt_http_comp_compressor_t *compressor;
526583

584+
printf("%s: \n", __func__);
585+
527586
*ctx = (nxt_http_comp_ctx_t){ .resp_clen = -1 };
528587

529588
if (nxt_http_comp_nr_enabled_compressors == 0) {
@@ -545,10 +604,15 @@ nxt_http_comp_check_compression(nxt_task_t *task, nxt_http_request_t *r)
545604
return NXT_OK;
546605
}
547606

607+
printf("%s: Response Content-Type [%.*s]\n", __func__,
608+
(int)mime_type.length, mime_type.start);
609+
548610
if (nxt_http_comp_mime_types_rule != NULL) {
549611
ret = nxt_http_route_test_rule(r, nxt_http_comp_mime_types_rule,
550612
mime_type.start,
551613
mime_type.length);
614+
printf("%s: mime_type : %d (%.*s)\n", __func__, ret,
615+
(int)mime_type.length, mime_type.start);
552616
if (ret == 0) {
553617
return NXT_OK;
554618
}
@@ -597,7 +661,11 @@ nxt_http_comp_check_compression(nxt_task_t *task, nxt_http_request_t *r)
597661

598662
min_len = compressor->opts.min_len;
599663

664+
printf("%s: content_length [%ld] min_len [%ld]\n", __func__,
665+
ctx->resp_clen, min_len);
600666
if (ctx->resp_clen > -1 && ctx->resp_clen < min_len) {
667+
printf("%s: %ld < %ld [skipping/clen]\n", __func__,
668+
ctx->resp_clen, min_len);
601669
return NXT_OK;
602670
}
603671

@@ -651,6 +719,8 @@ nxt_http_comp_set_compressor(nxt_task_t *task, nxt_router_conf_t *rtcf,
651719

652720
static const nxt_str_t token_str = nxt_string("encoding");
653721

722+
printf("%s: \n", __func__);
723+
654724
obj = nxt_conf_get_object_member(comp, &token_str, NULL);
655725
if (obj == NULL) {
656726
return NXT_ERROR;
@@ -664,6 +734,7 @@ nxt_http_comp_set_compressor(nxt_task_t *task, nxt_router_conf_t *rtcf,
664734
compr->type = &nxt_http_comp_compressors[cidx];
665735
compr->opts.level = compr->type->def_compr;
666736
compr->opts.min_len = -1;
737+
printf("%s: %s\n", __func__, compr->type->token.start);
667738

668739
ret = nxt_conf_map_object(rtcf->mem_pool, comp,
669740
nxt_http_comp_compressors_opts_map,
@@ -700,6 +771,8 @@ nxt_http_comp_compression_init(nxt_task_t *task, nxt_router_conf_t *rtcf,
700771
static const nxt_str_t comps_str = nxt_string("compressors");
701772
static const nxt_str_t mimes_str = nxt_string("types");
702773

774+
printf("%s: \n", __func__);
775+
703776
mimes = nxt_conf_get_object_member(comp_conf, &mimes_str, NULL);
704777
if (mimes != NULL) {
705778
nxt_http_comp_mime_types_rule =
@@ -739,6 +812,7 @@ nxt_http_comp_compression_init(nxt_task_t *task, nxt_router_conf_t *rtcf,
739812
.opts.min_len = -1 };
740813

741814
if (nxt_conf_type(comps) == NXT_CONF_OBJECT) {
815+
print_comp_config(nxt_http_comp_nr_enabled_compressors);
742816
return nxt_http_comp_set_compressor(task, rtcf, comps, 1);
743817
}
744818

@@ -752,5 +826,7 @@ nxt_http_comp_compression_init(nxt_task_t *task, nxt_router_conf_t *rtcf,
752826
}
753827
}
754828

829+
print_comp_config(nxt_http_comp_nr_enabled_compressors);
830+
755831
return NXT_OK;
756832
}

‎src/nxt_http_request.c‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -320,6 +320,8 @@ nxt_http_request_start(nxt_task_t *task, void *obj, void *data)
320320
nxt_socket_conf_t *skcf;
321321
nxt_http_request_t *r;
322322

323+
printf("%s: \n", __func__);
324+
323325
r = obj;
324326

325327
NXT_OTEL_TRACE();
@@ -692,6 +694,8 @@ nxt_http_request_header_send(nxt_task_t *task, nxt_http_request_t *r,
692694
nxt_http_field_t *server, *date, *content_length;
693695
nxt_socket_conf_t *skcf;
694696

697+
printf("%s: \n", __func__);
698+
695699
ret = nxt_http_set_headers(r);
696700
if (nxt_slow_path(ret != NXT_OK)) {
697701
goto fail;
@@ -783,6 +787,9 @@ void
783787
nxt_http_request_send(nxt_task_t *task, nxt_http_request_t *r, nxt_buf_t *out)
784788
{
785789
if (nxt_fast_path(r->proto.any != NULL)) {
790+
printf("%s: sending [%lu] bytes\n", __func__,
791+
nxt_buf_mem_used_size(&out->mem));
792+
786793
nxt_http_proto[r->protocol].send(task, r, out);
787794
}
788795
}

‎src/nxt_http_route.c‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -688,6 +688,8 @@ nxt_http_action_init(nxt_task_t *task, nxt_router_temp_conf_t *tmcf,
688688
nxt_router_conf_t *rtcf;
689689
nxt_http_action_conf_t acf;
690690

691+
printf("%s: \n", __func__);
692+
691693
nxt_memzero(&acf, sizeof(acf));
692694

693695
ret = nxt_conf_map_object(tmcf->mem_pool, cv, nxt_http_route_action_conf,

‎src/nxt_http_static.c‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -327,6 +327,8 @@ nxt_http_static_send(nxt_task_t *task, nxt_http_request_t *r,
327327
nxt_work_handler_t body_handler;
328328
nxt_http_static_conf_t *conf;
329329

330+
printf("%s: \n", __func__);
331+
330332
action = ctx->action;
331333
conf = action->u.conf;
332334
rtcf = r->conf->socket_conf->router_conf;
@@ -821,6 +823,8 @@ nxt_http_static_body_handler(nxt_task_t *task, void *obj, void *data)
821823
nxt_work_queue_t *wq;
822824
nxt_http_request_t *r;
823825

826+
printf("%s: \n", __func__);
827+
824828
r = obj;
825829
fb = r->out;
826830

@@ -881,6 +885,8 @@ nxt_http_static_buf_completion(nxt_task_t *task, void *obj, void *data)
881885
nxt_off_t rest;
882886
nxt_http_request_t *r;
883887

888+
printf("%s: \n", __func__);
889+
884890
b = obj;
885891
r = data;
886892

‎src/nxt_router.c‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4136,6 +4136,8 @@ nxt_router_response_ready_handler(nxt_task_t *task, nxt_port_recv_msg_t *msg,
41364136
nxt_unit_response_t *resp;
41374137
nxt_request_rpc_data_t *req_rpc_data;
41384138

4139+
printf("%s: \n", __func__);
4140+
41394141
req_rpc_data = data;
41404142

41414143
r = req_rpc_data->request;

‎src/nxt_zlib.c‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,11 +59,14 @@ nxt_zlib_deflate(nxt_http_comp_compressor_ctx_t *ctx, const uint8_t *in_buf,
5959
z->avail_out = out_len;
6060
z->next_out = out_buf;
6161

62+
printf("%s: in_len [%lu], out_len [%lu]\n", __func__, in_len, out_len);
63+
6264
compressed_bytes = z->total_out;
6365

6466
ret = deflate(z, last ? Z_FINISH : Z_SYNC_FLUSH);
6567
if (ret == Z_STREAM_ERROR || ret == Z_BUF_ERROR) {
6668
deflateEnd(z);
69+
printf("%s: ret = %d\n", __func__, ret);
6770
return -1;
6871
}
6972

‎src/nxt_zstd.c‎

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,8 @@ nxt_zstd_init(nxt_http_comp_compressor_ctx_t *ctx)
1818

1919
*zstd = ZSTD_createCStream();
2020
ZSTD_initCStream(*zstd, ctx->level);
21+
22+
printf("%s: zstd compression level [%d]\n", __func__, ctx->level);
2123
}
2224

2325

@@ -37,9 +39,13 @@ nxt_zstd_compress(nxt_http_comp_compressor_ctx_t *ctx, const uint8_t *in_buf,
3739
ZSTD_inBuffer zinb = { .src = in_buf, .size = in_len };
3840
ZSTD_outBuffer zoutb = { .dst = out_buf, .size = out_len };
3941

42+
printf("%s: in_len [%lu] out_len [%lu] last [%s]\n", __func__,
43+
in_len, out_len, last ? "true" : "false");
44+
4045
ret = ZSTD_compressStream(zstd, &zoutb, &zinb);
4146

4247
if (zinb.pos < zinb.size) {
48+
printf("%s: short by [%d]\n", __func__, zinb.pos < zinb.size);
4349
ret = ZSTD_flushStream(zstd, &zoutb);
4450
}
4551

@@ -48,7 +54,9 @@ nxt_zstd_compress(nxt_http_comp_compressor_ctx_t *ctx, const uint8_t *in_buf,
4854
ZSTD_freeCStream(zstd);
4955
}
5056

57+
printf("%s: ret [%lu]\n", __func__, ret);
5158
if (ZSTD_isError(ret)) {
59+
printf("%s: [%s]\n", __func__, ZSTD_getErrorName(ret));
5260
return -1;
5361
}
5462

0 commit comments

Comments
 (0)