- Sort Score
- Num 10 results
- Language All
Results 401 - 410 of 702 for cdone (0.02 seconds)
-
cmd/iam-object-store.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 26.6K bytes - Click Count (0) -
internal/ringbuffer/ring_buffer.go
// A goroutine will be started and run until the provided context is canceled. func (r *RingBuffer) WithCancel(ctx context.Context) *RingBuffer { go func() { <-ctx.Done() r.CloseWithError(ctx.Err()) }() return r } func (r *RingBuffer) setErr(err error, locked bool) error { if !locked { r.mu.Lock() defer r.mu.Unlock() } if r.err != nil && r.err != io.EOF {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* future.addListener(new Runnable() { * public void run() { * processedCount.incrementAndGet(); * inFlight.remove(name); * lastProcessed.set(name); * logger.info("Done with {0}", name); * } * }, executor); * } * * <h3>How to get an instance</h3> * * <p>We encourage you to return {@code ListenableFuture} from your methods so that your users can
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 8K bytes - Click Count (0) -
internal/event/target/webhook.go
id: event.TargetID{ID: id, Name: "webhook"}, args: args, loggerOnce: loggerOnce, transport: transport, store: queueStore, cancel: cancel, cancelCh: ctx.Done(), } // Calculate the webhook addr with the port number format target.addr = args.Endpoint.HostCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 8.8K bytes - Click Count (0) -
ci/official/containers/ml_build/builder.devtoolset/build_devtoolset.sh
PYTHON_VERSIONS=("python3.9" "python3.10" "python3.11" "python3.12") for v in "${PYTHON_VERSIONS[@]}"; do ln -s "/usr/local/include/${v}" "/${TARGET}/usr/include/x86_64-linux-gnu/${v}" done # Patch glibc to be compatable with modern clang case "${VERSION}" in devtoolset-9) cd / patch -p0 < /glibc2.17-inline.patch ;;Created: Tue Dec 30 12:39:10 GMT 2025 - Last Modified: Tue Sep 24 20:45:58 GMT 2024 - 8K bytes - Click Count (0) -
cmd/metrics-v2.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 133.6K bytes - Click Count (0) -
cmd/background-newdisks-heal-ops.go
h.ItemsSkipped = h.ResumeItemsSkipped h.BytesDone = h.ResumeBytesDone h.BytesFailed = h.ResumeBytesFailed h.BytesSkipped = h.ResumeBytesSkipped } // bucketDone should be called when a bucket is done healing. // Adds the bucket to the list of healed buckets and updates resume numbers. func (h *healingTracker) bucketDone(bucket string) { h.mu.Lock() defer h.mu.Unlock() h.ResumeItemsHealed = h.ItemsHealed
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 16.5K bytes - Click Count (0) -
android/guava/src/com/google/common/escape/ArrayBasedCharEscaper.java
* * @param c the character to escape * @return the replacement characters, or {@code null} if no escaping was required */ // TODO(dbeaumont,cpovirk): Rename this something better once refactoring done protected abstract char @Nullable [] escapeUnsafe(char c);Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 6.2K bytes - Click Count (0) -
internal/config/lambda/target/webhook.go
target := &WebhookTarget{ id: event.TargetID{ID: id, Name: "webhook"}, args: args, loggerOnce: loggerOnce, transport: transport, cancel: cancel, cancelCh: ctx.Done(), } return target, nilCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Jul 08 21:39:49 GMT 2024 - 6.7K bytes - Click Count (0) -
internal/event/target/redis.go
return nil, err } } else { if _, err = conn.Do("AUTH", args.Password); err != nil { conn.Close() return nil, err } } } // Must be done after AUTH if _, err = conn.Do("CLIENT", "SETNAME", "MinIO"); err != nil { conn.Close() return nil, err } return conn, nil }, TestOnBorrow: func(c redis.Conn, t time.Time) error {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 9.1K bytes - Click Count (0)