543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
|
[self raiseException: e];
ret = false;
}
return ret;
}
- (void)stream: (OF_KINDOF(OFStream *))sock
didFailWithException: (id)exception
{
if ([exception isKindOfClass: [OFWriteFailedException class]] &&
([exception errNo] == ECONNRESET || [exception errNo] == EPIPE)) {
/* In case a keep-alive connection timed out */
[self closeAndReconnect];
return;
}
if ([exception isKindOfClass: [OFInvalidEncodingException class]])
exception = [OFInvalidServerReplyException exception];
[self raiseException: exception];
}
- (size_t)stream: (OF_KINDOF(OFStream *))sock
didWriteBuffer: (const void **)request
length: (size_t)length
{
|
|
|
>
>
>
>
>
>
>
>
>
<
<
<
|
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
|
[self raiseException: e];
ret = false;
}
return ret;
}
- (void)stream: (OF_KINDOF(OFStream *))sock
didFailToReadWithException: (id)exception
{
if ([exception isKindOfClass: [OFInvalidEncodingException class]])
exception = [OFInvalidServerReplyException exception];
[self raiseException: exception];
}
- (void)stream: (OF_KINDOF(OFStream *))sock
didFailToWriteWithException: (id)exception
{
if ([exception isKindOfClass: [OFWriteFailedException class]] &&
([exception errNo] == ECONNRESET || [exception errNo] == EPIPE)) {
/* In case a keep-alive connection timed out */
[self closeAndReconnect];
return;
}
[self raiseException: exception];
}
- (size_t)stream: (OF_KINDOF(OFStream *))sock
didWriteBuffer: (const void **)request
length: (size_t)length
{
|