- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 170 for ccancel (0.04 sec)
-
src/main/java/jcifs/internal/smb1/trans/nt/SmbComNtCancel.java
import jcifs.internal.smb1.ServerMessageBlock; /** * SMB1 NT Cancel command implementation. * Provides functionality to cancel previously issued SMB1 NT transaction commands * that are in progress, allowing clients to abort long-running operations. * * @author mbechler */ public class SmbComNtCancel extends ServerMessageBlock { /** * Constructs an NT cancel command. * * @param config the configuration
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/Smb2CancelRequest.java
import jcifs.internal.util.SMBUtil; /** * SMB2 Cancel request message. * * This command is used to cancel a previously sent command * that is still being processed by the server. * * @author mbechler */ public class Smb2CancelRequest extends ServerMessageBlock2 implements CommonServerMessageBlockRequest { /** * Constructs a SMB2 cancel request * * @param config
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 4.5K bytes - Viewed (0) -
src/main/java/jcifs/util/transport/Request.java
* * @param credits the number of credits to set */ void setRequestCredits(int credits); /** * Checks if this is a cancel request. * * @return whether this is a cancel request */ boolean isCancel(); /** * Gets the next request in the chain. * * @return chained request */ Request getNext(); /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 1.7K bytes - Viewed (0) -
cmd/consolelogger.go
if ok { if (lg.Entry != log.Entry{}) { logs = append(logs, lg.Entry) } } } }) sys.RUnlock() return } // Cancel - cancels the target func (sys *HTTPConsoleLoggerSys) Cancel() { } // Type - returns type of the target func (sys *HTTPConsoleLoggerSys) Type() types.TargetType { return types.TargetConsole }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/timer/TimeoutTask.java
* * @return whether the task has been canceled */ public boolean isCanceled() { return status == CANCELED; } /** * Cancels the task. */ public void cancel() { status = CANCELED; } /** * Returns whether the task is stopped. * * @return whether the task is stopped */ public boolean isStopped() {
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 2.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Call.kt
* exception. * * @throws IllegalStateException when the call has already been executed. */ fun enqueue(responseCallback: Callback) /** Cancels the request, if possible. Requests that are already complete cannot be canceled. */ fun cancel() /** * Returns true if this call has been either [executed][execute] or [enqueued][enqueue]. It is an * error to execute a call more than once. */
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.6K bytes - Viewed (0) -
CONTRIBUTING.md
+ Fork the repository on GitHub. Making and Submitting Changes -------------- We accept Pull Requests via GitHub. The [developer mailing list][dev-ml-list] is the main channel of communication for contributors. There are some guidelines which will make applying PRs easier for us: + Create a topic branch from where you want to base your work (this is usually the master branch).
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Sat Jun 07 09:55:33 UTC 2025 - 4.2K bytes - Viewed (0) -
cmd/etcd.go
timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() _, err := client.Delete(timeoutCtx, key) etcdLogIf(ctx, err) return etcdErrToErr(err, client.Endpoints()) } func readKeyEtcd(ctx context.Context, client *etcd.Client, key string) ([]byte, error) { timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout) defer cancel() resp, err := client.Get(timeoutCtx, key)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 2.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
async.setFuture(inner); async.cancel(false); assertTrue(inner.isCancelled()); assertFalse(inner.wasInterrupted()); assertThrows(CancellationException.class, () -> inner.get()); } public void testCancel_beforeSet() throws Exception { SettableFuture<Object> async = SettableFuture.create(); async.cancel(true); assertFalse(async.set(42)); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 7.3K bytes - Viewed (0) -
cmd/server-startup-msg_test.go
t.Fatalf("Expected %#v, got %#v", apiEndpoints, newAPIEndpoints) } } // Test printing server common message. func TestPrintServerCommonMessage(t *testing.T) { ctx, cancel := context.WithCancel(t.Context()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil { t.Fatal(err)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 09 14:28:39 UTC 2025 - 3K bytes - Viewed (0)