security-and-privacy/gnupg
security-and-privacy/gnupg
1
0
Fork 0
mirror of git://git.gnupg.org/gnupg.git synced 2025-05-19 09:02:22 +02:00
Code Activity

w32: Fix http access module.

Browse Source 
* common/http.c (write_server) [W32]: Rework to use send() instead of
write even when build with npth.
(cookie_read) [W32]: Rework to use recv() instead of read even when
build with npth.
This commit is contained in:
Werner Koch 2014-11-07 18:21:50 +01:00
parent c7c79e3193
commit f0f5cb6b3e
1 changed files with 25 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
common/http.c
View File

@ -2320,14 +2320,20 @@ write_server (int sock, const char *data, size_t length)
nleft = length; nleft = length;
while (nleft > 0) while (nleft > 0)
{ {
#if defined(HAVE_W32_SYSTEM) && !defined(USE_NPTH) #if defined(HAVE_W32_SYSTEM)
# if defined(USE_NPTH)
npth_unprotect ();
# endif
nwritten = send (sock, data, nleft, 0); nwritten = send (sock, data, nleft, 0);
# if defined(USE_NPTH)
npth_protect ();
# endif
if ( nwritten == SOCKET_ERROR ) if ( nwritten == SOCKET_ERROR )
{ {
log_info ("network write failed: ec=%d\n", (int)WSAGetLastError ()); log_info ("network write failed: ec=%d\n", (int)WSAGetLastError ());
return gpg_error (GPG_ERR_NETWORK); return gpg_error (GPG_ERR_NETWORK);
} }
#else /*!HAVE_W32_SYSTEM || USE_NPTH*/ #else /*!HAVE_W32_SYSTEM*/
# ifdef USE_NPTH # ifdef USE_NPTH
nwritten = npth_write (sock, data, nleft); nwritten = npth_write (sock, data, nleft);
# else # else
@ -2349,7 +2355,7 @@ write_server (int sock, const char *data, size_t length)
log_info ("network write failed: %s\n", strerror (errno)); log_info ("network write failed: %s\n", strerror (errno));
return gpg_error_from_syserror (); return gpg_error_from_syserror ();
} }
#endif /*!HAVE_W32_SYSTEM || USE_NPTH*/ #endif /*!HAVE_W32_SYSTEM*/
nleft -= nwritten; nleft -= nwritten;
data += nwritten; data += nwritten;
} }
@ -2404,14 +2410,25 @@ cookie_read (void *cookie, void *buffer, size_t size)
{ {
do do
{ {
#ifdef USE_NPTH #ifdef HAVE_W32_SYSTEM
nread = npth_read (c->sock->fd, buffer, size);
#elif defined(HAVE_W32_SYSTEM)
/* Under Windows we need to use recv for a socket. */ /* Under Windows we need to use recv for a socket. */
# if defined(USE_NPTH)
npth_unprotect ();
# endif
nread = recv (c->sock->fd, buffer, size, 0); nread = recv (c->sock->fd, buffer, size, 0);
#else # if defined(USE_NPTH)
npth_protect ();
# endif
#else /*!HAVE_W32_SYSTEM*/
# ifdef USE_NPTH
nread = npth_read (c->sock->fd, buffer, size);
# else
nread = read (c->sock->fd, buffer, size); nread = read (c->sock->fd, buffer, size);
#endif # endif
#endif /*!HAVE_W32_SYSTEM*/
} }
while (nread == -1 && errno == EINTR); while (nread == -1 && errno == EINTR);
} }