522
523
524
525
526
527
528
529
530
531
532
533
534
535
|
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
|
+
+
+
+
+
+
+
|
- (size_t)socket: (OFTCPSocket *)socket
didWriteBody: (const void **)body
length: (size_t)length
context: (id)context
exception: (id)exception
{
if (exception != nil) {
[_client->_delegate client: _client
didEncounterException: exception
forRequest: _request];
return 0;
}
[socket asyncReadLineWithTarget: self
selector: @selector(socket:didReadLine:context:
exception:)
context: nil];
return 0;
}
|
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
|
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
|
-
+
|
[self closeAndReconnect];
return false;
}
[_client->_delegate client: _client
didEncounterException: exception
forRequest: _request];
return false;
return 0;
}
if ((body = [_request body]) != nil) {
[socket asyncWriteBuffer: [body items]
length: [body count] * [body itemSize]
target: self
selector: @selector(socket:didWriteBody:length:
|