Skip to content

Commit 99eb00b

Browse files
committed
add dummy pid to peer info in tests
1 parent 83dde8e commit 99eb00b

File tree

4 files changed

+13
-10
lines changed

4 files changed

+13
-10
lines changed

Tests/GRPCCoreTests/Call/Client/Internal/ClientRPCExecutorTestSupport/ClientRPCExecutorTestHarness.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,13 +47,13 @@ struct ClientRPCExecutorTestHarness {
4747

4848
switch transport {
4949
case .inProcess:
50-
let server = InProcessTransport.Server(peer: "in-process")
50+
let server = InProcessTransport.Server(peer: "in-process:1234")
5151
let client = server.spawnClientTransport()
5252
self.serverTransport = StreamCountingServerTransport(wrapping: server)
5353
self.clientTransport = StreamCountingClientTransport(wrapping: client)
5454

5555
case .throwsOnStreamCreation(let code):
56-
let server = InProcessTransport.Server(peer: "in-process") // Will never be called.
56+
let server = InProcessTransport.Server(peer: "in-process:1234") // Will never be called.
5757
let client = ThrowOnStreamCreationTransport(code: code)
5858
self.serverTransport = StreamCountingServerTransport(wrapping: server)
5959
self.clientTransport = StreamCountingClientTransport(wrapping: client)

Tests/GRPCCoreTests/GRPCServerTests.swift

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -334,7 +334,10 @@ final class GRPCServerTests: XCTestCase {
334334
}
335335

336336
func testTestRunStoppedServer() async throws {
337-
let server = GRPCServer(transport: InProcessTransport.Server(peer: "in-process"), services: [])
337+
let server = GRPCServer(
338+
transport: InProcessTransport.Server(peer: "in-process:1234"),
339+
services: []
340+
)
338341
// Run the server.
339342
let task = Task { try await server.serve() }
340343
task.cancel()

Tests/GRPCInProcessTransportTests/InProcessClientTransportTests.swift

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,7 @@ final class InProcessClientTransportTests: XCTestCase {
142142
}
143143

144144
func testOpenStreamSuccessfullyAndThenClose() async throws {
145-
let server = InProcessTransport.Server(peer: "in-process")
145+
let server = InProcessTransport.Server(peer: "in-process:1234")
146146
let client = makeClient(server: server)
147147

148148
try await withThrowingTaskGroup(of: Void.self) { group in
@@ -199,7 +199,7 @@ final class InProcessClientTransportTests: XCTestCase {
199199
)
200200

201201
var client = InProcessTransport.Client(
202-
server: InProcessTransport.Server(peer: "in-process"),
202+
server: InProcessTransport.Server(peer: "in-process:1234"),
203203
serviceConfig: serviceConfig
204204
)
205205

@@ -223,7 +223,7 @@ final class InProcessClientTransportTests: XCTestCase {
223223
)
224224
serviceConfig.methodConfig.append(overrideConfiguration)
225225
client = InProcessTransport.Client(
226-
server: InProcessTransport.Server(peer: "in-process"),
226+
server: InProcessTransport.Server(peer: "in-process:1234"),
227227
serviceConfig: serviceConfig
228228
)
229229

@@ -239,7 +239,7 @@ final class InProcessClientTransportTests: XCTestCase {
239239
}
240240

241241
func testOpenMultipleStreamsThenClose() async throws {
242-
let server = InProcessTransport.Server(peer: "in-process")
242+
let server = InProcessTransport.Server(peer: "in-process:1234")
243243
let client = makeClient(server: server)
244244

245245
try await withThrowingTaskGroup(of: Void.self) { group in
@@ -269,7 +269,7 @@ final class InProcessClientTransportTests: XCTestCase {
269269
}
270270

271271
func makeClient(
272-
server: InProcessTransport.Server = InProcessTransport.Server(peer: "in-process")
272+
server: InProcessTransport.Server = InProcessTransport.Server(peer: "in-process:1234")
273273
) -> InProcessTransport.Client {
274274
let defaultPolicy = RetryPolicy(
275275
maxAttempts: 10,

Tests/GRPCInProcessTransportTests/InProcessServerTransportTests.swift

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ import XCTest
2121

2222
final class InProcessServerTransportTests: XCTestCase {
2323
func testStartListening() async throws {
24-
let transport = InProcessTransport.Server(peer: "in-process")
24+
let transport = InProcessTransport.Server(peer: "in-process:1234")
2525

2626
let outbound = GRPCAsyncThrowingStream.makeStream(of: RPCResponsePart.self)
2727
let stream = RPCStream<
@@ -53,7 +53,7 @@ final class InProcessServerTransportTests: XCTestCase {
5353
}
5454

5555
func testStopListening() async throws {
56-
let transport = InProcessTransport.Server(peer: "in-process")
56+
let transport = InProcessTransport.Server(peer: "in-process:1234")
5757

5858
let firstStreamOutbound = GRPCAsyncThrowingStream.makeStream(of: RPCResponsePart.self)
5959
let firstStream = RPCStream<

0 commit comments

Comments
 (0)