diff options
author | Christian Grothoff <christian@grothoff.org> | 2020-12-31 21:23:33 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2020-12-31 21:23:33 +0100 |
commit | 3399ece8c3600ab630b9c99d47f6c3511c5c72f2 (patch) | |
tree | 45c451d6fdbaa67e6a2c622fb4cd717c2ced77c4 /src/util/taler-helper-crypto-eddsa.c | |
parent | 25ce6506d1c21ef6dda5f64bdef93a67c6796c67 (diff) | |
download | exchange-3399ece8c3600ab630b9c99d47f6c3511c5c72f2.tar.xz |
proposed fix for #6667
Diffstat (limited to 'src/util/taler-helper-crypto-eddsa.c')
-rw-r--r-- | src/util/taler-helper-crypto-eddsa.c | 42 |
1 files changed, 31 insertions, 11 deletions
diff --git a/src/util/taler-helper-crypto-eddsa.c b/src/util/taler-helper-crypto-eddsa.c index 6cf4c466e..8e05302c8 100644 --- a/src/util/taler-helper-crypto-eddsa.c +++ b/src/util/taler-helper-crypto-eddsa.c @@ -432,7 +432,13 @@ free_key (struct Key *key) /** - * Send a message starting with @a hdr to @a client. + * Send a message starting with @a hdr to @a client. We expect that + * the client is mostly able to handle everything at whatever speed + * we have (after all, the crypto should be the slow part). However, + * especially on startup when we send all of our keys, it is possible + * that the client cannot keep up. In that case, we throttle when + * sending fails. This does not work with poll() as we cannot specify + * the sendto() target address with poll(). So we nanosleep() instead. * * @param addr address where to send the message * @param addr_size number of bytes in @a addr @@ -446,18 +452,32 @@ transmit (const struct sockaddr_un *addr, { ssize_t ret; - ret = GNUNET_NETWORK_socket_sendto (unix_sock, - hdr, - ntohs (hdr->size), - (const struct sockaddr *) addr, - addr_size); - if (ret != ntohs (hdr->size)) + for (unsigned int i = 0; i<100; i++) { - GNUNET_log_strerror (GNUNET_ERROR_TYPE_INFO, - "sendto"); - return GNUNET_SYSERR; + ret = GNUNET_NETWORK_socket_sendto (unix_sock, + hdr, + ntohs (hdr->size), + (const struct sockaddr *) addr, + addr_size); + if ( (-1 == ret) && + (EAGAIN == errno) ) + { + /* Wait a bit, in case client is just too slow */ + struct timespec req = { + .tv_sec = 0, + .tv_nsec = 1000 + }; + nanosleep (&req, NULL); + continue; + } + if (ret == ntohs (hdr->size)) + return GNUNET_OK; + if (ret != ntohs (hdr->size)) + break; } - return GNUNET_OK; + GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, + "sendto"); + return GNUNET_SYSERR; } |