mirror of
https://github.com/neovim/neovim.git
synced 2026-08-12 10:15:33 +00:00
0fc8597f01
* refactor: format header files with uncrustify * fixup(justin): skip formatting of terminfo_defs.h * fixup: force winsock2 to be included first * fixup: simplify disable/enable directive to "uncrustify:off/on"
63 lines
1.6 KiB
C
63 lines
1.6 KiB
C
#ifndef NVIM_EVENT_STREAM_H
|
|
#define NVIM_EVENT_STREAM_H
|
|
|
|
#include <stdbool.h>
|
|
#include <stddef.h>
|
|
#include <uv.h>
|
|
|
|
#include "nvim/event/loop.h"
|
|
#include "nvim/rbuffer.h"
|
|
|
|
typedef struct stream Stream;
|
|
/// Type of function called when the Stream buffer is filled with data
|
|
///
|
|
/// @param stream The Stream instance
|
|
/// @param buf The associated RBuffer instance
|
|
/// @param count Number of bytes that was read.
|
|
/// @param data User-defined data
|
|
/// @param eof If the stream reached EOF.
|
|
typedef void (*stream_read_cb)(Stream *stream, RBuffer *buf, size_t count,
|
|
void *data, bool eof);
|
|
|
|
/// Type of function called when the Stream has information about a write
|
|
/// request.
|
|
///
|
|
/// @param stream The Stream instance
|
|
/// @param data User-defined data
|
|
/// @param status 0 on success, anything else indicates failure
|
|
typedef void (*stream_write_cb)(Stream *stream, void *data, int status);
|
|
typedef void (*stream_close_cb)(Stream *stream, void *data);
|
|
|
|
struct stream {
|
|
bool closed;
|
|
bool did_eof;
|
|
union {
|
|
uv_pipe_t pipe;
|
|
uv_tcp_t tcp;
|
|
uv_idle_t idle;
|
|
#ifdef WIN32
|
|
uv_tty_t tty;
|
|
#endif
|
|
} uv;
|
|
uv_stream_t *uvstream;
|
|
uv_buf_t uvbuf;
|
|
RBuffer *buffer;
|
|
uv_file fd;
|
|
stream_read_cb read_cb;
|
|
stream_write_cb write_cb;
|
|
void *cb_data;
|
|
stream_close_cb close_cb, internal_close_cb;
|
|
void *close_cb_data, *internal_data;
|
|
size_t fpos;
|
|
size_t curmem;
|
|
size_t maxmem;
|
|
size_t pending_reqs;
|
|
size_t num_bytes;
|
|
MultiQueue *events;
|
|
};
|
|
|
|
#ifdef INCLUDE_GENERATED_DECLARATIONS
|
|
# include "event/stream.h.generated.h"
|
|
#endif
|
|
#endif // NVIM_EVENT_STREAM_H
|