Home
last modified time | relevance | path

Searched +full:cancel +full:- +full:in +full:- +full:progress (Results 1 – 25 of 253) sorted by relevance

1234567891011

/third_party/rust/rust/src/tools/rust-analyzer/crates/flycheck/src/
Dlib.rs2 //! another compatible command (f.x. clippy) in a background thread and provide
62 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt()
90 ) -> FlycheckHandle { in spawn()
100 /// Schedule a re-start of the cargo check worker.
106 pub fn cancel(&self) { in cancel() method
107 self.sender.send(StateChange::Cancel).unwrap(); in cancel()
110 pub fn id(&self) -> usize { in id()
119 /// Request check progress notification to client
120 Progress { enumerator
123 progress: Progress,
[all …]
/third_party/libuv/docs/src/guide/
Dthreads.rst5 way** to do *web-scale programming*? Well... no. Threads are still the medium in
21 required, signal errors directly via return values, and, as shown in the
22 :ref:`first example <thread-create-example>`, don't even require a running
29 running in one thread (the main thread)**. No other thread interacts
33 ----------------------
38 .. _thread-create-example:
40 .. rubric:: thread-create/main.c
41 .. literalinclude:: ../../code/thread-create/main.c
44 :lines: 26-36
45 :emphasize-lines: 3-7
[all …]
/third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/aio_cancel/
D7-1.c13 * requested operations cannot be canceled because it is in progress.
18 * then cancel all operation belonging to this file descriptor
20 * - if aio_error() is EINPROGRESS and aio_cancel() is not AIO_NOTCANCELED
22 * - if aio_error() is succes (0) and aio_cancel() is AIO_NOTCANCELED
24 * - otherwise result is unresolved
41 #define TNAME "aio_cancel/7-1.c"
61 if (fd == -1) { in main()
79 aiocb[i]->aio_fildes = fd; in main()
80 aiocb[i]->aio_buf = malloc(BUF_SIZE); in main()
82 if (aiocb[i]->aio_buf == NULL) { in main()
[all …]
D3-1.c18 * next we try to cancel all operations on this file descriptor
19 * we guess some have been finished, other are in progress,
21 * we guess we can cancel all operations waiting
22 * then we analyze aio_error() in the event handler
24 * otherwise, we don't know (perhaps we haven't cancel any operation ?)
26 * the test fails (in fact it hangs).
45 #define TNAME "aio_cancel/3-1.c"
56 struct aiocb *a = info->si_value.sival_ptr; in sig_handler()
63 countdown--; in sig_handler()
84 if (fd == -1) { in main()
[all …]
Dcoverage.txt17 - cancelable operations are implementation specific
18 - we have no way to be sure we try to cancel an operation that is not
19 already done or is in progress.
/third_party/grpc/src/core/lib/iomgr/event_engine_shims/
Dtcp_client.h4 // you may not use this file except in compliance with the License.
7 // http://www.apache.org/licenses/LICENSE-2.0
9 // Unless required by applicable law or agreed to in writing, software
28 /// which can later be used to cancel an in progress connection attempt.
35 /// Attempts to cancel an in progress connection attempt represented by the
36 /// passed in connection handle. It returns true if the cancellation attempt
/third_party/grpc/examples/python/cancellation/
DREADME.md3 In the example, we implement a silly algorithm. We search for bytestrings whose
10 In particular, we ensure that client processes cancel the stream explicitly
11 before terminating and we ensure that server processes cancel RPCs that have gone on longer
16 A client may cancel an RPC for several reasons. Perhaps the data it requested
20 ##### Cancelling a Server-Side Unary RPC from the Client
32 to be executed when the RPC completes, or to cancel the RPC before it has
35 In the example, we use this interface to cancel our in-progress RPC when the
36 user interrupts the process with ctrl-c.
42 future.cancel()
55 ##### Cancelling a Server-Side Streaming RPC from the Client
[all …]
/third_party/mesa3d/src/panfrost/midgard/
Dnir_fuse_io_16.c6 * to deal in the Software without restriction, including without limitation
12 * paragraph) shall be included in all copies or substantial portions of the
17 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
19 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
20 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
21 * IN THE SOFTWARE.
40 if (parent->type != nir_instr_type_alu) in nir_src_is_f2fmp()
44 return (alu->op == nir_op_f2fmp); in nir_src_is_f2fmp()
50 bool progress = false; in nir_fuse_io_16() local
55 if (instr->type != nir_instr_type_intrinsic) in nir_fuse_io_16()
[all …]
/third_party/skia/third_party/externals/oboe/apps/OboeTester/app/src/main/java/com/google/sample/oboe/manualtest/
DRoundTripLatencyActivity.java5 * you may not use this file except in compliance with the License.
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
35 private static final int STATE_GOT_DATA = 2; // Defined in LatencyAnalyzer.h
48 private int mBufferBursts = -1;
75 cancel(); in onAnalyserDone()
148 public void cancel() { in cancel() method in RoundTripLatencyActivity.LatencyAverager
206 int progress = getAnalyzerProgress(); in getProgressText() local
209 String message = String.format("progress = %d, state = %d, #resets = %d\n", in getProgressText()
210 progress, state, resetCount); in getProgressText()
[all …]
/third_party/protobuf/java/core/src/main/java/com/google/protobuf/
DRpcController.java1 // Protocol Buffers - Google's data interchange format
4 // Use of this source code is governed by a BSD-style
5 // license that can be found in the LICENSE file or at
6 // https://developers.google.com/open-source/licenses/bsd
13 * RPC-level errors.
17 * implementation. This way the generated code can be more appropriate for the implementation in use
27 // -----------------------------------------------------------------
32 * Resets the RpcController to its initial state so that it may be reused in a new call. This can
33 * be called from the client side only. It must not be called while an RPC is in progress.
44 /** If {@code failed()} is {@code true}, returns a human-readable description of the error. */
[all …]
/third_party/protobuf/python/google/protobuf/
Dservice.py1 # Protocol Buffers - Google's data interchange format
4 # Use of this source code is governed by a BSD-style
5 # license that can be found in the LICENSE file or at
6 # https://developers.google.com/open-source/licenses/bsd
16 the generated code can be more appropriate for the implementation in use
27 'the RPC implementation. service.py will be removed in Jan 2025',
38 """Abstract base interface for protocol-buffer-based RPC services.
58 In the blocking case, RpcException will be raised on error.
73 before CallMethod() returns or it may be at some point in the future.
99 the response protocol message. It's provided anyway in case it is useful
[all …]
/third_party/python/Lib/asyncio/
Dtaskgroups.py25 a task will cancel all remaining tasks and wait for them to exit.
93 # await ... # <- CancelledError
95 # or there's an exception in "async with":
103 # We use while-loop here because "self._on_completed_fut"
106 # our own cancellation is already in progress)
134 # are other errors -- those have priority.
146 me = BaseExceptionGroup('unhandled errors in a TaskGroup', self._errors)
152 """Create a new task in this group and return it.
175 def _is_base_error(self, exc: BaseException) -> bool:
182 for t in self._tasks:
[all …]
/third_party/rust/rust/compiler/rustc_codegen_cranelift/.github/workflows/
Dabi-cafe.yml1 name: Abi-cafe
4 - push
8 runs-on: ${{ matrix.os }}
9 timeout-minutes: 60
11 … group: ${{ github.workflow }}-${{ github.ref }}-${{ matrix.os }}-${{ matrix.env.TARGET_TRIPLE }}
12 cancel-in-progress: true
19 fail-fast: true
22 - os: ubuntu-latest
24 TARGET_TRIPLE: x86_64-unknown-linux-gnu
25 - os: macos-latest
[all …]
/third_party/skia/third_party/externals/oboe/apps/fxlab/app/src/main/java/com/mobileer/androidfxlab/
DEffectsAdapter.kt5 * you may not use this file except in compliance with the License. in <lambda>()
8 * https://www.apache.org/licenses/LICENSE-2.0 in <lambda>()
10 * Unless required by applicable law or agreed to in writing, software in <lambda>()
40 // This class adapts view in effect_view.xml for Effect class in <lambda>()
45 private var index: Int = -1 in <lambda>()
60 checkBoxView.setOnCheckedChangeListener { _, checked -> in <lambda>()
64 dragHandleView.setOnTouchListener { _, event -> in <lambda>()
71 header.setOnTouchListener { _, event -> in <lambda>()
79 for (ind in effect.effectDescription.paramValues.withIndex()) { in <lambda>()
94 seekBar.progress = in <lambda>()
[all …]
/third_party/curl/lib/
Dcurl_sasl.c10 * This software is licensed as described in the file COPYING, which
21 * SPDX-License-Identifier: curl
23 * RFC2195 CRAM-MD5 authentication
25 * RFC2831 DIGEST-MD5 authentication
28 * RFC5802 SCRAM-SHA-1 authentication
29 * RFC7677 SCRAM-SHA-256 authentication
32 * Draft LOGIN SASL Mechanism <draft-murchison-sasl-login-00.txt>
55 /* The last 3 #include files should be in this order */
68 { "CRAM-MD5", 8, SASL_MECH_CRAM_MD5 },
69 { "DIGEST-MD5", 10, SASL_MECH_DIGEST_MD5 },
[all …]
Dcurl_sasl.h12 * This software is licensed as described in the file COPYING, which
23 * SPDX-License-Identifier: curl
55 #define SASL_MECH_STRING_CRAM_MD5 "CRAM-MD5"
56 #define SASL_MECH_STRING_DIGEST_MD5 "DIGEST-MD5"
62 #define SASL_MECH_STRING_SCRAM_SHA_1 "SCRAM-SHA-1"
63 #define SASL_MECH_STRING_SCRAM_SHA_256 "SCRAM-SHA-256"
66 #define SASL_FLAG_BASE64 0x0001 /* Messages are base64-encoded */
90 /* Progress indicator */
107 /* Cancel authentication. */
112 command length - other characters count.
[all …]
/third_party/skia/m133/third_party/externals/zlib/google/
Dzip_reader.h2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
36 // the output file). Return false on failure to cancel extraction.
39 // Invoked to write the next chunk of data. Return false on failure to cancel
43 // Sets the last-modified time of the data.
57 // is to scan entries in a ZIP archive and extract them. The code will look
67 // auto writer = CreateFilePathWriterDelegate(extract_dir, entry->path);
92 // Information of an entry (file or directory) in a ZIP archive.
94 // Path of this entry, in its original encoding as it is stored in the ZIP
96 // UTF-8, and the caller needs to use other means to determine the encoding
[all …]
/third_party/grpc/src/objective-c/GRPCClient/
DGRPCCall.h6 * you may not use this file except in compliance with the License.
9 * http://www.apache.org/licenses/LICENSE-2.0
11 * Unless required by applicable law or agreed to in writing, software
25 * message, the protocol also supports RPCs that return multiple individual messages in a streaming
30 * the "non-streaming type" sending only one message in the corresponding direction (the protocol
57 - (void)didReceiveInitialMetadata:(nullable NSDictionary *)initialMetadata;
68 - (void)didReceiveRawMessage:(nullable NSData *)message;
72 * or HTTP compression algorithm specified in the response header. \p data could be any type as
76 * type of \p data unless an agreement is made on how it should be used in a particular call
79 - (void)didReceiveData:(id)data;
[all …]
/third_party/skia/third_party/externals/dawn/src/dawn_node/tools/src/cmd/run-cts/
Dmain.go4 // you may not use this file except in compliance with the License.
7 // http://www.apache.org/licenses/LICENSE-2.0
9 // Unless required by applicable law or agreed to in writing, software
15 // run-cts is a tool used to run the WebGPU CTS using the Dawn module for NodeJS
41 "github.com/mattn/go-colorable"
42 "github.com/mattn/go-isatty"
58 run-cts is a tool used to run the WebGPU CTS using the Dawn module for NodeJS
61 run-cts --dawn-node=<path to dawn.node> --cts=<path to WebGPU CTS> [test-query]`)
78 // Multiple flags must be passed in indivually:
79 // -flag=a=b -dawn_node_flag=c=d
[all …]
/third_party/cups/scheduler/
Djob.h4 * Copyright © 2020-2024 by OpenPrinting.
5 * Copyright 2007-2015 by Apple Inc.
6 * Copyright 1997-2007 by Easy Software Products, all rights reserved.
32 ipp_jstate_t state_value; /* Cached job-state */
33 int pending_timeout;/* Non-zero if the job was created and
38 int koctets; /* job-k-octets */
41 int num_files; /* Number of files in job */
44 ipp_attribute_t *impressions, /* job-impressions-completed */
45 *sheets; /* job-media-sheets-completed */
47 cancel_time, /* When to cancel/send SIGTERM */
[all …]
/third_party/python/Tools/msi/bundle/
DDefault.wxl1 <?xml version="1.0" encoding="utf-8"?>
2 <WixLocalization Culture="en-us" Language="1033" xmlns="http://schemas.microsoft.com/wix/2006/local…
18 <String Id="CancelButton">&amp;Cancel</String>
25 <String Id="ConfirmCancelMessage">Are you sure you want to cancel?</String>
30 "/passive" to display progress without requiring user interaction
38 "/layout [\[]directory[\]]" to pre-download all components
95 <String Id="ProgressHeader">[ActionLikeInstallation] Progress</String>
109 …n&lt;/a&gt;. At your terminal, type "py" to launch Python, or search for Python in your Start menu.
111 …n.org/[ShortVersion]/whatsnew/[ShortVersion].html"&gt;what's new&lt;/a&gt; in this release, or fin…
/third_party/grpc/src/core/handshaker/
Dhandshaker.cc6 // you may not use this file except in compliance with the License.
9 // http://www.apache.org/licenses/LICENSE-2.0
11 // Unless required by applicable law or agreed to in writing, software
54 args->event_engine->Run([on_handshake_done = std::move(on_handshake_done), in InvokeOnHandshakeDone()
59 // Destroy callback while ExecCtx is still in scope. in InvokeOnHandshakeDone()
69 args->endpoint.get(), args->args.ToString(), in HandshakerArgsString()
70 args->read_buffer.Length(), args->exit_early); in HandshakerArgsString()
83 << std::string(handshaker->name()) << " [" << handshaker.get() in Add()
94 // wind up invoking on_handshake_done in another thread before we in DoHandshake()
108 if (acceptor != nullptr && acceptor->external_connection && in DoHandshake()
[all …]
/third_party/rust/crates/libloading/.github/workflows/
Dlibloading.yml2 group: ${{ github.workflow }}-${{ github.ref }}
3 cancel-in-progress: true
8 paths-ignore: ['*.mkd', 'LICENSE']
13 native-test:
14 runs-on: ${{ matrix.os }}
16 fail-fast: false
19 os: [ubuntu-latest, windows-latest, macOS-latest]
20 timeout-minutes: 20
22 - uses: actions/checkout@v2
23 - run: rustup install ${{ matrix.rust_toolchain }} --profile=minimal
[all …]
/third_party/backends/backend/pixma/
Dpixma.h1 /* SANE - Scanner Access Now Easy.
3 Copyright (C) 2011-2020 Rolf Bensch <rolf at bensch hyphen online dot de>
4 Copyright (C) 2007-2008 Nicolas Martin, <nicols-guest at alioth dot debian dot org>
5 Copyright (C) 2006-2007 Wittawat Yamwong <wittawat@web.de>
14 This program is distributed in the hope that it will be useful, but
23 additional uses of the libraries contained in this release of SANE.
28 License. Your use of that executable is in no way restricted on
35 If you submit changes to SANE to the maintainers to be included in
78 * interrupt pixma_read_image(). It does not cancel the operation
83 * - \subpage API
[all …]
/third_party/rust/rust/src/tools/rust-analyzer/crates/rust-analyzer/src/handlers/
Dnotification.rs20 pub(crate) fn handle_cancel(state: &mut GlobalState, params: CancelParams) -> Result<()> { in handle_cancel()
25 state.cancel(id); in handle_cancel()
32 ) -> Result<()> { in handle_work_done_progress_cancel()
34 if let Some(id) = s.strip_prefix("rust-analyzer/flycheck/") { in handle_work_done_progress_cancel()
37 flycheck.cancel(); in handle_work_done_progress_cancel()
43 // Just ignore this. It is OK to continue sending progress in handle_work_done_progress_cancel()
52 ) -> Result<()> { in handle_did_open_text_document()
71 ) -> Result<()> { in handle_did_change_text_document()
77 … // The version passed in DidChangeTextDocument is the version after all edits are applied in handle_did_change_text_document()
103 ) -> Result<()> { in handle_did_close_text_document()
[all …]

1234567891011