TD-100
This commit is contained in:
parent
a299c6769e
commit
34cda1cb94
|
@ -291,6 +291,30 @@ int taosInitTimer(void (*callback)(int), int ms) {
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
ssize_t tread(int fd, void *buf, size_t count) {
|
||||||
|
size_t leftbytes = count;
|
||||||
|
ssize_t readbytes;
|
||||||
|
char * tbuf = (char *)buf;
|
||||||
|
|
||||||
|
while (leftbytes > 0) {
|
||||||
|
readbytes = read(fd, (void *)tbuf, leftbytes);
|
||||||
|
if (readbytes < 0) {
|
||||||
|
if (errno == EINTR) {
|
||||||
|
continue;
|
||||||
|
} else {
|
||||||
|
return -1;
|
||||||
|
}
|
||||||
|
} else if (readbytes == 0) {
|
||||||
|
return (ssize_t)(count - leftbytes);
|
||||||
|
}
|
||||||
|
|
||||||
|
leftbytes -= readbytes;
|
||||||
|
tbuf += readbytes;
|
||||||
|
}
|
||||||
|
|
||||||
|
return (ssize_t)count;
|
||||||
|
}
|
||||||
|
|
||||||
ssize_t tsendfile(int dfd, int sfd, off_t *offset, size_t size) {
|
ssize_t tsendfile(int dfd, int sfd, off_t *offset, size_t size) {
|
||||||
size_t leftbytes = size;
|
size_t leftbytes = size;
|
||||||
ssize_t sentbytes;
|
ssize_t sentbytes;
|
||||||
|
@ -308,6 +332,8 @@ ssize_t tsendfile(int dfd, int sfd, off_t *offset, size_t size) {
|
||||||
else {
|
else {
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
} else if (sentbytes == 0) {
|
||||||
|
return (ssize_t)(size - leftbytes);
|
||||||
}
|
}
|
||||||
|
|
||||||
leftbytes -= sentbytes;
|
leftbytes -= sentbytes;
|
||||||
|
|
Loading…
Reference in New Issue