- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 72 for WithCancel (0.08 sec)
-
internal/ringbuffer/ring_buffer.go
r.readCond = sync.NewCond(&r.mu) r.writeCond = sync.NewCond(&r.mu) } return r } // WithCancel sets a context to cancel the ring buffer. // When the context is canceled, the ring buffer will be closed with the context error. // A goroutine will be started and run until the provided context is canceled. func (r *RingBuffer) WithCancel(ctx context.Context) *RingBuffer { go func() { select { case <-ctx.Done():
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/erasure-sets_test.go
} } // TestNewErasure - tests initialization of all input disks // and constructs a valid `Erasure` object func TestNewErasureSets(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() nDisks := 16 // Maximum disks. var erasureDisks []string for i := 0; i < nDisks; i++ { // Do not attempt to create this path, the test validates
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 12 07:21:56 UTC 2024 - 6.9K bytes - Viewed (0) -
cmd/signature-v4_test.go
t.Errorf("(%d) expected to get %s, instead got %s", i, niceError(testCase.expected), niceError(code)) } } } func TestDoesPresignedSignatureMatch(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 10.5K bytes - Viewed (0) -
cmd/global-heal.go
// NewBgHealSequence creates a background healing sequence // operation which scans all objects and heal them. func newBgHealSequence() *healSequence { reqInfo := &logger.ReqInfo{API: "BackgroundHeal"} ctx, cancelCtx := context.WithCancel(logger.SetReqInfo(GlobalContext, reqInfo)) hs := madmin.HealOpts{ // Remove objects that do not have read-quorum Remove: healDeleteDangling, } return &healSequence{ startTime: UTCNow(),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.3K bytes - Viewed (0) -
api/go1.7.txt
pkg bytes, method (*Reader) Reset([]uint8) pkg compress/flate, const HuffmanOnly = -2 pkg compress/flate, const HuffmanOnly ideal-int pkg context, func Background() Context pkg context, func TODO() Context pkg context, func WithCancel(Context) (Context, CancelFunc) pkg context, func WithDeadline(Context, time.Time) (Context, CancelFunc) pkg context, func WithTimeout(Context, time.Duration) (Context, CancelFunc)
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Jun 28 15:08:11 UTC 2016 - 13.6K bytes - Viewed (0) -
cni/pkg/install/install_test.go
}, } for _, c := range cases { t.Run(c.name, func(t *testing.T) { // Create temp directory for files tempDir := t.TempDir() // Initialize parameters ctx, cancel := context.WithCancel(context.Background()) defer cancel() cfg := &config.InstallConfig{ MountedCNINetDir: tempDir, ChainedCNIPlugin: c.chainedCNIPlugin, }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 11.1K bytes - Viewed (0) -
cmd/admin-handlers.go
} w.WriteHeader(http.StatusOK) } // NetperfHandler - perform mesh style network throughput test func (a adminAPIHandlers) NetperfHandler(w http.ResponseWriter, r *http.Request) { ctx, cancel := context.WithCancel(r.Context()) defer cancel() objectAPI, _ := validateAdminReq(ctx, w, r, policy.HealthInfoAdminAction) if objectAPI == nil { return } if !globalIsDistErasure {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K bytes - Viewed (0) -
cni/test/install_cni.go
KubeconfigMode: constants.DefaultKubeconfigMode, CNIConfName: envPreconf, K8sServiceAccountPath: tempK8sSvcAcctDir, }, } ctx, cancel := context.WithCancel(context.Background()) wg := sync.WaitGroup{} wg.Add(1) defer func() { cancel() wg.Wait() }() go func() { startInstallServer(ctx, &installConfig, t) wg.Done() }()
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 01 18:38:14 UTC 2024 - 11.3K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
if err = queueStore.Open(); err != nil { return fmt.Errorf("unable to initialize the queue store of %s webhook: %w", h.Name(), err) } ctx, cancel := context.WithCancel(ctx) h.store = queueStore h.storeCtxCancel = cancel store.StreamItems(h.store, h, ctx.Done(), h.kconfig.LogOnce) return } func (h *Target) startKafkaLogger() { h.logChMu.RLock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10.2K bytes - Viewed (0) -
cmd/sftp-server-driver.go
case "Rmdir": bucket, prefix := path2BucketObject(r.Filepath) if bucket == "" { return errors.New("deleting all buckets not allowed") } cctx, cancel := context.WithCancel(context.Background()) defer cancel() if prefix == "" { // if all objects are not deleted yet this call may fail. return clnt.RemoveBucket(cctx, bucket) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 11.1K bytes - Viewed (0)