@@ -11,43 +11,13 @@ public final class SFTPClient {
11
11
fileprivate let channel : Channel
12
12
13
13
/// A monotonically increasing counter for gneerating request IDs.
14
- /// Causes a race condition
15
- // private var nextRequestId: UInt32 = 0
16
-
17
- // private let syncQueue = DispatchQueue(label: "com.test.myQueue", attributes: .concurrent)
18
14
private var _nextRequestId : UInt32 = 0
19
15
20
16
@MainActor
21
17
private func incrementAndGetNextRequestId( ) -> UInt32 {
22
- // syncQueue.sync {
23
18
self . _nextRequestId &+= 1
24
19
return _nextRequestId
25
- // }
26
20
}
27
- // var nextRequestId: UInt32 {
28
- // get {
29
- // syncQueue.async(flags: .barrier) {
30
- // self.nextRequestId &+= 1
31
- // return _nextRequestId
32
- // }
33
- // }
34
- //// get {
35
- //// syncQueue.sync {
36
- //// print("In grab. \(self._nextRequestId)")
37
- //// return _nextRequestId
38
- //// }
39
- //// }
40
- //// incrementAndGrab() -> UInt32 {
41
- //// self.nextRequestId &+= 1
42
- //// }
43
- //// set {
44
- //// syncQueue.async(flags: .barrier) {
45
- //// print("In set. \(self._nextRequestId)")
46
- //// self._nextRequestId = newValue
47
- //// print("After set. \(self._nextRequestId)")
48
- //// }
49
- //// }
50
- // }
51
21
52
22
/// In-flight request ID tracker.
53
23
fileprivate let responses : SFTPResponses
@@ -101,10 +71,6 @@ public final class SFTPClient {
101
71
/// a response; that is handled by `sendRequest(_:)`.
102
72
@MainActor internal func allocateRequestId( ) -> UInt32 {
103
73
return incrementAndGetNextRequestId ( )
104
- // defer {
105
- // self.nextRequestId &+= 1
106
- // } syncQueue.sync {
107
- // return self.nextRequestId
108
74
}
109
75
110
76
/// Sends an SFTP request. The request's ID is used to track the response.
0 commit comments