- update code for caching function for enhancing access speed of cin …

…below cnt resource (cbs_cache) - update to send notification along binding protocol of nu of sub resource
IoTKETI · Jun 23, 2018 · 467835c · 467835c
1 parent 0d08774
commit 467835c
Show file tree

Hide file tree

Showing 9 changed files with 827 additions and 1,025 deletions.
diff --git a/app.js b/app.js
diff --git a/cache_man.js b/cache_man.js
@@ -44,7 +44,7 @@ function ss_ri_cache_ttl_manager() {
 wdt.set_wdt(require('shortid').generate(), ss_ri_cache_keep, ss_ri_cache_ttl_manager);
 
 /*
-var cbs_cache_keep = 12 * 60 * 60;
+var cbs_cache_keep = 10 * 60;
 function cbs_cache_ttl_manager() {
     try {
         for(var idx in cbs_cache) {

diff --git a/mobius/cnt.js b/mobius/cnt.js
@@ -74,8 +74,8 @@ exports.build_cnt = function(request, response, resource_Obj, body_Obj, callback
     resource_Obj[rootnm].or = (body_Obj[rootnm].or) ? body_Obj[rootnm].or : '';
     resource_Obj[rootnm].cr = (body_Obj[rootnm].cr) ? body_Obj[rootnm].cr : request.headers['x-m2m-origin'];
 
-    resource_Obj[rootnm].cni = '0';
-    resource_Obj[rootnm].cbs = '0';
+    resource_Obj[rootnm].cni = 0;
+    resource_Obj[rootnm].cbs = 0;
 
     callback('1', resource_Obj);
 };

diff --git a/mobius/resource.js b/mobius/resource.js
diff --git a/mobius/responder.js b/mobius/responder.js
@@ -1955,14 +1955,7 @@ function request_noti_http(nu, bodyString, bodytype, xm2mri) {
     });
 
     req.on('close', function() {
-        ss_fail_count[req._headers.ri]++;
         console.log('[nonblocking-async-http] close: no response for notification');
-
-        var xm2mri = require('shortid').generate();
-        if (ss_fail_count[req._headers.ri] >= 8) {
-            delete ss_fail_count[req._headers.ri];
-            delete_sub(req._headers.ri, xm2mri);
-        }
     });
 
     console.log('<---- [nonblocking-async-http] notification for non-blocking request with ' + bodytype + ' to ' + nu);

diff --git a/mobius/sgn.js b/mobius/sgn.js
diff --git a/mobius/sql_action.js b/mobius/sql_action.js
diff --git a/mobius/ts.js b/mobius/ts.js
@@ -46,8 +46,8 @@ exports.build_ts = function(request, response, resource_Obj, body_Obj, callback)
     resource_Obj[rootnm].mdc = (body_Obj[rootnm].mdc) ? body_Obj[rootnm].mdc : '0';
     resource_Obj[rootnm].mdt = (body_Obj[rootnm].mdt) ? body_Obj[rootnm].mdt : '0';
 
-    resource_Obj[rootnm].cni = '0';
-    resource_Obj[rootnm].cbs = '0';
+    resource_Obj[rootnm].cni = 0;
+    resource_Obj[rootnm].cbs = 0;
 
     callback('1', resource_Obj);
 };

diff --git a/pxy_ws.js b/pxy_ws.js