From 2336252efc6b413e8dc72fe38fd148d563a829f4 Mon Sep 17 00:00:00 2001 From: Richard Ramos Date: Thu, 4 Nov 2021 12:19:59 -0400 Subject: [PATCH] add size to store message channel --- waku/v2/protocol/store/waku_store.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/waku/v2/protocol/store/waku_store.go b/waku/v2/protocol/store/waku_store.go index d138c0fc..3edb23de 100644 --- a/waku/v2/protocol/store/waku_store.go +++ b/waku/v2/protocol/store/waku_store.go @@ -255,7 +255,7 @@ func (store *WakuStore) Start(ctx context.Context, h host.Host) { store.started = true store.h = h store.ctx = ctx - store.MsgC = make(chan *protocol.Envelope) + store.MsgC = make(chan *protocol.Envelope, 1024) store.h.SetStreamHandlerMatch(StoreID_v20beta3, protocol.PrefixTextMatch(string(StoreID_v20beta3)), store.onRequest) @@ -487,7 +487,7 @@ func DefaultOptions() []HistoryRequestOption { } func (store *WakuStore) queryFrom(ctx context.Context, q *pb.HistoryQuery, selectedPeer peer.ID, requestId []byte) (*pb.HistoryResponse, error) { - log.Info(fmt.Sprintf("Resuming message history with peer %s", selectedPeer)) + log.Info(fmt.Sprintf("Querying message history with peer %s", selectedPeer)) connOpt, err := store.h.NewStream(ctx, selectedPeer, StoreID_v20beta3) if err != nil {