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. 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. #if os(Linux)
  20. let writeResult = send(target, &buffer + writeCounter, readResult - writeCounter, Int32(MSG_NOSIGNAL))
  21. #else
  22. let writeResult = write(target, &buffer + writeCounter, readResult - writeCounter)
  23. #endif
  24. guard writeResult > 0 else {
  25. return Int32(writeResult)
  26. }
  27. writeCounter = writeCounter + writeResult
  28. }
  29. }
  30. }
  31. #endif
  32. extension Socket {
  33. public func writeFile(_ file: String.File) throws -> Void {
  34. var offset: off_t = 0
  35. var sf: sf_hdtr = sf_hdtr()
  36. #if os(iOS) || os(tvOS) || os (Linux)
  37. let result = sendfileImpl(file.pointer, self.socketFileDescriptor, 0, &offset, &sf, 0)
  38. #else
  39. let result = sendfile(fileno(file.pointer), self.socketFileDescriptor, 0, &offset, &sf, 0)
  40. #endif
  41. if result == -1 {
  42. throw SocketError.writeFailed("sendfile: " + Errno.description())
  43. }
  44. }
  45. }