adding argument to GNUNET_CORE_connect -- not yet implemented

5 files changed, 16 insertions, 8 deletions

diff --git a/src/core/core_api.c b/src/core/core_api.c
index cb5ba3ecb..a1e6aea65 100644
--- a/src/core/core_api.c
+++ b/src/core/core_api.c
@@ -129,6 +129,11 @@ struct GNUNET_CORE_Handle
   GNUNET_SCHEDULER_TaskIdentifier reconnect_task;
 
   /**
+   * Number of messages we should queue per target.
+   */
+  unsigned int queue_size;
+
+  /**
    * Number of entries in the handlers array.
    */
   unsigned int hcnt;
@@ -722,6 +727,7 @@ transmit_start (void *cls, size_t size, void *buf)
  * complete (or fail) asynchronously.
  *
  * @param cfg configuration to use
+ * @param queue_size size of the per-peer message queue
  * @param timeout after how long should we give up trying to connect to the core service?
  * @param cls closure for the various callbacks that follow (including handlers in the handlers array)
  * @param init callback to call on timeout or once we have successfully
@@ -743,6 +749,7 @@ transmit_start (void *cls, size_t size, void *buf)
  */
 struct GNUNET_CORE_Handle *
 GNUNET_CORE_connect (const struct GNUNET_CONFIGURATION_Handle *cfg,
+                     unsigned int queue_size,
                      struct GNUNET_TIME_Relative timeout,
                      void *cls,
                      GNUNET_CORE_StartupCallback init,
@@ -769,6 +776,7 @@ GNUNET_CORE_connect (const struct GNUNET_CONFIGURATION_Handle *cfg,
   h->inbound_hdr_only = inbound_hdr_only;
   h->outbound_hdr_only = outbound_hdr_only;
   h->handlers = handlers;
+  h->queue_size = queue_size;
   h->client_notifications = GNUNET_CLIENT_connect ("core", cfg);
   if (h->client_notifications == NULL)
     {
diff --git a/src/core/test_core_api.c b/src/core/test_core_api.c
index 65b09c835..129184587 100644
--- a/src/core/test_core_api.c
+++ b/src/core/test_core_api.c
@@ -219,7 +219,7 @@ init_notify (void *cls,
       GNUNET_assert (ok == 2);
       OKPP;
       /* connect p2 */
-      GNUNET_CORE_connect (p2.cfg,
+      GNUNET_CORE_connect (p2.cfg, 1,
                            TIMEOUT,
                            &p2,
                            &init_notify,                         
@@ -310,7 +310,7 @@ run (void *cls,
   OKPP;
   setup_peer (&p1, "test_core_api_peer1.conf");
   setup_peer (&p2, "test_core_api_peer2.conf");
-  GNUNET_CORE_connect (p1.cfg,
+  GNUNET_CORE_connect (p1.cfg, 1,
                        TIMEOUT,
                        &p1,
                        &init_notify,
diff --git a/src/core/test_core_api_reliability.c b/src/core/test_core_api_reliability.c
index da67bb4d4..f22a9022e 100644
--- a/src/core/test_core_api_reliability.c
+++ b/src/core/test_core_api_reliability.c
@@ -365,7 +365,7 @@ init_notify (void *cls,
       GNUNET_assert (ok == 2);
       OKPP;
       /* connect p2 */
-      GNUNET_CORE_connect (p2.cfg,
+      GNUNET_CORE_connect (p2.cfg, 1,
                            TIMEOUT,
                            &p2,
                            &init_notify,                         
@@ -455,7 +455,7 @@ run (void *cls,
   OKPP;
   setup_peer (&p1, "test_core_api_peer1.conf");
   setup_peer (&p2, "test_core_api_peer2.conf");
-  GNUNET_CORE_connect (p1.cfg,
+  GNUNET_CORE_connect (p1.cfg, 1,
                        TIMEOUT,
                        &p1,
                        &init_notify,
diff --git a/src/core/test_core_api_start_only.c b/src/core/test_core_api_start_only.c
index da7217f39..e39179196 100644
--- a/src/core/test_core_api_start_only.c
+++ b/src/core/test_core_api_start_only.c
@@ -125,7 +125,7 @@ init_notify (void *cls,
   if (cls == &p1)
     {
       /* connect p2 */
-      GNUNET_CORE_connect (p2.cfg,
+      GNUNET_CORE_connect (p2.cfg, 1,
                            TIMEOUT,
                            &p2,
                            &init_notify,                         
@@ -172,7 +172,7 @@ run (void *cls,
   OKPP;
   setup_peer (&p1, "test_core_api_peer1.conf");
   setup_peer (&p2, "test_core_api_peer2.conf");
-  GNUNET_CORE_connect (p1.cfg,
+  GNUNET_CORE_connect (p1.cfg, 1,
                        TIMEOUT,
                        &p1,
                        &init_notify,
diff --git a/src/core/test_core_quota_compliance.c b/src/core/test_core_quota_compliance.c
index 822dc2c46..5a3e3dc14 100644
--- a/src/core/test_core_quota_compliance.c
+++ b/src/core/test_core_quota_compliance.c
@@ -452,7 +452,7 @@ init_notify (void *cls,
       GNUNET_assert (ok == 2);
       OKPP;
       /* connect p2 */
-      GNUNET_CORE_connect (p2.cfg,
+      GNUNET_CORE_connect (p2.cfg, 1,
                            TIMEOUT,
                            &p2,
                            &init_notify,                         
@@ -533,7 +533,7 @@ run (void *cls,
   OKPP;
   setup_peer (&p1, "test_core_quota_peer1.conf");
   setup_peer (&p2, "test_core_quota_peer2.conf");
-  GNUNET_CORE_connect (p1.cfg,
+  GNUNET_CORE_connect (p1.cfg, 1,
                        TIMEOUT,
                        &p1,
                        &init_notify,