fix
authorChristian Grothoff <christian@grothoff.org>
Mon, 30 May 2011 09:04:56 +0000 (09:04 +0000)
committerChristian Grothoff <christian@grothoff.org>
Mon, 30 May 2011 09:04:56 +0000 (09:04 +0000)
src/datastore/datastore_api.c

index d861157d9b048fb29e1c20b15aa4d67e09596ac7..33b5cc2329b5dd110cb646e2d9364a116e26e237 100644 (file)
@@ -764,6 +764,8 @@ process_status_message (void *cls,
                 _("Failed to receive status response from database."));
       if (was_transmitted == GNUNET_YES)
        do_disconnect (h);
+      else
+       process_queue (h);
       return;
     }
   GNUNET_assert (GNUNET_YES == qe->was_transmitted);
@@ -1234,6 +1236,8 @@ process_result_message (void *cls,
                     NULL, 0, NULL, 0, 0, 0, 
                     GNUNET_TIME_UNIT_ZERO_ABS, 0);    
        }
+      else
+       process_queue (h);
       return;
     }
   if (ntohs(msg->type) == GNUNET_MESSAGE_TYPE_DATASTORE_DATA_END) 
@@ -1289,6 +1293,7 @@ process_result_message (void *cls,
 #endif
   free_queue_entry (qe);
   h->retry_time.rel_value = 0;
+  process_queue (h);
   if (rc.proc != NULL)
     rc.proc (rc.proc_cls,
             &dm->key,