Return to ngx_event_pipe.h CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / nginx / src / event

Annotation of embedaddon/nginx/src/event/ngx_event_pipe.h, revision 1.1.1.1

1.1       misho       1: 
                      2: /*
                      3:  * Copyright (C) Igor Sysoev
                      4:  * Copyright (C) Nginx, Inc.
                      5:  */
                      6: 
                      7: 
                      8: #ifndef _NGX_EVENT_PIPE_H_INCLUDED_
                      9: #define _NGX_EVENT_PIPE_H_INCLUDED_
                     10: 
                     11: 
                     12: #include <ngx_config.h>
                     13: #include <ngx_core.h>
                     14: #include <ngx_event.h>
                     15: 
                     16: 
                     17: typedef struct ngx_event_pipe_s  ngx_event_pipe_t;
                     18: 
                     19: typedef ngx_int_t (*ngx_event_pipe_input_filter_pt)(ngx_event_pipe_t *p,
                     20:                                                     ngx_buf_t *buf);
                     21: typedef ngx_int_t (*ngx_event_pipe_output_filter_pt)(void *data,
                     22:                                                      ngx_chain_t *chain);
                     23: 
                     24: 
                     25: struct ngx_event_pipe_s {
                     26:     ngx_connection_t  *upstream;
                     27:     ngx_connection_t  *downstream;
                     28: 
                     29:     ngx_chain_t       *free_raw_bufs;
                     30:     ngx_chain_t       *in;
                     31:     ngx_chain_t      **last_in;
                     32: 
                     33:     ngx_chain_t       *out;
                     34:     ngx_chain_t       *free;
                     35:     ngx_chain_t       *busy;
                     36: 
                     37:     /*
                     38:      * the input filter i.e. that moves HTTP/1.1 chunks
                     39:      * from the raw bufs to an incoming chain
                     40:      */
                     41: 
                     42:     ngx_event_pipe_input_filter_pt    input_filter;
                     43:     void                             *input_ctx;
                     44: 
                     45:     ngx_event_pipe_output_filter_pt   output_filter;
                     46:     void                             *output_ctx;
                     47: 
                     48:     unsigned           read:1;
                     49:     unsigned           cacheable:1;
                     50:     unsigned           single_buf:1;
                     51:     unsigned           free_bufs:1;
                     52:     unsigned           upstream_done:1;
                     53:     unsigned           upstream_error:1;
                     54:     unsigned           upstream_eof:1;
                     55:     unsigned           upstream_blocked:1;
                     56:     unsigned           downstream_done:1;
                     57:     unsigned           downstream_error:1;
                     58:     unsigned           cyclic_temp_file:1;
                     59: 
                     60:     ngx_int_t          allocated;
                     61:     ngx_bufs_t         bufs;
                     62:     ngx_buf_tag_t      tag;
                     63: 
                     64:     ssize_t            busy_size;
                     65: 
                     66:     off_t              read_length;
                     67:     off_t              length;
                     68: 
                     69:     off_t              max_temp_file_size;
                     70:     ssize_t            temp_file_write_size;
                     71: 
                     72:     ngx_msec_t         read_timeout;
                     73:     ngx_msec_t         send_timeout;
                     74:     ssize_t            send_lowat;
                     75: 
                     76:     ngx_pool_t        *pool;
                     77:     ngx_log_t         *log;
                     78: 
                     79:     ngx_chain_t       *preread_bufs;
                     80:     size_t             preread_size;
                     81:     ngx_buf_t         *buf_to_file;
                     82: 
                     83:     ngx_temp_file_t   *temp_file;
                     84: 
                     85:     /* STUB */ int     num;
                     86: };
                     87: 
                     88: 
                     89: ngx_int_t ngx_event_pipe(ngx_event_pipe_t *p, ngx_int_t do_write);
                     90: ngx_int_t ngx_event_pipe_copy_input_filter(ngx_event_pipe_t *p, ngx_buf_t *buf);
                     91: ngx_int_t ngx_event_pipe_add_free_buf(ngx_event_pipe_t *p, ngx_buf_t *b);
                     92: 
                     93: 
                     94: #endif /* _NGX_EVENT_PIPE_H_INCLUDED_ */