- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 352 for pcancel (0.14 sec)
-
src/context/x_test.go
root, cancel := WithCancel(Background()) m := map[Context]CancelFunc{root: cancel} q := []Context{root} // Create a tree of contexts. for len(q) != 0 && len(m) < 100 { parent := q[0] q = q[1:] for i := 0; i < 4; i++ { ctx, cancel := WithCancel(parent) m[ctx] = cancel q = append(q, ctx) } } // Start all the cancels in a random order. var wg sync.WaitGroup
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 26.3K bytes - Viewed (0) -
platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/Cancel.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.launcher.daemon.protocol; public class Cancel extends Message {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 702 bytes - Viewed (0) -
src/context/context.go
return contextName(c.Context) + ".WithCancel" } // cancel closes c.done, cancels each of c's children, and, if // removeFromParent is true, removes c from its parent's children. // cancel sets c.cause to cause if this is the first time c is canceled. func (c *cancelCtx) cancel(removeFromParent bool, err, cause error) { if err == nil { panic("context: internal error: missing cancel error") } if cause == nil { cause = err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 23.7K bytes - Viewed (0) -
src/net/http/transport_dial_test.go
func (dt *transportDialTester) roundTrip() *transportDialTesterRoundTrip { dt.t.Helper() ctx, cancel := context.WithCancel(context.Background()) pr, pw := io.Pipe() rt := &transportDialTesterRoundTrip{ t: dt.t, roundTripID: dt.roundTripCount, done: make(chan struct{}), reqBody: pw, cancel: cancel, } dt.roundTripCount++ dt.t.Logf("RoundTrip %v: started", rt.roundTripID)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 6.3K bytes - Viewed (0) -
src/net/http/client.go
} initialReqCancel := req.Cancel // the user's original Request.Cancel, if any var cancelCtx func() if timeBeforeContextDeadline(deadline, oldCtx) { req.ctx, cancelCtx = context.WithDeadline(oldCtx, deadline) } cancel := make(chan struct{}) req.Cancel = cancel doCancel := func() { // The second way in the func comment above: close(cancel) // The first way, used only for RoundTripper
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 06:06:11 UTC 2024 - 33.7K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
if err != nil { atomic.AddInt64(&h.failedMessages, 1) return } // Delete the event from store. return h.store.Del(key.Name) } // Cancel - cancels the target func (h *Target) Cancel() { // If queuestore is configured, cancel it's context to // stop the replay go-routine. if h.store != nil { h.storeCtxCancel() } // Set logch to nil and close it.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/server.go
if err != nil { return nil, cancel, "", err } applyHeaders(req.Header, header, "Accept", "User-Agent", "X-Prometheus-Scrape-Timeout-Seconds", ) resp, err := s.http.Do(req) if err != nil { return nil, cancel, "", fmt.Errorf("error scraping %s: %v", url, err) } if resp.StatusCode != http.StatusOK { resp.Body.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 31.1K bytes - Viewed (1) -
pkg/kubelet/cm/dra/plugin/noderesources.go
c.mutex.Lock() defer c.mutex.Unlock() if active := c.activePlugins[driverName]; active != nil { active.cancel(errors.New("plugin has re-registered")) } active := &activePlugin{} cancelCtx, cancel := context.WithCancelCause(c.ctx) active.cancel = cancel c.activePlugins[driverName] = active c.queue.Add(driverName) c.wg.Add(1) go func() { defer c.wg.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/wait_test.go
ctx, cancel := context.WithCancel(context.Background()) cancel() return ctx, cancel } func deadlinedContext() (context.Context, context.CancelFunc) { ctx, cancel := context.WithTimeout(context.Background(), time.Millisecond) for ctx.Err() != context.DeadlineExceeded { time.Sleep(501 * time.Microsecond) } return ctx, cancel }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 41.1K bytes - Viewed (0)