Home
last modified time | relevance | path

Searched refs:cancellationToken (Results 1 – 25 of 86) sorted by relevance

1234

/third_party/grpc/src/csharp/Grpc.Core.Api/
DCallOptions.cs33 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/
DcancellationToken.ts21 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/
DbuilderPublic.ts59 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…
Dbuilder.ts341 …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 …]
DtsbuildPublic.ts134 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/
DTestServerCallContext.cs34 …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/
DDefaultServerCallContext.cs37 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;
DContextPropagationTokenImpl.cs50 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/
DTestGrpc.cs275 …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 …]
DBenchmarkServiceGrpc.cs208 …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 …]
DXdsInteropClient.cs120 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()
DWorkerServiceGrpc.cs201 …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 …]
DMetricsGrpc.cs152 …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/
DinferFromUsage.ts52 …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 …]
DaddMissingAwait.ts33 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 …]
DfixUnusedIdentifier.ts21 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/
DMathGrpc.cs190 …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/
Dclassifier2020.ts18 …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();
DoutliningElementsCollector.ts3 …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();
DcodeFixProvider.ts92 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/
Dserver.ts28 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/
DHelloworldGrpc.cs97 …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/
DHelloworldGrpc.cs97 …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/
DCallOptionsTest.cs42 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/
DHealthGrpc.cs162 …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()

1234