[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.