I'll keep monitoring this, and see - I have an idea of what could be causing thread starvation, so I'll also look into that
Just to be sure.
I only see this SQL timeout and membership issue once in the log
just and FYI - I'm using System.Data.SqlClient
You can get into the container and capture a dump using
dotnet-dump See https://devblogs.microsoft.com/dotnet/diagnostics-improvements-in-net-5/
There's been issues like dotnet/runtime#24301, albeit I think all of them are fixed even for this older connector library.
It could also be that if all the connections are used and persisting takes too much time, the membership queries time out.
Azure SQL Server has a fairly low concurrent connection limit.
Or had at least...
When I first register an event via Stream on the client side. This error occurs.
I have consulted the relevant documentation. I have checked the documentation and searched git and Google for the relevant information with no luck. Where do I go to solve this problem?
I have consulted the relevant documentation. I have checked the documentation and searched git and Google for the relevant information with no luck. Where do I go to solve this problem?
System.NullReferenceException: Object reference not set to an instance of an object.
at Orleans.Internal.OrleansTaskExtentions.<ToTypedTask>g__ConvertAsync|4_0T
at Orleans.Streams.StreamPubSubImpl.GetAllSubscriptions(StreamId streamId, IStreamConsumerExtension streamConsumer)
at Orleans.Streams.StreamConsumer`1.GetAllSubscriptions()
at Orleans.Internal.OrleansTaskExtentions.<ToTypedTask>g__ConvertAsync|4_0T
at Orleans.Streams.StreamPubSubImpl.GetAllSubscriptions(StreamId streamId, IStreamConsumerExtension streamConsumer)
at Orleans.Streams.StreamConsumer`1.GetAllSubscriptions()
My Client Code
Client = new ClientBuilder()
.UseCosmosDBGatewayListProvider(options =>
{
options.AccountEndpoint = "---";
options.AccountKey = "---";
})
.Configure<ClusterOptions>(options =>
{
options.ClusterId = "Test1";
options.ServiceId = "HelloWorld";
})
.Configure<GatewayOptions>(d => d.GatewayListRefreshPeriod = TimeSpan.FromSeconds(5))
.ConfigureLogging(logging => logging.AddConsole())
.AddSimpleMessageStreamProvider(Constants.GuildInfoStreamProvider)
.Build();
Register Code
var guildProvider = actorComponent.Client.GetStreamProvider(Constants.GuildInfoStreamProvider);
var guildChanged = guildProvider.GetStream<PlayerGuildChangedMsg>(Guid.Empty, info.id);
var guildChangedSubEvent = await guildChanged.SubscribeAsync((msg, token) => GuildChangedCallback(session, msg,db));
Silo Code
ISiloHostBuilder builder = new SiloHostBuilder()
.AddCosmosDBGrainStorage("Profile",options =>
{
options.Client = DatabaseClient.Core;
options.CanCreateResources = true;
})
.AddCosmosDBGrainStorage("PubSubStore",options =>
{
options.Client = DatabaseClient.Core;
})
.UseCosmosDBMembership(options =>
{
options.Client = DatabaseClient.Core;
options.CanCreateResources = true;
})
.Configure<ClusterOptions>(options =>
{
options.ClusterId = "Test1";
options.ServiceId = "HelloWorld";
})
.Configure<EndpointOptions>(options =>
{
options.AdvertisedIPAddress = IPAddress.Loopback;
options.SiloPort = siloPort;
options.GatewayPort = gatewayPort;
})
.ConfigureServices(collection =>
{
collection.AddSingleton(DatabaseClient);
})
.AddSimpleMessageStreamProvider(Constants.GuildInfoStreamProvider)
.ConfigureApplicationParts(parts => parts.AddApplicationPart(typeof(StateCode).Assembly).WithReferences())
.ConfigureLogging(logging => logging.AddConsole());
The error occurs when I use GetAllSubscriptionHandles. But calling SubscribeAsync also throws an error that there is no instance
public class PlayerGuildChangedMsg
{
public long GuildId;
}