Added an option to configure the number of parameters per request in GetParameterValues and SetParameterValues methods.
This commit is contained in:
1 parent
47b0d06493
commit
28394af707
2 files changed
+3
-3
No files matched your search
@@ -39,6 +39,7 @@ exports.IGNORE_XML_NAMESPACES = false # Traverse XML using element's local name
|
|||||||
exports.LIBXMLJS_OPTIONS = {} # Options passed directly to libxmljs
|
exports.LIBXMLJS_OPTIONS = {} # Options passed directly to libxmljs
|
||||||
exports.SESSION_TIMEOUT = 30
|
exports.SESSION_TIMEOUT = 30
|
||||||
exports.GET_PARAMETER_NAMES_DEPTH_THRESHOLD = 0
|
exports.GET_PARAMETER_NAMES_DEPTH_THRESHOLD = 0
|
||||||
|
exports.TASK_PARAMETERS_BATCH_SIZE = 32
|
||||||
|
|
||||||
exports.MONGODB_OPTIONS = {
|
exports.MONGODB_OPTIONS = {
|
||||||
db : {
|
db : {
|
||||||
|
|||||||
+2
-3
@@ -43,7 +43,6 @@ common = require './common'
|
|||||||
db = require './db'
|
db = require './db'
|
||||||
mongodb = require 'mongodb'
|
mongodb = require 'mongodb'
|
||||||
customCommands = require './custom-commands'
|
customCommands = require './custom-commands'
|
||||||
BATCH_SIZE = 16
|
|
||||||
|
|
||||||
exports.STATUS_OK = STATUS_OK = 1
|
exports.STATUS_OK = STATUS_OK = 1
|
||||||
exports.STATUS_FAULT = STATUS_FAULT = 2
|
exports.STATUS_FAULT = STATUS_FAULT = 2
|
||||||
@@ -156,7 +155,7 @@ this.getParameterValues = (task, methodResponse, callback) ->
|
|||||||
else if methodResponse.parameterList?
|
else if methodResponse.parameterList?
|
||||||
task.session.currentIndex = task.session.nextIndex
|
task.session.currentIndex = task.session.nextIndex
|
||||||
|
|
||||||
task.session.nextIndex = Math.min(task.session.currentIndex + BATCH_SIZE, task.parameterNames.length)
|
task.session.nextIndex = Math.min(task.session.currentIndex + config.TASK_PARAMETERS_BATCH_SIZE, task.parameterNames.length)
|
||||||
names = task.parameterNames.slice(task.session.currentIndex, task.session.nextIndex)
|
names = task.parameterNames.slice(task.session.currentIndex, task.session.nextIndex)
|
||||||
|
|
||||||
if methodResponse.type is 'GetParameterValuesResponse'
|
if methodResponse.type is 'GetParameterValuesResponse'
|
||||||
@@ -186,7 +185,7 @@ this.setParameterValues = (task, methodResponse, callback) ->
|
|||||||
prevValues = task.parameterValues.slice(task.session.currentIndex, task.session.nextIndex)
|
prevValues = task.parameterValues.slice(task.session.currentIndex, task.session.nextIndex)
|
||||||
task.session.currentIndex = task.session.nextIndex
|
task.session.currentIndex = task.session.nextIndex
|
||||||
|
|
||||||
task.session.nextIndex = Math.min(task.session.currentIndex + BATCH_SIZE, task.parameterValues.length)
|
task.session.nextIndex = Math.min(task.session.currentIndex + config.TASK_PARAMETERS_BATCH_SIZE, task.parameterValues.length)
|
||||||
values = task.parameterValues.slice(task.session.currentIndex, task.session.nextIndex)
|
values = task.parameterValues.slice(task.session.currentIndex, task.session.nextIndex)
|
||||||
|
|
||||||
if prevValues?
|
if prevValues?
|
||||||
|
|||||||
Reference in new issue
Block a user