66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
}
- (BOOL)_isAtEndOfStream
{
return atEndOfStream;
}
- (size_t)_readNBytes: (size_t)length
intoBuffer: (void*)buffer
|
<
|
>
|
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
}
- (BOOL)_isAtEndOfStream
{
return atEndOfStream;
}
- (size_t)_readIntoBuffer: (void*)buffer
length: (size_t)length
{
ssize_t ret;
if (sock == INVALID_SOCKET)
@throw [OFNotConnectedException exceptionWithClass: isa
socket: self];
|
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
if (ret == 0)
atEndOfStream = YES;
return ret;
}
- (void)_writeNBytes: (size_t)length
fromBuffer: (const void*)buffer
|
<
|
>
|
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
if (ret == 0)
atEndOfStream = YES;
return ret;
}
- (void)_writeBuffer: (const void*)buffer
length: (size_t)length
{
if (sock == INVALID_SOCKET)
@throw [OFNotConnectedException exceptionWithClass: isa
socket: self];
if (atEndOfStream) {
OFWriteFailedException *e;
|