getting rid of unnecessary ignore_shutdown calls
authorChristian Grothoff <christian@grothoff.org>
Sun, 23 Oct 2011 10:06:07 +0000 (10:06 +0000)
committerChristian Grothoff <christian@grothoff.org>
Sun, 23 Oct 2011 10:06:07 +0000 (10:06 +0000)
src/arm/arm_api.c
src/arm/test_exponential_backoff.c
src/include/gnunet_client_lib.h
src/util/client.c
src/util/connection.c

index 6d6cb978fea901d68681fc357dec45bcd1e104ae..c15c59875bbac2052b19faf0e43ad445ebe574d1 100644 (file)
@@ -470,7 +470,6 @@ handle_response (void *cls, const struct GNUNET_MessageHeader *msg)
     GNUNET_CLIENT_disconnect (sc->h->client, GNUNET_NO);
     sc->h->client = GNUNET_CLIENT_connect ("arm", sc->h->cfg);
     GNUNET_assert (NULL != sc->h->client);
-    GNUNET_CLIENT_ignore_shutdown (sc->h->client, GNUNET_YES);
     if (sc->callback != NULL)
       sc->callback (sc->cls, GNUNET_SYSERR);
     GNUNET_free (sc);
@@ -618,7 +617,6 @@ GNUNET_ARM_start_service (struct GNUNET_ARM_Handle *h, const char *service_name,
     }
     LOG (GNUNET_ERROR_TYPE_DEBUG,
          "arm_api, GNUNET_CLIENT_connect returned non-NULL\n");
-    GNUNET_CLIENT_ignore_shutdown (client, GNUNET_YES);
     h->client = client;
   }
   LOG (GNUNET_ERROR_TYPE_DEBUG, "arm_api, h->client non-NULL\n");
@@ -673,7 +671,6 @@ GNUNET_ARM_stop_service (struct GNUNET_ARM_Handle *h, const char *service_name,
       cb (cb_cls, GNUNET_SYSERR);
       return;
     }
-    GNUNET_CLIENT_ignore_shutdown (client, GNUNET_YES);
     h->client = client;
   }
   if (0 == strcasecmp ("arm", service_name))
index ec2f4545d8b9e18ce41ebbb12cf3c9fd5318f671..3ff4d284fd0166c46f4e485556fe695a6c73ac02 100644 (file)
@@ -188,7 +188,7 @@ write_shutdown (void *cls, size_t size, void *buf)
 
   if (size < sizeof (struct GNUNET_MessageHeader))
   {
-    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
+    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
                 _("Failed to transmit shutdown request to client.\n"));
     shutdown_ctx->cont (shutdown_ctx->cont_cls, GNUNET_SYSERR);
     GNUNET_CLIENT_disconnect (shutdown_ctx->sock, GNUNET_NO);
index a962158869b5553ad4a8fe7fda4c2b8d95d7a37d..60fa938c80b6cbc6bcbeff7dd606148317bc200f 100644 (file)
@@ -58,18 +58,6 @@ GNUNET_CLIENT_connect (const char *service_name,
                        const struct GNUNET_CONFIGURATION_Handle *cfg);
 
 
-/**
- * Configure this connection to ignore shutdown signals.
- *
- * @param h client handle
- * @param do_ignore GNUNET_YES to ignore, GNUNET_NO to restore default
- */
-void
-GNUNET_CLIENT_ignore_shutdown (struct GNUNET_CLIENT_Connection *h,
-                               int do_ignore);
-
-
-
 /**
  * Destroy connection with the service.  This will automatically
  * cancel any pending "receive" request (however, the handler will
index 5d5387ef91a2dab2f0d4d940c6b16bff24e45d1f..d2f347947c4151e21a0906005015d12c2cd60bd0 100644 (file)
@@ -241,11 +241,6 @@ struct GNUNET_CLIENT_Connection
    */
   int in_receive;
 
-  /**
-   * Are we ignoring shutdown signals?
-   */
-  int ignore_shutdown;
-
   /**
    * How often have we tried to connect?
    */
@@ -381,22 +376,6 @@ GNUNET_CLIENT_connect (const char *service_name,
 }
 
 
-/**
- * Configure this connection to ignore shutdown signals.
- *
- * @param h client handle
- * @param do_ignore GNUNET_YES to ignore, GNUNET_NO to restore default
- */
-void
-GNUNET_CLIENT_ignore_shutdown (struct GNUNET_CLIENT_Connection *h,
-                              int do_ignore)
-{
-  h->ignore_shutdown = do_ignore;
-  if (h->sock != NULL)
-    GNUNET_CONNECTION_ignore_shutdown (h->sock, do_ignore);
-}
-
-
 /**
  * Destroy connection with the service.  This will automatically
  * cancel any pending "receive" request (however, the handler will
@@ -960,8 +939,6 @@ client_delayed_retry (void *cls,
        GNUNET_SCHEDULER_add_delayed (delay, &client_delayed_retry, th);
       return;
     }
-  GNUNET_CONNECTION_ignore_shutdown (th->sock->sock,
-                                    th->sock->ignore_shutdown);
   th->th =
     GNUNET_CONNECTION_notify_transmit_ready (th->sock->sock, th->size,
                                             GNUNET_TIME_absolute_get_remaining
index 4beafa3f39940d3357b985082d84add761474b34..cd0035a8f30626c6a98af87e9282e4814128d3c0 100644 (file)
@@ -1495,7 +1495,8 @@ transmit_ready (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
   GNUNET_assert (sock->nth.timeout_task == GNUNET_SCHEDULER_NO_TASK);
   if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
     {
-      if (sock->ignore_shutdown == GNUNET_YES)
+      if ( (sock->ignore_shutdown == GNUNET_YES) &&
+          (NULL != sock->sock) )
        goto SCHEDULE_WRITE;    /* ignore shutdown, go again immediately */
 #if DEBUG_CONNECTION
       LOG (GNUNET_ERROR_TYPE_DEBUG,