| | | 1 | | // Copyright (c) ZeroC, Inc. |
| | | 2 | | |
| | | 3 | | using IceRpc.Transports.Coloc.Internal; |
| | | 4 | | using System.Collections.Concurrent; |
| | | 5 | | |
| | | 6 | | namespace IceRpc.Transports.Coloc; |
| | | 7 | | |
| | | 8 | | /// <summary>The Coloc transport class provides a client and server duplex transport that can be used for in-process |
| | | 9 | | /// communications.</summary> |
| | | 10 | | public sealed class ColocTransport |
| | | 11 | | { |
| | | 12 | | /// <summary>The transport name.</summary> |
| | | 13 | | public const string Name = "coloc"; |
| | | 14 | | |
| | | 15 | | /// <summary>Gets the colocated client transport.</summary> |
| | | 16 | | /// <value>The client transport.</value> |
| | 579 | 17 | | public IDuplexClientTransport ClientTransport { get; } |
| | | 18 | | |
| | | 19 | | /// <summary>Gets the colocated server transport.</summary> |
| | | 20 | | /// <value>The server transport.</value> |
| | 586 | 21 | | public IDuplexServerTransport ServerTransport { get; } |
| | | 22 | | |
| | | 23 | | /// <summary>Constructs a <see cref="ColocTransport" />.</summary> |
| | | 24 | | public ColocTransport() |
| | 37 | 25 | | : this(new ColocTransportOptions()) |
| | 37 | 26 | | { |
| | 37 | 27 | | } |
| | | 28 | | |
| | | 29 | | /// <summary>Constructs a <see cref="ColocTransport" />.</summary> |
| | | 30 | | /// <param name="options">The options to configure the Coloc transport.</param> |
| | | 31 | | /// <exception cref="ArgumentException">Thrown when the <see cref="ColocTransportOptions.ResumeWriterThreshold" /> |
| | | 32 | | /// of <paramref name="options" /> is greater than its <see cref="ColocTransportOptions.PauseWriterThreshold" |
| | | 33 | | /// />.</exception> |
| | 568 | 34 | | public ColocTransport(ColocTransportOptions options) |
| | 568 | 35 | | { |
| | 568 | 36 | | if (options.ResumeWriterThreshold > options.PauseWriterThreshold) |
| | 0 | 37 | | { |
| | 0 | 38 | | throw new ArgumentException( |
| | 0 | 39 | | $"The value of {nameof(ColocTransportOptions.ResumeWriterThreshold)} cannot be greater than the value of |
| | 0 | 40 | | nameof(options)); |
| | | 41 | | } |
| | | 42 | | |
| | 568 | 43 | | var listeners = new ConcurrentDictionary<(string Host, ushort Port), ColocListener>(); |
| | 568 | 44 | | ClientTransport = new ColocClientTransport(listeners, options); |
| | 568 | 45 | | ServerTransport = new ColocServerTransport(listeners, options); |
| | 568 | 46 | | } |
| | | 47 | | } |