nxt_controller.c (54:8c3dfaedd423) nxt_controller.c (56:92b4984ca3c1)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#include <nxt_main.h>

--- 226 unchanged lines hidden (view full) ---

235
236 nxt_event_conn_read(engine, c);
237}
238
239
240static const nxt_event_conn_state_t nxt_controller_conn_read_state
241 nxt_aligned(64) =
242{
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Valentin V. Bartenev
5 * Copyright (C) NGINX, Inc.
6 */
7
8#include <nxt_main.h>

--- 226 unchanged lines hidden (view full) ---

235
236 nxt_event_conn_read(engine, c);
237}
238
239
240static const nxt_event_conn_state_t nxt_controller_conn_read_state
241 nxt_aligned(64) =
242{
243 NXT_EVENT_NO_BUF_PROCESS,
244 NXT_EVENT_TIMER_NO_AUTORESET,
243 .ready_handler = nxt_controller_conn_read,
244 .close_handler = nxt_controller_conn_close,
245 .error_handler = nxt_controller_conn_read_error,
245
246
246 nxt_controller_conn_read,
247 nxt_controller_conn_close,
248 nxt_controller_conn_read_error,
249
250 nxt_controller_conn_read_timeout,
251 nxt_controller_conn_timeout_value,
252 60 * 1000,
247 .timer_handler = nxt_controller_conn_read_timeout,
248 .timer_value = nxt_controller_conn_timeout_value,
249 .timer_data = 60 * 1000,
253};
254
255
256static void
257nxt_controller_conn_read(nxt_task_t *task, void *obj, void *data)
258{
259 size_t preread;
260 nxt_buf_t *b;

--- 99 unchanged lines hidden (view full) ---

360
361 nxt_controller_conn_close(task, c, data);
362}
363
364
365static const nxt_event_conn_state_t nxt_controller_conn_body_read_state
366 nxt_aligned(64) =
367{
250};
251
252
253static void
254nxt_controller_conn_read(nxt_task_t *task, void *obj, void *data)
255{
256 size_t preread;
257 nxt_buf_t *b;

--- 99 unchanged lines hidden (view full) ---

357
358 nxt_controller_conn_close(task, c, data);
359}
360
361
362static const nxt_event_conn_state_t nxt_controller_conn_body_read_state
363 nxt_aligned(64) =
364{
368 NXT_EVENT_NO_BUF_PROCESS,
369 NXT_EVENT_TIMER_AUTORESET,
365 .ready_handler = nxt_controller_conn_body_read,
366 .close_handler = nxt_controller_conn_close,
367 .error_handler = nxt_controller_conn_read_error,
370
368
371 nxt_controller_conn_body_read,
372 nxt_controller_conn_close,
373 nxt_controller_conn_read_error,
374
375 nxt_controller_conn_read_timeout,
376 nxt_controller_conn_timeout_value,
377 60 * 1000,
369 .timer_handler = nxt_controller_conn_read_timeout,
370 .timer_value = nxt_controller_conn_timeout_value,
371 .timer_data = 60 * 1000,
372 .timer_autoreset = 1,
378};
379
380
381static void
382nxt_controller_conn_body_read(nxt_task_t *task, void *obj, void *data)
383{
384 size_t rest;
385 nxt_buf_t *b;

--- 18 unchanged lines hidden (view full) ---

404
405 nxt_event_conn_read(task->thread->engine, c);
406}
407
408
409static const nxt_event_conn_state_t nxt_controller_conn_write_state
410 nxt_aligned(64) =
411{
373};
374
375
376static void
377nxt_controller_conn_body_read(nxt_task_t *task, void *obj, void *data)
378{
379 size_t rest;
380 nxt_buf_t *b;

--- 18 unchanged lines hidden (view full) ---

399
400 nxt_event_conn_read(task->thread->engine, c);
401}
402
403
404static const nxt_event_conn_state_t nxt_controller_conn_write_state
405 nxt_aligned(64) =
406{
412 NXT_EVENT_NO_BUF_PROCESS,
413 NXT_EVENT_TIMER_AUTORESET,
407 .ready_handler = nxt_controller_conn_write,
408 .error_handler = nxt_controller_conn_write_error,
414
409
415 nxt_controller_conn_write,
416 NULL,
417 nxt_controller_conn_write_error,
418
419 nxt_controller_conn_write_timeout,
420 nxt_controller_conn_timeout_value,
421 60 * 1000,
410 .timer_handler = nxt_controller_conn_write_timeout,
411 .timer_value = nxt_controller_conn_timeout_value,
412 .timer_data = 60 * 1000,
413 .timer_autoreset = 1,
422};
423
424
425static void
426nxt_controller_conn_write(nxt_task_t *task, void *obj, void *data)
427{
428 nxt_buf_t *b;
429 nxt_event_conn_t *c;

--- 44 unchanged lines hidden (view full) ---

474
475 nxt_controller_conn_close(task, c, data);
476}
477
478
479static const nxt_event_conn_state_t nxt_controller_conn_close_state
480 nxt_aligned(64) =
481{
414};
415
416
417static void
418nxt_controller_conn_write(nxt_task_t *task, void *obj, void *data)
419{
420 nxt_buf_t *b;
421 nxt_event_conn_t *c;

--- 44 unchanged lines hidden (view full) ---

466
467 nxt_controller_conn_close(task, c, data);
468}
469
470
471static const nxt_event_conn_state_t nxt_controller_conn_close_state
472 nxt_aligned(64) =
473{
482 NXT_EVENT_NO_BUF_PROCESS,
483 NXT_EVENT_TIMER_NO_AUTORESET,
484
485 nxt_controller_conn_free,
486 NULL,
487 NULL,
488
489 NULL,
490 NULL,
491 0,
474 .ready_handler = nxt_controller_conn_free,
492};
493
494
495static void
496nxt_controller_conn_close(nxt_task_t *task, void *obj, void *data)
497{
498 nxt_event_conn_t *c;
499

--- 319 unchanged lines hidden ---
475};
476
477
478static void
479nxt_controller_conn_close(nxt_task_t *task, void *obj, void *data)
480{
481 nxt_event_conn_t *c;
482

--- 319 unchanged lines hidden ---