http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/b434b067/distribution/src/main/scripts/interface/gen-js/Blur.js ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-js/Blur.js b/distribution/src/main/scripts/interface/gen-js/Blur.js index 4a90276..d7dc27b 100644 --- a/distribution/src/main/scripts/interface/gen-js/Blur.js +++ b/distribution/src/main/scripts/interface/gen-js/Blur.js @@ -92,17 +92,25 @@ Blur_execute_args.prototype.write = function(output) { Blur_execute_result = function(args) { this.success = null; - this.ex = null; + this.bex = null; + this.tex = null; if (args instanceof BlurException) { - this.ex = args; + this.bex = args; + return; + } + if (args instanceof TimeoutException) { + this.tex = args; return; } if (args) { if (args.success !== undefined) { this.success = args.success; } - if (args.ex !== undefined) { - this.ex = args.ex; + if (args.bex !== undefined) { + this.bex = args.bex; + } + if (args.tex !== undefined) { + this.tex = args.tex; } } }; @@ -130,8 +138,16 @@ Blur_execute_result.prototype.read = function(input) { break; case 1: if (ftype == Thrift.Type.STRUCT) { - this.ex = new BlurException(); - this.ex.read(input); + this.bex = new BlurException(); + this.bex.read(input); + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRUCT) { + this.tex = new TimeoutException(); + this.tex.read(input); } else { input.skip(ftype); } @@ -152,9 +168,67 @@ Blur_execute_result.prototype.write = function(output) { this.success.write(output); output.writeFieldEnd(); } - if (this.ex !== null && this.ex !== undefined) { - output.writeFieldBegin('ex', Thrift.Type.STRUCT, 1); - this.ex.write(output); + if (this.bex !== null && this.bex !== undefined) { + output.writeFieldBegin('bex', Thrift.Type.STRUCT, 1); + this.bex.write(output); + output.writeFieldEnd(); + } + if (this.tex !== null && this.tex !== undefined) { + output.writeFieldBegin('tex', Thrift.Type.STRUCT, 2); + this.tex.write(output); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Blur_reconnect_args = function(args) { + this.executionId = null; + if (args) { + if (args.executionId !== undefined) { + this.executionId = args.executionId; + } + } +}; +Blur_reconnect_args.prototype = {}; +Blur_reconnect_args.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.executionId = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 0: + input.skip(ftype); + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Blur_reconnect_args.prototype.write = function(output) { + output.writeStructBegin('Blur_reconnect_args'); + if (this.executionId !== null && this.executionId !== undefined) { + output.writeFieldBegin('executionId', Thrift.Type.STRING, 1); + output.writeString(this.executionId); output.writeFieldEnd(); } output.writeFieldStop(); @@ -162,6 +236,155 @@ Blur_execute_result.prototype.write = function(output) { return; }; +Blur_reconnect_result = function(args) { + this.success = null; + this.bex = null; + this.tex = null; + if (args instanceof BlurException) { + this.bex = args; + return; + } + if (args instanceof TimeoutException) { + this.tex = args; + return; + } + if (args) { + if (args.success !== undefined) { + this.success = args.success; + } + if (args.bex !== undefined) { + this.bex = args.bex; + } + if (args.tex !== undefined) { + this.tex = args.tex; + } + } +}; +Blur_reconnect_result.prototype = {}; +Blur_reconnect_result.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 0: + if (ftype == Thrift.Type.STRUCT) { + this.success = new Response(); + this.success.read(input); + } else { + input.skip(ftype); + } + break; + case 1: + if (ftype == Thrift.Type.STRUCT) { + this.bex = new BlurException(); + this.bex.read(input); + } else { + input.skip(ftype); + } + break; + case 2: + if (ftype == Thrift.Type.STRUCT) { + this.tex = new TimeoutException(); + this.tex.read(input); + } else { + input.skip(ftype); + } + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Blur_reconnect_result.prototype.write = function(output) { + output.writeStructBegin('Blur_reconnect_result'); + if (this.success !== null && this.success !== undefined) { + output.writeFieldBegin('success', Thrift.Type.STRUCT, 0); + this.success.write(output); + output.writeFieldEnd(); + } + if (this.bex !== null && this.bex !== undefined) { + output.writeFieldBegin('bex', Thrift.Type.STRUCT, 1); + this.bex.write(output); + output.writeFieldEnd(); + } + if (this.tex !== null && this.tex !== undefined) { + output.writeFieldBegin('tex', Thrift.Type.STRUCT, 2); + this.tex.write(output); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Blur_refresh_args = function(args) { +}; +Blur_refresh_args.prototype = {}; +Blur_refresh_args.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + input.skip(ftype); + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Blur_refresh_args.prototype.write = function(output) { + output.writeStructBegin('Blur_refresh_args'); + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Blur_refresh_result = function(args) { +}; +Blur_refresh_result.prototype = {}; +Blur_refresh_result.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + input.skip(ftype); + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Blur_refresh_result.prototype.write = function(output) { + output.writeStructBegin('Blur_refresh_result'); + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + Blur_createTable_args = function(args) { this.tableDescriptor = null; if (args) { @@ -818,18 +1041,18 @@ Blur_tableList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size252 = 0; - var _rtmp3256; + var _size262 = 0; + var _rtmp3266; this.success = []; - var _etype255 = 0; - _rtmp3256 = input.readListBegin(); - _etype255 = _rtmp3256.etype; - _size252 = _rtmp3256.size; - for (var _i257 = 0; _i257 < _size252; ++_i257) + var _etype265 = 0; + _rtmp3266 = input.readListBegin(); + _etype265 = _rtmp3266.etype; + _size262 = _rtmp3266.size; + for (var _i267 = 0; _i267 < _size262; ++_i267) { - var elem258 = null; - elem258 = input.readString().value; - this.success.push(elem258); + var elem268 = null; + elem268 = input.readString().value; + this.success.push(elem268); } input.readListEnd(); } else { @@ -858,12 +1081,12 @@ Blur_tableList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter259 in this.success) + for (var iter269 in this.success) { - if (this.success.hasOwnProperty(iter259)) + if (this.success.hasOwnProperty(iter269)) { - iter259 = this.success[iter259]; - output.writeString(iter259); + iter269 = this.success[iter269]; + output.writeString(iter269); } } output.writeListEnd(); @@ -964,18 +1187,18 @@ Blur_tableListByCluster_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size260 = 0; - var _rtmp3264; + var _size270 = 0; + var _rtmp3274; this.success = []; - var _etype263 = 0; - _rtmp3264 = input.readListBegin(); - _etype263 = _rtmp3264.etype; - _size260 = _rtmp3264.size; - for (var _i265 = 0; _i265 < _size260; ++_i265) + var _etype273 = 0; + _rtmp3274 = input.readListBegin(); + _etype273 = _rtmp3274.etype; + _size270 = _rtmp3274.size; + for (var _i275 = 0; _i275 < _size270; ++_i275) { - var elem266 = null; - elem266 = input.readString().value; - this.success.push(elem266); + var elem276 = null; + elem276 = input.readString().value; + this.success.push(elem276); } input.readListEnd(); } else { @@ -1004,12 +1227,12 @@ Blur_tableListByCluster_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter267 in this.success) + for (var iter277 in this.success) { - if (this.success.hasOwnProperty(iter267)) + if (this.success.hasOwnProperty(iter277)) { - iter267 = this.success[iter267]; - output.writeString(iter267); + iter277 = this.success[iter277]; + output.writeString(iter277); } } output.writeListEnd(); @@ -1995,40 +2218,40 @@ Blur_listSnapshots_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size268 = 0; - var _rtmp3272; + var _size278 = 0; + var _rtmp3282; this.success = {}; - var _ktype269 = 0; - var _vtype270 = 0; - _rtmp3272 = input.readMapBegin(); - _ktype269 = _rtmp3272.ktype; - _vtype270 = _rtmp3272.vtype; - _size268 = _rtmp3272.size; - for (var _i273 = 0; _i273 < _size268; ++_i273) + var _ktype279 = 0; + var _vtype280 = 0; + _rtmp3282 = input.readMapBegin(); + _ktype279 = _rtmp3282.ktype; + _vtype280 = _rtmp3282.vtype; + _size278 = _rtmp3282.size; + for (var _i283 = 0; _i283 < _size278; ++_i283) { - if (_i273 > 0 ) { + if (_i283 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key274 = null; - var val275 = null; - key274 = input.readString().value; - var _size276 = 0; - var _rtmp3280; - val275 = []; - var _etype279 = 0; - _rtmp3280 = input.readListBegin(); - _etype279 = _rtmp3280.etype; - _size276 = _rtmp3280.size; - for (var _i281 = 0; _i281 < _size276; ++_i281) + var key284 = null; + var val285 = null; + key284 = input.readString().value; + var _size286 = 0; + var _rtmp3290; + val285 = []; + var _etype289 = 0; + _rtmp3290 = input.readListBegin(); + _etype289 = _rtmp3290.etype; + _size286 = _rtmp3290.size; + for (var _i291 = 0; _i291 < _size286; ++_i291) { - var elem282 = null; - elem282 = input.readString().value; - val275.push(elem282); + var elem292 = null; + elem292 = input.readString().value; + val285.push(elem292); } input.readListEnd(); - this.success[key274] = val275; + this.success[key284] = val285; } input.readMapEnd(); } else { @@ -2057,19 +2280,19 @@ Blur_listSnapshots_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.MAP, 0); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.LIST, Thrift.objectLength(this.success)); - for (var kiter283 in this.success) + for (var kiter293 in this.success) { - if (this.success.hasOwnProperty(kiter283)) + if (this.success.hasOwnProperty(kiter293)) { - var viter284 = this.success[kiter283]; - output.writeString(kiter283); - output.writeListBegin(Thrift.Type.STRING, viter284.length); - for (var iter285 in viter284) + var viter294 = this.success[kiter293]; + output.writeString(kiter293); + output.writeListBegin(Thrift.Type.STRING, viter294.length); + for (var iter295 in viter294) { - if (viter284.hasOwnProperty(iter285)) + if (viter294.hasOwnProperty(iter295)) { - iter285 = viter284[iter285]; - output.writeString(iter285); + iter295 = viter294[iter295]; + output.writeString(iter295); } } output.writeListEnd(); @@ -2483,19 +2706,19 @@ Blur_fetchRowBatch_args.prototype.read = function(input) { break; case 2: if (ftype == Thrift.Type.LIST) { - var _size286 = 0; - var _rtmp3290; + var _size296 = 0; + var _rtmp3300; this.selectors = []; - var _etype289 = 0; - _rtmp3290 = input.readListBegin(); - _etype289 = _rtmp3290.etype; - _size286 = _rtmp3290.size; - for (var _i291 = 0; _i291 < _size286; ++_i291) + var _etype299 = 0; + _rtmp3300 = input.readListBegin(); + _etype299 = _rtmp3300.etype; + _size296 = _rtmp3300.size; + for (var _i301 = 0; _i301 < _size296; ++_i301) { - var elem292 = null; - elem292 = new Selector(); - elem292.read(input); - this.selectors.push(elem292); + var elem302 = null; + elem302 = new Selector(); + elem302.read(input); + this.selectors.push(elem302); } input.readListEnd(); } else { @@ -2521,12 +2744,12 @@ Blur_fetchRowBatch_args.prototype.write = function(output) { if (this.selectors !== null && this.selectors !== undefined) { output.writeFieldBegin('selectors', Thrift.Type.LIST, 2); output.writeListBegin(Thrift.Type.STRUCT, this.selectors.length); - for (var iter293 in this.selectors) + for (var iter303 in this.selectors) { - if (this.selectors.hasOwnProperty(iter293)) + if (this.selectors.hasOwnProperty(iter303)) { - iter293 = this.selectors[iter293]; - iter293.write(output); + iter303 = this.selectors[iter303]; + iter303.write(output); } } output.writeListEnd(); @@ -2569,19 +2792,19 @@ Blur_fetchRowBatch_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size294 = 0; - var _rtmp3298; + var _size304 = 0; + var _rtmp3308; this.success = []; - var _etype297 = 0; - _rtmp3298 = input.readListBegin(); - _etype297 = _rtmp3298.etype; - _size294 = _rtmp3298.size; - for (var _i299 = 0; _i299 < _size294; ++_i299) + var _etype307 = 0; + _rtmp3308 = input.readListBegin(); + _etype307 = _rtmp3308.etype; + _size304 = _rtmp3308.size; + for (var _i309 = 0; _i309 < _size304; ++_i309) { - var elem300 = null; - elem300 = new FetchResult(); - elem300.read(input); - this.success.push(elem300); + var elem310 = null; + elem310 = new FetchResult(); + elem310.read(input); + this.success.push(elem310); } input.readListEnd(); } else { @@ -2610,12 +2833,12 @@ Blur_fetchRowBatch_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRUCT, this.success.length); - for (var iter301 in this.success) + for (var iter311 in this.success) { - if (this.success.hasOwnProperty(iter301)) + if (this.success.hasOwnProperty(iter311)) { - iter301 = this.success[iter301]; - iter301.write(output); + iter311 = this.success[iter311]; + iter311.write(output); } } output.writeListEnd(); @@ -2879,19 +3102,19 @@ Blur_mutateBatch_args.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.LIST) { - var _size302 = 0; - var _rtmp3306; + var _size312 = 0; + var _rtmp3316; this.mutations = []; - var _etype305 = 0; - _rtmp3306 = input.readListBegin(); - _etype305 = _rtmp3306.etype; - _size302 = _rtmp3306.size; - for (var _i307 = 0; _i307 < _size302; ++_i307) + var _etype315 = 0; + _rtmp3316 = input.readListBegin(); + _etype315 = _rtmp3316.etype; + _size312 = _rtmp3316.size; + for (var _i317 = 0; _i317 < _size312; ++_i317) { - var elem308 = null; - elem308 = new RowMutation(); - elem308.read(input); - this.mutations.push(elem308); + var elem318 = null; + elem318 = new RowMutation(); + elem318.read(input); + this.mutations.push(elem318); } input.readListEnd(); } else { @@ -2915,12 +3138,12 @@ Blur_mutateBatch_args.prototype.write = function(output) { if (this.mutations !== null && this.mutations !== undefined) { output.writeFieldBegin('mutations', Thrift.Type.LIST, 1); output.writeListBegin(Thrift.Type.STRUCT, this.mutations.length); - for (var iter309 in this.mutations) + for (var iter319 in this.mutations) { - if (this.mutations.hasOwnProperty(iter309)) + if (this.mutations.hasOwnProperty(iter319)) { - iter309 = this.mutations[iter309]; - iter309.write(output); + iter319 = this.mutations[iter319]; + iter319.write(output); } } output.writeListEnd(); @@ -3013,19 +3236,19 @@ Blur_enqueueMutateBatch_args.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.LIST) { - var _size310 = 0; - var _rtmp3314; + var _size320 = 0; + var _rtmp3324; this.mutations = []; - var _etype313 = 0; - _rtmp3314 = input.readListBegin(); - _etype313 = _rtmp3314.etype; - _size310 = _rtmp3314.size; - for (var _i315 = 0; _i315 < _size310; ++_i315) + var _etype323 = 0; + _rtmp3324 = input.readListBegin(); + _etype323 = _rtmp3324.etype; + _size320 = _rtmp3324.size; + for (var _i325 = 0; _i325 < _size320; ++_i325) { - var elem316 = null; - elem316 = new RowMutation(); - elem316.read(input); - this.mutations.push(elem316); + var elem326 = null; + elem326 = new RowMutation(); + elem326.read(input); + this.mutations.push(elem326); } input.readListEnd(); } else { @@ -3049,12 +3272,12 @@ Blur_enqueueMutateBatch_args.prototype.write = function(output) { if (this.mutations !== null && this.mutations !== undefined) { output.writeFieldBegin('mutations', Thrift.Type.LIST, 1); output.writeListBegin(Thrift.Type.STRUCT, this.mutations.length); - for (var iter317 in this.mutations) + for (var iter327 in this.mutations) { - if (this.mutations.hasOwnProperty(iter317)) + if (this.mutations.hasOwnProperty(iter327)) { - iter317 = this.mutations[iter317]; - iter317.write(output); + iter327 = this.mutations[iter327]; + iter327.write(output); } } output.writeListEnd(); @@ -3332,18 +3555,18 @@ Blur_queryStatusIdList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size318 = 0; - var _rtmp3322; + var _size328 = 0; + var _rtmp3332; this.success = []; - var _etype321 = 0; - _rtmp3322 = input.readListBegin(); - _etype321 = _rtmp3322.etype; - _size318 = _rtmp3322.size; - for (var _i323 = 0; _i323 < _size318; ++_i323) + var _etype331 = 0; + _rtmp3332 = input.readListBegin(); + _etype331 = _rtmp3332.etype; + _size328 = _rtmp3332.size; + for (var _i333 = 0; _i333 < _size328; ++_i333) { - var elem324 = null; - elem324 = input.readString().value; - this.success.push(elem324); + var elem334 = null; + elem334 = input.readString().value; + this.success.push(elem334); } input.readListEnd(); } else { @@ -3372,12 +3595,12 @@ Blur_queryStatusIdList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter325 in this.success) + for (var iter335 in this.success) { - if (this.success.hasOwnProperty(iter325)) + if (this.success.hasOwnProperty(iter335)) { - iter325 = this.success[iter325]; - output.writeString(iter325); + iter335 = this.success[iter335]; + output.writeString(iter335); } } output.writeListEnd(); @@ -3677,18 +3900,18 @@ Blur_terms_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size326 = 0; - var _rtmp3330; + var _size336 = 0; + var _rtmp3340; this.success = []; - var _etype329 = 0; - _rtmp3330 = input.readListBegin(); - _etype329 = _rtmp3330.etype; - _size326 = _rtmp3330.size; - for (var _i331 = 0; _i331 < _size326; ++_i331) + var _etype339 = 0; + _rtmp3340 = input.readListBegin(); + _etype339 = _rtmp3340.etype; + _size336 = _rtmp3340.size; + for (var _i341 = 0; _i341 < _size336; ++_i341) { - var elem332 = null; - elem332 = input.readString().value; - this.success.push(elem332); + var elem342 = null; + elem342 = input.readString().value; + this.success.push(elem342); } input.readListEnd(); } else { @@ -3717,12 +3940,12 @@ Blur_terms_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter333 in this.success) + for (var iter343 in this.success) { - if (this.success.hasOwnProperty(iter333)) + if (this.success.hasOwnProperty(iter343)) { - iter333 = this.success[iter333]; - output.writeString(iter333); + iter343 = this.success[iter343]; + output.writeString(iter343); } } output.writeListEnd(); @@ -3967,18 +4190,18 @@ Blur_shardClusterList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size334 = 0; - var _rtmp3338; + var _size344 = 0; + var _rtmp3348; this.success = []; - var _etype337 = 0; - _rtmp3338 = input.readListBegin(); - _etype337 = _rtmp3338.etype; - _size334 = _rtmp3338.size; - for (var _i339 = 0; _i339 < _size334; ++_i339) + var _etype347 = 0; + _rtmp3348 = input.readListBegin(); + _etype347 = _rtmp3348.etype; + _size344 = _rtmp3348.size; + for (var _i349 = 0; _i349 < _size344; ++_i349) { - var elem340 = null; - elem340 = input.readString().value; - this.success.push(elem340); + var elem350 = null; + elem350 = input.readString().value; + this.success.push(elem350); } input.readListEnd(); } else { @@ -4007,12 +4230,12 @@ Blur_shardClusterList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter341 in this.success) + for (var iter351 in this.success) { - if (this.success.hasOwnProperty(iter341)) + if (this.success.hasOwnProperty(iter351)) { - iter341 = this.success[iter341]; - output.writeString(iter341); + iter351 = this.success[iter351]; + output.writeString(iter351); } } output.writeListEnd(); @@ -4113,18 +4336,18 @@ Blur_shardServerList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size342 = 0; - var _rtmp3346; + var _size352 = 0; + var _rtmp3356; this.success = []; - var _etype345 = 0; - _rtmp3346 = input.readListBegin(); - _etype345 = _rtmp3346.etype; - _size342 = _rtmp3346.size; - for (var _i347 = 0; _i347 < _size342; ++_i347) + var _etype355 = 0; + _rtmp3356 = input.readListBegin(); + _etype355 = _rtmp3356.etype; + _size352 = _rtmp3356.size; + for (var _i357 = 0; _i357 < _size352; ++_i357) { - var elem348 = null; - elem348 = input.readString().value; - this.success.push(elem348); + var elem358 = null; + elem358 = input.readString().value; + this.success.push(elem358); } input.readListEnd(); } else { @@ -4153,12 +4376,12 @@ Blur_shardServerList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter349 in this.success) + for (var iter359 in this.success) { - if (this.success.hasOwnProperty(iter349)) + if (this.success.hasOwnProperty(iter359)) { - iter349 = this.success[iter349]; - output.writeString(iter349); + iter359 = this.success[iter359]; + output.writeString(iter359); } } output.writeListEnd(); @@ -4234,18 +4457,18 @@ Blur_controllerServerList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size350 = 0; - var _rtmp3354; + var _size360 = 0; + var _rtmp3364; this.success = []; - var _etype353 = 0; - _rtmp3354 = input.readListBegin(); - _etype353 = _rtmp3354.etype; - _size350 = _rtmp3354.size; - for (var _i355 = 0; _i355 < _size350; ++_i355) + var _etype363 = 0; + _rtmp3364 = input.readListBegin(); + _etype363 = _rtmp3364.etype; + _size360 = _rtmp3364.size; + for (var _i365 = 0; _i365 < _size360; ++_i365) { - var elem356 = null; - elem356 = input.readString().value; - this.success.push(elem356); + var elem366 = null; + elem366 = input.readString().value; + this.success.push(elem366); } input.readListEnd(); } else { @@ -4274,12 +4497,12 @@ Blur_controllerServerList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter357 in this.success) + for (var iter367 in this.success) { - if (this.success.hasOwnProperty(iter357)) + if (this.success.hasOwnProperty(iter367)) { - iter357 = this.success[iter357]; - output.writeString(iter357); + iter367 = this.success[iter367]; + output.writeString(iter367); } } output.writeListEnd(); @@ -4380,27 +4603,27 @@ Blur_shardServerLayout_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size358 = 0; - var _rtmp3362; + var _size368 = 0; + var _rtmp3372; this.success = {}; - var _ktype359 = 0; - var _vtype360 = 0; - _rtmp3362 = input.readMapBegin(); - _ktype359 = _rtmp3362.ktype; - _vtype360 = _rtmp3362.vtype; - _size358 = _rtmp3362.size; - for (var _i363 = 0; _i363 < _size358; ++_i363) + var _ktype369 = 0; + var _vtype370 = 0; + _rtmp3372 = input.readMapBegin(); + _ktype369 = _rtmp3372.ktype; + _vtype370 = _rtmp3372.vtype; + _size368 = _rtmp3372.size; + for (var _i373 = 0; _i373 < _size368; ++_i373) { - if (_i363 > 0 ) { + if (_i373 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key364 = null; - var val365 = null; - key364 = input.readString().value; - val365 = input.readString().value; - this.success[key364] = val365; + var key374 = null; + var val375 = null; + key374 = input.readString().value; + val375 = input.readString().value; + this.success[key374] = val375; } input.readMapEnd(); } else { @@ -4429,13 +4652,13 @@ Blur_shardServerLayout_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.MAP, 0); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.success)); - for (var kiter366 in this.success) + for (var kiter376 in this.success) { - if (this.success.hasOwnProperty(kiter366)) + if (this.success.hasOwnProperty(kiter376)) { - var viter367 = this.success[kiter366]; - output.writeString(kiter366); - output.writeString(viter367); + var viter377 = this.success[kiter376]; + output.writeString(kiter376); + output.writeString(viter377); } } output.writeMapEnd(); @@ -4536,49 +4759,49 @@ Blur_shardServerLayoutState_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size368 = 0; - var _rtmp3372; + var _size378 = 0; + var _rtmp3382; this.success = {}; - var _ktype369 = 0; - var _vtype370 = 0; - _rtmp3372 = input.readMapBegin(); - _ktype369 = _rtmp3372.ktype; - _vtype370 = _rtmp3372.vtype; - _size368 = _rtmp3372.size; - for (var _i373 = 0; _i373 < _size368; ++_i373) + var _ktype379 = 0; + var _vtype380 = 0; + _rtmp3382 = input.readMapBegin(); + _ktype379 = _rtmp3382.ktype; + _vtype380 = _rtmp3382.vtype; + _size378 = _rtmp3382.size; + for (var _i383 = 0; _i383 < _size378; ++_i383) { - if (_i373 > 0 ) { + if (_i383 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key374 = null; - var val375 = null; - key374 = input.readString().value; - var _size376 = 0; - var _rtmp3380; - val375 = {}; - var _ktype377 = 0; - var _vtype378 = 0; - _rtmp3380 = input.readMapBegin(); - _ktype377 = _rtmp3380.ktype; - _vtype378 = _rtmp3380.vtype; - _size376 = _rtmp3380.size; - for (var _i381 = 0; _i381 < _size376; ++_i381) + var key384 = null; + var val385 = null; + key384 = input.readString().value; + var _size386 = 0; + var _rtmp3390; + val385 = {}; + var _ktype387 = 0; + var _vtype388 = 0; + _rtmp3390 = input.readMapBegin(); + _ktype387 = _rtmp3390.ktype; + _vtype388 = _rtmp3390.vtype; + _size386 = _rtmp3390.size; + for (var _i391 = 0; _i391 < _size386; ++_i391) { - if (_i381 > 0 ) { + if (_i391 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key382 = null; - var val383 = null; - key382 = input.readString().value; - val383 = input.readI32().value; - val375[key382] = val383; + var key392 = null; + var val393 = null; + key392 = input.readString().value; + val393 = input.readI32().value; + val385[key392] = val393; } input.readMapEnd(); - this.success[key374] = val375; + this.success[key384] = val385; } input.readMapEnd(); } else { @@ -4607,20 +4830,20 @@ Blur_shardServerLayoutState_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.MAP, 0); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.MAP, Thrift.objectLength(this.success)); - for (var kiter384 in this.success) + for (var kiter394 in this.success) { - if (this.success.hasOwnProperty(kiter384)) + if (this.success.hasOwnProperty(kiter394)) { - var viter385 = this.success[kiter384]; - output.writeString(kiter384); - output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.I32, Thrift.objectLength(viter385)); - for (var kiter386 in viter385) + var viter395 = this.success[kiter394]; + output.writeString(kiter394); + output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.I32, Thrift.objectLength(viter395)); + for (var kiter396 in viter395) { - if (viter385.hasOwnProperty(kiter386)) + if (viter395.hasOwnProperty(kiter396)) { - var viter387 = viter385[kiter386]; - output.writeString(kiter386); - output.writeI32(viter387); + var viter397 = viter395[kiter396]; + output.writeString(kiter396); + output.writeI32(viter397); } } output.writeMapEnd(); @@ -4823,27 +5046,27 @@ Blur_configuration_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size388 = 0; - var _rtmp3392; + var _size398 = 0; + var _rtmp3402; this.success = {}; - var _ktype389 = 0; - var _vtype390 = 0; - _rtmp3392 = input.readMapBegin(); - _ktype389 = _rtmp3392.ktype; - _vtype390 = _rtmp3392.vtype; - _size388 = _rtmp3392.size; - for (var _i393 = 0; _i393 < _size388; ++_i393) + var _ktype399 = 0; + var _vtype400 = 0; + _rtmp3402 = input.readMapBegin(); + _ktype399 = _rtmp3402.ktype; + _vtype400 = _rtmp3402.vtype; + _size398 = _rtmp3402.size; + for (var _i403 = 0; _i403 < _size398; ++_i403) { - if (_i393 > 0 ) { + if (_i403 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key394 = null; - var val395 = null; - key394 = input.readString().value; - val395 = input.readString().value; - this.success[key394] = val395; + var key404 = null; + var val405 = null; + key404 = input.readString().value; + val405 = input.readString().value; + this.success[key404] = val405; } input.readMapEnd(); } else { @@ -4872,13 +5095,13 @@ Blur_configuration_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.MAP, 0); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRING, Thrift.objectLength(this.success)); - for (var kiter396 in this.success) + for (var kiter406 in this.success) { - if (this.success.hasOwnProperty(kiter396)) + if (this.success.hasOwnProperty(kiter406)) { - var viter397 = this.success[kiter396]; - output.writeString(kiter396); - output.writeString(viter397); + var viter407 = this.success[kiter406]; + output.writeString(kiter406); + output.writeString(viter407); } } output.writeMapEnd(); @@ -4918,18 +5141,18 @@ Blur_metrics_args.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.SET) { - var _size398 = 0; - var _rtmp3402; + var _size408 = 0; + var _rtmp3412; this.metrics = []; - var _etype401 = 0; - _rtmp3402 = input.readSetBegin(); - _etype401 = _rtmp3402.etype; - _size398 = _rtmp3402.size; - for (var _i403 = 0; _i403 < _size398; ++_i403) + var _etype411 = 0; + _rtmp3412 = input.readSetBegin(); + _etype411 = _rtmp3412.etype; + _size408 = _rtmp3412.size; + for (var _i413 = 0; _i413 < _size408; ++_i413) { - var elem404 = null; - elem404 = input.readString().value; - this.metrics.push(elem404); + var elem414 = null; + elem414 = input.readString().value; + this.metrics.push(elem414); } input.readSetEnd(); } else { @@ -4953,12 +5176,12 @@ Blur_metrics_args.prototype.write = function(output) { if (this.metrics !== null && this.metrics !== undefined) { output.writeFieldBegin('metrics', Thrift.Type.SET, 1); output.writeSetBegin(Thrift.Type.STRING, this.metrics.length); - for (var iter405 in this.metrics) + for (var iter415 in this.metrics) { - if (this.metrics.hasOwnProperty(iter405)) + if (this.metrics.hasOwnProperty(iter415)) { - iter405 = this.metrics[iter405]; - output.writeString(iter405); + iter415 = this.metrics[iter415]; + output.writeString(iter415); } } output.writeSetEnd(); @@ -5001,28 +5224,28 @@ Blur_metrics_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.MAP) { - var _size406 = 0; - var _rtmp3410; + var _size416 = 0; + var _rtmp3420; this.success = {}; - var _ktype407 = 0; - var _vtype408 = 0; - _rtmp3410 = input.readMapBegin(); - _ktype407 = _rtmp3410.ktype; - _vtype408 = _rtmp3410.vtype; - _size406 = _rtmp3410.size; - for (var _i411 = 0; _i411 < _size406; ++_i411) + var _ktype417 = 0; + var _vtype418 = 0; + _rtmp3420 = input.readMapBegin(); + _ktype417 = _rtmp3420.ktype; + _vtype418 = _rtmp3420.vtype; + _size416 = _rtmp3420.size; + for (var _i421 = 0; _i421 < _size416; ++_i421) { - if (_i411 > 0 ) { + if (_i421 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key412 = null; - var val413 = null; - key412 = input.readString().value; - val413 = new Metric(); - val413.read(input); - this.success[key412] = val413; + var key422 = null; + var val423 = null; + key422 = input.readString().value; + val423 = new Metric(); + val423.read(input); + this.success[key422] = val423; } input.readMapEnd(); } else { @@ -5051,13 +5274,13 @@ Blur_metrics_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.MAP, 0); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRUCT, Thrift.objectLength(this.success)); - for (var kiter414 in this.success) + for (var kiter424 in this.success) { - if (this.success.hasOwnProperty(kiter414)) + if (this.success.hasOwnProperty(kiter424)) { - var viter415 = this.success[kiter414]; - output.writeString(kiter414); - viter415.write(output); + var viter425 = this.success[kiter424]; + output.writeString(kiter424); + viter425.write(output); } } output.writeMapEnd(); @@ -5227,18 +5450,18 @@ Blur_traceList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size416 = 0; - var _rtmp3420; + var _size426 = 0; + var _rtmp3430; this.success = []; - var _etype419 = 0; - _rtmp3420 = input.readListBegin(); - _etype419 = _rtmp3420.etype; - _size416 = _rtmp3420.size; - for (var _i421 = 0; _i421 < _size416; ++_i421) + var _etype429 = 0; + _rtmp3430 = input.readListBegin(); + _etype429 = _rtmp3430.etype; + _size426 = _rtmp3430.size; + for (var _i431 = 0; _i431 < _size426; ++_i431) { - var elem422 = null; - elem422 = input.readString().value; - this.success.push(elem422); + var elem432 = null; + elem432 = input.readString().value; + this.success.push(elem432); } input.readListEnd(); } else { @@ -5267,12 +5490,12 @@ Blur_traceList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter423 in this.success) + for (var iter433 in this.success) { - if (this.success.hasOwnProperty(iter423)) + if (this.success.hasOwnProperty(iter433)) { - iter423 = this.success[iter423]; - output.writeString(iter423); + iter433 = this.success[iter433]; + output.writeString(iter433); } } output.writeListEnd(); @@ -5373,18 +5596,18 @@ Blur_traceRequestList_result.prototype.read = function(input) { { case 0: if (ftype == Thrift.Type.LIST) { - var _size424 = 0; - var _rtmp3428; + var _size434 = 0; + var _rtmp3438; this.success = []; - var _etype427 = 0; - _rtmp3428 = input.readListBegin(); - _etype427 = _rtmp3428.etype; - _size424 = _rtmp3428.size; - for (var _i429 = 0; _i429 < _size424; ++_i429) + var _etype437 = 0; + _rtmp3438 = input.readListBegin(); + _etype437 = _rtmp3438.etype; + _size434 = _rtmp3438.size; + for (var _i439 = 0; _i439 < _size434; ++_i439) { - var elem430 = null; - elem430 = input.readString().value; - this.success.push(elem430); + var elem440 = null; + elem440 = input.readString().value; + this.success.push(elem440); } input.readListEnd(); } else { @@ -5413,12 +5636,12 @@ Blur_traceRequestList_result.prototype.write = function(output) { if (this.success !== null && this.success !== undefined) { output.writeFieldBegin('success', Thrift.Type.LIST, 0); output.writeListBegin(Thrift.Type.STRING, this.success.length); - for (var iter431 in this.success) + for (var iter441 in this.success) { - if (this.success.hasOwnProperty(iter431)) + if (this.success.hasOwnProperty(iter441)) { - iter431 = this.success[iter431]; - output.writeString(iter431); + iter441 = this.success[iter441]; + output.writeString(iter441); } } output.writeListEnd(); @@ -5985,14 +6208,68 @@ BlurClient.prototype.recv_execute = function() { result.read(this.input); this.input.readMessageEnd(); - if (null !== result.ex) { - throw result.ex; + if (null !== result.bex) { + throw result.bex; + } + if (null !== result.tex) { + throw result.tex; } if (null !== result.success) { return result.success; } throw 'execute failed: unknown result'; }; +BlurClient.prototype.reconnect = function(executionId) { + this.send_reconnect(executionId); + return this.recv_reconnect(); +}; + +BlurClient.prototype.send_reconnect = function(executionId) { + this.output.writeMessageBegin('reconnect', Thrift.MessageType.CALL, this.seqid); + var args = new Blur_reconnect_args(); + args.executionId = executionId; + args.write(this.output); + this.output.writeMessageEnd(); + return this.output.getTransport().flush(); +}; + +BlurClient.prototype.recv_reconnect = function() { + var ret = this.input.readMessageBegin(); + var fname = ret.fname; + var mtype = ret.mtype; + var rseqid = ret.rseqid; + if (mtype == Thrift.MessageType.EXCEPTION) { + var x = new Thrift.TApplicationException(); + x.read(this.input); + this.input.readMessageEnd(); + throw x; + } + var result = new Blur_reconnect_result(); + result.read(this.input); + this.input.readMessageEnd(); + + if (null !== result.bex) { + throw result.bex; + } + if (null !== result.tex) { + throw result.tex; + } + if (null !== result.success) { + return result.success; + } + throw 'reconnect failed: unknown result'; +}; +BlurClient.prototype.refresh = function() { + this.send_refresh(); +}; + +BlurClient.prototype.send_refresh = function() { + this.output.writeMessageBegin('refresh', Thrift.MessageType.CALL, this.seqid); + var args = new Blur_refresh_args(); + args.write(this.output); + this.output.writeMessageEnd(); + return this.output.getTransport().flush(); +}; BlurClient.prototype.createTable = function(tableDescriptor) { this.send_createTable(tableDescriptor); this.recv_createTable();
http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/b434b067/distribution/src/main/scripts/interface/gen-js/Blur_types.js ---------------------------------------------------------------------- diff --git a/distribution/src/main/scripts/interface/gen-js/Blur_types.js b/distribution/src/main/scripts/interface/gen-js/Blur_types.js index 97e02d0..963aef5 100644 --- a/distribution/src/main/scripts/interface/gen-js/Blur_types.js +++ b/distribution/src/main/scripts/interface/gen-js/Blur_types.js @@ -139,6 +139,60 @@ BlurException.prototype.write = function(output) { return; }; +TimeoutException = function(args) { + this.executionId = null; + if (args) { + if (args.executionId !== undefined) { + this.executionId = args.executionId; + } + } +}; +Thrift.inherits(TimeoutException, Thrift.TException); +TimeoutException.prototype.name = 'TimeoutException'; +TimeoutException.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.executionId = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 0: + input.skip(ftype); + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +TimeoutException.prototype.write = function(output) { + output.writeStructBegin('TimeoutException'); + if (this.executionId !== null && this.executionId !== undefined) { + output.writeFieldBegin('executionId', Thrift.Type.STRING, 1); + output.writeString(this.executionId); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + User = function(args) { this.username = null; this.attributes = null; @@ -3834,13 +3888,123 @@ Value.prototype.write = function(output) { return; }; +Shard = function(args) { + this.shard = null; + if (args) { + if (args.shard !== undefined) { + this.shard = args.shard; + } + } +}; +Shard.prototype = {}; +Shard.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.shard = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 0: + input.skip(ftype); + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Shard.prototype.write = function(output) { + output.writeStructBegin('Shard'); + if (this.shard !== null && this.shard !== undefined) { + output.writeFieldBegin('shard', Thrift.Type.STRING, 1); + output.writeString(this.shard); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + +Server = function(args) { + this.server = null; + if (args) { + if (args.server !== undefined) { + this.server = args.server; + } + } +}; +Server.prototype = {}; +Server.prototype.read = function(input) { + input.readStructBegin(); + while (true) + { + var ret = input.readFieldBegin(); + var fname = ret.fname; + var ftype = ret.ftype; + var fid = ret.fid; + if (ftype == Thrift.Type.STOP) { + break; + } + switch (fid) + { + case 1: + if (ftype == Thrift.Type.STRING) { + this.server = input.readString().value; + } else { + input.skip(ftype); + } + break; + case 0: + input.skip(ftype); + break; + default: + input.skip(ftype); + } + input.readFieldEnd(); + } + input.readStructEnd(); + return; +}; + +Server.prototype.write = function(output) { + output.writeStructBegin('Server'); + if (this.server !== null && this.server !== undefined) { + output.writeFieldBegin('server', Thrift.Type.STRING, 1); + output.writeString(this.server); + output.writeFieldEnd(); + } + output.writeFieldStop(); + output.writeStructEnd(); + return; +}; + Response = function(args) { this.shardToValue = null; + this.serverToValue = null; this.value = null; if (args) { if (args.shardToValue !== undefined) { this.shardToValue = args.shardToValue; } + if (args.serverToValue !== undefined) { + this.serverToValue = args.serverToValue; + } if (args.value !== undefined) { this.value = args.value; } @@ -3880,7 +4044,8 @@ Response.prototype.read = function(input) { } var key238 = null; var val239 = null; - key238 = input.readString().value; + key238 = new Shard(); + key238.read(input); val239 = new Value(); val239.read(input); this.shardToValue[key238] = val239; @@ -3891,6 +4056,37 @@ Response.prototype.read = function(input) { } break; case 2: + if (ftype == Thrift.Type.MAP) { + var _size240 = 0; + var _rtmp3244; + this.serverToValue = {}; + var _ktype241 = 0; + var _vtype242 = 0; + _rtmp3244 = input.readMapBegin(); + _ktype241 = _rtmp3244.ktype; + _vtype242 = _rtmp3244.vtype; + _size240 = _rtmp3244.size; + for (var _i245 = 0; _i245 < _size240; ++_i245) + { + if (_i245 > 0 ) { + if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { + input.rstack.pop(); + } + } + var key246 = null; + var val247 = null; + key246 = new Server(); + key246.read(input); + val247 = new Value(); + val247.read(input); + this.serverToValue[key246] = val247; + } + input.readMapEnd(); + } else { + input.skip(ftype); + } + break; + case 3: if (ftype == Thrift.Type.STRUCT) { this.value = new Value(); this.value.read(input); @@ -3911,21 +4107,36 @@ Response.prototype.write = function(output) { output.writeStructBegin('Response'); if (this.shardToValue !== null && this.shardToValue !== undefined) { output.writeFieldBegin('shardToValue', Thrift.Type.MAP, 1); - output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRUCT, Thrift.objectLength(this.shardToValue)); - for (var kiter240 in this.shardToValue) + output.writeMapBegin(Thrift.Type.STRUCT, Thrift.Type.STRUCT, Thrift.objectLength(this.shardToValue)); + for (var kiter248 in this.shardToValue) { - if (this.shardToValue.hasOwnProperty(kiter240)) + if (this.shardToValue.hasOwnProperty(kiter248)) { - var viter241 = this.shardToValue[kiter240]; - output.writeString(kiter240); - viter241.write(output); + var viter249 = this.shardToValue[kiter248]; + kiter248.write(output); + viter249.write(output); + } + } + output.writeMapEnd(); + output.writeFieldEnd(); + } + if (this.serverToValue !== null && this.serverToValue !== undefined) { + output.writeFieldBegin('serverToValue', Thrift.Type.MAP, 2); + output.writeMapBegin(Thrift.Type.STRUCT, Thrift.Type.STRUCT, Thrift.objectLength(this.serverToValue)); + for (var kiter250 in this.serverToValue) + { + if (this.serverToValue.hasOwnProperty(kiter250)) + { + var viter251 = this.serverToValue[kiter250]; + kiter250.write(output); + viter251.write(output); } } output.writeMapEnd(); output.writeFieldEnd(); } if (this.value !== null && this.value !== undefined) { - output.writeFieldBegin('value', Thrift.Type.STRUCT, 2); + output.writeFieldBegin('value', Thrift.Type.STRUCT, 3); this.value.write(output); output.writeFieldEnd(); } @@ -3958,28 +4169,28 @@ Arguments.prototype.read = function(input) { { case 1: if (ftype == Thrift.Type.MAP) { - var _size242 = 0; - var _rtmp3246; + var _size252 = 0; + var _rtmp3256; this.values = {}; - var _ktype243 = 0; - var _vtype244 = 0; - _rtmp3246 = input.readMapBegin(); - _ktype243 = _rtmp3246.ktype; - _vtype244 = _rtmp3246.vtype; - _size242 = _rtmp3246.size; - for (var _i247 = 0; _i247 < _size242; ++_i247) + var _ktype253 = 0; + var _vtype254 = 0; + _rtmp3256 = input.readMapBegin(); + _ktype253 = _rtmp3256.ktype; + _vtype254 = _rtmp3256.vtype; + _size252 = _rtmp3256.size; + for (var _i257 = 0; _i257 < _size252; ++_i257) { - if (_i247 > 0 ) { + if (_i257 > 0 ) { if (input.rstack.length > input.rpos[input.rpos.length -1] + 1) { input.rstack.pop(); } } - var key248 = null; - var val249 = null; - key248 = input.readString().value; - val249 = new Value(); - val249.read(input); - this.values[key248] = val249; + var key258 = null; + var val259 = null; + key258 = input.readString().value; + val259 = new Value(); + val259.read(input); + this.values[key258] = val259; } input.readMapEnd(); } else { @@ -4003,13 +4214,13 @@ Arguments.prototype.write = function(output) { if (this.values !== null && this.values !== undefined) { output.writeFieldBegin('values', Thrift.Type.MAP, 1); output.writeMapBegin(Thrift.Type.STRING, Thrift.Type.STRUCT, Thrift.objectLength(this.values)); - for (var kiter250 in this.values) + for (var kiter260 in this.values) { - if (this.values.hasOwnProperty(kiter250)) + if (this.values.hasOwnProperty(kiter260)) { - var viter251 = this.values[kiter250]; - output.writeString(kiter250); - viter251.write(output); + var viter261 = this.values[kiter260]; + output.writeString(kiter260); + viter261.write(output); } } output.writeMapEnd();
