42 |
else |
else |
43 |
return make_fixnum1(0); |
return make_fixnum1(0); |
44 |
} |
} |
45 |
|
#ifdef STATIC_FUNCTION_POINTERS |
46 |
|
object |
47 |
|
fScheck_fd_for_input(fixnum fd,fixnum timeout) { |
48 |
|
return FFN(fScheck_fd_for_input)(fd,timeout); |
49 |
|
} |
50 |
|
#endif |
51 |
|
|
52 |
|
|
53 |
|
|
183 |
{ bcopy(sfd->valid_data,sfd->read_buffer,sfd->valid_data_size); |
{ bcopy(sfd->valid_data,sfd->read_buffer,sfd->valid_data_size); |
184 |
sfd->valid_data=sfd->read_buffer;} |
sfd->valid_data=sfd->read_buffer;} |
185 |
/* there is at least a packet size of space available */ |
/* there is at least a packet size of space available */ |
186 |
if ((fix(fScheck_fd_for_input(sfd->fd,sfd->write_timeout))>0)); |
if ((fix(FFN(fScheck_fd_for_input)(sfd->fd,sfd->write_timeout))>0)); |
187 |
again: |
again: |
188 |
{char *start = sfd->valid_data+sfd->valid_data_size; |
{char *start = sfd->valid_data+sfd->valid_data_size; |
189 |
nread = read(sfd->fd,start, |
nread = read(sfd->fd,start, |
266 |
"Read on FD until nothing left to read. Return number of bytes read") |
"Read on FD until nothing left to read. Return number of bytes read") |
267 |
{char buffer[0x1000]; |
{char buffer[0x1000]; |
268 |
int n=0; |
int n=0; |
269 |
while (fix(fScheck_fd_for_input(fd,0))) |
while (fix(FFN(fScheck_fd_for_input)(fd,0))) |
270 |
{ n+=read(fd,buffer,sizeof(buffer)); |
{ n+=read(fd,buffer,sizeof(buffer)); |
271 |
} |
} |
272 |
|
|
273 |
return make_fixnum1(n); |
return make_fixnum1(n); |
274 |
} |
} |
275 |
|
#ifdef STATIC_FUNCTION_POINTERS |
276 |
|
object |
277 |
|
fSclear_connection(fixnum fd) { |
278 |
|
return FFN(fSclear_connection)(fd); |
279 |
|
} |
280 |
|
#endif |
281 |
|
|
282 |
|
|
283 |
|
|