Modules: added "js_shared_array_zone" directive.

The directive makes a flat shared memory available as SharedArrayBuffer
to JS code.

Author: xeioex

nginx/config

@@ -8,12 +8,14 @@ NJS_QUICKJS=${NJS_QUICKJS:-YES}
 NJS_DEPS="$ngx_addon_dir/ngx_js.h \
     $ngx_addon_dir/ngx_js_http.h \
     $ngx_addon_dir/ngx_js_fetch.h \
-    $ngx_addon_dir/ngx_js_shared_dict.h"
+    $ngx_addon_dir/ngx_js_shared_dict.h \
+    $ngx_addon_dir/ngx_js_shared_array.h"
 NJS_SRCS="$ngx_addon_dir/ngx_js.c \
     $ngx_addon_dir/ngx_js_http.c \
     $ngx_addon_dir/ngx_js_fetch.c \
     $ngx_addon_dir/ngx_js_regex.c \
-    $ngx_addon_dir/ngx_js_shared_dict.c"
+    $ngx_addon_dir/ngx_js_shared_dict.c \
+    $ngx_addon_dir/ngx_js_shared_array.c"
 
 QJS_DEPS=""
 QJS_SRCS=""

nginx/ngx_http_js_module.c

@@ -382,6 +382,8 @@ static char *ngx_http_js_content(ngx_conf_t *cf, ngx_command_t *cmd,
     void *conf);
 static char *ngx_http_js_shared_dict_zone(ngx_conf_t *cf, ngx_command_t *cmd,
     void *conf);
+static char *ngx_http_js_shared_array_zone(ngx_conf_t *cf, ngx_command_t *cmd,
+    void *conf);
 static char *ngx_http_js_fetch_proxy(ngx_conf_t *cf, ngx_command_t *cmd,
     void *conf);
 static char *ngx_http_js_body_filter_set(ngx_conf_t *cf, ngx_command_t *cmd,
@@ -569,6 +571,13 @@ static ngx_command_t  ngx_http_js_commands[] = {
       0,
       NULL },
 
+    { ngx_string("js_shared_array_zone"),
+      NGX_HTTP_MAIN_CONF|NGX_CONF_TAKE1,
+      ngx_http_js_shared_array_zone,
+      0,
+      0,
+      NULL },
+
     { ngx_string("js_fetch_keepalive"),
       NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
       ngx_conf_set_num_slot,
@@ -1079,6 +1088,7 @@ njs_module_t *njs_http_js_addon_modules[] = {
     &ngx_js_ngx_module,
     &ngx_js_fetch_module,
     &ngx_js_shared_dict_module,
+    &ngx_js_shared_array_module,
 #ifdef NJS_HAVE_OPENSSL
     &njs_webcrypto_module,
 #endif
@@ -1219,6 +1229,7 @@ static JSClassDef ngx_http_qjs_headers_out_class = {
 qjs_module_t *njs_http_qjs_addon_modules[] = {
     &ngx_qjs_ngx_module,
     &ngx_qjs_ngx_shared_dict_module,
+    &ngx_qjs_ngx_shared_array_module,
 #ifdef NJS_HAVE_QUICKJS
     &ngx_qjs_ngx_fetch_module,
 #endif
@@ -8217,6 +8228,14 @@ ngx_http_js_shared_dict_zone(ngx_conf_t *cf, ngx_command_t *cmd,
 }
 
 
+static char *
+ngx_http_js_shared_array_zone(ngx_conf_t *cf, ngx_command_t *cmd,
+    void *conf)
+{
+    return ngx_js_shared_array_zone(cf, cmd, conf, &ngx_http_js_module);
+}
+
+
 static char *
 ngx_http_js_body_filter_set(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
 {

nginx/ngx_js.c

@@ -179,6 +179,28 @@ static njs_external_t  ngx_js_ext_global_shared[] = {
 };
 
 
+static njs_external_t  ngx_js_ext_global_shared_array[] = {
+
+    {
+        .flags = NJS_EXTERN_PROPERTY | NJS_EXTERN_SYMBOL,
+        .name.symbol = NJS_SYMBOL_TO_STRING_TAG,
+        .u.property = {
+            .value = "GlobalSharedArray",
+        }
+    },
+
+    {
+        .flags = NJS_EXTERN_SELF,
+        .u.object = {
+            .enumerable = 1,
+            .prop_handler = njs_js_ext_global_shared_array_prop,
+            .keys = njs_js_ext_global_shared_array_keys,
+        }
+    },
+
+};
+
+
 static njs_external_t  ngx_js_ext_core[] = {
 
     {
@@ -271,6 +293,18 @@ static njs_external_t  ngx_js_ext_core[] = {
         }
     },
 
+    {
+        .flags = NJS_EXTERN_OBJECT,
+        .name.string = njs_str("sharedArray"),
+        .enumerable = 1,
+        .writable = 1,
+        .u.object = {
+            .enumerable = 1,
+            .properties = ngx_js_ext_global_shared_array,
+            .nproperties = njs_nitems(ngx_js_ext_global_shared_array),
+        }
+    },
+
     {
         .flags = NJS_EXTERN_PROPERTY,
         .name.string = njs_str("prefix"),

nginx/ngx_js.h

@@ -63,6 +63,8 @@ enum {
     NGX_QJS_CLASS_ID_SHARED,
     NGX_QJS_CLASS_ID_SHARED_DICT,
     NGX_QJS_CLASS_ID_SHARED_DICT_ERROR,
+    NGX_QJS_CLASS_ID_SHARED_ARRAY_EXOTIC,
+    NGX_QJS_CLASS_ID_SHARED_ARRAY_INSTANCE,
     NGX_QJS_CLASS_ID_FETCH_HEADERS,
     NGX_QJS_CLASS_ID_FETCH_REQUEST,
     NGX_QJS_CLASS_ID_FETCH_RESPONSE,
@@ -73,6 +75,7 @@ enum {
 typedef struct ngx_js_loc_conf_s ngx_js_loc_conf_t;
 typedef struct ngx_js_event_s ngx_js_event_t;
 typedef struct ngx_js_dict_s  ngx_js_dict_t;
+typedef struct ngx_js_shared_array_s ngx_js_shared_array_t;
 typedef struct ngx_js_ctx_s  ngx_js_ctx_t;
 typedef struct ngx_engine_s  ngx_engine_t;
 
@@ -122,6 +125,7 @@ typedef struct {
 
 #define NGX_JS_COMMON_MAIN_CONF                                               \
     ngx_js_dict_t         *dicts;                                             \
+    ngx_js_shared_array_t *shared_arrays;                                     \
     ngx_array_t           *periodics                                          \
 
 
@@ -436,6 +440,7 @@ extern qjs_module_t  qjs_xml_module;
 extern qjs_module_t  qjs_zlib_module;
 extern qjs_module_t  ngx_qjs_ngx_module;
 extern qjs_module_t  ngx_qjs_ngx_shared_dict_module;
+extern qjs_module_t  ngx_qjs_ngx_shared_array_module;
 extern qjs_module_t  ngx_qjs_ngx_fetch_module;
 
 #endif
@@ -495,5 +500,6 @@ extern njs_module_t  njs_zlib_module;
 
 #include "ngx_js_fetch.h"
 #include "ngx_js_shared_dict.h"
+#include "ngx_js_shared_array.h"
 
 #endif /* _NGX_JS_H_INCLUDED_ */