Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for cancelling (0.25 sec)

  1. docs/changelogs/changelog_2x.md

        includes potential security problems (newline characters) as well as simple
        non-ASCII characters (including international characters and emoji).
    
     *  **Call canceling is more reliable.**  We had a bug where a socket being
         connected wasn't being closed when the application used `Call.cancel()`.
    
     *  **Changing a HttpUrl’s scheme now tracks the default port.** We had a bug
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 26.6K bytes
    - Viewed (0)
  2. tensorflow/c/eager/c_api_experimental.cc

      return tensorflow::unwrap(cancellation_manager)->IsCancelled();
    }
    
    bool TFE_CancellationManagerIsCancelling(
        TFE_CancellationManager* cancellation_manager) {
      return tensorflow::unwrap(cancellation_manager)->IsCancelling();
    }
    
    TFE_CancellationToken TFE_CancellationManagerGetToken(
        TFE_CancellationManager* cancellation_manager) {
      return tensorflow::unwrap(cancellation_manager)->get_cancellation_token();
    }
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 11 23:52:39 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-decom.go

    	}
    
    	if z.SinglePool() {
    		return errInvalidArgument
    	}
    
    	z.poolMetaMutex.Lock()
    	defer z.poolMetaMutex.Unlock()
    
    	fn := z.decommissionCancelers[idx]
    	if fn == nil {
    		// canceling a decommission before it started return an error.
    		return errDecommissionNotStarted
    	}
    
    	defer fn() // cancel any active thread.
    
    	if z.poolMeta.DecommissionCancel(idx) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 06 14:30:43 UTC 2024
    - 41.5K bytes
    - Viewed (1)
  4. staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go

    	}
    
    	notAcceptingNewRequestCh := s.lifecycleSignals.NotAcceptingNewRequest
    	drainedCh := s.lifecycleSignals.InFlightRequestsDrained
    	// Canceling the parent context does not immediately cancel the HTTP server.
    	// We only inherit context values here and deal with cancellation ourselves.
    	stopHTTPServerCtx, stopHTTPServer := context.WithCancelCause(context.WithoutCancel(ctx))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 42.9K bytes
    - Viewed (0)
  5. src/os/exec/exec.go

    			// (Perhaps c.Wait hadn't been called, or perhaps it happened to race with
    			// c.ctx being canceled.) Don't inject a needless error.
    		} else {
    			err = wrappedError{
    				prefix: "exec: canceling Cmd",
    				err:    interruptErr,
    			}
    		}
    	}
    	if c.WaitDelay == 0 {
    		resultc <- ctxResult{err: err}
    		return
    	}
    
    	timer := time.NewTimer(c.WaitDelay)
    	select {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 20:13:53 UTC 2024
    - 41.4K bytes
    - Viewed (0)
  6. src/os/exec/exec_test.go

    			// Panic instead of calling t.Fatal so that we get a goroutine dump.
    			// We want to know exactly what the os/exec goroutines got stuck on.
    			debug.SetTraceback("system")
    			panic("canceling context did not stop program")
    		}
    
    		// Back off exponentially (up to 1-second sleeps) to give the OS time to
    		// terminate the process.
    		delay *= 2
    		if delay > 1*time.Second {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 20:13:53 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top