remove ? to prevent nullable warnings (#327)
This commit is contained in:
Родитель
7a6e760b59
Коммит
96b832eb5c
|
@ -61,7 +61,7 @@ namespace DurableTask.Netherite
|
|||
this.host = host;
|
||||
}
|
||||
|
||||
public void HandleError(string context, string message, Exception? exception, bool terminatePartition, bool isWarning)
|
||||
public void HandleError(string context, string message, Exception exception, bool terminatePartition, bool isWarning)
|
||||
{
|
||||
bool isFatal = exception != null && Utils.IsFatal(exception);
|
||||
|
||||
|
@ -94,7 +94,7 @@ namespace DurableTask.Netherite
|
|||
}
|
||||
}
|
||||
|
||||
void TraceError(bool isWarning, string context, string message, Exception? exception, bool terminatePartition)
|
||||
void TraceError(bool isWarning, string context, string message, Exception exception, bool terminatePartition)
|
||||
{
|
||||
var logLevel = isWarning ? LogLevel.Warning : LogLevel.Error;
|
||||
if (this.logLevelLimit <= logLevel)
|
||||
|
|
|
@ -31,15 +31,15 @@ namespace DurableTask.Netherite.Faster
|
|||
|
||||
// periodic index and store checkpointing
|
||||
CheckpointTrigger pendingCheckpointTrigger;
|
||||
Task? pendingIndexCheckpoint;
|
||||
Task<(long, (long,int))>? pendingStoreCheckpoint;
|
||||
Task pendingIndexCheckpoint;
|
||||
Task<(long, (long,int))> pendingStoreCheckpoint;
|
||||
(long,int) lastCheckpointedInputQueuePosition;
|
||||
long lastCheckpointedCommitLogPosition;
|
||||
long numberEventsSinceLastCheckpoint;
|
||||
DateTime timeOfNextIdleCheckpoint;
|
||||
|
||||
// periodic compaction
|
||||
Task<long?>? pendingCompaction;
|
||||
Task<long?> pendingCompaction;
|
||||
|
||||
// periodic load publishing
|
||||
PartitionLoadInfo loadInfo;
|
||||
|
@ -301,7 +301,7 @@ namespace DurableTask.Netherite.Faster
|
|||
long inputQueuePositionLag = this.GetInputQueuePositionLag();
|
||||
|
||||
// since this is a pure function, we declare it as local static for improved performance
|
||||
static string ReportNullableTaskStatus(Task? t)
|
||||
static string ReportNullableTaskStatus(Task t)
|
||||
{
|
||||
if (t == null)
|
||||
{
|
||||
|
|
Загрузка…
Ссылка в новой задаче