initial checkin: methods get_upstreams() and get_servers() now work.

Author: agentzh

.gitignore

@@ -0,0 +1,61 @@
+*.mobi
+genmobi.sh
+.libs
+*.swp
+*.slo
+*.la
+*.swo
+*.lo
+*~
+*.o
+print.txt
+.rsync
+*.tar.gz
+dist
+build[78]
+build
+tags
+update-readme
+*.tmp
+test/Makefile
+test/blib
+test.sh
+t/t.sh
+test/t/servroot/
+releng
+reset
+*.t_
+src/handler.h
+src/util.c
+src/module.h
+src/module.c
+src/drizzle.c
+src/processor.h
+src/handler.c
+src/util.h
+src/drizzle.h
+src/processor.c
+src/output.c
+src/output.h
+libdrizzle
+ctags
+src/stream.h
+nginx
+keepalive
+reindex
+util/bench
+*.html
+trace.out*
+try.sh
+build9
+src/module.[ch]
+t/servroot/
+headers.[ch]
+buildroot/
+build1[0-9]
+go
+all
+analyze
+addr2line
+*.plist
+Makefile

README.md

@@ -0,0 +1,149 @@
+Name
+====
+
+ngx_lua_upstream - Nginx C module to expose Lua API to ngx_lua for Nginx upstreams
+
+Table of Contents
+=================
+
+* [Name](#name)
+* [Status](#status)
+* [Synopsis](#synopsis)
+* [Installation](#installation)
+* [Author](#author)
+* [Copyright and License](#copyright-and-license)
+* [See Also](#see-also)
+
+Status
+======
+
+This module is still under early development.
+
+Synopsis
+========
+
+```nginx
+```
+
+    upstream foo.com:1234 {
+        server 127.0.0.1 fail_timeout=53 weight=4 max_fails=100;
+        server agentzh.org:81;
+    }
+
+    upstream bar {
+        server 127.0.0.2;
+    }
+
+    server {
+        listen 8080;
+
+        # sample output for the following /upstream interface:
+        # upstream foo.com:
+        #     addr = 127.0.0.1:80, weight = 4, fail_timeout = 53, max_fails = 100
+        #     addr = 106.187.41.147:81, weight = 1, fail_timeout = 10, max_fails = 1
+        # upstream bar:
+        #     addr = 127.0.0.2:80, weight = 1, fail_timeout = 10, max_fails = 1
+
+        location = /upstreams {
+            default_type text/plain;
+            content_by_lua '
+                local upstream = require "ngx.upstream"
+                local get_servers = upstream.get_servers
+                local get_upstreams = upstream.get_upstreams
+
+                local us = get_upstreams()
+                for _, u in ipairs(us) do
+                    ngx.say("upstream ", u, ":")
+                    local srvs, err = get_servers(u)
+                    if not srvs then
+                        ngx.say("failed to get servers in upstream ", u)
+                    else
+                        for _, srv in ipairs(srvs) do
+                            local first = true
+                            for k, v in pairs(srv) do
+                                if first then
+                                    first = false
+                                    ngx.print("    ")
+                                else
+                                    ngx.print(", ")
+                                end
+                                ngx.print(k, " = ", v)
+                            end
+                            ngx.print("\\n")
+                        end
+                    end
+                end
+            ';
+        }
+    }
+
+Compatibility
+=============
+
+The following versions of Nginx should work with this module:
+
+* **1.5.x**                       (last tested: 1.5.8)
+
+Installation
+============
+
+1. Grab the nginx source code from [nginx.org](http://nginx.org/), for example,
+the version 1.5.8 (see [nginx compatibility](#compatibility)), 
+2. then grab the source code of the [ngx_lua](https://github.com/chaoslawful/lua-nginx-module#installation) as well as its dependencies like [LuaJIT](http://luajit.org/download.html).
+3. and finally build the source with this module:
+
+```bash
+$ wget 'http://nginx.org/download/nginx-1.5.8.tar.gz'
+$ tar -xzvf nginx-1.5.8.tar.gz
+$ cd nginx-1.5.8/
+
+# assuming your luajit is installed to /opt/luajit:
+export LUAJIT_LIB=/opt/luajit/lib
+
+# assuming you are using LuaJIT 2.0.x:
+export LUAJIT_INC=/opt/luajit/include/luajit-2.0
+
+# Here we assume you would install you nginx under /opt/nginx/.
+$ ./configure --prefix=/opt/nginx \
+    --with-ld-opt="-Wl,-rpath,$LUAJIT_LIB" \
+    --add-module=/path/to/lua-nginx-module \
+    --add-module=/path/to/lua-upstream-nginx-module
+
+$ make -j2
+$ make install
+```
+
+[Back to TOC](#table-of-contents)
+
+Author
+======
+
+Yichun "agentzh" Zhang (章亦春) <[email protected]>, CloudFlare Inc.
+
+[Back to TOC](#table-of-contents)
+
+Copyright and License
+=====================
+
+This module is licensed under the BSD license.
+
+Copyright (C) 2014, by Yichun "agentzh" Zhang, CloudFlare Inc.
+
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met:
+
+* Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer.
+
+* Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the following disclaimer in the documentation and/or other materials provided with the distribution.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+[Back to TOC](#table-of-contents)
+
+See Also
+========
+* the ngx_lua module: http://github.com/chaoslawful/lua-nginx-module#readme
+
+[Back to TOC](#table-of-contents)
+

config

@@ -0,0 +1,3 @@
+ngx_addon_name=ngx_http_lua_upstream_module
+HTTP_MODULES="$HTTP_MODULES ngx_http_lua_upstream_module"
+NGX_ADDON_SRCS="$NGX_ADDON_SRCS $ngx_addon_dir/src/ngx_http_lua_upstream_module.c"

src/ddebug.h

@@ -0,0 +1,82 @@
+
+/*
+ * Copyright (C) Yichun Zhang (agentzh)
+ */
+
+
+#ifndef _DDEBUG_H_INCLUDED_
+#define _DDEBUG_H_INCLUDED_
+
+
+#include <nginx.h>
+#include <ngx_core.h>
+
+
+#if defined(DDEBUG) && (DDEBUG)
+
+#   if (NGX_HAVE_VARIADIC_MACROS)
+
+#       define dd(...) fprintf(stderr, "lua-upstream *** %s: ", __func__); \
+            fprintf(stderr, __VA_ARGS__); \
+            fprintf(stderr, " at %s line %d.\n", __FILE__, __LINE__)
+
+#   else
+
+#include <stdarg.h>
+#include <stdio.h>
+
+#include <stdarg.h>
+
+static void dd(const char *fmt, ...) {
+}
+
+#    endif
+
+#else
+
+#   if (NGX_HAVE_VARIADIC_MACROS)
+
+#       define dd(...)
+
+#   else
+
+#include <stdarg.h>
+
+static void dd(const char *fmt, ...) {
+}
+
+#   endif
+
+#endif
+
+#if defined(DDEBUG) && (DDEBUG)
+
+#define dd_check_read_event_handler(r)   \
+    dd("r->read_event_handler = %s", \
+        r->read_event_handler == ngx_http_block_reading ? \
+            "ngx_http_block_reading" : \
+        r->read_event_handler == ngx_http_test_reading ? \
+            "ngx_http_test_reading" : \
+        r->read_event_handler == ngx_http_request_empty_handler ? \
+            "ngx_http_request_empty_handler" : "UNKNOWN")
+
+#define dd_check_write_event_handler(r)   \
+    dd("r->write_event_handler = %s", \
+        r->write_event_handler == ngx_http_handler ? \
+            "ngx_http_handler" : \
+        r->write_event_handler == ngx_http_core_run_phases ? \
+            "ngx_http_core_run_phases" : \
+        r->write_event_handler == ngx_http_request_empty_handler ? \
+            "ngx_http_request_empty_handler" : "UNKNOWN")
+
+#else
+
+#define dd_check_read_event_handler(r)
+#define dd_check_write_event_handler(r)
+
+#endif
+
+
+#endif /* _DDEBUG_H_INCLUDED_ */
+
+/* vi:set ft=c ts=4 sw=4 et fdm=marker: */