2006-08-21 20:43:43 +02:00
|
|
|
#include "cache.h"
|
|
|
|
|
2007-01-08 16:58:08 +01:00
|
|
|
int read_in_full(int fd, void *buf, size_t count)
|
2006-12-23 08:33:55 +01:00
|
|
|
{
|
|
|
|
char *p = buf;
|
2007-01-08 16:58:08 +01:00
|
|
|
ssize_t total = 0;
|
2006-12-23 08:33:55 +01:00
|
|
|
|
|
|
|
while (count > 0) {
|
2007-01-12 05:37:38 +01:00
|
|
|
ssize_t loaded = xread(fd, p, count);
|
|
|
|
if (loaded <= 0)
|
|
|
|
return total ? total : loaded;
|
2006-12-23 08:33:55 +01:00
|
|
|
count -= loaded;
|
|
|
|
p += loaded;
|
2007-01-08 16:58:08 +01:00
|
|
|
total += loaded;
|
2006-12-23 08:33:55 +01:00
|
|
|
}
|
2007-01-08 16:58:08 +01:00
|
|
|
|
|
|
|
return total;
|
|
|
|
}
|
|
|
|
|
2007-01-08 16:58:23 +01:00
|
|
|
int write_in_full(int fd, const void *buf, size_t count)
|
2006-08-21 20:43:43 +02:00
|
|
|
{
|
|
|
|
const char *p = buf;
|
2007-01-08 16:58:23 +01:00
|
|
|
ssize_t total = 0;
|
2006-08-21 20:43:43 +02:00
|
|
|
|
|
|
|
while (count > 0) {
|
2007-01-11 22:04:11 +01:00
|
|
|
size_t written = xwrite(fd, p, count);
|
|
|
|
if (written < 0)
|
|
|
|
return -1;
|
|
|
|
if (!written) {
|
|
|
|
errno = ENOSPC;
|
|
|
|
return -1;
|
2006-08-21 20:43:43 +02:00
|
|
|
}
|
|
|
|
count -= written;
|
|
|
|
p += written;
|
2007-01-08 16:58:23 +01:00
|
|
|
total += written;
|
2006-08-21 20:43:43 +02:00
|
|
|
}
|
2007-01-08 16:58:23 +01:00
|
|
|
|
|
|
|
return total;
|
2006-08-21 20:43:43 +02:00
|
|
|
}
|
2006-08-31 08:42:11 +02:00
|
|
|
|
2007-01-08 16:58:23 +01:00
|
|
|
void write_or_die(int fd, const void *buf, size_t count)
|
2006-08-31 08:42:11 +02:00
|
|
|
{
|
2007-01-12 05:23:00 +01:00
|
|
|
if (write_in_full(fd, buf, count) < 0) {
|
2007-01-08 16:58:23 +01:00
|
|
|
if (errno == EPIPE)
|
|
|
|
exit(0);
|
|
|
|
die("write error (%s)", strerror(errno));
|
2007-01-08 16:57:52 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
int write_or_whine_pipe(int fd, const void *buf, size_t count, const char *msg)
|
|
|
|
{
|
2007-01-12 05:23:00 +01:00
|
|
|
if (write_in_full(fd, buf, count) < 0) {
|
2007-01-08 16:57:52 +01:00
|
|
|
if (errno == EPIPE)
|
|
|
|
exit(0);
|
|
|
|
fprintf(stderr, "%s: write error (%s)\n",
|
|
|
|
msg, strerror(errno));
|
|
|
|
return 0;
|
2006-08-31 08:42:11 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
return 1;
|
|
|
|
}
|
2007-01-02 15:12:09 +01:00
|
|
|
|
2007-01-08 16:57:52 +01:00
|
|
|
int write_or_whine(int fd, const void *buf, size_t count, const char *msg)
|
2007-01-02 15:12:09 +01:00
|
|
|
{
|
2007-01-12 05:23:00 +01:00
|
|
|
if (write_in_full(fd, buf, count) < 0) {
|
2007-01-08 16:57:52 +01:00
|
|
|
fprintf(stderr, "%s: write error (%s)\n",
|
|
|
|
msg, strerror(errno));
|
|
|
|
return 0;
|
2007-01-02 15:12:09 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
return 1;
|
|
|
|
}
|