haiwen/libsearpc
1
0
Fork 0
mirror of https://github.com/haiwen/libsearpc.git synced 2025-09-02 05:14:48 +00:00
Code Issues Releases Wiki Activity

Replace tabs with spaces.

Browse Source
This commit is contained in:
Shuai Lin
2016-05-19 12:04:01 +08:00
parent ae0cebc0eb
commit b76607f784
2 changed files with 33 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
lib/searpc-utils.c
View File

@@ -247,52 +247,52 @@ GObject *json_gobject_deserialize (GType gtype, json_t *object)
ssize_t ssize_t
pipe_write_n(int fd, const void *vptr, size_t n) pipe_write_n(int fd, const void *vptr, size_t n)
{ {
size_t nleft; size_t nleft;
ssize_t nwritten; ssize_t nwritten;
const char *ptr; const char *ptr;
ptr = vptr; ptr = vptr;
nleft = n; nleft = n;
while (nleft > 0) { while (nleft > 0) {
#ifndef WIN32 #ifndef WIN32
if ( (nwritten = write(fd, ptr, nleft)) <= 0) if ( (nwritten = write(fd, ptr, nleft)) <= 0)
#else #else
if ( (nwritten = send(fd, ptr, nleft, 0)) <= 0) if ( (nwritten = send(fd, ptr, nleft, 0)) <= 0)
#endif #endif
{ {
if (nwritten < 0 && errno == EINTR) if (nwritten < 0 && errno == EINTR)
nwritten = 0; /* and call write() again */ nwritten = 0; /* and call write() again */
else else
return(-1); /* error */ return(-1); /* error */
} }
nleft -= nwritten; nleft -= nwritten;
ptr += nwritten; ptr += nwritten;
} }
return(n); return(n);
} }
// Read "n" bytes from a descriptor. // Read "n" bytes from a descriptor.
ssize_t ssize_t
pipe_read_n(int fd, void *vptr, size_t n) pipe_read_n(int fd, void *vptr, size_t n)
{ {
size_t nleft; size_t nleft;
ssize_t nread; ssize_t nread;
char *ptr; char *ptr;
ptr = vptr; ptr = vptr;
nleft = n; nleft = n;
while (nleft > 0) { while (nleft > 0) {
if ( (nread = read(fd, ptr, nleft)) < 0) { if ( (nread = read(fd, ptr, nleft)) < 0) {
if (errno == EINTR) if (errno == EINTR)
nread = 0; /* and call read() again */ nread = 0; /* and call read() again */
else else
return(-1); return(-1);
} else if (nread == 0) } else if (nread == 0)
break; /* EOF */ break; /* EOF */
nleft -= nread; nleft -= nread;
ptr += nread; ptr += nread;
} }
return(n - nleft); /* return >= 0 */ return(n - nleft); /* return >= 0 */
} }

2
lib/searpc-utils.h
View File

@@ -62,4 +62,4 @@ inline static json_int_t json_array_get_int_element (json_t *array, size_t index
ssize_t pipe_write_n(int fd, const void *vptr, size_t n); ssize_t pipe_write_n(int fd, const void *vptr, size_t n);
// Read "n" bytes from a descriptor. // Read "n" bytes from a descriptor.
ssize_t pipe_read_n(int fd, void *vptr, size_t n); ssize_t pipe_read_n(int fd, void *vptr, size_t n);