macosx-10.9.5/CF-855.17/CFConcreteStreams.c

556     _CFReadDataStreamContext *dataStream = (_CFReadDataStreamContext *)info;
557     if (dataStream->scheduled) {
558         if (CFDataGetLength(dataStream->data) != 0) {
570     _CFReadDataStreamContext *dataStream = (_CFReadDataStreamContext *)info;
571     if (dataStream->scheduled == FALSE) {
572         dataStream->scheduled = TRUE;
575         if (CFDataGetBytePtr(dataStream->data) + CFDataGetLength(dataStream->data) > dataStream->loc) {
631     _CFWriteDataStreamContext *dataStream = (_CFWriteDataStreamContext *)info;
632     if (dataStream->scheduled) {
633         if (dataStream->bufferAllocator != kCFAllocatorNull || dataStream->currentBuf->capacity > dataStream->currentBuf->length) {
645     _CFWriteDataStreamContext *dataStream = (_CFWriteDataStreamContext *)info;
646     if (dataStream->scheduled == FALSE) {
647         dataStream->scheduled = TRUE;
650         if (dataStream->bufferAllocator != kCFAllocatorNull || dataStream->currentBuf->capacity > dataStream->currentBuf->length) {
659     _CFWriteDataStreamContext *dataStream = (_CFWriteDataStreamContext *)info;
661     CFIndex freeSpace = dataStream->currentBuf->capacity - dataStream->currentBuf->length;
662     if (dataStream->bufferAllocator == kCFAllocatorNull && bufferLength > freeSpace) {
671                 memmove(dataStream->currentBuf->bytes + dataStream->currentBuf->length, buffer, amountToCopy);
674                 dataStream->currentBuf->length += amountToCopy;
678                 _CFStreamByteBuffer *newBuf = (_CFStreamByteBuffer *)CFAllocatorAllocate(dataStream->bufferAllocator, sizeof(_CFStreamByteBuffer) + bufSize, 0);
688                     dataStream->currentBuf->next = newBuf;
689                     dataStream->currentBuf = newBuf;
696     if (dataStream->scheduled && (dataStream->bufferAllocator != kCFAllocatorNull || dataStream->currentBuf->capacity > dataStream->currentBuf->length)) {
703     _CFWriteDataStreamContext *dataStream = (_CFWriteDataStreamContext *)info;
704     if (dataStream->bufferAllocator != kCFAllocatorNull) return TRUE;
705     if (dataStream->currentBuf->capacity  > dataStream->currentBuf->length) return TRUE;
710     _CFWriteDataStreamContext *dataStream = (_CFWriteDataStreamContext *)info;
716     if (dataStream->bufferAllocator == kCFAllocatorNull)  return NULL;
717     alloc = dataStream->bufferAllocator;
718     for (buf = dataStream->firstBuf; buf != NULL; buf = buf->next) {
723     for (buf = dataStream->firstBuf; buf != NULL; buf = buf->next) {