-
Notifications
You must be signed in to change notification settings - Fork 265
Expand file tree
/
Copy pathVminitd+SocketRelay.swift
More file actions
48 lines (44 loc) · 1.97 KB
/
Vminitd+SocketRelay.swift
File metadata and controls
48 lines (44 loc) · 1.97 KB
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
//===----------------------------------------------------------------------===//
// Copyright © 2025 Apple Inc. and the Containerization project authors.
// All rights reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// https://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//===----------------------------------------------------------------------===//
extension Vminitd: SocketRelayAgent {
/// Sets up a relay between a host socket to a newly created guest socket, or vice versa.
public func relaySocket(port: UInt32, configuration: UnixSocketConfiguration) async throws {
let request = Com_Apple_Containerization_Sandbox_V3_ProxyVsockRequest.with {
$0.id = configuration.id
$0.vsockPort = port
if let perms = configuration.permissions {
$0.guestSocketPermissions = UInt32(perms.rawValue)
}
switch configuration.direction {
case .into:
$0.guestPath = configuration.to.path
$0.action = .into
case .outOf:
$0.guestPath = configuration.from.path
$0.action = .outOf
}
}
_ = try await client.proxyVsock(request)
}
/// Stops the specified socket relay.
public func stopSocketRelay(configuration: UnixSocketConfiguration) async throws {
let request = Com_Apple_Containerization_Sandbox_V3_StopVsockProxyRequest.with {
$0.id = configuration.id
}
_ = try await client.stopVsockProxy(request)
}
}