gnunet-svn
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[gnunet-scheme] 01/05: cadet/client: Add a message queue to the <channel


From: gnunet
Subject: [gnunet-scheme] 01/05: cadet/client: Add a message queue to the <channel> API.
Date: Sun, 31 Jul 2022 16:48:30 +0200

This is an automated email from the git hooks/post-receive script.

maxime-devos pushed a commit to branch master
in repository gnunet-scheme.

commit 8b1c8d1223ade5d8c1ffc244ae5b7cf3d285b391
Author: Maxime Devos <maximedevos@telenet.be>
AuthorDate: Sun Jul 31 14:25:04 2022 +0200

    cadet/client: Add a message queue to the <channel> API.
    
    * gnu/gnunet/cadet/client.scm (channel-message-queue): New field.
    (open-channel): For now just set the new field to #false, to be
    corrected later.
    * doc/cadet.tm (open-channel!, channel-message-queue): Document them.
---
 gnu/gnunet/cadet/client.scm | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/gnu/gnunet/cadet/client.scm b/gnu/gnunet/cadet/client.scm
index 5ae4ef8..6cbe163 100644
--- a/gnu/gnunet/cadet/client.scm
+++ b/gnu/gnunet/cadet/client.scm
@@ -19,6 +19,7 @@
   (export connect disconnect!
          make-cadet-address cadet-address? cadet-address-peer 
cadet-address-port
          channel? open-channel! close-channel!
+         channel-message-queue
          port? open-port! close-port!
          %max-cadet-message-size
 
@@ -105,11 +106,12 @@
              ;; a channel number is assigned.  After a reconnect, channel
              ;; numbers are reset.
              (mutable channel-number channel-channel-number
-                      set-channel-channel-number!))
+                      set-channel-channel-number!)
+             (immutable message-queue channel-message-queue)) ; <message-queue>
       (protocol (lambda (%make)
-                 (lambda (server destination options)
+                 (lambda (server destination options message-queue)
                    ((%make (losable-lost-and-found server)) server
-                    destination options #false)))))
+                    destination options #false message-queue)))))
 
     (define* (connect config #:key (connected values) (disconnected values)
                      (spawn spawn-fiber))
@@ -319,7 +321,8 @@ message @var{message}."
     ;; TODO: callbacks, message queue, actually test it
     (define* (open-channel! server address)
       (assert (and (server:cadet? server) (cadet-address? address)))
-      (define channel (%make-channel server address 0))
+      (define channel (%make-channel server address 0
+                                    #false)) ; TODO
       (maybe-send-control-message! server 'open-channel! channel)
       channel)
 

-- 
To stop receiving notification emails like this one, please contact
gnunet@gnunet.org.



reply via email to

[Prev in Thread] Current Thread [Next in Thread]