Skip to content

N
node-bigstream
Commit 8310cdee authored by project's avatar project
Browse files
Options

--no commit message 

--no commit message
parent d3a2bf1a
Hide whitespace changes
Inline Side-by-side
Showing with 7 additions and 3 deletions
storage-service/ws/v0.1/service-storage.js
View file @ 8310cdee
...@@ -64,6 +64,7 @@ router.get('/:id/objects',function (req, res) { ...@@ -64,6 +64,7 @@ router.get('/:id/objects',function (req, res) {
var from_seq = 1; var from_seq = 1;
var limit = 0; var limit = 0;
var sizelimit = 10 * 1000 * 1000;
if(query.obj_after){ if(query.obj_after){
var o_seq; var o_seq;
...@@ -80,6 +81,10 @@ router.get('/:id/objects',function (req, res) { ...@@ -80,6 +81,10 @@ router.get('/:id/objects',function (req, res) {
limit = Number(query.limit); limit = Number(query.limit);
} }
if(query.sizelimit){
sizelimit = Number(query.sizelimit) * 1000 * 1000;
}
if(query.seq_from){ if(query.seq_from){
from_seq = Number(query.seq_from); from_seq = Number(query.seq_from);
} }
...@@ -121,9 +126,8 @@ router.get('/:id/objects',function (req, res) { ...@@ -121,9 +126,8 @@ router.get('/:id/objects',function (req, res) {
if(resultIdx>0){res.write(',');} if(resultIdx>0){res.write(',');}
res.write(dataout); res.write(dataout);
counter+=dataout.length; counter+=dataout.length;
if(counter>1000000){ if(sizelimit>0 && counter>=sizelimit){
//res.flush(); cont=false;
counter=0;
} }
if(limit>0 && idx>=from_seq+limit){ if(limit>0 && idx>=from_seq+limit){
cont=false; cont=false;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment