return p;
}
+
/**
* Closes an interprocess channel
- * @param p pipe
+ *
+ * @param p pipe to close
* @return GNUNET_OK on success, GNUNET_SYSERR otherwise
*/
int
GNUNET_DISK_pipe_close (struct GNUNET_DISK_PipeHandle *p)
{
- int ret;
-
- ret = GNUNET_OK;
-
+ int ret = GNUNET_OK;
#ifdef MINGW
if (!CloseHandle (p->fd[0].h))
{
ret = GNUNET_SYSERR;
}
#else
- {
- int save;
-
- if (close (p->fd[0].fd) != -1)
- {
- ret = GNUNET_SYSERR;
- save = errno;
- }
- else
- save = 0;
-
- if (close (p->fd[1].fd) != -1)
- {
- ret = GNUNET_SYSERR;
- }
- else
- errno = save;
- }
+ int save;
+
+ if (0 != close (p->fd[0].fd))
+ {
+ ret = GNUNET_SYSERR;
+ save = errno;
+ }
+ else
+ save = 0;
+
+ if (0 != close (p->fd[1].fd))
+ ret = GNUNET_SYSERR;
+ else
+ errno = save;
#endif
GNUNET_free (p);
-
return ret;
}
+
/**
* Get the handle to a particular pipe end
* @param p pipe
"Server shutting down.\n");
#endif
GNUNET_assert (server->listen_socket == NULL);
- GNUNET_break (GNUNET_YES == GNUNET_DISK_pipe_close (server->shutpipe));
+ if (GNUNET_OK != GNUNET_DISK_pipe_close (server->shutpipe))
+ GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING,
+ "pipe-close");
while (server->clients != NULL)
{
pos = server->clients;
struct GNUNET_NETWORK_Descriptor *lsock;
struct GNUNET_NETWORK_FDSet *r;
- lsock = NULL; // FIXME NILS: this was -2, does that have a special meaning?
+ lsock = NULL;
if (serverAddr != NULL)
{
lsock = open_listen_socket (serverAddr, socklen);
}
ret = GNUNET_malloc (sizeof (struct GNUNET_SERVER_Handle));
ret->shutpipe = GNUNET_malloc (sizeof (struct GNUNET_DISK_FileDescriptor *[2]));
- if ((ret->shutpipe = GNUNET_DISK_pipe (GNUNET_NO)) == NULL)
+ if (NULL == (ret->shutpipe = GNUNET_DISK_pipe (GNUNET_NO)))
{
GNUNET_break (0 == GNUNET_NETWORK_socket_close (lsock));
GNUNET_free (ret->shutpipe);
static size_t sofar;
-static int ls;
+static struct GNUNET_NETWORK_Descriptor *ls;
if (GNUNET_NETWORK_socket_setsockopt (desc, SOL_SOCKET, SO_REUSEADDR, &on, sizeof (on)) < 0)
GNUNET_log (GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
"setsockopt");
- GNUNET_assert (GNUNET_NETWORK_socket_bind (desc, &sa, sizeof (sa)) >= 0);
+ GNUNET_assert (GNUNET_NETWORK_socket_bind (desc,
+ (const struct sockaddr*) &sa,
+ sizeof (sa)) >= 0);
GNUNET_NETWORK_socket_listen (desc, 5);
return desc;
}
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Test accepts connection\n");
#endif
asock = GNUNET_CONNECTION_create_from_accept (tc->sched,
- NULL, NULL, ls, 1024);
+ NULL, NULL, ls, 1024);
GNUNET_assert (asock != NULL);
GNUNET_assert (GNUNET_YES == GNUNET_CONNECTION_check (asock));
#if VERBOSE
if (GNUNET_NETWORK_socket_setsockopt (desc, SOL_SOCKET, SO_REUSEADDR, &on, sizeof (on)) < 0)
GNUNET_log (GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
"setsockopt");
- GNUNET_assert (GNUNET_NETWORK_socket_bind (desc, &sa, sizeof (sa)) >= 0);
+ GNUNET_assert (GNUNET_NETWORK_socket_bind (desc,
+ (const struct sockaddr*) &sa,
+ sizeof (sa)) >= 0);
GNUNET_NETWORK_socket_listen (desc, 5);
return desc;
}
if (GNUNET_NETWORK_socket_setsockopt (desc, SOL_SOCKET, SO_REUSEADDR, &on, sizeof (on)) < 0)
GNUNET_log (GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
"setsockopt");
- GNUNET_assert (GNUNET_NETWORK_socket_bind (desc, &sa, sizeof (sa)) >= 0);
+ GNUNET_assert (GNUNET_NETWORK_socket_bind (desc,
+ (const struct sockaddr*) &sa,
+ sizeof (sa)) >= 0);
GNUNET_NETWORK_socket_listen (desc, 5);
return desc;
}
if (GNUNET_NETWORK_socket_setsockopt (desc, SOL_SOCKET, SO_REUSEADDR, &on, sizeof (on)) < 0)
GNUNET_log (GNUNET_ERROR_TYPE_ERROR | GNUNET_ERROR_TYPE_BULK,
"setsockopt");
- GNUNET_assert (GNUNET_NETWORK_socket_bind (desc, &sa, sizeof (sa)) >= 0);
+ GNUNET_assert (GNUNET_NETWORK_socket_bind (desc,
+ (const struct sockaddr*) &sa,
+ sizeof (sa)) >= 0);
GNUNET_NETWORK_socket_listen (desc, 5);
return desc;
}
if (1 != GNUNET_CRYPTO_hash_get_bit (&d, 6))
return 1;
memset (&d, 0, sizeof (d));
- GNUNET_CRYPTO_hash_to_AES_key (&d, &skey, &iv);
+ GNUNET_CRYPTO_hash_to_aes_key (&d, &skey, &iv);
if ((0 != memcmp (&skey, &zskey, sizeof (skey) - sizeof (unsigned int))) ||
(0 != memcmp (&iv, &ziv, sizeof (iv))))
return 1;
}
struct GNUNET_DISK_PipeHandle *p;
-static struct GNUNET_DISK_FileHandle *fds[2];
+static const struct GNUNET_DISK_FileHandle *fds[2];
static void