/third_party/grpc/src/csharp/Grpc.Core.Api/ |
D | CallOptions.cs | 33 CancellationToken cancellationToken; field 48 …tadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(Ca… in CallOptions() 53 this.cancellationToken = cancellationToken; in CallOptions() 87 get { return cancellationToken; } 161 public CallOptions WithCancellationToken(CancellationToken cancellationToken) in WithCancellationToken() 164 newOptions.cancellationToken = cancellationToken; in WithCancellationToken()
|
/third_party/typescript/src/testRunner/unittests/tsserver/ |
D | cancellationToken.ts | 21 const cancellationToken: server.ServerCancellationToken = { constant 32 const session = createSession(host, { cancellationToken }); 70 const cancellationToken = new TestServerCancellationToken(); constant 75 cancellationToken 112 cancellationToken.setRequestToCancel(getErrId); 118 cancellationToken.resetToken(); 135 cancellationToken.setRequestToCancel(getErrId); 140 cancellationToken.resetToken(); 170 cancellationToken.resetToken(); 217 const cancellationToken = new TestServerCancellationToken(/*cancelAfterRequest*/ 3); constant [all …]
|
/third_party/typescript/src/compiler/ |
D | builderPublic.ts | 59 getOptionsDiagnostics(cancellationToken?: CancellationToken): readonly Diagnostic[]; 63 getGlobalDiagnostics(cancellationToken?: CancellationToken): readonly Diagnostic[]; 71 …getSyntacticDiagnostics(sourceFile?: SourceFile, cancellationToken?: CancellationToken): readonly … 75 …getDeclarationDiagnostics(sourceFile?: SourceFile, cancellationToken?: CancellationToken): readonl… 89 …getSemanticDiagnostics(sourceFile?: SourceFile, cancellationToken?: CancellationToken): readonly D… 101 …emit(targetSourceFile?: SourceFile, writeFile?: WriteFileCallback, cancellationToken?: Cancellatio… 103 … emitBuildInfo(writeFile?: WriteFileCallback, cancellationToken?: CancellationToken): EmitResult; 120 …getSemanticDiagnosticsOfNextAffectedFile(cancellationToken?: CancellationToken, ignoreSourceFile?:… 133 …emitNextAffectedFile(writeFile?: WriteFileCallback, cancellationToken?: CancellationToken, emitOnl…
|
D | builder.ts | 341 …function getNextAffectedFile(state: BuilderProgramState, cancellationToken: CancellationToken | un… 352 … handleDtsMayChangeOfAffectedFile(state, affectedFile, cancellationToken, computeHash); 389 …es = BuilderState.getFilesAffectedBy(state, program, nextKey.value, cancellationToken, computeHash… 426 …fAffectedFile(state: BuilderProgramState, affectedFile: SourceFile, cancellationToken: Cancellatio… 445 …e, affectedFile, (state, path) => handleDtsMayChangeOf(state, path, cancellationToken, computeHash… 453 …function handleDtsMayChangeOf(state: BuilderProgramState, path: Path, cancellationToken: Cancellat… 469 cancellationToken, 664 …agnosticsOfFile(state: BuilderProgramState, sourceFile: SourceFile, cancellationToken?: Cancellati… 666 getBinderAndCheckerDiagnosticsOfFile(state, sourceFile, cancellationToken), 675 …agnosticsOfFile(state: BuilderProgramState, sourceFile: SourceFile, cancellationToken?: Cancellati… [all …]
|
D | tsbuildPublic.ts | 134 build(project?: string, cancellationToken?: CancellationToken): ExitStatus; 136 buildReferences(project: string, cancellationToken?: CancellationToken): ExitStatus; 138 …getNextInvalidatedProject(cancellationToken?: CancellationToken): InvalidatedProject<T> | undefine… 578 …function setupInitialBuild(state: SolutionBuilderState, cancellationToken: CancellationToken | und… 592 if (cancellationToken) { 593 cancellationToken.throwIfCancellationRequested(); 611 …done(cancellationToken?: CancellationToken, writeFile?: WriteFileCallback, customTransformers?: Cu… 631 getOptionsDiagnostics(cancellationToken?: CancellationToken): readonly Diagnostic[]; 632 getGlobalDiagnostics(cancellationToken?: CancellationToken): readonly Diagnostic[]; 634 …getSyntacticDiagnostics(sourceFile?: SourceFile, cancellationToken?: CancellationToken): readonly … [all …]
|
/third_party/grpc/src/csharp/Grpc.Core.Testing/ |
D | TestServerCallContext.cs | 34 …thod, string host, DateTime deadline, Metadata requestHeaders, CancellationToken cancellationToken, in Create() argument 38 …eturn new TestingServerCallContext(method, host, deadline, requestHeaders, cancellationToken, peer, in Create() 48 private readonly CancellationToken cancellationToken; field in Grpc.Core.Testing.TestServerCallContext.TestingServerCallContext 58 …thod, string host, DateTime deadline, Metadata requestHeaders, CancellationToken cancellationToken, in TestingServerCallContext() argument 66 this.cancellationToken = cancellationToken; in TestingServerCallContext() 87 protected override CancellationToken CancellationTokenCore => cancellationToken;
|
/third_party/grpc/src/csharp/Grpc.Core/Internal/ |
D | DefaultServerCallContext.cs | 37 private readonly CancellationToken cancellationToken; field in Grpc.Core.DefaultServerCallContext 49 …Metadata requestHeaders, CancellationToken cancellationToken, IServerResponseStream serverResponse… in DefaultServerCallContext() argument 56 this.cancellationToken = cancellationToken; in DefaultServerCallContext() 64 … return new ContextPropagationTokenImpl(callHandle, deadline, cancellationToken, options); in CreatePropagationTokenCore() 82 protected override CancellationToken CancellationTokenCore => cancellationToken;
|
D | ContextPropagationTokenImpl.cs | 50 readonly CancellationToken cancellationToken; field in Grpc.Core.Internal.ContextPropagationTokenImpl 53 …mpl(CallSafeHandle parentCall, DateTime deadline, CancellationToken cancellationToken, ContextProp… in ContextPropagationTokenImpl() argument 57 this.cancellationToken = cancellationToken; in ContextPropagationTokenImpl() 90 return this.cancellationToken;
|
/third_party/grpc/src/csharp/Grpc.IntegrationTesting/ |
D | TestGrpc.cs | 275 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in EmptyCall() argument 277 return EmptyCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in EmptyCall() 297 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in EmptyCallAsync() argument 299 return EmptyCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in EmptyCallAsync() 319 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in UnaryCall() argument 321 return UnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCall() 341 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in UnaryCallAsync() argument 343 return UnaryCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCallAsync() 365 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in CacheableUnaryCall() argument 367 … return CacheableUnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in CacheableUnaryCall() [all …]
|
D | BenchmarkServiceGrpc.cs | 208 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in UnaryCall() argument 210 return UnaryCall(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCall() 232 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in UnaryCallAsync() argument 234 return UnaryCallAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in UnaryCallAsync() 256 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in StreamingCall() argument 258 return StreamingCall(new grpc::CallOptions(headers, deadline, cancellationToken)); in StreamingCall() 279 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in StreamingFromClient() argument 281 return StreamingFromClient(new grpc::CallOptions(headers, deadline, cancellationToken)); in StreamingFromClient() 302 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in StreamingFromServer() argument 304 … return StreamingFromServer(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in StreamingFromServer() [all …]
|
D | XdsInteropClient.cs | 120 internal async Task RunChannelsAsync(CancellationToken cancellationToken) in RunChannelsAsync() argument 125 var channelTask = RunSingleChannelAsync(channelId, cancellationToken); in RunChannelsAsync() 135 private async Task RunSingleChannelAsync(int channelId, CancellationToken cancellationToken) in RunSingleChannelAsync() argument 144 while (!cancellationToken.IsCancellationRequested) in RunSingleChannelAsync() 148 inflightTasks.Add(RunSingleRpcAsync(client, cancellationToken, rpcType)); in RunSingleChannelAsync() 169 …gleRpcAsync(TestService.TestServiceClient client, CancellationToken cancellationToken, RpcType rpc… in RunSingleRpcAsync() argument 189 …new CallOptions(headers: headers, cancellationToken: cancellationToken, deadline: DateTime.UtcNow.… in RunSingleRpcAsync() 202 …new CallOptions(headers: headers, cancellationToken: cancellationToken, deadline: DateTime.UtcNow.… in RunSingleRpcAsync()
|
D | WorkerServiceGrpc.cs | 201 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in RunServer() argument 203 return RunServer(new grpc::CallOptions(headers, deadline, cancellationToken)); in RunServer() 231 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in RunClient() argument 233 return RunClient(new grpc::CallOptions(headers, deadline, cancellationToken)); in RunClient() 257 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in CoreCount() argument 259 return CoreCount(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in CoreCount() 279 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in CoreCountAsync() argument 281 return CoreCountAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in CoreCountAsync() 301 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in QuitWorker() argument 303 return QuitWorker(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in QuitWorker() [all …]
|
D | MetricsGrpc.cs | 152 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in GetAllGauges() argument 154 return GetAllGauges(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in GetAllGauges() 175 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in GetGauge() argument 177 return GetGauge(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in GetGauge() 197 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in GetGaugeAsync() argument 199 return GetGaugeAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in GetGaugeAsync()
|
/third_party/typescript/src/services/codefixes/ |
D | inferFromUsage.ts | 52 …const { sourceFile, program, span: { start }, errorCode, cancellationToken, host, preferences } = … constant 56 …laration = doChange(changes, sourceFile, token, errorCode, program, cancellationToken, /*markSeen*… 63 const { sourceFile, program, cancellationToken, host, preferences } = context; constant 66 …ceFile, getTokenAtPosition(err.file, err.start), err.code, program, cancellationToken, markSeen, h… 109 …File: SourceFile, token: Node, errorCode: number, program: Program, cancellationToken: Cancellatio… 122 …ateVariableDeclaration(changes, importAdder, sourceFile, parent, program, host, cancellationToken); 127 … const type = inferTypeForVariableFromUsage(parent.name, program, cancellationToken); 142 …ation(changes, importAdder, sourceFile, symbol.valueDeclaration, program, host, cancellationToken); 160 …etAccessor(changes, importAdder, sourceFile, containingFunction, program, host, cancellationToken); 168 …ers(changes, importAdder, sourceFile, param, containingFunction, program, host, cancellationToken); [all …]
|
D | addMissingAwait.ts | 33 const { sourceFile, errorCode, span, cancellationToken, program } = context; constant 34 …xpression = getFixableErrorSpanExpression(sourceFile, errorCode, span, cancellationToken, program); 46 const { sourceFile, program, cancellationToken } = context; constant 50 …getFixableErrorSpanExpression(sourceFile, diagnostic.code, diagnostic, cancellationToken, program); 62 const { sourceFile, program, cancellationToken } = context; constant 63 …bleInitializers = findAwaitableInitializers(expression, sourceFile, cancellationToken, program, ch… 87 …aitError(sourceFile: SourceFile, errorCode: number, span: TextSpan, cancellationToken: Cancellatio… 89 const diagnostics = checker.getDiagnostics(sourceFile, cancellationToken); 97 …pression(sourceFile: SourceFile, errorCode: number, span: TextSpan, cancellationToken: Cancellatio… 110 && isMissingAwaitError(sourceFile, errorCode, span, cancellationToken, program) [all …]
|
D | fixUnusedIdentifier.ts | 21 const { errorCode, sourceFile, program, cancellationToken } = context; constant 39 …eteDeclaration(sourceFile, token, t, checker, sourceFiles, program, cancellationToken, /*isFixAll*… 78 …eteDeclaration(sourceFile, token, t, checker, sourceFiles, program, cancellationToken, /*isFixAll*… 94 const { sourceFile, program, cancellationToken } = context; constant 109 …laration(sourceFile, token, changes, checker, sourceFiles, program, cancellationToken, /*isFixAll*… 138 …laration(sourceFile, token, changes, checker, sourceFiles, program, cancellationToken, /*isFixAll*… 223 … TypeChecker, sourceFiles: readonly SourceFile[], program: Program, cancellationToken: Cancellatio… 224 …tionWorker(token, changes, sourceFile, checker, sourceFiles, program, cancellationToken, isFixAll); 235 … TypeChecker, sourceFiles: readonly SourceFile[], program: Program, cancellationToken: Cancellatio… 238 …Parameter(changes, sourceFile, parent, checker, sourceFiles, program, cancellationToken, isFixAll); [all …]
|
/third_party/grpc/src/csharp/Grpc.Examples/ |
D | MathGrpc.cs | 190 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in Div() argument 192 return Div(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in Div() 214 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in DivAsync() argument 216 return DivAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in DivAsync() 239 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in DivMany() argument 241 return DivMany(new grpc::CallOptions(headers, deadline, cancellationToken)); in DivMany() 265 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in Fib() argument 267 return Fib(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in Fib() 289 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in Sum() argument 291 return Sum(new grpc::CallOptions(headers, deadline, cancellationToken)); in Sum()
|
/third_party/typescript/src/services/ |
D | classifier2020.ts | 18 …export function getSemanticClassifications(program: Program, cancellationToken: CancellationToken,… 19 …const classifications = getEncodedSemanticClassifications(program, cancellationToken, sourceFile, … 34 …export function getEncodedSemanticClassifications(program: Program, cancellationToken: Cancellatio… 36 spans: getSemanticTokens(program, sourceFile, span, cancellationToken), 41 …ticTokens(program: Program, sourceFile: SourceFile, span: TextSpan, cancellationToken: Cancellatio… 49 collectTokens(program, sourceFile, span, collector, cancellationToken); 54 …or: (node: Node, tokenType: number, tokenModifier: number) => void, cancellationToken: Cancellatio… 68 cancellationToken.throwIfCancellationRequested();
|
D | outliningElementsCollector.ts | 3 …export function collectElements(sourceFile: SourceFile, cancellationToken: CancellationToken): Out… 5 addNodeOutliningSpans(sourceFile, cancellationToken, res); 10 …function addNodeOutliningSpans(sourceFile: SourceFile, cancellationToken: CancellationToken, out: … 24 … addOutliningForLeadingCommentsForNode(statements[current], sourceFile, cancellationToken, out); 35 cancellationToken.throwIfCancellationRequested(); 38 addOutliningForLeadingCommentsForNode(n, sourceFile, cancellationToken, out); 42 … addOutliningForLeadingCommentsForNode(n.parent.left, sourceFile, cancellationToken, out); 102 …OutliningForLeadingCommentsForNode(n: Node, sourceFile: SourceFile, cancellationToken: Cancellatio… 110 cancellationToken.throwIfCancellationRequested();
|
D | codeFixProvider.ts | 92 function getDiagnostics({ program, sourceFile, cancellationToken }: CodeFixContextBase) { 94 ...program.getSemanticDiagnostics(sourceFile, cancellationToken), 95 ...program.getSyntacticDiagnostics(sourceFile, cancellationToken), 96 ...computeSuggestionDiagnostics(sourceFile, program, cancellationToken)
|
/third_party/typescript/src/tsserver/ |
D | server.ts | 28 cancellationToken: ServerCancellationToken; property 31 …startSession: (option: StartSessionOptions, logger: Logger, cancellationToken: ServerCancellationT… 33 …function start({ args, logger, cancellationToken, serverMode, unknownServerMode, startSession: sta… 73 cancellationToken
|
/third_party/grpc/examples/csharp/HelloworldUnity/Assets/Scripts/ |
D | HelloworldGrpc.cs | 97 …tadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(Ca… in SayHello() argument 99 return SayHello(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in SayHello() 119 …tadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(Ca… in SayHelloAsync() argument 121 return SayHelloAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in SayHelloAsync()
|
/third_party/grpc/examples/csharp/HelloworldXamarin/HelloworldXamarin/ |
D | HelloworldGrpc.cs | 97 …tadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(Ca… in SayHello() argument 99 return SayHello(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in SayHello() 119 …tadata headers = null, DateTime? deadline = null, CancellationToken cancellationToken = default(Ca… in SayHelloAsync() argument 121 return SayHelloAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in SayHelloAsync()
|
/third_party/grpc/src/csharp/Grpc.Core.Tests/ |
D | CallOptionsTest.cs | 42 var cancellationToken = new CancellationTokenSource().Token; in WithMethods() 43 …Assert.AreEqual(cancellationToken, options.WithCancellationToken(cancellationToken).CancellationTo… in WithMethods() 84 …Assert.Throws(typeof(ArgumentException), () => new CallOptions(cancellationToken: token, propagati… in Normalize()
|
/third_party/grpc/src/csharp/Grpc.HealthCheck/ |
D | HealthGrpc.cs | 162 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in Check() argument 164 return Check(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in Check() 186 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in CheckAsync() argument 188 return CheckAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in CheckAsync() 223 …teTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(gl… in Watch() argument 225 return Watch(request, new grpc::CallOptions(headers, deadline, cancellationToken)); in Watch()
|