Mercurial > hg > nginx

comparison src/os/unix/ngx_os.h @ 5882:ec81934727a1

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Core: added limit to recv_chain().
author Roman Arutyunyan <arut@nginx.com>
date Tue, 28 Oct 2014 12:29:58 +0300
parents b63e829621ab
children 8e903522c17a
comparison
equal deleted inserted replaced
5881:ee9230cd4bda 5882:ec81934727a1
15 15
16 #define NGX_IO_SENDFILE 1 16 #define NGX_IO_SENDFILE 1
17 17
18 18
19 typedef ssize_t (*ngx_recv_pt)(ngx_connection_t *c, u_char *buf, size_t size); 19 typedef ssize_t (*ngx_recv_pt)(ngx_connection_t *c, u_char *buf, size_t size);
20 typedef ssize_t (*ngx_recv_chain_pt)(ngx_connection_t *c, ngx_chain_t *in); 20 typedef ssize_t (*ngx_recv_chain_pt)(ngx_connection_t *c, ngx_chain_t *in,
21 off_t limit);
21 typedef ssize_t (*ngx_send_pt)(ngx_connection_t *c, u_char *buf, size_t size); 22 typedef ssize_t (*ngx_send_pt)(ngx_connection_t *c, u_char *buf, size_t size);
22 typedef ngx_chain_t *(*ngx_send_chain_pt)(ngx_connection_t *c, ngx_chain_t *in, 23 typedef ngx_chain_t *(*ngx_send_chain_pt)(ngx_connection_t *c, ngx_chain_t *in,
23 off_t limit); 24 off_t limit);
24 25
25 typedef struct { 26 typedef struct {
39 ngx_int_t ngx_daemon(ngx_log_t *log); 40 ngx_int_t ngx_daemon(ngx_log_t *log);
40 ngx_int_t ngx_os_signal_process(ngx_cycle_t *cycle, char *sig, ngx_int_t pid); 41 ngx_int_t ngx_os_signal_process(ngx_cycle_t *cycle, char *sig, ngx_int_t pid);
41 42
42 43
43 ssize_t ngx_unix_recv(ngx_connection_t *c, u_char *buf, size_t size); 44 ssize_t ngx_unix_recv(ngx_connection_t *c, u_char *buf, size_t size);
44 ssize_t ngx_readv_chain(ngx_connection_t *c, ngx_chain_t *entry); 45 ssize_t ngx_readv_chain(ngx_connection_t *c, ngx_chain_t *entry, off_t limit);
45 ssize_t ngx_udp_unix_recv(ngx_connection_t *c, u_char *buf, size_t size); 46 ssize_t ngx_udp_unix_recv(ngx_connection_t *c, u_char *buf, size_t size);
46 ssize_t ngx_unix_send(ngx_connection_t *c, u_char *buf, size_t size); 47 ssize_t ngx_unix_send(ngx_connection_t *c, u_char *buf, size_t size);
47 ngx_chain_t *ngx_writev_chain(ngx_connection_t *c, ngx_chain_t *in, 48 ngx_chain_t *ngx_writev_chain(ngx_connection_t *c, ngx_chain_t *in,
48 off_t limit); 49 off_t limit);
49 50
50 #if (NGX_HAVE_AIO) 51 #if (NGX_HAVE_AIO)
51 ssize_t ngx_aio_read(ngx_connection_t *c, u_char *buf, size_t size); 52 ssize_t ngx_aio_read(ngx_connection_t *c, u_char *buf, size_t size);
52 ssize_t ngx_aio_read_chain(ngx_connection_t *c, ngx_chain_t *cl); 53 ssize_t ngx_aio_read_chain(ngx_connection_t *c, ngx_chain_t *cl, off_t limit);
53 ssize_t ngx_aio_write(ngx_connection_t *c, u_char *buf, size_t size); 54 ssize_t ngx_aio_write(ngx_connection_t *c, u_char *buf, size_t size);
54 ngx_chain_t *ngx_aio_write_chain(ngx_connection_t *c, ngx_chain_t *in, 55 ngx_chain_t *ngx_aio_write_chain(ngx_connection_t *c, ngx_chain_t *in,
55 off_t limit); 56 off_t limit);
56 #endif 57 #endif
57 58