diff options
author | Mattias Andrée <maandree@operamail.com> | 2015-08-19 13:37:19 +0200 |
---|---|---|
committer | Mattias Andrée <maandree@operamail.com> | 2015-08-19 13:37:19 +0200 |
commit | ce5160a39d26a8e7cf0633d0d144436a5156837a (patch) | |
tree | 5ac139854c4d620f7549c4be4c1231644ba0a49b /src/mds-echo.c | |
parent | typo + continued work on mds-colour (diff) | |
download | mds-ce5160a39d26a8e7cf0633d0d144436a5156837a.tar.gz mds-ce5160a39d26a8e7cf0633d0d144436a5156837a.tar.bz2 mds-ce5160a39d26a8e7cf0633d0d144436a5156837a.tar.xz |
put full_send in libmdsserver, clients that only has one socket uses a macro to remove the socket parameter
Signed-off-by: Mattias Andrée <maandree@operamail.com>
Diffstat (limited to 'src/mds-echo.c')
-rw-r--r-- | src/mds-echo.c | 42 |
1 files changed, 11 insertions, 31 deletions
diff --git a/src/mds-echo.c b/src/mds-echo.c index e1366eb..a531812 100644 --- a/src/mds-echo.c +++ b/src/mds-echo.c @@ -80,6 +80,17 @@ static size_t echo_buffer_size = 0; /** + * Send a full message even if interrupted + * + * @param message:const char* The message to send + * @param length:size_t The length of the message + * @return :int Zero on success, -1 on error + */ +#define full_send(message, length) \ + ((full_send)(socket_fd, message, length)) + + +/** * This function will be invoked before `initialise_server` (if not re-exec:ing) * or before `unmarshal_server` (if re-exec:ing) * @@ -332,37 +343,6 @@ int echo_message(void) /** - * Send a full message even if interrupted - * - * @param message The message to send - * @param length The length of the message - * @return Zero on success, -1 on error - */ -int full_send(const char* message, size_t length) -{ - size_t sent; - - while (length > 0) - { - sent = send_message(socket_fd, message, length); - if (sent > length) - { - eprint("Sent more of a message than exists in the message, aborting."); - return -1; - } - else - fail_if ((sent < length) && (errno != EINTR)); - message += sent; - length -= sent; - } - return 0; - fail: - xperror(*argv); - return -1; -} - - -/** * This function is called when a signal that * signals that the system to dump state information * and statistics has been received |