X-Git-Url: http://git.ithinksw.org/ITFoundation.git/blobdiff_plain/68089b190f6a03c185722c8532197dacabf52f8d..HEAD:/ITByteStream.m?ds=inline diff --git a/ITByteStream.m b/ITByteStream.m old mode 100755 new mode 100644 index e4607b4..a96aa7f --- a/ITByteStream.m +++ b/ITByteStream.m @@ -1,125 +1,107 @@ -// -// ITByteStream.h -// ITFoundation -// -// Created by Alexander Strange on Thu Feb 27 2003. -// Copyright (c) 2003 __MyCompanyName__. All rights reserved. -// - #import "ITByteStream.h" // TODO: Add NSCopying/NSCoding support. Blocking reads (how would this work? NSConditionLock?) @implementation ITByteStream --(id) init -{ - if (self == [super init]) - { - data = [[NSMutableData alloc] init]; - lock = [[NSLock alloc] init]; - delegate = nil; - } - return self; + +- (id)init { + if (self == [super init]) { + data = [[NSMutableData alloc] init]; + lock = [[NSLock alloc] init]; + delegate = nil; + } + return self; } --(id) initWithDelegate:(id)d -{ - if (self == [super init]) - { - data = [[NSMutableData alloc] init]; - lock = [[NSLock alloc] init]; - delegate = [d retain]; - } - return self; +- (id)initWithDelegate:(id )d { + if (self == [super init]) { + data = [[NSMutableData alloc] init]; + lock = [[NSLock alloc] init]; + delegate = [d retain]; + } + return self; } --(id) initWithStream:(ITByteStream*)stream delegate:(id)d -{ - if (self == [super init]) - { - data = [stream->data copy]; - lock = [[NSLock alloc] init]; - delegate = [d retain]; - } - return 0; +- (id)initWithStream:(ITByteStream*)stream delegate:(id )d { + if (self == [super init]) { + data = [stream->data copy]; + lock = [[NSLock alloc] init]; + delegate = [d retain]; + } + return 0; } --(oneway void) dealloc -{ - [lock lock]; - [data release]; - [lock unlock]; - [lock release]; - [super dealloc]; +- (oneway void)dealloc { + [lock lock]; + [data release]; + [lock unlock]; + [lock release]; + [super dealloc]; } --setDelegate:(id )d -{ - id old = delegate; - [delegate release]; - delegate = [d retain]; - return old; +- (id )setDelegate:(id )d { + id old = delegate; + [delegate release]; + delegate = [d retain]; + return old; } --(int) availableDataLength -{ - int len; - [lock lock]; - len = [data length]; - [lock unlock]; - return len; +- (id )delegate { + return delegate; } --(NSData*) readDataOfLength:(int)length -{ - NSData *ret; - NSRange range = {0, length}; - [lock lock]; - ret = [data subdataWithRange:range]; - [data replaceBytesInRange:range withBytes:nil length:0]; - [lock unlock]; - return ret; +- (int)availableDataLength { + int len; + [lock lock]; + len = [data length]; + [lock unlock]; + return len; } --(NSData*) readAllData -{ - NSData *ret; - [lock lock]; - ret = [data autorelease]; - data = [[NSMutableData alloc] init]; - [lock unlock]; - return ret; +- (NSData*)readDataOfLength:(int)length { + NSData *ret; + NSRange range = {0, length}; + [lock lock]; + ret = [data subdataWithRange:range]; + [data replaceBytesInRange:range withBytes:nil length:0]; + [lock unlock]; + return ret; } --(void) writeData:(in NSData*)_data -{ - [lock lock]; - [data appendData:_data]; - [lock unlock]; - [delegate newDataAdded:self]; +- (NSData*)readAllData { + NSData *ret; + [lock lock]; + ret = [data autorelease]; + data = [[NSMutableData alloc] init]; + [lock unlock]; + return ret; } --(void) writeBytes:(in char *)b len:(long)length -{ - [lock lock]; - [data appendBytes:b length:length]; - [lock unlock]; - [delegate newDataAdded:self]; +- (void)writeData:(in NSData*)_data { + [lock lock]; + [data appendData:_data]; + [lock unlock]; + [delegate newDataAdded:self]; } --(void) lockStream -{ - [lock lock]; +- (void)writeBytes:(in char *)b len:(long)length { + [lock lock]; + [data appendBytes:b length:length]; + [lock unlock]; + [delegate newDataAdded:self]; } --(void) unlockStream -{ - [lock unlock]; +- (void)lockStream { + [lock lock]; } --(void) shortenData:(long)length -{ - NSRange range = {0, length}; - [data replaceBytesInRange:range withBytes:nil length:0]; +- (void)unlockStream { + [lock unlock]; } + +- (void)shortenData:(long)length { + NSRange range = {0, length}; + [data replaceBytesInRange:range withBytes:nil length:0]; +} + @end