GCDAsyncSocket.h 59 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226
  1. //
  2. // GCDAsyncSocket.h
  3. //
  4. // This class is in the public domain.
  5. // Originally created by Robbie Hanson in Q3 2010.
  6. // Updated and maintained by Deusty LLC and the Apple development community.
  7. //
  8. // https://github.com/robbiehanson/CocoaAsyncSocket
  9. //
  10. #import <Foundation/Foundation.h>
  11. #import <Security/Security.h>
  12. #import <Security/SecureTransport.h>
  13. #import <dispatch/dispatch.h>
  14. #import <Availability.h>
  15. #include <sys/socket.h> // AF_INET, AF_INET6
  16. @class GCDAsyncReadPacket;
  17. @class GCDAsyncWritePacket;
  18. @class GCDAsyncSocketPreBuffer;
  19. @protocol GCDAsyncSocketDelegate;
  20. NS_ASSUME_NONNULL_BEGIN
  21. extern NSString *const GCDAsyncSocketException;
  22. extern NSString *const GCDAsyncSocketErrorDomain;
  23. extern NSString *const GCDAsyncSocketQueueName;
  24. extern NSString *const GCDAsyncSocketThreadName;
  25. extern NSString *const GCDAsyncSocketManuallyEvaluateTrust;
  26. #if TARGET_OS_IPHONE
  27. extern NSString *const GCDAsyncSocketUseCFStreamForTLS;
  28. #endif
  29. #define GCDAsyncSocketSSLPeerName (NSString *)kCFStreamSSLPeerName
  30. #define GCDAsyncSocketSSLCertificates (NSString *)kCFStreamSSLCertificates
  31. #define GCDAsyncSocketSSLIsServer (NSString *)kCFStreamSSLIsServer
  32. extern NSString *const GCDAsyncSocketSSLPeerID;
  33. extern NSString *const GCDAsyncSocketSSLProtocolVersionMin;
  34. extern NSString *const GCDAsyncSocketSSLProtocolVersionMax;
  35. extern NSString *const GCDAsyncSocketSSLSessionOptionFalseStart;
  36. extern NSString *const GCDAsyncSocketSSLSessionOptionSendOneByteRecord;
  37. extern NSString *const GCDAsyncSocketSSLCipherSuites;
  38. extern NSString *const GCDAsyncSocketSSLALPN;
  39. #if !TARGET_OS_IPHONE
  40. extern NSString *const GCDAsyncSocketSSLDiffieHellmanParameters;
  41. #endif
  42. #define GCDAsyncSocketLoggingContext 65535
  43. typedef NS_ERROR_ENUM(GCDAsyncSocketErrorDomain, GCDAsyncSocketError) {
  44. GCDAsyncSocketNoError = 0, // Never used
  45. GCDAsyncSocketBadConfigError, // Invalid configuration
  46. GCDAsyncSocketBadParamError, // Invalid parameter was passed
  47. GCDAsyncSocketConnectTimeoutError, // A connect operation timed out
  48. GCDAsyncSocketReadTimeoutError, // A read operation timed out
  49. GCDAsyncSocketWriteTimeoutError, // A write operation timed out
  50. GCDAsyncSocketReadMaxedOutError, // Reached set maxLength without completing
  51. GCDAsyncSocketClosedError, // The remote peer closed the connection
  52. GCDAsyncSocketOtherError, // Description provided in userInfo
  53. };
  54. ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  55. #pragma mark -
  56. ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  57. @interface GCDAsyncSocket : NSObject
  58. /**
  59. * GCDAsyncSocket uses the standard delegate paradigm,
  60. * but executes all delegate callbacks on a given delegate dispatch queue.
  61. * This allows for maximum concurrency, while at the same time providing easy thread safety.
  62. *
  63. * You MUST set a delegate AND delegate dispatch queue before attempting to
  64. * use the socket, or you will get an error.
  65. *
  66. * The socket queue is optional.
  67. * If you pass NULL, GCDAsyncSocket will automatically create it's own socket queue.
  68. * If you choose to provide a socket queue, the socket queue must not be a concurrent queue.
  69. * If you choose to provide a socket queue, and the socket queue has a configured target queue,
  70. * then please see the discussion for the method markSocketQueueTargetQueue.
  71. *
  72. * The delegate queue and socket queue can optionally be the same.
  73. **/
  74. - (instancetype)init;
  75. - (instancetype)initWithSocketQueue:(nullable dispatch_queue_t)sq;
  76. - (instancetype)initWithDelegate:(nullable id<GCDAsyncSocketDelegate>)aDelegate delegateQueue:(nullable dispatch_queue_t)dq;
  77. - (instancetype)initWithDelegate:(nullable id<GCDAsyncSocketDelegate>)aDelegate delegateQueue:(nullable dispatch_queue_t)dq socketQueue:(nullable dispatch_queue_t)sq NS_DESIGNATED_INITIALIZER;
  78. /**
  79. * Create GCDAsyncSocket from already connect BSD socket file descriptor
  80. **/
  81. + (nullable instancetype)socketFromConnectedSocketFD:(int)socketFD socketQueue:(nullable dispatch_queue_t)sq error:(NSError**)error;
  82. + (nullable instancetype)socketFromConnectedSocketFD:(int)socketFD delegate:(nullable id<GCDAsyncSocketDelegate>)aDelegate delegateQueue:(nullable dispatch_queue_t)dq error:(NSError**)error;
  83. + (nullable instancetype)socketFromConnectedSocketFD:(int)socketFD delegate:(nullable id<GCDAsyncSocketDelegate>)aDelegate delegateQueue:(nullable dispatch_queue_t)dq socketQueue:(nullable dispatch_queue_t)sq error:(NSError **)error;
  84. #pragma mark Configuration
  85. @property (atomic, weak, readwrite, nullable) id<GCDAsyncSocketDelegate> delegate;
  86. #if OS_OBJECT_USE_OBJC
  87. @property (atomic, strong, readwrite, nullable) dispatch_queue_t delegateQueue;
  88. #else
  89. @property (atomic, assign, readwrite, nullable) dispatch_queue_t delegateQueue;
  90. #endif
  91. - (void)getDelegate:(id<GCDAsyncSocketDelegate> __nullable * __nullable)delegatePtr delegateQueue:(dispatch_queue_t __nullable * __nullable)delegateQueuePtr;
  92. - (void)setDelegate:(nullable id<GCDAsyncSocketDelegate>)delegate delegateQueue:(nullable dispatch_queue_t)delegateQueue;
  93. /**
  94. * If you are setting the delegate to nil within the delegate's dealloc method,
  95. * you may need to use the synchronous versions below.
  96. **/
  97. - (void)synchronouslySetDelegate:(nullable id<GCDAsyncSocketDelegate>)delegate;
  98. - (void)synchronouslySetDelegateQueue:(nullable dispatch_queue_t)delegateQueue;
  99. - (void)synchronouslySetDelegate:(nullable id<GCDAsyncSocketDelegate>)delegate delegateQueue:(nullable dispatch_queue_t)delegateQueue;
  100. /**
  101. * By default, both IPv4 and IPv6 are enabled.
  102. *
  103. * For accepting incoming connections, this means GCDAsyncSocket automatically supports both protocols,
  104. * and can simulataneously accept incoming connections on either protocol.
  105. *
  106. * For outgoing connections, this means GCDAsyncSocket can connect to remote hosts running either protocol.
  107. * If a DNS lookup returns only IPv4 results, GCDAsyncSocket will automatically use IPv4.
  108. * If a DNS lookup returns only IPv6 results, GCDAsyncSocket will automatically use IPv6.
  109. * If a DNS lookup returns both IPv4 and IPv6 results, the preferred protocol will be chosen.
  110. * By default, the preferred protocol is IPv4, but may be configured as desired.
  111. **/
  112. @property (atomic, assign, readwrite, getter=isIPv4Enabled) BOOL IPv4Enabled;
  113. @property (atomic, assign, readwrite, getter=isIPv6Enabled) BOOL IPv6Enabled;
  114. @property (atomic, assign, readwrite, getter=isIPv4PreferredOverIPv6) BOOL IPv4PreferredOverIPv6;
  115. /**
  116. * When connecting to both IPv4 and IPv6 using Happy Eyeballs (RFC 6555) https://tools.ietf.org/html/rfc6555
  117. * this is the delay between connecting to the preferred protocol and the fallback protocol.
  118. *
  119. * Defaults to 300ms.
  120. **/
  121. @property (atomic, assign, readwrite) NSTimeInterval alternateAddressDelay;
  122. /**
  123. * User data allows you to associate arbitrary information with the socket.
  124. * This data is not used internally by socket in any way.
  125. **/
  126. @property (atomic, strong, readwrite, nullable) id userData;
  127. #pragma mark Accepting
  128. /**
  129. * Tells the socket to begin listening and accepting connections on the given port.
  130. * When a connection is accepted, a new instance of GCDAsyncSocket will be spawned to handle it,
  131. * and the socket:didAcceptNewSocket: delegate method will be invoked.
  132. *
  133. * The socket will listen on all available interfaces (e.g. wifi, ethernet, etc)
  134. **/
  135. - (BOOL)acceptOnPort:(uint16_t)port error:(NSError **)errPtr;
  136. /**
  137. * This method is the same as acceptOnPort:error: with the
  138. * additional option of specifying which interface to listen on.
  139. *
  140. * For example, you could specify that the socket should only accept connections over ethernet,
  141. * and not other interfaces such as wifi.
  142. *
  143. * The interface may be specified by name (e.g. "en1" or "lo0") or by IP address (e.g. "192.168.4.34").
  144. * You may also use the special strings "localhost" or "loopback" to specify that
  145. * the socket only accept connections from the local machine.
  146. *
  147. * You can see the list of interfaces via the command line utility "ifconfig",
  148. * or programmatically via the getifaddrs() function.
  149. *
  150. * To accept connections on any interface pass nil, or simply use the acceptOnPort:error: method.
  151. **/
  152. - (BOOL)acceptOnInterface:(nullable NSString *)interface port:(uint16_t)port error:(NSError **)errPtr;
  153. /**
  154. * Tells the socket to begin listening and accepting connections on the unix domain at the given url.
  155. * When a connection is accepted, a new instance of GCDAsyncSocket will be spawned to handle it,
  156. * and the socket:didAcceptNewSocket: delegate method will be invoked.
  157. *
  158. * The socket will listen on all available interfaces (e.g. wifi, ethernet, etc)
  159. **/
  160. - (BOOL)acceptOnUrl:(NSURL *)url error:(NSError **)errPtr;
  161. #pragma mark Connecting
  162. /**
  163. * Connects to the given host and port.
  164. *
  165. * This method invokes connectToHost:onPort:viaInterface:withTimeout:error:
  166. * and uses the default interface, and no timeout.
  167. **/
  168. - (BOOL)connectToHost:(NSString *)host onPort:(uint16_t)port error:(NSError **)errPtr;
  169. /**
  170. * Connects to the given host and port with an optional timeout.
  171. *
  172. * This method invokes connectToHost:onPort:viaInterface:withTimeout:error: and uses the default interface.
  173. **/
  174. - (BOOL)connectToHost:(NSString *)host
  175. onPort:(uint16_t)port
  176. withTimeout:(NSTimeInterval)timeout
  177. error:(NSError **)errPtr;
  178. /**
  179. * Connects to the given host & port, via the optional interface, with an optional timeout.
  180. *
  181. * The host may be a domain name (e.g. "deusty.com") or an IP address string (e.g. "192.168.0.2").
  182. * The host may also be the special strings "localhost" or "loopback" to specify connecting
  183. * to a service on the local machine.
  184. *
  185. * The interface may be a name (e.g. "en1" or "lo0") or the corresponding IP address (e.g. "192.168.4.35").
  186. * The interface may also be used to specify the local port (see below).
  187. *
  188. * To not time out use a negative time interval.
  189. *
  190. * This method will return NO if an error is detected, and set the error pointer (if one was given).
  191. * Possible errors would be a nil host, invalid interface, or socket is already connected.
  192. *
  193. * If no errors are detected, this method will start a background connect operation and immediately return YES.
  194. * The delegate callbacks are used to notify you when the socket connects, or if the host was unreachable.
  195. *
  196. * Since this class supports queued reads and writes, you can immediately start reading and/or writing.
  197. * All read/write operations will be queued, and upon socket connection,
  198. * the operations will be dequeued and processed in order.
  199. *
  200. * The interface may optionally contain a port number at the end of the string, separated by a colon.
  201. * This allows you to specify the local port that should be used for the outgoing connection. (read paragraph to end)
  202. * To specify both interface and local port: "en1:8082" or "192.168.4.35:2424".
  203. * To specify only local port: ":8082".
  204. * Please note this is an advanced feature, and is somewhat hidden on purpose.
  205. * You should understand that 99.999% of the time you should NOT specify the local port for an outgoing connection.
  206. * If you think you need to, there is a very good chance you have a fundamental misunderstanding somewhere.
  207. * Local ports do NOT need to match remote ports. In fact, they almost never do.
  208. * This feature is here for networking professionals using very advanced techniques.
  209. **/
  210. - (BOOL)connectToHost:(NSString *)host
  211. onPort:(uint16_t)port
  212. viaInterface:(nullable NSString *)interface
  213. withTimeout:(NSTimeInterval)timeout
  214. error:(NSError **)errPtr;
  215. /**
  216. * Connects to the given address, specified as a sockaddr structure wrapped in a NSData object.
  217. * For example, a NSData object returned from NSNetService's addresses method.
  218. *
  219. * If you have an existing struct sockaddr you can convert it to a NSData object like so:
  220. * struct sockaddr sa -> NSData *dsa = [NSData dataWithBytes:&remoteAddr length:remoteAddr.sa_len];
  221. * struct sockaddr *sa -> NSData *dsa = [NSData dataWithBytes:remoteAddr length:remoteAddr->sa_len];
  222. *
  223. * This method invokes connectToAddress:remoteAddr viaInterface:nil withTimeout:-1 error:errPtr.
  224. **/
  225. - (BOOL)connectToAddress:(NSData *)remoteAddr error:(NSError **)errPtr;
  226. /**
  227. * This method is the same as connectToAddress:error: with an additional timeout option.
  228. * To not time out use a negative time interval, or simply use the connectToAddress:error: method.
  229. **/
  230. - (BOOL)connectToAddress:(NSData *)remoteAddr withTimeout:(NSTimeInterval)timeout error:(NSError **)errPtr;
  231. /**
  232. * Connects to the given address, using the specified interface and timeout.
  233. *
  234. * The address is specified as a sockaddr structure wrapped in a NSData object.
  235. * For example, a NSData object returned from NSNetService's addresses method.
  236. *
  237. * If you have an existing struct sockaddr you can convert it to a NSData object like so:
  238. * struct sockaddr sa -> NSData *dsa = [NSData dataWithBytes:&remoteAddr length:remoteAddr.sa_len];
  239. * struct sockaddr *sa -> NSData *dsa = [NSData dataWithBytes:remoteAddr length:remoteAddr->sa_len];
  240. *
  241. * The interface may be a name (e.g. "en1" or "lo0") or the corresponding IP address (e.g. "192.168.4.35").
  242. * The interface may also be used to specify the local port (see below).
  243. *
  244. * The timeout is optional. To not time out use a negative time interval.
  245. *
  246. * This method will return NO if an error is detected, and set the error pointer (if one was given).
  247. * Possible errors would be a nil host, invalid interface, or socket is already connected.
  248. *
  249. * If no errors are detected, this method will start a background connect operation and immediately return YES.
  250. * The delegate callbacks are used to notify you when the socket connects, or if the host was unreachable.
  251. *
  252. * Since this class supports queued reads and writes, you can immediately start reading and/or writing.
  253. * All read/write operations will be queued, and upon socket connection,
  254. * the operations will be dequeued and processed in order.
  255. *
  256. * The interface may optionally contain a port number at the end of the string, separated by a colon.
  257. * This allows you to specify the local port that should be used for the outgoing connection. (read paragraph to end)
  258. * To specify both interface and local port: "en1:8082" or "192.168.4.35:2424".
  259. * To specify only local port: ":8082".
  260. * Please note this is an advanced feature, and is somewhat hidden on purpose.
  261. * You should understand that 99.999% of the time you should NOT specify the local port for an outgoing connection.
  262. * If you think you need to, there is a very good chance you have a fundamental misunderstanding somewhere.
  263. * Local ports do NOT need to match remote ports. In fact, they almost never do.
  264. * This feature is here for networking professionals using very advanced techniques.
  265. **/
  266. - (BOOL)connectToAddress:(NSData *)remoteAddr
  267. viaInterface:(nullable NSString *)interface
  268. withTimeout:(NSTimeInterval)timeout
  269. error:(NSError **)errPtr;
  270. /**
  271. * Connects to the unix domain socket at the given url, using the specified timeout.
  272. */
  273. - (BOOL)connectToUrl:(NSURL *)url withTimeout:(NSTimeInterval)timeout error:(NSError **)errPtr;
  274. /**
  275. * Iterates over the given NetService's addresses in order, and invokes connectToAddress:error:. Stops at the
  276. * first invocation that succeeds and returns YES; otherwise returns NO.
  277. */
  278. - (BOOL)connectToNetService:(NSNetService *)netService error:(NSError **)errPtr;
  279. #pragma mark Disconnecting
  280. /**
  281. * Disconnects immediately (synchronously). Any pending reads or writes are dropped.
  282. *
  283. * If the socket is not already disconnected, an invocation to the socketDidDisconnect:withError: delegate method
  284. * will be queued onto the delegateQueue asynchronously (behind any previously queued delegate methods).
  285. * In other words, the disconnected delegate method will be invoked sometime shortly after this method returns.
  286. *
  287. * Please note the recommended way of releasing a GCDAsyncSocket instance (e.g. in a dealloc method)
  288. * [asyncSocket setDelegate:nil];
  289. * [asyncSocket disconnect];
  290. * [asyncSocket release];
  291. *
  292. * If you plan on disconnecting the socket, and then immediately asking it to connect again,
  293. * you'll likely want to do so like this:
  294. * [asyncSocket setDelegate:nil];
  295. * [asyncSocket disconnect];
  296. * [asyncSocket setDelegate:self];
  297. * [asyncSocket connect...];
  298. **/
  299. - (void)disconnect;
  300. /**
  301. * Disconnects after all pending reads have completed.
  302. * After calling this, the read and write methods will do nothing.
  303. * The socket will disconnect even if there are still pending writes.
  304. **/
  305. - (void)disconnectAfterReading;
  306. /**
  307. * Disconnects after all pending writes have completed.
  308. * After calling this, the read and write methods will do nothing.
  309. * The socket will disconnect even if there are still pending reads.
  310. **/
  311. - (void)disconnectAfterWriting;
  312. /**
  313. * Disconnects after all pending reads and writes have completed.
  314. * After calling this, the read and write methods will do nothing.
  315. **/
  316. - (void)disconnectAfterReadingAndWriting;
  317. #pragma mark Diagnostics
  318. /**
  319. * Returns whether the socket is disconnected or connected.
  320. *
  321. * A disconnected socket may be recycled.
  322. * That is, it can be used again for connecting or listening.
  323. *
  324. * If a socket is in the process of connecting, it may be neither disconnected nor connected.
  325. **/
  326. @property (atomic, readonly) BOOL isDisconnected;
  327. @property (atomic, readonly) BOOL isConnected;
  328. /**
  329. * Returns the local or remote host and port to which this socket is connected, or nil and 0 if not connected.
  330. * The host will be an IP address.
  331. **/
  332. @property (atomic, readonly, nullable) NSString *connectedHost;
  333. @property (atomic, readonly) uint16_t connectedPort;
  334. @property (atomic, readonly, nullable) NSURL *connectedUrl;
  335. @property (atomic, readonly, nullable) NSString *localHost;
  336. @property (atomic, readonly) uint16_t localPort;
  337. /**
  338. * Returns the local or remote address to which this socket is connected,
  339. * specified as a sockaddr structure wrapped in a NSData object.
  340. *
  341. * @seealso connectedHost
  342. * @seealso connectedPort
  343. * @seealso localHost
  344. * @seealso localPort
  345. **/
  346. @property (atomic, readonly, nullable) NSData *connectedAddress;
  347. @property (atomic, readonly, nullable) NSData *localAddress;
  348. /**
  349. * Returns whether the socket is IPv4 or IPv6.
  350. * An accepting socket may be both.
  351. **/
  352. @property (atomic, readonly) BOOL isIPv4;
  353. @property (atomic, readonly) BOOL isIPv6;
  354. /**
  355. * Returns whether or not the socket has been secured via SSL/TLS.
  356. *
  357. * See also the startTLS method.
  358. **/
  359. @property (atomic, readonly) BOOL isSecure;
  360. #pragma mark Reading
  361. // The readData and writeData methods won't block (they are asynchronous).
  362. //
  363. // When a read is complete the socket:didReadData:withTag: delegate method is dispatched on the delegateQueue.
  364. // When a write is complete the socket:didWriteDataWithTag: delegate method is dispatched on the delegateQueue.
  365. //
  366. // You may optionally set a timeout for any read/write operation. (To not timeout, use a negative time interval.)
  367. // If a read/write opertion times out, the corresponding "socket:shouldTimeout..." delegate method
  368. // is called to optionally allow you to extend the timeout.
  369. // Upon a timeout, the "socket:didDisconnectWithError:" method is called
  370. //
  371. // The tag is for your convenience.
  372. // You can use it as an array index, step number, state id, pointer, etc.
  373. /**
  374. * Reads the first available bytes that become available on the socket.
  375. *
  376. * If the timeout value is negative, the read operation will not use a timeout.
  377. **/
  378. - (void)readDataWithTimeout:(NSTimeInterval)timeout tag:(long)tag;
  379. /**
  380. * Reads the first available bytes that become available on the socket.
  381. * The bytes will be appended to the given byte buffer starting at the given offset.
  382. * The given buffer will automatically be increased in size if needed.
  383. *
  384. * If the timeout value is negative, the read operation will not use a timeout.
  385. * If the buffer is nil, the socket will create a buffer for you.
  386. *
  387. * If the bufferOffset is greater than the length of the given buffer,
  388. * the method will do nothing, and the delegate will not be called.
  389. *
  390. * If you pass a buffer, you must not alter it in any way while the socket is using it.
  391. * After completion, the data returned in socket:didReadData:withTag: will be a subset of the given buffer.
  392. * That is, it will reference the bytes that were appended to the given buffer via
  393. * the method [NSData dataWithBytesNoCopy:length:freeWhenDone:NO].
  394. **/
  395. - (void)readDataWithTimeout:(NSTimeInterval)timeout
  396. buffer:(nullable NSMutableData *)buffer
  397. bufferOffset:(NSUInteger)offset
  398. tag:(long)tag;
  399. /**
  400. * Reads the first available bytes that become available on the socket.
  401. * The bytes will be appended to the given byte buffer starting at the given offset.
  402. * The given buffer will automatically be increased in size if needed.
  403. * A maximum of length bytes will be read.
  404. *
  405. * If the timeout value is negative, the read operation will not use a timeout.
  406. * If the buffer is nil, a buffer will automatically be created for you.
  407. * If maxLength is zero, no length restriction is enforced.
  408. *
  409. * If the bufferOffset is greater than the length of the given buffer,
  410. * the method will do nothing, and the delegate will not be called.
  411. *
  412. * If you pass a buffer, you must not alter it in any way while the socket is using it.
  413. * After completion, the data returned in socket:didReadData:withTag: will be a subset of the given buffer.
  414. * That is, it will reference the bytes that were appended to the given buffer via
  415. * the method [NSData dataWithBytesNoCopy:length:freeWhenDone:NO].
  416. **/
  417. - (void)readDataWithTimeout:(NSTimeInterval)timeout
  418. buffer:(nullable NSMutableData *)buffer
  419. bufferOffset:(NSUInteger)offset
  420. maxLength:(NSUInteger)length
  421. tag:(long)tag;
  422. /**
  423. * Reads the given number of bytes.
  424. *
  425. * If the timeout value is negative, the read operation will not use a timeout.
  426. *
  427. * If the length is 0, this method does nothing and the delegate is not called.
  428. **/
  429. - (void)readDataToLength:(NSUInteger)length withTimeout:(NSTimeInterval)timeout tag:(long)tag;
  430. /**
  431. * Reads the given number of bytes.
  432. * The bytes will be appended to the given byte buffer starting at the given offset.
  433. * The given buffer will automatically be increased in size if needed.
  434. *
  435. * If the timeout value is negative, the read operation will not use a timeout.
  436. * If the buffer is nil, a buffer will automatically be created for you.
  437. *
  438. * If the length is 0, this method does nothing and the delegate is not called.
  439. * If the bufferOffset is greater than the length of the given buffer,
  440. * the method will do nothing, and the delegate will not be called.
  441. *
  442. * If you pass a buffer, you must not alter it in any way while AsyncSocket is using it.
  443. * After completion, the data returned in socket:didReadData:withTag: will be a subset of the given buffer.
  444. * That is, it will reference the bytes that were appended to the given buffer via
  445. * the method [NSData dataWithBytesNoCopy:length:freeWhenDone:NO].
  446. **/
  447. - (void)readDataToLength:(NSUInteger)length
  448. withTimeout:(NSTimeInterval)timeout
  449. buffer:(nullable NSMutableData *)buffer
  450. bufferOffset:(NSUInteger)offset
  451. tag:(long)tag;
  452. /**
  453. * Reads bytes until (and including) the passed "data" parameter, which acts as a separator.
  454. *
  455. * If the timeout value is negative, the read operation will not use a timeout.
  456. *
  457. * If you pass nil or zero-length data as the "data" parameter,
  458. * the method will do nothing (except maybe print a warning), and the delegate will not be called.
  459. *
  460. * To read a line from the socket, use the line separator (e.g. CRLF for HTTP, see below) as the "data" parameter.
  461. * If you're developing your own custom protocol, be sure your separator can not occur naturally as
  462. * part of the data between separators.
  463. * For example, imagine you want to send several small documents over a socket.
  464. * Using CRLF as a separator is likely unwise, as a CRLF could easily exist within the documents.
  465. * In this particular example, it would be better to use a protocol similar to HTTP with
  466. * a header that includes the length of the document.
  467. * Also be careful that your separator cannot occur naturally as part of the encoding for a character.
  468. *
  469. * The given data (separator) parameter should be immutable.
  470. * For performance reasons, the socket will retain it, not copy it.
  471. * So if it is immutable, don't modify it while the socket is using it.
  472. **/
  473. - (void)readDataToData:(nullable NSData *)data withTimeout:(NSTimeInterval)timeout tag:(long)tag;
  474. /**
  475. * Reads bytes until (and including) the passed "data" parameter, which acts as a separator.
  476. * The bytes will be appended to the given byte buffer starting at the given offset.
  477. * The given buffer will automatically be increased in size if needed.
  478. *
  479. * If the timeout value is negative, the read operation will not use a timeout.
  480. * If the buffer is nil, a buffer will automatically be created for you.
  481. *
  482. * If the bufferOffset is greater than the length of the given buffer,
  483. * the method will do nothing (except maybe print a warning), and the delegate will not be called.
  484. *
  485. * If you pass a buffer, you must not alter it in any way while the socket is using it.
  486. * After completion, the data returned in socket:didReadData:withTag: will be a subset of the given buffer.
  487. * That is, it will reference the bytes that were appended to the given buffer via
  488. * the method [NSData dataWithBytesNoCopy:length:freeWhenDone:NO].
  489. *
  490. * To read a line from the socket, use the line separator (e.g. CRLF for HTTP, see below) as the "data" parameter.
  491. * If you're developing your own custom protocol, be sure your separator can not occur naturally as
  492. * part of the data between separators.
  493. * For example, imagine you want to send several small documents over a socket.
  494. * Using CRLF as a separator is likely unwise, as a CRLF could easily exist within the documents.
  495. * In this particular example, it would be better to use a protocol similar to HTTP with
  496. * a header that includes the length of the document.
  497. * Also be careful that your separator cannot occur naturally as part of the encoding for a character.
  498. *
  499. * The given data (separator) parameter should be immutable.
  500. * For performance reasons, the socket will retain it, not copy it.
  501. * So if it is immutable, don't modify it while the socket is using it.
  502. **/
  503. - (void)readDataToData:(NSData *)data
  504. withTimeout:(NSTimeInterval)timeout
  505. buffer:(nullable NSMutableData *)buffer
  506. bufferOffset:(NSUInteger)offset
  507. tag:(long)tag;
  508. /**
  509. * Reads bytes until (and including) the passed "data" parameter, which acts as a separator.
  510. *
  511. * If the timeout value is negative, the read operation will not use a timeout.
  512. *
  513. * If maxLength is zero, no length restriction is enforced.
  514. * Otherwise if maxLength bytes are read without completing the read,
  515. * it is treated similarly to a timeout - the socket is closed with a GCDAsyncSocketReadMaxedOutError.
  516. * The read will complete successfully if exactly maxLength bytes are read and the given data is found at the end.
  517. *
  518. * If you pass nil or zero-length data as the "data" parameter,
  519. * the method will do nothing (except maybe print a warning), and the delegate will not be called.
  520. * If you pass a maxLength parameter that is less than the length of the data parameter,
  521. * the method will do nothing (except maybe print a warning), and the delegate will not be called.
  522. *
  523. * To read a line from the socket, use the line separator (e.g. CRLF for HTTP, see below) as the "data" parameter.
  524. * If you're developing your own custom protocol, be sure your separator can not occur naturally as
  525. * part of the data between separators.
  526. * For example, imagine you want to send several small documents over a socket.
  527. * Using CRLF as a separator is likely unwise, as a CRLF could easily exist within the documents.
  528. * In this particular example, it would be better to use a protocol similar to HTTP with
  529. * a header that includes the length of the document.
  530. * Also be careful that your separator cannot occur naturally as part of the encoding for a character.
  531. *
  532. * The given data (separator) parameter should be immutable.
  533. * For performance reasons, the socket will retain it, not copy it.
  534. * So if it is immutable, don't modify it while the socket is using it.
  535. **/
  536. - (void)readDataToData:(NSData *)data withTimeout:(NSTimeInterval)timeout maxLength:(NSUInteger)length tag:(long)tag;
  537. /**
  538. * Reads bytes until (and including) the passed "data" parameter, which acts as a separator.
  539. * The bytes will be appended to the given byte buffer starting at the given offset.
  540. * The given buffer will automatically be increased in size if needed.
  541. *
  542. * If the timeout value is negative, the read operation will not use a timeout.
  543. * If the buffer is nil, a buffer will automatically be created for you.
  544. *
  545. * If maxLength is zero, no length restriction is enforced.
  546. * Otherwise if maxLength bytes are read without completing the read,
  547. * it is treated similarly to a timeout - the socket is closed with a GCDAsyncSocketReadMaxedOutError.
  548. * The read will complete successfully if exactly maxLength bytes are read and the given data is found at the end.
  549. *
  550. * If you pass a maxLength parameter that is less than the length of the data (separator) parameter,
  551. * the method will do nothing (except maybe print a warning), and the delegate will not be called.
  552. * If the bufferOffset is greater than the length of the given buffer,
  553. * the method will do nothing (except maybe print a warning), and the delegate will not be called.
  554. *
  555. * If you pass a buffer, you must not alter it in any way while the socket is using it.
  556. * After completion, the data returned in socket:didReadData:withTag: will be a subset of the given buffer.
  557. * That is, it will reference the bytes that were appended to the given buffer via
  558. * the method [NSData dataWithBytesNoCopy:length:freeWhenDone:NO].
  559. *
  560. * To read a line from the socket, use the line separator (e.g. CRLF for HTTP, see below) as the "data" parameter.
  561. * If you're developing your own custom protocol, be sure your separator can not occur naturally as
  562. * part of the data between separators.
  563. * For example, imagine you want to send several small documents over a socket.
  564. * Using CRLF as a separator is likely unwise, as a CRLF could easily exist within the documents.
  565. * In this particular example, it would be better to use a protocol similar to HTTP with
  566. * a header that includes the length of the document.
  567. * Also be careful that your separator cannot occur naturally as part of the encoding for a character.
  568. *
  569. * The given data (separator) parameter should be immutable.
  570. * For performance reasons, the socket will retain it, not copy it.
  571. * So if it is immutable, don't modify it while the socket is using it.
  572. **/
  573. - (void)readDataToData:(NSData *)data
  574. withTimeout:(NSTimeInterval)timeout
  575. buffer:(nullable NSMutableData *)buffer
  576. bufferOffset:(NSUInteger)offset
  577. maxLength:(NSUInteger)length
  578. tag:(long)tag;
  579. /**
  580. * Returns progress of the current read, from 0.0 to 1.0, or NaN if no current read (use isnan() to check).
  581. * The parameters "tag", "done" and "total" will be filled in if they aren't NULL.
  582. **/
  583. - (float)progressOfReadReturningTag:(nullable long *)tagPtr bytesDone:(nullable NSUInteger *)donePtr total:(nullable NSUInteger *)totalPtr;
  584. #pragma mark Writing
  585. /**
  586. * Writes data to the socket, and calls the delegate when finished.
  587. *
  588. * If you pass in nil or zero-length data, this method does nothing and the delegate will not be called.
  589. * If the timeout value is negative, the write operation will not use a timeout.
  590. *
  591. * Thread-Safety Note:
  592. * If the given data parameter is mutable (NSMutableData) then you MUST NOT alter the data while
  593. * the socket is writing it. In other words, it's not safe to alter the data until after the delegate method
  594. * socket:didWriteDataWithTag: is invoked signifying that this particular write operation has completed.
  595. * This is due to the fact that GCDAsyncSocket does NOT copy the data. It simply retains it.
  596. * This is for performance reasons. Often times, if NSMutableData is passed, it is because
  597. * a request/response was built up in memory. Copying this data adds an unwanted/unneeded overhead.
  598. * If you need to write data from an immutable buffer, and you need to alter the buffer before the socket
  599. * completes writing the bytes (which is NOT immediately after this method returns, but rather at a later time
  600. * when the delegate method notifies you), then you should first copy the bytes, and pass the copy to this method.
  601. **/
  602. - (void)writeData:(nullable NSData *)data withTimeout:(NSTimeInterval)timeout tag:(long)tag;
  603. /**
  604. * Returns progress of the current write, from 0.0 to 1.0, or NaN if no current write (use isnan() to check).
  605. * The parameters "tag", "done" and "total" will be filled in if they aren't NULL.
  606. **/
  607. - (float)progressOfWriteReturningTag:(nullable long *)tagPtr bytesDone:(nullable NSUInteger *)donePtr total:(nullable NSUInteger *)totalPtr;
  608. #pragma mark Security
  609. /**
  610. * Secures the connection using SSL/TLS.
  611. *
  612. * This method may be called at any time, and the TLS handshake will occur after all pending reads and writes
  613. * are finished. This allows one the option of sending a protocol dependent StartTLS message, and queuing
  614. * the upgrade to TLS at the same time, without having to wait for the write to finish.
  615. * Any reads or writes scheduled after this method is called will occur over the secured connection.
  616. *
  617. * ==== The available TOP-LEVEL KEYS are:
  618. *
  619. * - GCDAsyncSocketManuallyEvaluateTrust
  620. * The value must be of type NSNumber, encapsulating a BOOL value.
  621. * If you set this to YES, then the underlying SecureTransport system will not evaluate the SecTrustRef of the peer.
  622. * Instead it will pause at the moment evaulation would typically occur,
  623. * and allow us to handle the security evaluation however we see fit.
  624. * So GCDAsyncSocket will invoke the delegate method socket:shouldTrustPeer: passing the SecTrustRef.
  625. *
  626. * Note that if you set this option, then all other configuration keys are ignored.
  627. * Evaluation will be completely up to you during the socket:didReceiveTrust:completionHandler: delegate method.
  628. *
  629. * For more information on trust evaluation see:
  630. * Apple's Technical Note TN2232 - HTTPS Server Trust Evaluation
  631. * https://developer.apple.com/library/ios/technotes/tn2232/_index.html
  632. *
  633. * If unspecified, the default value is NO.
  634. *
  635. * - GCDAsyncSocketUseCFStreamForTLS (iOS only)
  636. * The value must be of type NSNumber, encapsulating a BOOL value.
  637. * By default GCDAsyncSocket will use the SecureTransport layer to perform encryption.
  638. * This gives us more control over the security protocol (many more configuration options),
  639. * plus it allows us to optimize things like sys calls and buffer allocation.
  640. *
  641. * However, if you absolutely must, you can instruct GCDAsyncSocket to use the old-fashioned encryption
  642. * technique by going through the CFStream instead. So instead of using SecureTransport, GCDAsyncSocket
  643. * will instead setup a CFRead/CFWriteStream. And then set the kCFStreamPropertySSLSettings property
  644. * (via CFReadStreamSetProperty / CFWriteStreamSetProperty) and will pass the given options to this method.
  645. *
  646. * Thus all the other keys in the given dictionary will be ignored by GCDAsyncSocket,
  647. * and will passed directly CFReadStreamSetProperty / CFWriteStreamSetProperty.
  648. * For more infomation on these keys, please see the documentation for kCFStreamPropertySSLSettings.
  649. *
  650. * If unspecified, the default value is NO.
  651. *
  652. * ==== The available CONFIGURATION KEYS are:
  653. *
  654. * - kCFStreamSSLPeerName
  655. * The value must be of type NSString.
  656. * It should match the name in the X.509 certificate given by the remote party.
  657. * See Apple's documentation for SSLSetPeerDomainName.
  658. *
  659. * - kCFStreamSSLCertificates
  660. * The value must be of type NSArray.
  661. * See Apple's documentation for SSLSetCertificate.
  662. *
  663. * - kCFStreamSSLIsServer
  664. * The value must be of type NSNumber, encapsulationg a BOOL value.
  665. * See Apple's documentation for SSLCreateContext for iOS.
  666. * This is optional for iOS. If not supplied, a NO value is the default.
  667. * This is not needed for Mac OS X, and the value is ignored.
  668. *
  669. * - GCDAsyncSocketSSLPeerID
  670. * The value must be of type NSData.
  671. * You must set this value if you want to use TLS session resumption.
  672. * See Apple's documentation for SSLSetPeerID.
  673. *
  674. * - GCDAsyncSocketSSLProtocolVersionMin
  675. * - GCDAsyncSocketSSLProtocolVersionMax
  676. * The value(s) must be of type NSNumber, encapsulting a SSLProtocol value.
  677. * See Apple's documentation for SSLSetProtocolVersionMin & SSLSetProtocolVersionMax.
  678. * See also the SSLProtocol typedef.
  679. *
  680. * - GCDAsyncSocketSSLSessionOptionFalseStart
  681. * The value must be of type NSNumber, encapsulating a BOOL value.
  682. * See Apple's documentation for kSSLSessionOptionFalseStart.
  683. *
  684. * - GCDAsyncSocketSSLSessionOptionSendOneByteRecord
  685. * The value must be of type NSNumber, encapsulating a BOOL value.
  686. * See Apple's documentation for kSSLSessionOptionSendOneByteRecord.
  687. *
  688. * - GCDAsyncSocketSSLCipherSuites
  689. * The values must be of type NSArray.
  690. * Each item within the array must be a NSNumber, encapsulating an SSLCipherSuite.
  691. * See Apple's documentation for SSLSetEnabledCiphers.
  692. * See also the SSLCipherSuite typedef.
  693. *
  694. * - GCDAsyncSocketSSLDiffieHellmanParameters (Mac OS X only)
  695. * The value must be of type NSData.
  696. * See Apple's documentation for SSLSetDiffieHellmanParams.
  697. *
  698. * ==== The following UNAVAILABLE KEYS are: (with throw an exception)
  699. *
  700. * - kCFStreamSSLAllowsAnyRoot (UNAVAILABLE)
  701. * You MUST use manual trust evaluation instead (see GCDAsyncSocketManuallyEvaluateTrust).
  702. * Corresponding deprecated method: SSLSetAllowsAnyRoot
  703. *
  704. * - kCFStreamSSLAllowsExpiredRoots (UNAVAILABLE)
  705. * You MUST use manual trust evaluation instead (see GCDAsyncSocketManuallyEvaluateTrust).
  706. * Corresponding deprecated method: SSLSetAllowsExpiredRoots
  707. *
  708. * - kCFStreamSSLAllowsExpiredCertificates (UNAVAILABLE)
  709. * You MUST use manual trust evaluation instead (see GCDAsyncSocketManuallyEvaluateTrust).
  710. * Corresponding deprecated method: SSLSetAllowsExpiredCerts
  711. *
  712. * - kCFStreamSSLValidatesCertificateChain (UNAVAILABLE)
  713. * You MUST use manual trust evaluation instead (see GCDAsyncSocketManuallyEvaluateTrust).
  714. * Corresponding deprecated method: SSLSetEnableCertVerify
  715. *
  716. * - kCFStreamSSLLevel (UNAVAILABLE)
  717. * You MUST use GCDAsyncSocketSSLProtocolVersionMin & GCDAsyncSocketSSLProtocolVersionMin instead.
  718. * Corresponding deprecated method: SSLSetProtocolVersionEnabled
  719. *
  720. *
  721. * Please refer to Apple's documentation for corresponding SSLFunctions.
  722. *
  723. * If you pass in nil or an empty dictionary, the default settings will be used.
  724. *
  725. * IMPORTANT SECURITY NOTE:
  726. * The default settings will check to make sure the remote party's certificate is signed by a
  727. * trusted 3rd party certificate agency (e.g. verisign) and that the certificate is not expired.
  728. * However it will not verify the name on the certificate unless you
  729. * give it a name to verify against via the kCFStreamSSLPeerName key.
  730. * The security implications of this are important to understand.
  731. * Imagine you are attempting to create a secure connection to MySecureServer.com,
  732. * but your socket gets directed to MaliciousServer.com because of a hacked DNS server.
  733. * If you simply use the default settings, and MaliciousServer.com has a valid certificate,
  734. * the default settings will not detect any problems since the certificate is valid.
  735. * To properly secure your connection in this particular scenario you
  736. * should set the kCFStreamSSLPeerName property to "MySecureServer.com".
  737. *
  738. * You can also perform additional validation in socketDidSecure.
  739. **/
  740. - (void)startTLS:(nullable NSDictionary <NSString*,NSObject*>*)tlsSettings;
  741. #pragma mark Advanced
  742. /**
  743. * Traditionally sockets are not closed until the conversation is over.
  744. * However, it is technically possible for the remote enpoint to close its write stream.
  745. * Our socket would then be notified that there is no more data to be read,
  746. * but our socket would still be writeable and the remote endpoint could continue to receive our data.
  747. *
  748. * The argument for this confusing functionality stems from the idea that a client could shut down its
  749. * write stream after sending a request to the server, thus notifying the server there are to be no further requests.
  750. * In practice, however, this technique did little to help server developers.
  751. *
  752. * To make matters worse, from a TCP perspective there is no way to tell the difference from a read stream close
  753. * and a full socket close. They both result in the TCP stack receiving a FIN packet. The only way to tell
  754. * is by continuing to write to the socket. If it was only a read stream close, then writes will continue to work.
  755. * Otherwise an error will be occur shortly (when the remote end sends us a RST packet).
  756. *
  757. * In addition to the technical challenges and confusion, many high level socket/stream API's provide
  758. * no support for dealing with the problem. If the read stream is closed, the API immediately declares the
  759. * socket to be closed, and shuts down the write stream as well. In fact, this is what Apple's CFStream API does.
  760. * It might sound like poor design at first, but in fact it simplifies development.
  761. *
  762. * The vast majority of the time if the read stream is closed it's because the remote endpoint closed its socket.
  763. * Thus it actually makes sense to close the socket at this point.
  764. * And in fact this is what most networking developers want and expect to happen.
  765. * However, if you are writing a server that interacts with a plethora of clients,
  766. * you might encounter a client that uses the discouraged technique of shutting down its write stream.
  767. * If this is the case, you can set this property to NO,
  768. * and make use of the socketDidCloseReadStream delegate method.
  769. *
  770. * The default value is YES.
  771. **/
  772. @property (atomic, assign, readwrite) BOOL autoDisconnectOnClosedReadStream;
  773. /**
  774. * GCDAsyncSocket maintains thread safety by using an internal serial dispatch_queue.
  775. * In most cases, the instance creates this queue itself.
  776. * However, to allow for maximum flexibility, the internal queue may be passed in the init method.
  777. * This allows for some advanced options such as controlling socket priority via target queues.
  778. * However, when one begins to use target queues like this, they open the door to some specific deadlock issues.
  779. *
  780. * For example, imagine there are 2 queues:
  781. * dispatch_queue_t socketQueue;
  782. * dispatch_queue_t socketTargetQueue;
  783. *
  784. * If you do this (pseudo-code):
  785. * socketQueue.targetQueue = socketTargetQueue;
  786. *
  787. * Then all socketQueue operations will actually get run on the given socketTargetQueue.
  788. * This is fine and works great in most situations.
  789. * But if you run code directly from within the socketTargetQueue that accesses the socket,
  790. * you could potentially get deadlock. Imagine the following code:
  791. *
  792. * - (BOOL)socketHasSomething
  793. * {
  794. * __block BOOL result = NO;
  795. * dispatch_block_t block = ^{
  796. * result = [self someInternalMethodToBeRunOnlyOnSocketQueue];
  797. * }
  798. * if (is_executing_on_queue(socketQueue))
  799. * block();
  800. * else
  801. * dispatch_sync(socketQueue, block);
  802. *
  803. * return result;
  804. * }
  805. *
  806. * What happens if you call this method from the socketTargetQueue? The result is deadlock.
  807. * This is because the GCD API offers no mechanism to discover a queue's targetQueue.
  808. * Thus we have no idea if our socketQueue is configured with a targetQueue.
  809. * If we had this information, we could easily avoid deadlock.
  810. * But, since these API's are missing or unfeasible, you'll have to explicitly set it.
  811. *
  812. * IF you pass a socketQueue via the init method,
  813. * AND you've configured the passed socketQueue with a targetQueue,
  814. * THEN you should pass the end queue in the target hierarchy.
  815. *
  816. * For example, consider the following queue hierarchy:
  817. * socketQueue -> ipQueue -> moduleQueue
  818. *
  819. * This example demonstrates priority shaping within some server.
  820. * All incoming client connections from the same IP address are executed on the same target queue.
  821. * And all connections for a particular module are executed on the same target queue.
  822. * Thus, the priority of all networking for the entire module can be changed on the fly.
  823. * Additionally, networking traffic from a single IP cannot monopolize the module.
  824. *
  825. * Here's how you would accomplish something like that:
  826. * - (dispatch_queue_t)newSocketQueueForConnectionFromAddress:(NSData *)address onSocket:(GCDAsyncSocket *)sock
  827. * {
  828. * dispatch_queue_t socketQueue = dispatch_queue_create("", NULL);
  829. * dispatch_queue_t ipQueue = [self ipQueueForAddress:address];
  830. *
  831. * dispatch_set_target_queue(socketQueue, ipQueue);
  832. * dispatch_set_target_queue(iqQueue, moduleQueue);
  833. *
  834. * return socketQueue;
  835. * }
  836. * - (void)socket:(GCDAsyncSocket *)sock didAcceptNewSocket:(GCDAsyncSocket *)newSocket
  837. * {
  838. * [clientConnections addObject:newSocket];
  839. * [newSocket markSocketQueueTargetQueue:moduleQueue];
  840. * }
  841. *
  842. * Note: This workaround is ONLY needed if you intend to execute code directly on the ipQueue or moduleQueue.
  843. * This is often NOT the case, as such queues are used solely for execution shaping.
  844. **/
  845. - (void)markSocketQueueTargetQueue:(dispatch_queue_t)socketQueuesPreConfiguredTargetQueue;
  846. - (void)unmarkSocketQueueTargetQueue:(dispatch_queue_t)socketQueuesPreviouslyConfiguredTargetQueue;
  847. /**
  848. * It's not thread-safe to access certain variables from outside the socket's internal queue.
  849. *
  850. * For example, the socket file descriptor.
  851. * File descriptors are simply integers which reference an index in the per-process file table.
  852. * However, when one requests a new file descriptor (by opening a file or socket),
  853. * the file descriptor returned is guaranteed to be the lowest numbered unused descriptor.
  854. * So if we're not careful, the following could be possible:
  855. *
  856. * - Thread A invokes a method which returns the socket's file descriptor.
  857. * - The socket is closed via the socket's internal queue on thread B.
  858. * - Thread C opens a file, and subsequently receives the file descriptor that was previously the socket's FD.
  859. * - Thread A is now accessing/altering the file instead of the socket.
  860. *
  861. * In addition to this, other variables are not actually objects,
  862. * and thus cannot be retained/released or even autoreleased.
  863. * An example is the sslContext, of type SSLContextRef, which is actually a malloc'd struct.
  864. *
  865. * Although there are internal variables that make it difficult to maintain thread-safety,
  866. * it is important to provide access to these variables
  867. * to ensure this class can be used in a wide array of environments.
  868. * This method helps to accomplish this by invoking the current block on the socket's internal queue.
  869. * The methods below can be invoked from within the block to access
  870. * those generally thread-unsafe internal variables in a thread-safe manner.
  871. * The given block will be invoked synchronously on the socket's internal queue.
  872. *
  873. * If you save references to any protected variables and use them outside the block, you do so at your own peril.
  874. **/
  875. - (void)performBlock:(dispatch_block_t)block;
  876. /**
  877. * These methods are only available from within the context of a performBlock: invocation.
  878. * See the documentation for the performBlock: method above.
  879. *
  880. * Provides access to the socket's file descriptor(s).
  881. * If the socket is a server socket (is accepting incoming connections),
  882. * it might actually have multiple internal socket file descriptors - one for IPv4 and one for IPv6.
  883. **/
  884. - (int)socketFD;
  885. - (int)socket4FD;
  886. - (int)socket6FD;
  887. #if TARGET_OS_IPHONE
  888. /**
  889. * These methods are only available from within the context of a performBlock: invocation.
  890. * See the documentation for the performBlock: method above.
  891. *
  892. * Provides access to the socket's internal CFReadStream/CFWriteStream.
  893. *
  894. * These streams are only used as workarounds for specific iOS shortcomings:
  895. *
  896. * - Apple has decided to keep the SecureTransport framework private is iOS.
  897. * This means the only supplied way to do SSL/TLS is via CFStream or some other API layered on top of it.
  898. * Thus, in order to provide SSL/TLS support on iOS we are forced to rely on CFStream,
  899. * instead of the preferred and faster and more powerful SecureTransport.
  900. *
  901. * - If a socket doesn't have backgrounding enabled, and that socket is closed while the app is backgrounded,
  902. * Apple only bothers to notify us via the CFStream API.
  903. * The faster and more powerful GCD API isn't notified properly in this case.
  904. *
  905. * See also: (BOOL)enableBackgroundingOnSocket
  906. **/
  907. - (nullable CFReadStreamRef)readStream;
  908. - (nullable CFWriteStreamRef)writeStream;
  909. /**
  910. * This method is only available from within the context of a performBlock: invocation.
  911. * See the documentation for the performBlock: method above.
  912. *
  913. * Configures the socket to allow it to operate when the iOS application has been backgrounded.
  914. * In other words, this method creates a read & write stream, and invokes:
  915. *
  916. * CFReadStreamSetProperty(readStream, kCFStreamNetworkServiceType, kCFStreamNetworkServiceTypeVoIP);
  917. * CFWriteStreamSetProperty(writeStream, kCFStreamNetworkServiceType, kCFStreamNetworkServiceTypeVoIP);
  918. *
  919. * Returns YES if successful, NO otherwise.
  920. *
  921. * Note: Apple does not officially support backgrounding server sockets.
  922. * That is, if your socket is accepting incoming connections, Apple does not officially support
  923. * allowing iOS applications to accept incoming connections while an app is backgrounded.
  924. *
  925. * Example usage:
  926. *
  927. * - (void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port
  928. * {
  929. * [asyncSocket performBlock:^{
  930. * [asyncSocket enableBackgroundingOnSocket];
  931. * }];
  932. * }
  933. **/
  934. - (BOOL)enableBackgroundingOnSocket;
  935. #endif
  936. /**
  937. * This method is only available from within the context of a performBlock: invocation.
  938. * See the documentation for the performBlock: method above.
  939. *
  940. * Provides access to the socket's SSLContext, if SSL/TLS has been started on the socket.
  941. **/
  942. - (nullable SSLContextRef)sslContext;
  943. #pragma mark Utilities
  944. /**
  945. * The address lookup utility used by the class.
  946. * This method is synchronous, so it's recommended you use it on a background thread/queue.
  947. *
  948. * The special strings "localhost" and "loopback" return the loopback address for IPv4 and IPv6.
  949. *
  950. * @returns
  951. * A mutable array with all IPv4 and IPv6 addresses returned by getaddrinfo.
  952. * The addresses are specifically for TCP connections.
  953. * You can filter the addresses, if needed, using the other utility methods provided by the class.
  954. **/
  955. + (nullable NSMutableArray *)lookupHost:(NSString *)host port:(uint16_t)port error:(NSError **)errPtr;
  956. /**
  957. * Extracting host and port information from raw address data.
  958. **/
  959. + (nullable NSString *)hostFromAddress:(NSData *)address;
  960. + (uint16_t)portFromAddress:(NSData *)address;
  961. + (BOOL)isIPv4Address:(NSData *)address;
  962. + (BOOL)isIPv6Address:(NSData *)address;
  963. + (BOOL)getHost:( NSString * __nullable * __nullable)hostPtr port:(nullable uint16_t *)portPtr fromAddress:(NSData *)address;
  964. + (BOOL)getHost:(NSString * __nullable * __nullable)hostPtr port:(nullable uint16_t *)portPtr family:(nullable sa_family_t *)afPtr fromAddress:(NSData *)address;
  965. /**
  966. * A few common line separators, for use with the readDataToData:... methods.
  967. **/
  968. + (NSData *)CRLFData; // 0x0D0A
  969. + (NSData *)CRData; // 0x0D
  970. + (NSData *)LFData; // 0x0A
  971. + (NSData *)ZeroData; // 0x00
  972. @end
  973. ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  974. #pragma mark -
  975. ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
  976. @protocol GCDAsyncSocketDelegate <NSObject>
  977. @optional
  978. /**
  979. * This method is called immediately prior to socket:didAcceptNewSocket:.
  980. * It optionally allows a listening socket to specify the socketQueue for a new accepted socket.
  981. * If this method is not implemented, or returns NULL, the new accepted socket will create its own default queue.
  982. *
  983. * Since you cannot autorelease a dispatch_queue,
  984. * this method uses the "new" prefix in its name to specify that the returned queue has been retained.
  985. *
  986. * Thus you could do something like this in the implementation:
  987. * return dispatch_queue_create("MyQueue", NULL);
  988. *
  989. * If you are placing multiple sockets on the same queue,
  990. * then care should be taken to increment the retain count each time this method is invoked.
  991. *
  992. * For example, your implementation might look something like this:
  993. * dispatch_retain(myExistingQueue);
  994. * return myExistingQueue;
  995. **/
  996. - (nullable dispatch_queue_t)newSocketQueueForConnectionFromAddress:(NSData *)address onSocket:(GCDAsyncSocket *)sock;
  997. /**
  998. * Called when a socket accepts a connection.
  999. * Another socket is automatically spawned to handle it.
  1000. *
  1001. * You must retain the newSocket if you wish to handle the connection.
  1002. * Otherwise the newSocket instance will be released and the spawned connection will be closed.
  1003. *
  1004. * By default the new socket will have the same delegate and delegateQueue.
  1005. * You may, of course, change this at any time.
  1006. **/
  1007. - (void)socket:(GCDAsyncSocket *)sock didAcceptNewSocket:(GCDAsyncSocket *)newSocket;
  1008. /**
  1009. * Called when a socket connects and is ready for reading and writing.
  1010. * The host parameter will be an IP address, not a DNS name.
  1011. **/
  1012. - (void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port;
  1013. /**
  1014. * Called when a socket connects and is ready for reading and writing.
  1015. * The host parameter will be an IP address, not a DNS name.
  1016. **/
  1017. - (void)socket:(GCDAsyncSocket *)sock didConnectToUrl:(NSURL *)url;
  1018. /**
  1019. * Called when a socket has completed reading the requested data into memory.
  1020. * Not called if there is an error.
  1021. **/
  1022. - (void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag;
  1023. /**
  1024. * Called when a socket has read in data, but has not yet completed the read.
  1025. * This would occur if using readToData: or readToLength: methods.
  1026. * It may be used for things such as updating progress bars.
  1027. **/
  1028. - (void)socket:(GCDAsyncSocket *)sock didReadPartialDataOfLength:(NSUInteger)partialLength tag:(long)tag;
  1029. /**
  1030. * Called when a socket has completed writing the requested data. Not called if there is an error.
  1031. **/
  1032. - (void)socket:(GCDAsyncSocket *)sock didWriteDataWithTag:(long)tag;
  1033. /**
  1034. * Called when a socket has written some data, but has not yet completed the entire write.
  1035. * It may be used for things such as updating progress bars.
  1036. **/
  1037. - (void)socket:(GCDAsyncSocket *)sock didWritePartialDataOfLength:(NSUInteger)partialLength tag:(long)tag;
  1038. /**
  1039. * Called if a read operation has reached its timeout without completing.
  1040. * This method allows you to optionally extend the timeout.
  1041. * If you return a positive time interval (> 0) the read's timeout will be extended by the given amount.
  1042. * If you don't implement this method, or return a non-positive time interval (<= 0) the read will timeout as usual.
  1043. *
  1044. * The elapsed parameter is the sum of the original timeout, plus any additions previously added via this method.
  1045. * The length parameter is the number of bytes that have been read so far for the read operation.
  1046. *
  1047. * Note that this method may be called multiple times for a single read if you return positive numbers.
  1048. **/
  1049. - (NSTimeInterval)socket:(GCDAsyncSocket *)sock shouldTimeoutReadWithTag:(long)tag
  1050. elapsed:(NSTimeInterval)elapsed
  1051. bytesDone:(NSUInteger)length;
  1052. /**
  1053. * Called if a write operation has reached its timeout without completing.
  1054. * This method allows you to optionally extend the timeout.
  1055. * If you return a positive time interval (> 0) the write's timeout will be extended by the given amount.
  1056. * If you don't implement this method, or return a non-positive time interval (<= 0) the write will timeout as usual.
  1057. *
  1058. * The elapsed parameter is the sum of the original timeout, plus any additions previously added via this method.
  1059. * The length parameter is the number of bytes that have been written so far for the write operation.
  1060. *
  1061. * Note that this method may be called multiple times for a single write if you return positive numbers.
  1062. **/
  1063. - (NSTimeInterval)socket:(GCDAsyncSocket *)sock shouldTimeoutWriteWithTag:(long)tag
  1064. elapsed:(NSTimeInterval)elapsed
  1065. bytesDone:(NSUInteger)length;
  1066. /**
  1067. * Conditionally called if the read stream closes, but the write stream may still be writeable.
  1068. *
  1069. * This delegate method is only called if autoDisconnectOnClosedReadStream has been set to NO.
  1070. * See the discussion on the autoDisconnectOnClosedReadStream method for more information.
  1071. **/
  1072. - (void)socketDidCloseReadStream:(GCDAsyncSocket *)sock;
  1073. /**
  1074. * Called when a socket disconnects with or without error.
  1075. *
  1076. * If you call the disconnect method, and the socket wasn't already disconnected,
  1077. * then an invocation of this delegate method will be enqueued on the delegateQueue
  1078. * before the disconnect method returns.
  1079. *
  1080. * Note: If the GCDAsyncSocket instance is deallocated while it is still connected,
  1081. * and the delegate is not also deallocated, then this method will be invoked,
  1082. * but the sock parameter will be nil. (It must necessarily be nil since it is no longer available.)
  1083. * This is a generally rare, but is possible if one writes code like this:
  1084. *
  1085. * asyncSocket = nil; // I'm implicitly disconnecting the socket
  1086. *
  1087. * In this case it may preferrable to nil the delegate beforehand, like this:
  1088. *
  1089. * asyncSocket.delegate = nil; // Don't invoke my delegate method
  1090. * asyncSocket = nil; // I'm implicitly disconnecting the socket
  1091. *
  1092. * Of course, this depends on how your state machine is configured.
  1093. **/
  1094. - (void)socketDidDisconnect:(GCDAsyncSocket *)sock withError:(nullable NSError *)err;
  1095. /**
  1096. * Called after the socket has successfully completed SSL/TLS negotiation.
  1097. * This method is not called unless you use the provided startTLS method.
  1098. *
  1099. * If a SSL/TLS negotiation fails (invalid certificate, etc) then the socket will immediately close,
  1100. * and the socketDidDisconnect:withError: delegate method will be called with the specific SSL error code.
  1101. **/
  1102. - (void)socketDidSecure:(GCDAsyncSocket *)sock;
  1103. /**
  1104. * Allows a socket delegate to hook into the TLS handshake and manually validate the peer it's connecting to.
  1105. *
  1106. * This is only called if startTLS is invoked with options that include:
  1107. * - GCDAsyncSocketManuallyEvaluateTrust == YES
  1108. *
  1109. * Typically the delegate will use SecTrustEvaluate (and related functions) to properly validate the peer.
  1110. *
  1111. * Note from Apple's documentation:
  1112. * Because [SecTrustEvaluate] might look on the network for certificates in the certificate chain,
  1113. * [it] might block while attempting network access. You should never call it from your main thread;
  1114. * call it only from within a function running on a dispatch queue or on a separate thread.
  1115. *
  1116. * Thus this method uses a completionHandler block rather than a normal return value.
  1117. * The completionHandler block is thread-safe, and may be invoked from a background queue/thread.
  1118. * It is safe to invoke the completionHandler block even if the socket has been closed.
  1119. **/
  1120. - (void)socket:(GCDAsyncSocket *)sock didReceiveTrust:(SecTrustRef)trust
  1121. completionHandler:(void (^)(BOOL shouldTrustPeer))completionHandler;
  1122. @end
  1123. NS_ASSUME_NONNULL_END