internal subrctx test

should modernize the test file...

t/proxyinternal.lua

@@ -2,12 +2,30 @@ function mcp_config_pools()
     return true
 end
 
+function make_sub()
+    local fg = mcp.funcgen_new()
+    local h = fg:new_handle(mcp.internal_backend)
+    fg:ready({ n = "subint", f = function(rctx)
+        return function(r)
+            return rctx:enqueue_and_wait(r, h)
+        end
+    end})
+    return fg
+end
+
 function mcp_config_routes(zones)
     local fg = mcp.funcgen_new()
+    local subfg = make_sub()
     local h = fg:new_handle(mcp.internal_backend)
+    local hsub = fg:new_handle(subfg)
     fg:ready({ n = "internal", f = function(rctx)
         return function(r)
-            return rctx:enqueue_and_wait(r, h)
+            local k = r:key()
+            if string.find(k, "^/sub/") then
+                return rctx:enqueue_and_wait(r, hsub)
+            else
+                return rctx:enqueue_and_wait(r, h)
+            end
         end
     end})
 

t/proxyinternal.t

@@ -91,6 +91,9 @@ note "ascii basic";
     # non-multiget get mode.
     print $ps "get /b/miss\r\n";
     is(scalar <$ps>, "END\r\n", "basic miss");
+    print $ps "get /sub/miss\r\n";
+    is(scalar <$ps>, "END\r\n", "basic subrctx miss");
+
     check_version($ps);
 }
 
@@ -108,10 +111,18 @@ note "ascii basic";
 {
     print $ps "set /b/foo 0 0 2\r\nhi\r\n";
     is(scalar <$ps>, "STORED\r\n", "int set");
+    print $ps "set /sub/foo 0 0 2\r\nhi\r\n";
+    is(scalar <$ps>, "STORED\r\n", "int set");
+
     print $ps "get /b/foo\r\n";
     is(scalar <$ps>, "VALUE /b/foo 0 2\r\n", "get response");
     is(scalar <$ps>, "hi\r\n", "get value");
     is(scalar <$ps>, "END\r\n", "get END");
+
+    print $ps "get /sub/foo\r\n";
+    is(scalar <$ps>, "VALUE /sub/foo 0 2\r\n", "get response");
+    is(scalar <$ps>, "hi\r\n", "get value");
+    is(scalar <$ps>, "END\r\n", "get END");
     check_version($ps);
 }
 
@@ -149,12 +160,21 @@ subtest 'fetch from extstore' => sub {
     my $data = 'x' x 1000;
     print $ps "set /b/ext 0 0 1000\r\n$data\r\n";
     is(scalar <$ps>, "STORED\r\n", "int set for extstore");
+
+    print $ps "set /sub/ext 0 0 1000\r\n$data\r\n";
+    is(scalar <$ps>, "STORED\r\n", "int set for subrctx extstore");
+
     wait_ext_flush($ps);
 
     print $ps "get /b/ext\r\n";
     is(scalar <$ps>, "VALUE /b/ext 0 1000\r\n", "get response from extstore");
     is(scalar <$ps>, "$data\r\n", "got data from extstore");
     is(scalar <$ps>, "END\r\n", "get END");
+
+    print $ps "get /sub/ext\r\n";
+    is(scalar <$ps>, "VALUE /sub/ext 0 1000\r\n", "get response from subrctx extstore");
+    is(scalar <$ps>, "$data\r\n", "got data from extstore");
+    is(scalar <$ps>, "END\r\n", "get END");
 };
 
 #diag "flood memory"