fix check for close
authorChristian Grothoff <christian@grothoff.org>
Sat, 29 Aug 2009 20:00:36 +0000 (20:00 +0000)
committerChristian Grothoff <christian@grothoff.org>
Sat, 29 Aug 2009 20:00:36 +0000 (20:00 +0000)
src/util/disk.c
src/util/server.c
src/util/test_connection.c
src/util/test_connection_addressing.c
src/util/test_connection_receive_cancel.c
src/util/test_connection_timeout.c
src/util/test_crypto_hash.c
src/util/test_scheduler.c

index ef7a6235187f274faf9b421c26e91e2bcd5ba591..412f8fb16326fa2b1ce196d8a5619a6c994b16cf 100644 (file)
@@ -1481,18 +1481,17 @@ GNUNET_DISK_pipe (int blocking)
   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))
     {
@@ -1506,30 +1505,26 @@ GNUNET_DISK_pipe_close (struct GNUNET_DISK_PipeHandle *p)
       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
index 8fcc20830cc2a7588d867e2c18233d63fe78245f..c05247a63656c1ab06556da647fbf1164a936242 100644 (file)
@@ -282,7 +282,9 @@ destroy_server (struct GNUNET_SERVER_Handle *server)
              "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;
@@ -455,7 +457,7 @@ GNUNET_SERVER_create (struct GNUNET_SCHEDULER_Handle *sched,
   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);
@@ -464,7 +466,7 @@ GNUNET_SERVER_create (struct GNUNET_SCHEDULER_Handle *sched,
     }
   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);
index 3ca09281d041496348e68ecc90ef29fa4828c20a..770b34e8ce08595c6f1bab4da0d269f7cba5a70c 100644 (file)
@@ -40,7 +40,7 @@ static struct GNUNET_CONNECTION_Handle *lsock;
 
 static size_t sofar;
 
-static int ls;
+static struct GNUNET_NETWORK_Descriptor *ls;
 
 
 
@@ -64,7 +64,9 @@ open_listen_socket ()
   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;
 }
@@ -113,7 +115,7 @@ run_accept (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
   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
index 650b716af0a2f1f21a5695c1f12015f43a4f71ef..de11560d3306ff935d94869f2a63867f37384cfe 100644 (file)
@@ -63,7 +63,9 @@ open_listen_socket ()
   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;
 }
index 338caa737820eff1ed3e572ad9c160e54cb91371..eb9d906ffed5a55897aa9f9b1e5028a3b4a97104 100644 (file)
@@ -64,7 +64,9 @@ open_listen_socket ()
   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;
 }
index 61d9a2d0774fcbc9ef649e9be12675b1c3d613ab..289bb102a01c59026c403914e77ed26fe550f0c4 100644 (file)
@@ -57,7 +57,9 @@ open_listen_socket ()
   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;
 }
index a22a0e16a1f80ed14caa25f0d41e6de9bab6fdea..e10aee9b1c11ebb531a537b1cfe7cd68a080efb4 100644 (file)
@@ -98,7 +98,7 @@ testArithmetic ()
   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;
index 34def7b1eeda898d771b6a866bd410fc94eec8c5..6ae293058a6b43a07bc937e01a7b28a0227dce95 100644 (file)
@@ -57,7 +57,7 @@ task4 (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 }
 
 struct GNUNET_DISK_PipeHandle *p;
-static struct GNUNET_DISK_FileHandle *fds[2];
+static const struct GNUNET_DISK_FileHandle *fds[2];
 
 
 static void