openresty bundle

1 files changed, 76 insertions, 0 deletions

diff --git a/ngx_stream_lua-0.0.16/src/ngx_stream_lua_socket_udp.h b/ngx_stream_lua-0.0.16/src/ngx_stream_lua_socket_udp.h
new file mode 100644
index 0000000..abcc76d
--- /dev/null
+++ b/ngx_stream_lua-0.0.16/src/ngx_stream_lua_socket_udp.h
@@ -0,0 +1,76 @@
+
+/*
+ * !!! DO NOT EDIT DIRECTLY !!!
+ * This file was automatically generated from the following template:
+ *
+ * src/subsys/ngx_subsys_lua_socket_udp.h.tt2
+ */
+
+
+/*
+ * Copyright (C) Yichun Zhang (agentzh)
+ */
+
+
+#ifndef _NGX_STREAM_LUA_SOCKET_UDP_H_INCLUDED_
+#define _NGX_STREAM_LUA_SOCKET_UDP_H_INCLUDED_
+
+
+#include "ngx_stream_lua_common.h"
+
+
+typedef struct ngx_stream_lua_socket_udp_upstream_s
+    ngx_stream_lua_socket_udp_upstream_t;
+
+
+typedef
+    int (*ngx_stream_lua_socket_udp_retval_handler)(ngx_stream_lua_request_t *r,
+        ngx_stream_lua_socket_udp_upstream_t *u, lua_State *L);
+
+
+typedef void (*ngx_stream_lua_socket_udp_upstream_handler_pt)
+    (ngx_stream_lua_request_t *r, ngx_stream_lua_socket_udp_upstream_t *u);
+
+
+typedef struct {
+    ngx_connection_t         *connection;
+    struct sockaddr          *sockaddr;
+    socklen_t                 socklen;
+    ngx_str_t                 server;
+    ngx_log_t                 log;
+} ngx_stream_lua_udp_connection_t;
+
+
+struct ngx_stream_lua_socket_udp_upstream_s {
+    ngx_stream_lua_socket_udp_retval_handler                prepare_retvals;
+    ngx_stream_lua_socket_udp_upstream_handler_pt           read_event_handler;
+
+    ngx_stream_lua_loc_conf_t               *conf;
+    ngx_stream_lua_cleanup_pt               *cleanup;
+    ngx_stream_lua_request_t                *request;
+    ngx_stream_lua_udp_connection_t          udp_connection;
+
+    ngx_msec_t                               read_timeout;
+
+    ngx_stream_upstream_resolved_t          *resolved;
+
+    ngx_uint_t                               ft_type;
+    ngx_err_t                                socket_errno;
+    size_t                                   received; /* for receive */
+    size_t                                   recv_buf_size;
+
+    ngx_stream_lua_co_ctx_t                 *co_ctx;
+
+    unsigned                                 waiting:1;
+
+    unsigned                                 raw_downstream:1;
+};
+
+
+void ngx_stream_lua_inject_socket_udp_api(ngx_log_t *log, lua_State *L);
+int ngx_stream_lua_req_socket_udp(lua_State *L);
+
+
+#endif /* _NGX_STREAM_LUA_SOCKET_UDP_H_INCLUDED_ */
+
+/* vi:set ft=c ts=4 sw=4 et fdm=marker: */