#region Copyright notice and license
// Copyright 2015 gRPC authors.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
#endregion
using System;
using System.Threading;
using Grpc.Core.Internal;
using Grpc.Core.Utils;
namespace Grpc.Core
{
///
/// Token for propagating context of server side handlers to child calls.
/// In situations when a backend is making calls to another backend,
/// it makes sense to propagate properties like deadline and cancellation
/// token of the server call to the child call.
/// The gRPC native layer provides some other contexts (like tracing context) that
/// are not accessible to explicitly C# layer, but this token still allows propagating them.
///
public class ContextPropagationToken
{
///
/// Default propagation mask used by C core.
///
private const ContextPropagationFlags DefaultCoreMask = (ContextPropagationFlags)0xffff;
///
/// Default propagation mask used by C# - we want to propagate deadline
/// and cancellation token by our own means.
///
internal const ContextPropagationFlags DefaultMask = DefaultCoreMask
& ~ContextPropagationFlags.Deadline & ~ContextPropagationFlags.Cancellation;
readonly CallSafeHandle parentCall;
readonly DateTime deadline;
readonly CancellationToken cancellationToken;
readonly ContextPropagationOptions options;
internal ContextPropagationToken(CallSafeHandle parentCall, DateTime deadline, CancellationToken cancellationToken, ContextPropagationOptions options)
{
this.parentCall = GrpcPreconditions.CheckNotNull(parentCall);
this.deadline = deadline;
this.cancellationToken = cancellationToken;
this.options = options ?? ContextPropagationOptions.Default;
}
///
/// Gets the native handle of the parent call.
///
internal CallSafeHandle ParentCall
{
get
{
return this.parentCall;
}
}
///
/// Gets the parent call's deadline.
///
internal DateTime ParentDeadline
{
get
{
return this.deadline;
}
}
///
/// Gets the parent call's cancellation token.
///
internal CancellationToken ParentCancellationToken
{
get
{
return this.cancellationToken;
}
}
///
/// Get the context propagation options.
///
internal ContextPropagationOptions Options
{
get
{
return this.options;
}
}
}
///
/// Options for .
///
public class ContextPropagationOptions
{
///
/// The context propagation options that will be used by default.
///
public static readonly ContextPropagationOptions Default = new ContextPropagationOptions();
bool propagateDeadline;
bool propagateCancellation;
///
/// Creates new context propagation options.
///
/// If set to true parent call's deadline will be propagated to the child call.
/// If set to true parent call's cancellation token will be propagated to the child call.
public ContextPropagationOptions(bool propagateDeadline = true, bool propagateCancellation = true)
{
this.propagateDeadline = propagateDeadline;
this.propagateCancellation = propagateCancellation;
}
/// true if parent call's deadline should be propagated to the child call.
public bool IsPropagateDeadline
{
get { return this.propagateDeadline; }
}
/// true if parent call's cancellation token should be propagated to the child call.
public bool IsPropagateCancellation
{
get { return this.propagateCancellation; }
}
}
///
/// Context propagation flags from grpc/grpc.h.
///
[Flags]
internal enum ContextPropagationFlags
{
Deadline = 1,
CensusStatsContext = 2,
CensusTracingContext = 4,
Cancellation = 8
}
}