33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
-
+
|
self = [super init];
if (isa == [OFStream class])
@throw [OFNotImplementedException newWithClass: isa
selector: _cmd];
cache = NULL;
wcache = NULL;
wbuffer = NULL;
return self;
}
- (BOOL)_atEndOfStream
{
@throw [OFNotImplementedException newWithClass: isa
|
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
|
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
|
-
+
-
+
-
+
-
+
-
-
+
+
-
-
-
-
+
+
+
+
-
+
-
-
-
-
+
+
+
+
|
[self freeMemory: tmp];
}
/* Get rid of a warning, never reached anyway */
assert(0);
}
- cacheWrites
- bufferWrites
{
use_wcache = YES;
use_wbuffer = YES;
return self;
}
- flushWriteCache
- flushWriteBuffer
{
if (wcache == NULL)
if (wbuffer == NULL)
return self;
[self _writeNBytes: wcache_len
fromBuffer: wcache];
[self _writeNBytes: wbuffer_len
fromBuffer: wbuffer];
[self freeMemory: wcache];
wcache = NULL;
wcache_len = 0;
use_wcache = NO;
[self freeMemory: wbuffer];
wbuffer = NULL;
wbuffer_len = 0;
use_wbuffer = NO;
return self;
}
- (size_t)writeNBytes: (size_t)size
fromBuffer: (const char*)buf
{
if (!use_wcache)
if (!use_wbuffer)
return [self _writeNBytes: size
fromBuffer: buf];
else {
wcache = [self resizeMemory: wcache
toSize: wcache_len + size];
memcpy(wcache + wcache_len, buf, size);
wcache_len += size;
wbuffer = [self resizeMemory: wbuffer
toSize: wbuffer_len + size];
memcpy(wbuffer + wbuffer_len, buf, size);
wbuffer_len += size;
return size;
}
}
- (void)writeInt8: (uint8_t)int8
{
|