X-Git-Url: http://git.silcnet.org/gitweb/?p=runtime.git;a=blobdiff_plain;f=lib%2Fsilcutil%2Funix%2Fsilcunixsocketstream.c;h=35b0ceedcde1d702dc1c37496b9fbaee9a54fc1d;hp=60d458d4a19bb39be74a42dbd3ca625cf7ee32a6;hb=afcd9ed820b767d8b6676a9156fa561b24ac2363;hpb=ff6a990d9e7361a5d1eb9909483bcea7decef4d4 diff --git a/lib/silcutil/unix/silcunixsocketstream.c b/lib/silcutil/unix/silcunixsocketstream.c index 60d458d4..35b0ceed 100644 --- a/lib/silcutil/unix/silcunixsocketstream.c +++ b/lib/silcutil/unix/silcunixsocketstream.c @@ -16,9 +16,8 @@ GNU General Public License for more details. */ -/* $Id$ */ -#include "silc.h" +#include "silcruntime.h" /************************ Static utility functions **************************/ @@ -77,6 +76,7 @@ int silc_socket_stream_read(SilcStream stream, unsigned char *buf, if (!sock->qos) { len = read(sock->sock, buf, buf_len); if (len < 0) { + silc_set_errno_posix(errno); if (errno == EAGAIN || errno == EINTR) { SILC_LOG_DEBUG(("Could not read immediately, will do it later")); silc_schedule_set_listen_fd(sock->schedule, sock->sock, @@ -88,7 +88,6 @@ int silc_socket_stream_read(SilcStream stream, unsigned char *buf, SILC_LOG_DEBUG(("Cannot read from socket: %d:%s", sock->sock, strerror(errno))); silc_schedule_unset_listen_fd(sock->schedule, sock->sock); - sock->sock_error = errno; return -2; } @@ -123,6 +122,7 @@ int silc_socket_stream_read(SilcStream stream, unsigned char *buf, sock->qos->read_limit_bytes); len = read(sock->sock, qosbuf, len); if (len < 0) { + silc_set_errno_posix(errno); if (errno == EAGAIN || errno == EINTR) { SILC_LOG_DEBUG(("Could not read immediately, will do it later")); silc_schedule_set_listen_fd(sock->schedule, sock->sock, @@ -136,7 +136,6 @@ int silc_socket_stream_read(SilcStream stream, unsigned char *buf, silc_schedule_unset_listen_fd(sock->schedule, sock->sock); silc_schedule_task_del_by_context(sock->schedule, sock->qos); sock->qos->data_len = 0; - sock->sock_error = errno; return -2; } @@ -188,6 +187,7 @@ int silc_socket_stream_write(SilcStream stream, const unsigned char *data, ret = write(sock->sock, data, data_len); if (ret < 0) { + silc_set_errno_posix(errno); if (errno == EAGAIN || errno == EINTR) { SILC_LOG_DEBUG(("Could not write immediately, will do it later")); silc_schedule_set_listen_fd(sock->schedule, sock->sock, @@ -196,7 +196,6 @@ int silc_socket_stream_write(SilcStream stream, const unsigned char *data, } SILC_LOG_DEBUG(("Cannot write to socket: %s", strerror(errno))); silc_schedule_unset_listen_fd(sock->schedule, sock->sock); - sock->sock_error = errno; return -2; } @@ -232,27 +231,6 @@ int silc_socket_udp_stream_write(SilcStream stream, const unsigned char *data, return silc_socket_stream_write(stream, data, data_len); } -#if 0 -/* Returns human readable socket error message */ - -SilcBool silc_socket_get_error(SilcStream sock, char *error, - SilcUInt32 error_len) -{ - char *err; - - if (!sock->sock_error) - return FALSE; - - err = strerror(sock->sock_error); - if (strlen(err) > error_len) - return FALSE; - - memset(error, 0, error_len); - memcpy(error, err, strlen(err)); - return TRUE; -} -#endif - /* Closes socket */ SilcBool silc_socket_stream_close(SilcStream stream)