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
110
111
112
113
114
115
|
//
// Copyright (c) ZeroC, Inc. All rights reserved.
//
import Foundation
import Ice
import TestCommon
let testString = "This is a test string"
class Cookie {
func getString() -> String {
return testString
}
}
func allTests(_ helper: TestHelper) throws -> MyClassPrx {
func test(_ value: Bool, file: String = #file, line: Int = #line) throws {
try helper.test(value, file: file, line: line)
}
let output = helper.getWriter()
let communicator = helper.communicator()
let baseProxy = try communicator.stringToProxy("test:\(helper.getTestEndpoint(num: 0))")!
let cl = try checkedCast(prx: baseProxy, type: MyClassPrx.self)!
let oneway = cl.ice_oneway()
let batchOneway = cl.ice_batchOneway()
output.write("testing ice_invoke... ")
do {
try test(oneway.ice_invoke(operation: "opOneway", mode: .Normal, inEncaps: Data()).ok)
try test(batchOneway.ice_invoke(operation: "opOneway", mode: .Normal, inEncaps: Data()).ok)
try test(batchOneway.ice_invoke(operation: "opOneway", mode: .Normal, inEncaps: Data()).ok)
try test(batchOneway.ice_invoke(operation: "opOneway", mode: .Normal, inEncaps: Data()).ok)
try test(batchOneway.ice_invoke(operation: "opOneway", mode: .Normal, inEncaps: Data()).ok)
try batchOneway.ice_flushBatchRequests()
let outS = Ice.OutputStream(communicator: communicator)
outS.startEncapsulation()
outS.write(testString)
outS.endEncapsulation()
let inEncaps = outS.finished()
let result = try cl.ice_invoke(operation: "opString", mode: .Normal, inEncaps: inEncaps)
try test(result.ok)
let inS = Ice.InputStream(communicator: communicator, bytes: result.outEncaps)
_ = try inS.startEncapsulation()
var s: String = try inS.read()
try test(s == testString)
s = try inS.read()
try inS.endEncapsulation()
try test(s == testString)
}
for i in 0 ..< 2 {
var ctx: Ice.Context!
if i == 1 {
ctx = Ice.Context()
ctx["raise"] = ""
}
let result = try cl.ice_invoke(operation: "opException", mode: .Normal, inEncaps: Data(), context: ctx)
try test(!result.ok)
let inS = Ice.InputStream(communicator: communicator, bytes: result.outEncaps)
_ = try inS.startEncapsulation()
do {
try inS.throwException()
} catch is MyException {
try inS.endEncapsulation()
} catch {
try test(false)
}
}
output.writeLine("ok")
output.write("testing asynchronous ice_invoke... ")
do {
var result = try oneway.ice_invokeAsync(operation: "opOneway", mode: .Normal, inEncaps: Data()).wait()
try test(result.ok)
let outS = Ice.OutputStream(communicator: communicator)
outS.startEncapsulation()
outS.write(testString)
outS.endEncapsulation()
let inEncaps = outS.finished()
result = try cl.ice_invokeAsync(operation: "opString", mode: .Normal, inEncaps: inEncaps).wait()
try test(result.ok)
let inS = Ice.InputStream(communicator: communicator, bytes: result.outEncaps)
_ = try inS.startEncapsulation()
var s: String = try inS.read()
try test(s == testString)
s = try inS.read()
try inS.endEncapsulation()
try test(s == testString)
}
do {
let result = try cl.ice_invokeAsync(operation: "opException", mode: .Normal, inEncaps: Data()).wait()
try test(!result.ok)
let inS = Ice.InputStream(communicator: communicator, bytes: result.outEncaps)
_ = try inS.startEncapsulation()
do {
try inS.throwException()
} catch is MyException {
try inS.endEncapsulation()
} catch {
try test(false)
}
}
output.writeLine("ok")
return cl
}
|
