Socket+File.swift 1.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253
  1. //
  2. // Socket+File.swift
  3. // Swifter
  4. //
  5. // Created by Damian Kolakowski on 13/07/16.
  6. //
  7. import Foundation
  8. #if os(iOS) || os(tvOS) || os (Linux)
  9. // swiftlint:disable type_name function_parameter_count
  10. struct sf_hdtr { }
  11. private func sendfileImpl(_ source: UnsafeMutablePointer<FILE>, _ target: Int32, _: off_t, _: UnsafeMutablePointer<off_t>, _: UnsafeMutablePointer<sf_hdtr>, _: Int32) -> Int32 {
  12. var buffer = [UInt8](repeating: 0, count: 1024)
  13. while true {
  14. let readResult = fread(&buffer, 1, buffer.count, source)
  15. guard readResult > 0 else {
  16. return Int32(readResult)
  17. }
  18. var writeCounter = 0
  19. while writeCounter < readResult {
  20. #if os(Linux)
  21. let writeResult = send(target, &buffer + writeCounter, readResult - writeCounter, Int32(MSG_NOSIGNAL))
  22. #else
  23. let writeResult = write(target, &buffer + writeCounter, readResult - writeCounter)
  24. #endif
  25. guard writeResult > 0 else {
  26. return Int32(writeResult)
  27. }
  28. writeCounter += writeResult
  29. }
  30. }
  31. }
  32. #endif
  33. extension Socket {
  34. public func writeFile(_ file: String.File) throws {
  35. var offset: off_t = 0
  36. var sf: sf_hdtr = sf_hdtr()
  37. #if os(iOS) || os(tvOS) || os (Linux)
  38. let result = sendfileImpl(file.pointer, self.socketFileDescriptor, 0, &offset, &sf, 0)
  39. #else
  40. let result = sendfile(fileno(file.pointer), self.socketFileDescriptor, 0, &offset, &sf, 0)
  41. #endif
  42. if result == -1 {
  43. throw SocketError.writeFailed("sendfile: " + Errno.description())
  44. }
  45. }
  46. }