1
0

Socket+File.swift 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  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. struct sf_hdtr { }
  10. private func sendfileImpl(_ source: UnsafeMutablePointer<FILE>, _ target: Int32, _: off_t, _: UnsafeMutablePointer<off_t>, _: UnsafeMutablePointer<sf_hdtr>, _: Int32) -> Int32 {
  11. var buffer = [UInt8](repeating: 0, count: 1024)
  12. while true {
  13. let readResult = fread(&buffer, 1, buffer.count, source)
  14. guard readResult > 0 else {
  15. return Int32(readResult)
  16. }
  17. var writeCounter = 0
  18. while writeCounter < readResult {
  19. let writeResult = send(target, &buffer + writeCounter, readResult - writeCounter, Int32(MSG_NOSIGNAL))
  20. guard writeResult > 0 else {
  21. return Int32(writeResult)
  22. }
  23. writeCounter = writeCounter + writeResult
  24. }
  25. }
  26. }
  27. #endif
  28. extension Socket {
  29. public func writeFile(_ file: String.File) throws -> Void {
  30. var offset: off_t = 0
  31. var sf: sf_hdtr = sf_hdtr()
  32. #if os(iOS) || os(tvOS) || os (Linux)
  33. let result = sendfileImpl(file.pointer, self.socketFileDescriptor, 0, &offset, &sf, 0)
  34. #else
  35. let result = sendfile(fileno(file.pointer), self.socketFileDescriptor, 0, &offset, &sf, 0)
  36. #endif
  37. if result == -1 {
  38. throw SocketError.writeFailed("sendfile: " + Errno.description())
  39. }
  40. }
  41. }