From 16cbf3c076a0aca6d47adaf3f719493674cf2363 Mon Sep 17 00:00:00 2001 From: Igor Sysoev Date: Tue, 17 Jan 2017 20:00:00 +0300 Subject: Initial version. --- src/nxt_stream_source.h | 31 +++++++++++++++++++++++++++++++ 1 file changed, 31 insertions(+) create mode 100644 src/nxt_stream_source.h (limited to 'src/nxt_stream_source.h') diff --git a/src/nxt_stream_source.h b/src/nxt_stream_source.h new file mode 100644 index 00000000..ae8d5b71 --- /dev/null +++ b/src/nxt_stream_source.h @@ -0,0 +1,31 @@ + +/* + * Copyright (C) Igor Sysoev + * Copyright (C) NGINX, Inc. + */ + +#ifndef _NXT_STREAM_SOURCE_H_INCLUDED_ +#define _NXT_STREAM_SOURCE_H_INCLUDED_ + + +typedef struct nxt_stream_source_s nxt_stream_source_t; + +typedef void (*nxt_stream_source_handler_t)(nxt_stream_source_t *u); + +struct nxt_stream_source_s { + nxt_event_conn_t *conn; + nxt_source_hook_t *next; + nxt_upstream_source_t *upstream; + + nxt_buf_t *out; + + uint32_t read_queued; /* 1 bit */ + + nxt_stream_source_handler_t error_handler; +}; + + +void nxt_stream_source_connect(nxt_stream_source_t *stream); + + +#endif /* _NXT_STREAM_SOURCE_H_INCLUDED_ */ -- cgit