mirror
/
swift-nio-transport-services
mirror of https://github.com/apple/swift-nio-transport-services.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Complying with new NIOPooledRecvBufferAllocator naming.

This commit is contained in:
Rafael Cepeda 2025-05-08 16:19:36 +01:00
parent b196953882
commit c06c50e74d
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Package.swift
View File

@ -21,7 +21,7 @@ let package = Package(
.library(name: "NIOTransportServices", targets: ["NIOTransportServices"])
],
dependencies: [
.package(url: "https://github.com/apple/swift-nio.git", from: "2.62.0"),
.package(url: "https://github.com/apple/swift-nio.git", branch: "main"),
.package(url: "https://github.com/apple/swift-atomics.git", from: "1.0.2"),
],
targets: [

14
Sources/NIOTransportServices/NIOTSConnectionChannel.swift
View File

@ -231,11 +231,11 @@ internal final class NIOTSConnectionChannel: StateManagedNWConnectionChannel {
/// A lock that guards the _addressCache.
internal let _addressCacheLock = NIOLock()
/// The `PooledRecvBufferAllocator` used to allocate buffers for incoming data
internal var recvBufferPool: PooledRecvBufferAllocator
/// A constant to hold the maximum amount of buffers that should be created by the `PooledRecvBufferAllocator`
/// The `NIOPooledRecvBufferAllocator` used to allocate buffers for incoming data
internal var recvBufferPool: NIOPooledRecvBufferAllocator
/// A constant to hold the maximum amount of buffers that should be created by the `NIOPooledRecvBufferAllocator`
///
/// Once we allow multiple messages per read on the channel, this should become a `maxMessagesPerRead` property
/// and a corresponding channel option that users can configure.
@ -418,11 +418,11 @@ extension NIOTSConnectionChannel {
// It would be nice if we didn't have to do this copy, but I'm not sure how to avoid it with the current Data
// APIs.
let (buffer, bytesReceived) = self.recvBufferPool.buffer(allocator: allocator) { $0.writeBytes(content) }
self.recvBufferPool.record(actualReadBytes: bytesReceived)
self.pipeline.fireChannelRead(NIOAny(buffer))
self.pipeline.fireChannelReadComplete()
}
// Next, we want to check if there's an error. If there is, we're going to deliver it, and then close the connection with