From 3e66d0e89a427405e388cb47f0dd8fdd3250e428 Mon Sep 17 00:00:00 2001 From: Ian Denhardt Date: Wed, 30 Nov 2022 19:45:48 -0500 Subject: [PATCH] Conn.sender: mpsc -> spsc We don't actually need multiple-producers here, since we're always holding Conn.mu when we send. --- rpc/rpc.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/rpc/rpc.go b/rpc/rpc.go index bcc0826f..e9a06596 100644 --- a/rpc/rpc.go +++ b/rpc/rpc.go @@ -10,7 +10,7 @@ import ( "capnproto.org/go/capnp/v3" "capnproto.org/go/capnp/v3/exc" - "capnproto.org/go/capnp/v3/exp/mpsc" + "capnproto.org/go/capnp/v3/exp/spsc" "capnproto.org/go/capnp/v3/internal/syncutil" "capnproto.org/go/capnp/v3/rpc/transport" rpccp "capnproto.org/go/capnp/v3/std/capnp/rpc" @@ -87,7 +87,7 @@ type Conn struct { closing bool // used to make shutdown() idempotent closed chan struct{} // closed when shutdown() returns - sender *mpsc.Queue[asyncSend] + sender spsc.Queue[asyncSend] // Tables questions []*question @@ -144,7 +144,7 @@ func NewConn(t Transport, opts *Options) *Conn { bgcancel: cancel, answers: make(map[answerID]*answer), imports: make(map[importID]*impent), - sender: mpsc.New[asyncSend](), + sender: spsc.New[asyncSend](), } if opts != nil { c.bootstrap = opts.BootstrapClient