Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 170 for ccancel (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top