taler/exchange
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

use blocking sendto() call to possibly eliminate need for nanosleep()

Browse Source
This commit is contained in:
Christian Grothoff 2021-01-06 10:07:12 +01:00
parent ad3d0a8997
commit e6f44e22ac
No known key found for this signature in database
GPG Key ID: 939E6BE1E29FC3CC
2 changed files with 16 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/util/taler-helper-crypto-eddsa.c
View File

@ -450,18 +450,19 @@ transmit (const struct sockaddr_un *addr,
socklen_t addr_size, socklen_t addr_size,
const struct GNUNET_MessageHeader *hdr) const struct GNUNET_MessageHeader *hdr)
{ {
ssize_t ret;
for (unsigned int i = 0; i<100; i++) for (unsigned int i = 0; i<100; i++)
{ {
ret = GNUNET_NETWORK_socket_sendto (unix_sock, ssize_t ret = sendto (GNUNET_NETWORK_get_fd (unix_sock),
hdr, hdr,
ntohs (hdr->size), ntohs (hdr->size),
(const struct sockaddr *) addr, 0 /* no flags => blocking! */,
addr_size); (const struct sockaddr *) addr,
addr_size);
if ( (-1 == ret) && if ( (-1 == ret) &&
(EAGAIN == errno) ) (EAGAIN == errno) )
{ {
/* _Maybe_ with blocking sendto(), this should no
longer be needed; still keeping it just in case. */
/* Wait a bit, in case client is just too slow */ /* Wait a bit, in case client is just too slow */
struct timespec req = { struct timespec req = {
.tv_sec = 0, .tv_sec = 0,

15
src/util/taler-helper-crypto-rsa.c
View File

@ -516,18 +516,19 @@ transmit (const struct sockaddr_un *addr,
socklen_t addr_size, socklen_t addr_size,
const struct GNUNET_MessageHeader *hdr) const struct GNUNET_MessageHeader *hdr)
{ {
ssize_t ret;
for (unsigned int i = 0; i<100; i++) for (unsigned int i = 0; i<100; i++)
{ {
ret = GNUNET_NETWORK_socket_sendto (unix_sock, ssize_t ret = sendto (GNUNET_NETWORK_get_fd (unix_sock),
hdr, hdr,
ntohs (hdr->size), ntohs (hdr->size),
(const struct sockaddr *) addr, 0 /* no flags => blocking! */,
addr_size); (const struct sockaddr *) addr,
addr_size);
if ( (-1 == ret) && if ( (-1 == ret) &&
(EAGAIN == errno) ) (EAGAIN == errno) )
{ {
/* _Maybe_ with blocking sendto(), this should no
longer be needed; still keeping it just in case. */
/* Wait a bit, in case client is just too slow */ /* Wait a bit, in case client is just too slow */
struct timespec req = { struct timespec req = {
.tv_sec = 0, .tv_sec = 0,