Searched refs:mk_stream_input (Results 1 – 8 of 8) sorted by relevance
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/lib/monkey/include/monkey/ |
| H A D | mk_stream.h | 73 struct mk_stream_input { struct
89 void (*cb_consumed)(struct mk_stream_input *, long); argument
90 void (*cb_finished)(struct mk_stream_input *); argument
126 int mk_stream_in_release(struct mk_stream_input *in);
146 static inline int mk_stream_input(struct mk_stream *stream, in mk_stream_input() function
159 in = mk_mem_alloc(sizeof(struct mk_stream_input)); in mk_stream_input()
197 return mk_stream_input(stream, in mk_stream_in_file()
212 return mk_stream_input(stream, in mk_stream_in_iov()
226 return mk_stream_input(stream, in mk_stream_in_raw()
240 struct mk_stream_input *in; in mk_stream_release()
[all …]
|
| H A D | mk_http_internal.h | 98 struct mk_stream_input in_headers;
99 struct mk_stream_input in_headers_extra;
100 struct mk_stream_input in_file;
101 struct mk_stream_input page_stream;
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/lib/monkey/mk_server/ |
| H A D | mk_stream.c | 39 struct mk_stream_input *in) in channel_write_in_file()
110 int mk_stream_in_release(struct mk_stream_input *in) in mk_stream_in_release()
131 struct mk_stream_input *input; in mk_channel_stream_write()
142 input = mk_list_entry(head, struct mk_stream_input, _head); in mk_channel_stream_write()
206 struct mk_stream_input *input; in mk_channel_write()
220 input = mk_list_entry_first(&stream->inputs, struct mk_stream_input, _head); in mk_channel_write()
317 struct mk_stream_input *in; in mk_channel_clean()
322 in = mk_list_entry(head_in, struct mk_stream_input, _head); in mk_channel_clean()
|
| H A D | mk_header.c | 129 static void mk_header_cb_finished(struct mk_stream_input *in) in SetSortByValueThenRelevance()
157 static void cb_stream_iov_extended_free(struct mk_stream_input *in)
399 struct mk_stream_input *in = &sr->in_headers_extra; in GetMSet()
|
| H A D | mk_http.c | 397 struct mk_stream_input *in; in mk_http_range_set()
607 static inline void mk_http_cb_file_on_consume(struct mk_stream_input *in, in mk_http_cb_file_on_consume()
1194 void cb_stream_page_finished(struct mk_stream_input *in) in cb_stream_page_finished()
|
| H A D | mk_lib.c | 632 static void free_chunk_header(struct mk_stream_input *input) in free_chunk_header()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/lib/monkey/plugins/dirlisting/ |
| H A D | dirlisting.c | 41 void mk_dirhtml_cb_body_rows(struct mk_stream_input *in);
617 void mk_dirhtml_cb_complete(struct mk_stream_input *in) in mk_dirhtml_cb_complete()
643 void mk_dirhtml_cb_chunk_body_rows(struct mk_stream_input *in, long bytes) in mk_dirhtml_cb_chunk_body_rows()
650 void mk_dirhtml_cb_body_rows(struct mk_stream_input *in) in mk_dirhtml_cb_body_rows()
656 void (*cb_ok)(struct mk_stream_input *) = NULL; in mk_dirhtml_cb_body_rows()
723 void cb_header_finish(struct mk_stream_input *in) in cb_header_finish()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/lib/monkey/plugins/fastcgi/ |
| H A D | fcgi_handler.c | 542 void fcgi_stream_eof(struct mk_stream_input *in)
|