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
107
108
109
|
//
// Copyright (c) ZeroC, Inc. All rights reserved.
//
import Darwin
import Ice
import TestCommon
func batchOneways(_ helper: TestHelper, _ p: MyClassPrx) throws {
func test(_ value: Bool, file: String = #file, line: Int = #line) throws {
try helper.test(value, file: file, line: line)
}
let bs1 = ByteSeq(repeating: 0, count: 10 * 1024)
let batch = p.ice_batchOneway()
try batch.ice_flushBatchRequests() // Empty flush
_ = try p.opByteSOnewayCallCount() // Reset the call count
for _ in 0 ..< 30 {
do {
try batch.opByteSOneway(bs1)
} catch is Ice.MemoryLimitException {
try test(false)
}
}
var count: Int32 = 0
while count < 27 { // 3 * 9 requests auto-flushed.
count += try p.opByteSOnewayCallCount()
usleep(100)
}
var conn = try batch.ice_getConnection()
if conn != nil {
let batch1 = p.ice_batchOneway()
let batch2 = p.ice_batchOneway()
try batch1.ice_ping()
try batch2.ice_ping()
try batch1.ice_flushBatchRequests()
try batch1.ice_getConnection()!.close(Ice.ConnectionClose.GracefullyWithWait)
try batch1.ice_ping()
try batch2.ice_ping()
_ = try batch1.ice_getConnection()
_ = try batch2.ice_getConnection()
try batch1.ice_ping()
try batch1.ice_getConnection()!.close(Ice.ConnectionClose.GracefullyWithWait)
try batch1.ice_ping()
try batch2.ice_ping()
}
var identity = Ice.Identity()
identity.name = "invalid"
let batch3 = batch.ice_identity(identity)
try batch3.ice_ping()
try batch3.ice_flushBatchRequests()
// Make sure that a bogus batch request doesn't cause troubles to other ones.
try batch3.ice_ping()
try batch.ice_ping()
try batch.ice_flushBatchRequests()
try batch.ice_ping()
try p.ice_ping()
var supportsCompress = true
do {
supportsCompress = try p.supportsCompress()
} catch is Ice.OperationNotExistException {}
conn = try p.ice_getConnection()
if supportsCompress,
conn != nil,
p.ice_getCommunicator().getProperties().getProperty("Ice.Override.Compress") == "" {
let prx = try p.ice_getConnection()!.createProxy(p.ice_getIdentity()).ice_batchOneway()
let batchC1 = uncheckedCast(prx: prx.ice_compress(false), type: MyClassPrx.self)
let batchC2 = uncheckedCast(prx: prx.ice_compress(true), type: MyClassPrx.self)
let batchC3 = uncheckedCast(prx: prx.ice_identity(identity), type: MyClassPrx.self)
try batchC1.opByteSOneway(bs1)
try batchC1.opByteSOneway(bs1)
try batchC1.opByteSOneway(bs1)
try batchC1.ice_getConnection()!.flushBatchRequests(Ice.CompressBatch.Yes)
try batchC2.opByteSOneway(bs1)
try batchC2.opByteSOneway(bs1)
try batchC2.opByteSOneway(bs1)
try batchC1.ice_getConnection()!.flushBatchRequests(Ice.CompressBatch.No)
try batchC1.opByteSOneway(bs1)
try batchC1.opByteSOneway(bs1)
try batchC1.opByteSOneway(bs1)
try batchC1.ice_getConnection()!.flushBatchRequests(Ice.CompressBatch.BasedOnProxy)
try batchC1.opByteSOneway(bs1)
try batchC2.opByteSOneway(bs1)
try batchC1.opByteSOneway(bs1)
try batchC1.ice_getConnection()!.flushBatchRequests(Ice.CompressBatch.BasedOnProxy)
try batchC1.opByteSOneway(bs1)
try batchC3.opByteSOneway(bs1)
try batchC1.opByteSOneway(bs1)
try batchC1.ice_getConnection()!.flushBatchRequests(Ice.CompressBatch.BasedOnProxy)
}
}
|
