Use C integer types

Instead of using hardcoded fixed width integers, use C integer types.
As the actual integer size of C depends on the implementation, even if
it is often 32bit, we use the C integer types to guard against cases,
where that is not the case.
This commit is contained in:
T. R. Bernstein
2026-03-12 00:32:14 +01:00
parent e44e1fc9b8
commit d57f998fd4
2 changed files with 26 additions and 26 deletions

View File

@@ -2,8 +2,8 @@ import Dispatch
import CInotify
public actor Inotify {
private let fd: Int32
private var watches: [Int32: String] = [:]
private let fd: CInt
private var watches: [CInt: String] = [:]
private var eventReader: any DispatchSourceRead
private var eventStream: AsyncStream<RawInotifyEvent>
public var events: AsyncCompactMapSequence<AsyncStream<RawInotifyEvent>, InotifyEvent> {
@@ -11,7 +11,7 @@ public actor Inotify {
}
public init() throws {
self.fd = inotify_init1(Int32(IN_NONBLOCK | IN_CLOEXEC))
self.fd = inotify_init1(CInt(IN_NONBLOCK | IN_CLOEXEC))
guard self.fd >= 0 else {
throw InotifyError.initFailed(errno: cinotify_get_errno())
}
@@ -19,7 +19,7 @@ public actor Inotify {
}
@discardableResult
public func addWatch(path: String, mask: InotifyEventMask) throws -> Int32 {
public func addWatch(path: String, mask: InotifyEventMask) throws -> CInt {
let wd = inotify_add_watch(self.fd, path, mask.rawValue)
guard wd >= 0 else {
throw InotifyError.addWatchFailed(path: path, errno: cinotify_get_errno())
@@ -28,7 +28,7 @@ public actor Inotify {
return wd
}
public func removeWatch(_ wd: Int32) throws {
public func removeWatch(_ wd: CInt) throws {
guard inotify_rm_watch(self.fd, wd) == 0 else {
throw InotifyError.removeWatchFailed(watchDescriptor: wd, errno: cinotify_get_errno())
}
@@ -44,7 +44,7 @@ public actor Inotify {
return InotifyEvent.init(from: rawEvent, inDirectory: path)
}
private static func createEventReader(forFileDescriptor fd: Int32) -> (any DispatchSourceRead, AsyncStream<RawInotifyEvent>) {
private static func createEventReader(forFileDescriptor fd: CInt) -> (any DispatchSourceRead, AsyncStream<RawInotifyEvent>) {
let (stream, continuation) = AsyncStream<RawInotifyEvent>.makeStream(
of: RawInotifyEvent.self,
bufferingPolicy: .bufferingNewest(512)