git.ithinksw.org
/
ITFoundation.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Enabling garbage collection support.
[ITFoundation.git]
/
ITByteStream.m
diff --git
a/ITByteStream.m
b/ITByteStream.m
old mode 100755
(executable)
new mode 100644
(file)
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
#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 <ITDataReceiver>)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 <ITDataReceiver>)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 <DataReciever>)d
-{
- id old = delegate;
- [delegate release];
- delegate = [d retain];
- return old;
+- (id <ITDataReceiver>)setDelegate:(id <ITDataReceiver>)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 <ITDataReceiver>)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 autoreleas
e];
-
data = [[NSMutableData alloc] init
];
- [lock unlock];
- return ret;
+-
(NSData*)readDataOfLength:(int)length {
+ NSData *ret;
+
NSRange range = {0, length}
;
+
[lock lock];
+
ret = [data subdataWithRange:rang
e];
+
[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
@end