1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
// **********************************************************************
//
// Copyright (c) 2003-2016 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
(function(module, require, exports)
{
var Ice = require("ice").Ice;
var Test = require("Test").Test;
var run = function(communicator, prx, Test, bidir)
{
var Promise = Ice.Promise;
var bs1, bs2, batch, batch2, batch3;
var p = new Promise();
var test = function(b)
{
if(!b)
{
try
{
throw new Error("test failed");
}
catch(err)
{
p.fail(err);
throw err;
}
}
};
Promise.try(() =>
{
var i;
bs1 = Ice.Buffer.createNative(new Array(10 * 1024));
for(i = 0; i < bs1.length; ++i)
{
bs1[i] = 0;
}
return prx.opByteSOnewayCallCount();
}
).then(count =>
{
batch = prx.ice_batchOneway();
return batch.ice_getConnection();
}
).then(() =>
{
test(batch.ice_flushBatchRequests().isCompleted()); // Empty flush
test(batch.ice_flushBatchRequests().isSent()); // Empty flush
test(batch.ice_flushBatchRequests().sentSynchronously()); // Empty flush
var all = [];
for(var i = 0; i < 30; ++i)
{
all[i] = batch.opByteSOneway(bs1);
}
return Promise.all(all).then(() =>
{
var wait = function(count)
{
if(count < 27) // 3 * 9 requests auto-flushed.
{
return Promise.delay(10)
.then(() => prx.opByteSOnewayCallCount())
.then(n => wait(n + count));
}
};
return wait(0);
});
}
).then(() =>
{
batch2 = prx.ice_batchOneway();
return Promise.all([batch.ice_ping(), batch2.ice_ping()]);
}
).then(count => batch.ice_flushBatchRequests()
).then(() => prx.opByteSOnewayCallCount()
).then(() => batch.ice_getConnection()
).then(con => bidir ? undefined : con.close(Ice.ConnectionClose.GracefullyWithWait)
).then(() => Promise.all([batch.ice_ping(), batch2.ice_ping()])
).then(() =>
{
var identity = Ice.stringToIdentity("invalid");
batch3 = batch.ice_identity(identity);
return batch3.ice_ping();
}
).then(() => batch3.ice_flushBatchRequests()
// Make sure that a bogus batch request doesn't cause troubles to other ones.
).then(() => Promise.all([batch3.ice_ping(), batch.ice_ping()])
).then(() => batch.ice_flushBatchRequests()
).then(() => prx.opByteSOnewayCallCount()
).then(p.resolve, p.reject);
return p;
};
exports.BatchOneways = { run: run };
}
(typeof(global) !== "undefined" && typeof(global.process) !== "undefined" ? module : undefined,
typeof(global) !== "undefined" && typeof(global.process) !== "undefined" ? require : this.Ice._require,
typeof(global) !== "undefined" && typeof(global.process) !== "undefined" ? exports : this));
|
