3 files changed, 52 insertions, 4 deletions

diff --git a/src/ruby/nxt_ruby.c b/src/ruby/nxt_ruby.c
index 62498127..8f4afd35 100644
--- a/src/ruby/nxt_ruby.c
+++ b/src/ruby/nxt_ruby.c
@@ -29,6 +29,7 @@ typedef struct {
 static nxt_int_t nxt_ruby_start(nxt_task_t *task,
     nxt_process_data_t *data);
 static VALUE nxt_ruby_init_basic(VALUE arg);
+static VALUE nxt_ruby_script_basename(nxt_str_t *script);
 
 static VALUE nxt_ruby_hook_procs_load(VALUE path);
 static VALUE nxt_ruby_hook_register(VALUE arg);
@@ -49,7 +50,7 @@ static void *nxt_ruby_thread_create_gvl(void *rctx);
 static VALUE nxt_ruby_thread_func(VALUE arg);
 static void *nxt_ruby_unit_run(void *ctx);
 static void nxt_ruby_ubf(void *ctx);
-static int nxt_ruby_init_threads(nxt_ruby_app_conf_t *c);
+static int nxt_ruby_init_threads(VALUE script, nxt_ruby_app_conf_t *c);
 static void nxt_ruby_join_threads(nxt_unit_ctx_t *ctx,
     nxt_ruby_app_conf_t *c);
 
@@ -260,7 +261,7 @@ static nxt_int_t
 nxt_ruby_start(nxt_task_t *task, nxt_process_data_t *data)
 {
     int                    state, rc;
-    VALUE                  res, path;
+    VALUE                  res, path, script;
     nxt_ruby_ctx_t         ruby_ctx;
     nxt_unit_ctx_t         *unit_ctx;
     nxt_unit_init_t        ruby_unit_init;
@@ -282,7 +283,10 @@ nxt_ruby_start(nxt_task_t *task, nxt_process_data_t *data)
     ruby_options(2, argv);
     ruby_script("NGINX_Unit");
 
+    script = nxt_ruby_script_basename(&c->script);
+
     ruby_ctx.env = Qnil;
+    ruby_ctx.script = script;
     ruby_ctx.io_input = Qnil;
     ruby_ctx.io_error = Qnil;
     ruby_ctx.thread = Qnil;
@@ -352,7 +356,7 @@ nxt_ruby_start(nxt_task_t *task, nxt_process_data_t *data)
         goto fail;
     }
 
-    rc = nxt_ruby_init_threads(c);
+    rc = nxt_ruby_init_threads(script, c);
     if (nxt_slow_path(rc == NXT_UNIT_ERROR)) {
         goto fail;
     }
@@ -421,6 +425,37 @@ fail:
 
 
 static VALUE
+nxt_ruby_script_basename(nxt_str_t *script)
+{
+    size_t  len;
+    u_char  *p, *last;
+
+    last = NULL;
+    p = script->start + script->length;
+
+    while (p > script->start) {
+
+        if (p[-1] == '/') {
+            last = p;
+            break;
+        }
+
+        p--;
+    }
+
+    if (last != NULL) {
+        len = script->length - (last - script->start);
+
+    } else {
+        last = script->start;
+        len = script->length;
+    }
+
+    return rb_str_new((const char *) last, len);
+}
+
+
+static VALUE
 nxt_ruby_init_basic(VALUE arg)
 {
     int                   state;
@@ -563,6 +598,7 @@ nxt_ruby_rack_env_create(VALUE arg)
     rb_ary_push(version, UINT2NUM(NXT_RUBY_RACK_API_VERSION_MAJOR));
     rb_ary_push(version, UINT2NUM(NXT_RUBY_RACK_API_VERSION_MINOR));
 
+    rb_hash_aset(hash_env, rb_str_new2("SCRIPT_NAME"), rctx->script);
     rb_hash_aset(hash_env, rb_str_new2("rack.version"), version);
     rb_hash_aset(hash_env, rb_str_new2("rack.input"), rctx->io_input);
     rb_hash_aset(hash_env, rb_str_new2("rack.errors"), rctx->io_error);
@@ -1357,7 +1393,7 @@ nxt_ruby_ubf(void *ctx)
 
 
 static int
-nxt_ruby_init_threads(nxt_ruby_app_conf_t *c)
+nxt_ruby_init_threads(VALUE script, nxt_ruby_app_conf_t *c)
 {
     int             state;
     uint32_t        i;
@@ -1379,6 +1415,7 @@ nxt_ruby_init_threads(nxt_ruby_app_conf_t *c)
         rctx = &nxt_ruby_ctxs[i];
 
         rctx->env = Qnil;
+        rctx->script = script;
         rctx->io_input = Qnil;
         rctx->io_error = Qnil;
         rctx->thread = Qnil;
diff --git a/src/ruby/nxt_ruby.h b/src/ruby/nxt_ruby.h
index 26430021..3bdd567a 100644
--- a/src/ruby/nxt_ruby.h
+++ b/src/ruby/nxt_ruby.h
@@ -22,6 +22,7 @@
 
 typedef struct {
     VALUE                    env;
+    VALUE                    script;
     VALUE                    io_input;
     VALUE                    io_error;
     VALUE                    thread;
diff --git a/src/ruby/nxt_ruby_stream_io.c b/src/ruby/nxt_ruby_stream_io.c
index 82ad3908..4ef69cee 100644
--- a/src/ruby/nxt_ruby_stream_io.c
+++ b/src/ruby/nxt_ruby_stream_io.c
@@ -18,6 +18,7 @@ static VALUE nxt_ruby_stream_io_puts(VALUE obj, VALUE args);
 static VALUE nxt_ruby_stream_io_write(VALUE obj, VALUE args);
 nxt_inline long nxt_ruby_stream_io_s_write(nxt_ruby_ctx_t *rctx, VALUE val);
 static VALUE nxt_ruby_stream_io_flush(VALUE obj);
+static VALUE nxt_ruby_stream_io_close(VALUE obj);
 
 
 VALUE
@@ -38,6 +39,7 @@ nxt_ruby_stream_io_input_init(void)
     rb_define_method(stream_io, "each", nxt_ruby_stream_io_each, 0);
     rb_define_method(stream_io, "read", nxt_ruby_stream_io_read, -2);
     rb_define_method(stream_io, "rewind", nxt_ruby_stream_io_rewind, 0);
+    rb_define_method(stream_io, "close", nxt_ruby_stream_io_close, 0);
 
     return stream_io;
 }
@@ -60,6 +62,7 @@ nxt_ruby_stream_io_error_init(void)
     rb_define_method(stream_io, "puts", nxt_ruby_stream_io_puts, -2);
     rb_define_method(stream_io, "write", nxt_ruby_stream_io_write, -2);
     rb_define_method(stream_io, "flush", nxt_ruby_stream_io_flush, 0);
+    rb_define_method(stream_io, "close", nxt_ruby_stream_io_close, 0);
 
     return stream_io;
 }
@@ -257,3 +260,10 @@ nxt_ruby_stream_io_flush(VALUE obj)
 {
     return Qnil;
 }
+
+
+static VALUE
+nxt_ruby_stream_io_close(VALUE obj)
+{
+    return Qnil;
+}