Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 59 of 59 for IMMEDIATE (0.12 sec)

  1. cmd/object-multipart-handlers.go

    			Status:    http.StatusText(http.StatusOK),
    		})
    	}
    
    	// Remove the transitioned object whose object version is being overwritten.
    	if !globalTierConfigMgr.Empty() {
    		// Schedule object for immediate transition if eligible.
    		enqueueTransitionImmediate(objInfo, lcEventSrc_s3CompleteMultipartUpload)
    		os.Sweep()
    	}
    }
    
    // AbortMultipartUploadHandler - Abort multipart upload
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 38.8K bytes
    - Viewed (0)
  2. internal/config/notify/parse.go

    			ExchangeType:      env.Get(exchangeTypeEnv, kv.Get(target.AmqpExchangeType)),
    			DeliveryMode:      uint8(deliveryMode),
    			Mandatory:         env.Get(mandatoryEnv, kv.Get(target.AmqpMandatory)) == config.EnableOn,
    			Immediate:         env.Get(immediateEnv, kv.Get(target.AmqpImmediate)) == config.EnableOn,
    			Durable:           env.Get(durableEnv, kv.Get(target.AmqpDurable)) == config.EnableOn,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    		if err != nil || len(b) != len(toWrite) {
    			continue
    		}
    
    		err = p.storage.Delete(context.Background(), minioMetaTmpBucket, fn, DeleteOptions{
    			Recursive: false,
    			Immediate: false,
    		})
    
    		if err == nil {
    			logger.Event(context.Background(), "healthcheck",
    				"node(%s): Read/Write/Delete successful, bringing drive %s online", globalLocalNodeName, p.storage.String())
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/Iterables.java

            }
            final Iterator<T> iterator = iterable.iterator();
    
            Iterators.advance(iterator, numberToSkip);
    
            /*
             * We can't just return the iterator because an immediate call to its
             * remove() method would remove one of the skipped elements instead of
             * throwing an IllegalStateException.
             */
            return new Iterator<T>() {
              boolean atStart = true;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Apr 24 19:38:27 UTC 2024
    - 42.8K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/Iterables.java

            }
            final Iterator<T> iterator = iterable.iterator();
    
            Iterators.advance(iterator, numberToSkip);
    
            /*
             * We can't just return the iterator because an immediate call to its
             * remove() method would remove one of the skipped elements instead of
             * throwing an IllegalStateException.
             */
            return new Iterator<T>() {
              boolean atStart = true;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Apr 24 19:38:27 UTC 2024
    - 42.5K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/controller.go

    ) {
    	wrappedHandler := func(prev, curr T, event model.Event) error {
    		curr = informer.Get(curr.GetName(), curr.GetNamespace())
    		if controllers.IsNil(curr) {
    			// this can happen when an immediate delete after update
    			// the delete event can be handled later
    			return nil
    		}
    		return handler(prev, curr, event)
    	}
    	// Pre-build our metric types to avoid recompute them on each event
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  7. platforms/documentation/docs/src/docs/userguide/releases/migrating/migrating_from_ant.adoc

    ====
    +
    This is not as robust or powerful as Gradle's <<declaring_dependencies_between_subprojects#sec:project_jar_dependencies,project dependencies>>, but it solves the immediate problem without big changes to the build.
    Just be careful to remove or override any dependencies on tasks that delegate to other subprojects, like the `buildRequiredProjects` task.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Mar 23 22:37:03 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  8. src/runtime/runtime2.go

    	limiterEvent limiterEvent
    
    	// gcMarkWorkerMode is the mode for the next mark worker to run in.
    	// That is, this is used to communicate with the worker goroutine
    	// selected for immediate execution by
    	// gcController.findRunnableGCWorker. When scheduling other goroutines,
    	// this field must be set to gcMarkWorkerNotWorker.
    	gcMarkWorkerMode gcMarkWorkerMode
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
  9. src/runtime/asm_arm64.s

    	MOVD	$0, R0
    	MOVD	R0, (R0)	// boom
    	UNDEF
    
    DATA	runtime·mainPC+0(SB)/8,$runtime·main<ABIInternal>(SB)
    GLOBL	runtime·mainPC(SB),RODATA,$8
    
    // Windows ARM64 needs an immediate 0xf000 argument.
    // See go.dev/issues/53837.
    #define BREAK	\
    #ifdef GOOS_windows	\
    	BRK	$0xf000 	\
    #else 				\
    	BRK 			\
    #endif 				\
    
    
    TEXT runtime·breakpoint(SB),NOSPLIT|NOFRAME,$0-0
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat May 11 20:38:24 UTC 2024
    - 43.4K bytes
    - Viewed (0)
Back to top