895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
|
[_stream writeBuffer: buffer length: length];
} @catch (OFWriteFailedException *e) {
OFEnsure(e.bytesWritten <= length);
_bytesWritten += (int64_t)e.bytesWritten;
_CRC32 = OFCRC32(_CRC32, buffer, e.bytesWritten);
if (e.errNo == EWOULDBLOCK)
return e.bytesWritten;
@throw e;
}
_bytesWritten += (int64_t)length;
_CRC32 = OFCRC32(_CRC32, buffer, length);
|
|
|
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
|
[_stream writeBuffer: buffer length: length];
} @catch (OFWriteFailedException *e) {
OFEnsure(e.bytesWritten <= length);
_bytesWritten += (int64_t)e.bytesWritten;
_CRC32 = OFCRC32(_CRC32, buffer, e.bytesWritten);
if (e.errNo == EWOULDBLOCK || e.errNo == EAGAIN)
return e.bytesWritten;
@throw e;
}
_bytesWritten += (int64_t)length;
_CRC32 = OFCRC32(_CRC32, buffer, length);
|