14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
#include <string.h>
#include <unistd.h>
#import "OFStream.h"
#import "OFExceptions.h"
#import "OFMacros.h"
extern int getpagesize(void);
|
>
>
>
|
>
>
>
>
>
>
>
>
>
>
>
>
>
|
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
#include <string.h>
#include <unistd.h>
#import "OFStream.h"
#import "OFExceptions.h"
#import "OFMacros.h"
#ifdef _WIN32
#include <windows.h>
#endif
static int pagesize = 0;
@implementation OFStream
- init
{
self = [super init];
cache = NULL;
#ifndef _WIN32
if (pagesize == 0)
if ((pagesize = sysconf(_SC_PAGESIZE)) == -1)
pagesize = 4096;
#else
if (pagesize == 0) {
SYSTEM_INFO si;
GetSystemInfo(&si);
pagesize = si.dwPageSize - 1;
}
#endif
return self;
}
- (size_t)readNBytes: (size_t)size
intoBuffer: (char*)buf
{
|
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
}
return ret;
}
}
}
/* Read until we get a newline or \0 */
tmp = [self allocWithSize: getpagesize()];
for (;;) {
@try {
len = [self readNBytes: getpagesize() - 1
intoBuffer: tmp];
} @catch (OFException *e) {
[self freeMem: tmp];
@throw e;
}
/* Look if there's a newline or \0 */
|
|
|
|
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
}
return ret;
}
}
}
/* Read until we get a newline or \0 */
tmp = [self allocWithSize: pagesize];
for (;;) {
@try {
len = [self readNBytes: pagesize - 1
intoBuffer: tmp];
} @catch (OFException *e) {
[self freeMem: tmp];
@throw e;
}
/* Look if there's a newline or \0 */
|