Deleted
Added
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 --- |