diff options
3 files changed, 345 insertions, 333 deletions
diff --git a/gnunet-build/packages/gnunet/gnunet/Buildrules b/gnunet-build/packages/gnunet/gnunet/Buildrules index ad3c193..89a4c87 100644 --- a/gnunet-build/packages/gnunet/gnunet/Buildrules +++ b/gnunet-build/packages/gnunet/gnunet/Buildrules @@ -132,6 +132,7 @@ pkg_compile() { --js-library "${F}/scheduler.js" \ --js-library "${F}/server.js" \ --js-library "${F}/service.js" \ + --js-library "${F}/plugin_datastore_emscripten_int.js" \ --pre-js "${F}/pre.js" \ --pre-js "${F}/datastore-pre.js" cp "${S}/src/datastore/.libs/gnunet-service-datastore.js" \ diff --git a/gnunet-build/packages/gnunet/gnunet/files/plugin_datastore_emscripten.c b/gnunet-build/packages/gnunet/gnunet/files/plugin_datastore_emscripten.c index e1610f5..d45cfe1 100644 --- a/gnunet-build/packages/gnunet/gnunet/files/plugin_datastore_emscripten.c +++ b/gnunet-build/packages/gnunet/gnunet/files/plugin_datastore_emscripten.c @@ -70,41 +70,14 @@ emscripten_plugin_put (void *cls, const struct GNUNET_HashCode *key, struct GNUNET_TIME_Absolute expiration, PluginPutCont cont, void *cont_cls) { + extern void emscripten_plugin_put_int(const void *key, const void *data, + int size, int type, int priority, int anonymity, int replication, + double expiration, void *vhash, void *cont, void *cons_cls); struct GNUNET_HashCode vhash; GNUNET_CRYPTO_hash (data, size, &vhash); - EM_ASM_ARGS({ - var key_pointer = $0; - var key = Array.prototype.slice.call(HEAP8.subarray($0, $0 + 64)); - var data = Array.prototype.slice.call(HEAP8.subarray($1, $1 + $2)); - var size = $2; - var type = $3; - var priority = $4; - var anonymity = $5; - var replication = $6; - var expiry = $7; - var vhash = Array.prototype.slice.call(HEAP8.subarray($8, $8 + 64)); - var cont = $9; - var cont_cls = $10; - var request = self.dsdb.transaction(['datastore'], 'readwrite') - .objectStore('datastore') - .put({key: key, - data: data, - type: type, - priority: priority, - anonymity: anonymity, - replication: replication, - expiry: expiry, - vhash: vhash}); - request.onerror = function(e) { - console.error('put request failed'); - Runtime.dynCall('viiiii', cont, [cont_cls, key_pointer, size, -1, 0]); - }; - request.onsuccess = function(e) { - Runtime.dynCall('viiiii', cont, [cont_cls, key_pointer, size, 1, 0]); - }; - }, key, data, size, type, priority, anonymity, replication, - (double)expiration.abs_value_us, &vhash, cont, cont_cls); + emscripten_plugin_put_int(key, data, size, type, priority, anonymity, + replication, expiration.abs_value_us, &vhash, cont, cont_cls); } @@ -148,92 +121,11 @@ emscripten_plugin_get_key (void *cls, uint64_t offset, enum GNUNET_BLOCK_Type type, PluginDatumProcessor proc, void *proc_cls) { - EM_ASM_ARGS({ - var offset = $0; - var key_pointer = $1; - var key = $1 ? Array.prototype.slice.call(HEAP8.subarray($1, $1 + 64)) - : null; - var vhash_pointer = $2; - var vhash = $2 ? Array.prototype.slice.call(HEAP8.subarray($2, $2 + 64)) - : null; - var type = $3; - var proc = $4; - var proc_cls = $5; - var datum_processor_wrapper = $6; - var emscripten_plugin_get_key = $7; - var count = 0; - var request = self.dsdb.transaction(['datastore'], 'readwrite') - .objectStore('datastore').index('by_key') - .openCursor(key); - request.onerror = function(e) { - console.error('cursor request failed'); - Runtime.dynCall('iiiiiiiiiii', proc, - [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); - }; - request.onsuccess = function(e) { - var cursor = e.target.result; - if (cursor) { - // optional filter by type - if (type && type != cursor.value.type) { - cursor.continue(); - return; - } - // optional filter by vhash - if (vhash != null) { - if (vhash.length != cursor.value.vhash.length - || !vhash.every(function(x, i) { - return x == cursor.value.vhash[i] - })) { - cursor.continue(); - return; - } - } - // filter by offset - if (offset != 0) { - --offset; - ++count; - cursor.continue(); - return; - } - // got a result - var stack = Runtime.stackSave(); - var expiry = Runtime.stackAlloc(Runtime.getNativeTypeSize('double')); - setValue(expiry, cursor.value.expiry, 'double'); - var ret = ccallFunc( - Runtime.getFuncWrapper(datum_processor_wrapper, - 'iiiiiiiiiii'), - 'number', - ['number', 'number', 'array', 'number', 'array', 'number', 'number', - 'number', 'number', 'number'], - [proc, proc_cls, cursor.value.key, cursor.value.data.length, - cursor.value.data, cursor.value.type, cursor.value.priority, - cursor.value.anonymity, expiry, cursor.value.uid]); - Runtime.stackRestore(stack); - if (!ret) { - cursor.delete().onerror = function(e) { - console.error('delete request failed'); - } - } - } else { - // did offset wrap around? - if (count != 0) { - offset = offset % count; - // recurse - ccallFunc(Runtime.getFuncWrapper(emscripten_plugin_get_key, - 'viiiiiiii'), - 'void', - ['number', 'number', 'number', 'number', 'number', 'number', - 'number', 'number'], - [0, offset, 0, key_pointer, vhash_pointer, type, proc, proc_cls]); - return; - } - // not found - Runtime.dynCall('iiiiiiiiiii', proc, - [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); - } - }; - }, (double)offset, key, vhash, type, proc, proc_cls, - &datum_processor_wrapper, &emscripten_plugin_get_key); + extern void emscripten_plugin_get_key_int(double offset, const void *key, + const void *vhash, int type, void *proc, void *proc_cls, void *wrapper); + + emscripten_plugin_get_key_int(offset, key, vhash, type, proc, proc_cls, + &datum_processor_wrapper); } @@ -252,56 +144,11 @@ static void emscripten_plugin_get_replication (void *cls, PluginDatumProcessor proc, void *proc_cls) { - EM_ASM_ARGS({ - var proc = $0; - var proc_cls = $1; - var datum_processor_wrapper = $2; - var transaction = self.dsdb.transaction(['datastore'], 'readwrite'); - var request = transaction.objectStore('datastore').index('by_replication') - .openCursor(null, 'prev'); - request.onerror = function(e) { - console.error('cursor request failed'); - Runtime.dynCall('iiiiiiiiiii', proc, - [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); - }; - request.onsuccess = function(e) { - var cursor = e.target.result; - if (cursor) { - // got a result - if (cursor.value.replication > 0) { - --cursor.value.replication; - } - var request = transaction.objectStore('datastore').put(value); - request.onerror = function(e) { - console.error('put request failed'); - Runtime.dynCall('iiiiiiiiiii', proc, - [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); - }; - request.onsuccess = function(e) { - var stack = Runtime.stackSave(); - var expiry = Runtime.stackAlloc(Runtime.getNativeTypeSize('double')); - setValue(expiry, cursor.value.expiry, 'double'); - var ret = ccallFunc( - Runtime.getFuncWrapper(datum_processor_wrapper, 'iiiiiiiiiii'), - 'number', - ['number', 'number', 'array', 'number', 'array', 'number', - 'number', 'number', 'number', 'number'], - [proc, proc_cls, cursor.value.key, cursor.value.data.length, - cursor.value.data, cursor.value.type, cursor.value.priority, - cursor.value.anonymity, expiry, cursor.value.uid]); - Runtime.stackRestore(stack); - if (!ret) { - cursor.delete().onerror = function(e) { - console.error('delete request failed'); - } - } - }; - } else { - Runtime.dynCall('iiiiiiiiiii', proc, - [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); - } - }; - }, proc, proc_cls, &datum_processor_wrapper); + extern void emscripten_plugin_get_replication_int(void *proc, void *proc_cls, + void *wrapper); + + emscripten_plugin_get_replication_int(proc, proc_cls, + &datum_processor_wrapper); } @@ -317,48 +164,12 @@ static void emscripten_plugin_get_expiration (void *cls, PluginDatumProcessor proc, void *proc_cls) { + extern void emscripten_plugin_get_expiration_int(void *proc, void *proc_cls, + double now, void *wrapper); struct GNUNET_TIME_Absolute now = GNUNET_TIME_absolute_get(); - EM_ASM_ARGS({ - var proc = $0; - var proc_cls = $1; - var now = $2; - var datum_processor_wrapper = $3; - var request = self.dsdb.transaction(['datastore'], 'readwrite') - .objectStore('datastore').index('by_expiry') - .openCursor(IDBKeyRange.upperBound(now, true)); - request.onerror = function(e) { - console.error('cursor request failed'); - Runtime.dynCall('iiiiiiiiiii', proc, - [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); - }; - request.onsuccess = function(e) { - var cursor = e.target.result; - if (cursor) { - // got a result - var stack = Runtime.stackSave(); - var expiry = Runtime.stackAlloc(Runtime.getNativeTypeSize('double')); - setValue(expiry, cursor.value.expiry, 'double'); - var ret = ccallFunc( - Runtime.getFuncWrapper(datum_processor_wrapper, - 'iiiiiiiiiii'), - 'number', - ['number', 'number', 'array', 'number', 'array', 'number', 'number', - 'number', 'number', 'number'], - [proc, proc_cls, cursor.value.key, cursor.value.data.length, - cursor.value.data, cursor.value.type, cursor.value.priority, - cursor.value.anonymity, expiry, cursor.value.uid]); - Runtime.stackRestore(stack); - if (!ret) { - cursor.delete().onerror = function(e) { - console.error('delete request failed'); - } - } - } else { - Runtime.dynCall('iiiiiiiiiii', proc, - [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); - } - }; - }, proc, proc_cls, (double)now.abs_value_us, &datum_processor_wrapper); + + emscripten_plugin_get_expiration_int(proc, proc_cls, now.abs_value_us, + &datum_processor_wrapper); } @@ -389,37 +200,10 @@ emscripten_plugin_update (void *cls, uint64_t uid, int delta, struct GNUNET_TIME_Absolute expire, PluginUpdateCont cont, void *cont_cls) { - EM_ASM_ARGS({ - var uid = $0; - var delta = $1; - var expiry = $2; - var cont = $3; - var cont_cls = $4; - var transaction = self.dsdb.transaction(['datastore'], 'readwrite'); - var request = transaction.objectStore('datastore').get(uid); - request.onerror = function(e) { - console.warning('get request failed'); - Runtime.dynCall('viii', cont, [cont_cls, -1, 0]); - }; - request.onsuccess = function(e) { - var value = e.target.result; - value.priority += delta; - if (value.priority < 0) { - value.priority = 0; - } - if (value.expiry < expiry) { - value.expiry = expiry; - } - var request = transaction.objectStore('datastore').put(value); - request.onerror = function(e) { - console.error('put request failed'); - Runtime.dynCall('viii', cont, [cont_cls, -1, 0]); - }; - request.onsuccess = function(e) { - Runtime.dynCall('viii', cont, [cont_cls, 1, 0]); - }; - }; - }, (uint32_t)uid, delta, (double)expire.abs_value_us, cont, cont_cls); + extern void emscripten_plugin_update_int(int uid, int delta, double expriy, + void *cont, void *cont_cls); + + emscripten_plugin_update_int(uid, delta, expire.abs_value_us, cont, cont_cls); } @@ -440,70 +224,11 @@ emscripten_plugin_get_zero_anonymity (void *cls, uint64_t offset, enum GNUNET_BLOCK_Type type, PluginDatumProcessor proc, void *proc_cls) { - EM_ASM_ARGS({ - var offset = $0; - var type = $1; - var proc = $2; - var proc_cls = $3; - var datum_processor_wrapper = $4; - var emscripten_plugin_get_zero_anonymity = $5; - var count = 0; - var request = self.dsdb.transaction(['datastore'], 'readwrite') - .objectStore('datastore').index('by_anon_type') - .openCursor([0, type]); - request.onerror = function(e) { - console.error('cursor request failed'); - Runtime.dynCall('iiiiiiiiiii', proc, - [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); - }; - request.onsuccess = function(e) { - var cursor = e.target.result; - if (cursor) { - // filter by offset - if (offset != 0) { - --offset; - ++count; - cursor.continue(); - return; - } - // got a result - var stack = Runtime.stackSave(); - var expiry = Runtime.stackAlloc(Runtime.getNativeTypeSize('double')); - setValue(expiry, cursor.value.expiry, 'double'); - var ret = ccallFunc( - Runtime.getFuncWrapper(datum_processor_wrapper, - 'iiiiiiiiiii'), - 'number', - ['number', 'number', 'array', 'number', 'array', 'number', 'number', - 'number', 'number', 'number'], - [proc, proc_cls, cursor.value.key, cursor.value.data.length, - cursor.value.data, cursor.value.type, cursor.value.priority, - cursor.value.anonymity, expiry, cursor.value.uid]); - Runtime.stackRestore(stack); - if (!ret) { - cursor.delete().onerror = function(e) { - console.error('delete request failed'); - } - } - } else { - // did offset wrap around? - if (count != 0) { - offset = offset % count; - // recurse - ccallFunc(Runtime.getFuncWrapper(emscripten_plugin_get_zero_anonymity, - 'viiiiii'), - 'void', - ['number', 'number', 'number', 'number', 'number', 'number'], - [0, offset, 0, type, proc, proc_cls]); - return; - } - // not found - Runtime.dynCall('iiiiiiiiiii', proc, - [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); - } - }; - }, (double)offset, type, proc, proc_cls, &datum_processor_wrapper, - &emscripten_plugin_get_zero_anonymity); + extern void emscripten_plugin_get_zero_anonymity_int(int offset, int type, + void *proc, void *proc_cls, void *wrapper); + + emscripten_plugin_get_zero_anonymity_int(offset, type, proc, proc_cls, + &datum_processor_wrapper); } @@ -529,35 +254,9 @@ emscripten_plugin_get_keys (void *cls, PluginKeyProcessor proc, void *proc_cls) { - EM_ASM_ARGS({ - var proc = $0; - var proc_cls = $1; - var index = self.dsdb.transaction(['datastore'], 'readonly') - .objectStore('datastore').index('by_key'); - var request = index.openKeyCursor(null, 'nextunique'); - request.onerror = function(e) { - console.error('cursor request failed'); - Runtime.dynCall('viii', proc, [proc_cls, 0, 0]); - }; - request.onsuccess = function(e) { - var cursor = e.target.result; - if (cursor) { - var request = index.count(cursor.key); - request.onerror = function(e) { - console.error('count request failed'); - }; - request.onsuccess = function(e) { - ccallFunc(Runtime.getFuncWrapper(proc, 'viii'), - 'void', - ['number', 'array', 'number'], - [proc_cls, cursor.key, e.target.result]); - }; - cursor.continue(); - } else { - Runtime.dynCall('viii', proc, [proc_cls, 0, 0]); - } - }; - }, proc, proc_cls); + extern void emscripten_plugin_get_keys_int(void *proc, void *proc_cls); + + emscripten_plugin_get_keys_int(proc, proc_cls); } diff --git a/gnunet-build/packages/gnunet/gnunet/files/plugin_datastore_emscripten_int.js b/gnunet-build/packages/gnunet/gnunet/files/plugin_datastore_emscripten_int.js new file mode 100644 index 0000000..3b988c1 --- /dev/null +++ b/gnunet-build/packages/gnunet/gnunet/files/plugin_datastore_emscripten_int.js @@ -0,0 +1,312 @@ +// plugin_datastore_emscripten_int.js - internal functions for datastore plugin +// Copyright (C) 2016 David Barksdale <amatus@amatus.name> +// +// This program is free software: you can redistribute it and/or modify +// it under the terms of the GNU General Public License as published by +// the Free Software Foundation, either version 3 of the License, or +// (at your option) any later version. +// +// This program is distributed in the hope that it will be useful, +// but WITHOUT ANY WARRANTY; without even the implied warranty of +// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +// GNU General Public License for more details. +// +// You should have received a copy of the GNU General Public License +// along with this program. If not, see <http://www.gnu.org/licenses/>. + +mergeInto(LibraryManager.library, { + emscripten_plugin_put_int: function(key_pointer, data_pointer, size, type, + priority, anonymity, replication, expiry, + vhash_pointer, cont, cont_cls) { + var key = Array.prototype.slice.call(HEAP8.subarray(key_pointer, + key_pointer + 64)); + var data = Array.prototype.slice.call(HEAP8.subarray(data_pointer, + data_pointer + size)); + var vhash = Array.prototype.slice.call(HEAP8.subarray(vhash_pointer, + vhash_pointer + 64)); + var request = self.dsdb.transaction(['datastore'], 'readwrite') + .objectStore('datastore') + .put({key: key, + data: data, + type: type, + priority: priority, + anonymity: anonymity, + replication: replication, + expiry: expiry, + vhash: vhash}); + request.onerror = function(e) { + console.error('put request failed'); + Runtime.dynCall('viiiii', cont, [cont_cls, key_pointer, size, -1, 0]); + }; + request.onsuccess = function(e) { + Runtime.dynCall('viiiii', cont, [cont_cls, key_pointer, size, 1, 0]); + }; + }, + emscripten_plugin_get_key_int: function(offset, key_pointer, vhash_pointer, + type, proc, proc_cls, + datum_processor_wrapper) { + var key = key_pointer ? Array.prototype.slice.call(HEAP8.subarray( + key_pointer, key_pointer + 64)) : null; + var vhash = vhash_pointer ? Array.prototype.slice.call(HEAP8.subarray( + vhash_pointer, vhash_pointer + 64)) : null; + var count = 0; + var request = self.dsdb.transaction(['datastore'], 'readwrite') + .objectStore('datastore').index('by_key') + .openCursor(key); + request.onerror = function(e) { + console.error('cursor request failed'); + Runtime.dynCall('iiiiiiiiiii', proc, + [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); + }; + request.onsuccess = function(e) { + var cursor = e.target.result; + if (cursor) { + // optional filter by type + if (type && type != cursor.value.type) { + cursor.continue(); + return; + } + // optional filter by vhash + if (vhash != null) { + if (vhash.length != cursor.value.vhash.length + || !vhash.every(function(x, i) { + return x == cursor.value.vhash[i] + })) { + cursor.continue(); + return; + } + } + // filter by offset + if (offset != 0) { + --offset; + ++count; + cursor.continue(); + return; + } + // got a result + var stack = Runtime.stackSave(); + var expiry = Runtime.stackAlloc(Runtime.getNativeTypeSize('double')); + setValue(expiry, cursor.value.expiry, 'double'); + var ret = ccallFunc( + Runtime.getFuncWrapper(datum_processor_wrapper, + 'iiiiiiiiiii'), + 'number', + ['number', 'number', 'array', 'number', 'array', 'number', 'number', + 'number', 'number', 'number'], + [proc, proc_cls, cursor.value.key, cursor.value.data.length, + cursor.value.data, cursor.value.type, cursor.value.priority, + cursor.value.anonymity, expiry, cursor.value.uid]); + Runtime.stackRestore(stack); + if (!ret) { + cursor.delete().onerror = function(e) { + console.error('delete request failed'); + } + } + } else { + // did offset wrap around? + if (count != 0) { + offset = offset % count; + // recurse + _emscripten_plugin_get_key_int(offset, key_pointer, vhash_pointer, + type, proc, proc_cls, datum_processor_wrapper); + return; + } + // not found + Runtime.dynCall('iiiiiiiiiii', proc, + [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); + } + }; + }, emscripten_plugin_get_replication_int: function(proc, proc_cls, + datum_processor_wrapper) { + var transaction = self.dsdb.transaction(['datastore'], 'readwrite'); + var request = transaction.objectStore('datastore').index('by_replication') + .openCursor(null, 'prev'); + request.onerror = function(e) { + console.error('cursor request failed'); + Runtime.dynCall('iiiiiiiiiii', proc, + [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); + }; + request.onsuccess = function(e) { + var cursor = e.target.result; + if (cursor) { + // got a result + if (cursor.value.replication > 0) { + --cursor.value.replication; + } + var request = transaction.objectStore('datastore').put(value); + request.onerror = function(e) { + console.error('put request failed'); + Runtime.dynCall('iiiiiiiiiii', proc, + [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); + }; + request.onsuccess = function(e) { + var stack = Runtime.stackSave(); + var expiry = Runtime.stackAlloc(Runtime.getNativeTypeSize('double')); + setValue(expiry, cursor.value.expiry, 'double'); + var ret = ccallFunc( + Runtime.getFuncWrapper(datum_processor_wrapper, 'iiiiiiiiiii'), + 'number', + ['number', 'number', 'array', 'number', 'array', 'number', + 'number', 'number', 'number', 'number'], + [proc, proc_cls, cursor.value.key, cursor.value.data.length, + cursor.value.data, cursor.value.type, cursor.value.priority, + cursor.value.anonymity, expiry, cursor.value.uid]); + Runtime.stackRestore(stack); + if (!ret) { + cursor.delete().onerror = function(e) { + console.error('delete request failed'); + } + } + }; + } else { + Runtime.dynCall('iiiiiiiiiii', proc, + [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); + } + }; + }, emscripten_plugin_get_expiration_int: function(proc, proc_cls, now, + datum_processor_wrapper) { + var request = self.dsdb.transaction(['datastore'], 'readwrite') + .objectStore('datastore').index('by_expiry') + .openCursor(IDBKeyRange.upperBound(now, true)); + request.onerror = function(e) { + console.error('cursor request failed'); + Runtime.dynCall('iiiiiiiiiii', proc, + [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); + }; + request.onsuccess = function(e) { + var cursor = e.target.result; + if (cursor) { + // got a result + var stack = Runtime.stackSave(); + var expiry = Runtime.stackAlloc(Runtime.getNativeTypeSize('double')); + setValue(expiry, cursor.value.expiry, 'double'); + var ret = ccallFunc( + Runtime.getFuncWrapper(datum_processor_wrapper, + 'iiiiiiiiiii'), + 'number', + ['number', 'number', 'array', 'number', 'array', 'number', 'number', + 'number', 'number', 'number'], + [proc, proc_cls, cursor.value.key, cursor.value.data.length, + cursor.value.data, cursor.value.type, cursor.value.priority, + cursor.value.anonymity, expiry, cursor.value.uid]); + Runtime.stackRestore(stack); + if (!ret) { + cursor.delete().onerror = function(e) { + console.error('delete request failed'); + } + } + } else { + Runtime.dynCall('iiiiiiiiiii', proc, + [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); + } + }; + }, emscripten_plugin_update_int: function(uid, delta, expiry, cont, + cont_cls) { + var transaction = self.dsdb.transaction(['datastore'], 'readwrite'); + var request = transaction.objectStore('datastore').get(uid); + request.onerror = function(e) { + console.warning('get request failed'); + Runtime.dynCall('viii', cont, [cont_cls, -1, 0]); + }; + request.onsuccess = function(e) { + var value = e.target.result; + value.priority += delta; + if (value.priority < 0) { + value.priority = 0; + } + if (value.expiry < expiry) { + value.expiry = expiry; + } + var request = transaction.objectStore('datastore').put(value); + request.onerror = function(e) { + console.error('put request failed'); + Runtime.dynCall('viii', cont, [cont_cls, -1, 0]); + }; + request.onsuccess = function(e) { + Runtime.dynCall('viii', cont, [cont_cls, 1, 0]); + }; + }; + }, emscripten_plugin_get_zero_anonymity_int: function(offset, type, proc, + proc_cls, datum_processor_wrapper) { + var count = 0; + var request = self.dsdb.transaction(['datastore'], 'readwrite') + .objectStore('datastore').index('by_anon_type') + .openCursor([0, type]); + request.onerror = function(e) { + console.error('cursor request failed'); + Runtime.dynCall('iiiiiiiiiii', proc, + [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); + }; + request.onsuccess = function(e) { + var cursor = e.target.result; + if (cursor) { + // filter by offset + if (offset != 0) { + --offset; + ++count; + cursor.continue(); + return; + } + // got a result + var stack = Runtime.stackSave(); + var expiry = Runtime.stackAlloc(Runtime.getNativeTypeSize('double')); + setValue(expiry, cursor.value.expiry, 'double'); + var ret = ccallFunc( + Runtime.getFuncWrapper(datum_processor_wrapper, + 'iiiiiiiiiii'), + 'number', + ['number', 'number', 'array', 'number', 'array', 'number', 'number', + 'number', 'number', 'number'], + [proc, proc_cls, cursor.value.key, cursor.value.data.length, + cursor.value.data, cursor.value.type, cursor.value.priority, + cursor.value.anonymity, expiry, cursor.value.uid]); + Runtime.stackRestore(stack); + if (!ret) { + cursor.delete().onerror = function(e) { + console.error('delete request failed'); + } + } + } else { + // did offset wrap around? + if (count != 0) { + offset = offset % count; + // recurse + _emscripten_plugin_get_zero_anonymity_int(offset, type, proc, + proc_cls, datum_processor_wrapper); + return; + } + // not found + Runtime.dynCall('iiiiiiiiiii', proc, + [proc_cls, 0, 0, 0, 0, 0, 0, 0, 0, 0]); + } + }; + }, emscripten_plugin_get_keys_int: function(proc, proc_cls) { + var index = self.dsdb.transaction(['datastore'], 'readonly') + .objectStore('datastore').index('by_key'); + var request = index.openKeyCursor(null, 'nextunique'); + request.onerror = function(e) { + console.error('cursor request failed'); + Runtime.dynCall('viii', proc, [proc_cls, 0, 0]); + }; + request.onsuccess = function(e) { + var cursor = e.target.result; + if (cursor) { + var request = index.count(cursor.key); + request.onerror = function(e) { + console.error('count request failed'); + }; + request.onsuccess = function(e) { + ccallFunc(Runtime.getFuncWrapper(proc, 'viii'), + 'void', + ['number', 'array', 'number'], + [proc_cls, cursor.key, e.target.result]); + }; + cursor.continue(); + } else { + Runtime.dynCall('viii', proc, [proc_cls, 0, 0]); + } + }; + } +}); + +/* vim: set expandtab ts=2 sw=2: */ |