Skip to content

Commit fec898e

Browse files
committed
Ensure that the tags are passed by ref
1 parent c12e46d commit fec898e

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

src/cluster/DotNext.Net.Cluster/Net/Multiplexing/MultiplexedListener.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,7 @@ protected override async ValueTask DisposeAsyncCore()
193193

194194
private sealed class MultiplexedStreamFactoryImpl(PipeOptions options, ChannelWriter<MultiplexedStream> backlog)
195195
{
196-
private MultiplexedStream? CreateStream(AsyncAutoResetEvent writeSignal, in TagList measurementTags)
196+
private MultiplexedStream? CreateStream(AsyncAutoResetEvent writeSignal, ref readonly TagList measurementTags)
197197
{
198198
var stream = new MultiplexedStream(options, writeSignal);
199199
if (backlog.TryWrite(stream))

src/cluster/DotNext.Net.Cluster/Net/Multiplexing/MultiplexedStreamFactory.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,4 +4,4 @@ namespace DotNext.Net.Multiplexing;
44

55
using Threading;
66

7-
internal delegate MultiplexedStream? MultiplexedStreamFactory(AsyncAutoResetEvent transportSignal, in TagList measurementTags);
7+
internal delegate MultiplexedStream? MultiplexedStreamFactory(AsyncAutoResetEvent transportSignal, ref readonly TagList measurementTags);

src/cluster/DotNext.Net.Cluster/Net/Multiplexing/OutputMultiplexer.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ private async Task ProcessCoreAsync(Socket socket)
8686
{
8787
continue;
8888
}
89-
else if ((stream = factory(TransportSignal, MeasurementTags)) is null)
89+
else if ((stream = factory(TransportSignal, in MeasurementTags)) is null)
9090
{
9191
Commands.TryAdd(new StreamRejectedCommand(header.Id));
9292
TransportSignal.Set();

0 commit comments

Comments
 (0)