nxt_port_memory.h (141:96a65c601420) nxt_port_memory.h (197:ae8f843e1fd4)
1
2/*
3 * Copyright (C) Max Romanov
4 * Copyright (C) NGINX, Inc.
5 */
6
7#ifndef _NXT_PORT_MEMORY_H_INCLUDED_
8#define _NXT_PORT_MEMORY_H_INCLUDED_

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

33nxt_port_mmap_header_t *
34nxt_port_incoming_port_mmap(nxt_task_t *task, nxt_process_t *process,
35 nxt_fd_t fd);
36
37void
38nxt_port_mmap_write(nxt_task_t *task, nxt_port_t *port,
39 nxt_port_send_msg_t *msg, nxt_sendbuf_coalesce_t *sb);
40
1
2/*
3 * Copyright (C) Max Romanov
4 * Copyright (C) NGINX, Inc.
5 */
6
7#ifndef _NXT_PORT_MEMORY_H_INCLUDED_
8#define _NXT_PORT_MEMORY_H_INCLUDED_

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

33nxt_port_mmap_header_t *
34nxt_port_incoming_port_mmap(nxt_task_t *task, nxt_process_t *process,
35 nxt_fd_t fd);
36
37void
38nxt_port_mmap_write(nxt_task_t *task, nxt_port_t *port,
39 nxt_port_send_msg_t *msg, nxt_sendbuf_coalesce_t *sb);
40
41nxt_inline void
42nxt_port_mmap_completion(nxt_task_t *task, nxt_work_queue_t *wq, nxt_buf_t *b) {
43 nxt_work_queue_add(wq, b->completion_handler, task, b, b->parent);
44}
45
46void
47nxt_port_mmap_read(nxt_task_t *task, nxt_port_t *port,
48 nxt_port_recv_msg_t *msg);
49
50enum nxt_port_method_e {
51 NXT_PORT_METHOD_ANY = 0,
52 NXT_PORT_METHOD_PLAIN,
53 NXT_PORT_METHOD_MMAP
54};
55
56typedef enum nxt_port_method_e nxt_port_method_t;
57
58nxt_port_method_t
59nxt_port_mmap_get_method(nxt_task_t *task, nxt_port_t *port, nxt_buf_t *b);
60
61
62#endif /* _NXT_PORT_MEMORY_H_INCLUDED_ */
41void
42nxt_port_mmap_read(nxt_task_t *task, nxt_port_t *port,
43 nxt_port_recv_msg_t *msg);
44
45enum nxt_port_method_e {
46 NXT_PORT_METHOD_ANY = 0,
47 NXT_PORT_METHOD_PLAIN,
48 NXT_PORT_METHOD_MMAP
49};
50
51typedef enum nxt_port_method_e nxt_port_method_t;
52
53nxt_port_method_t
54nxt_port_mmap_get_method(nxt_task_t *task, nxt_port_t *port, nxt_buf_t *b);
55
56
57#endif /* _NXT_PORT_MEMORY_H_INCLUDED_ */