From 7cdbcd71cac7f5e5db49e5afcbcb9291e05e4d2b Mon Sep 17 00:00:00 2001 From: Damian Debkowski Date: Sat, 23 Dec 2023 21:27:23 -0800 Subject: [PATCH] fix(bsr): missing buffer opts for channel writers --- internal/bsr/bsr.go | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/internal/bsr/bsr.go b/internal/bsr/bsr.go index a5eee4ceb1..0657774c84 100644 --- a/internal/bsr/bsr.go +++ b/internal/bsr/bsr.go @@ -727,7 +727,11 @@ func (c *Channel) NewMessagesWriter(ctx context.Context, dir Direction) (storage if err != nil { return nil, err } - m, err := c.container.create(ctx, messagesName) + m, err := c.container.create(ctx, messagesName, + storage.WithCreateFile(), + storage.WithFileAccessMode(storage.ReadWrite), + storage.WithBuffer(65*storage.LogicalBlockSize), + ) if err != nil { return nil, err } @@ -749,7 +753,11 @@ func (c *Channel) NewRequestsWriter(ctx context.Context, dir Direction) (storage if err != nil { return nil, err } - m, err := c.container.create(ctx, requestName) + m, err := c.container.create(ctx, requestName, + storage.WithCreateFile(), + storage.WithFileAccessMode(storage.ReadWrite), + storage.WithBuffer(65*storage.LogicalBlockSize), + ) if err != nil { return nil, err }