Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for IMMEDIATE (0.22 sec)

  1. cmd/metrics-v3-ilm.go

    	ilmTransitionPendingTasksMD         = NewGaugeMD(transitionPendingTasks, "Number of pending ILM transition tasks in the queue")
    	ilmTransitionMissedImmediateTasksMD = NewCounterMD(transitionMissedImmediateTasks, "Number of missed immediate ILM transition tasks")
    	ilmVersionsScannedMD                = NewCounterMD(versionsScanned, "Total number of object versions checked for ILM actions since server start")
    )
    
    // loadILMMetrics - `MetricsLoaderFn` for ILM metrics.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 06 09:36:25 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  2. cmd/erasure-healing_test.go

    		}
    
    		for i := 0; i < nfi.Erasure.ParityBlocks; i++ {
    			erasureDisks[i].Delete(context.Background(), bucket, pathJoin(object, xlStorageFormatFile), DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    		}
    
    		// Try healing now, it should heal the content properly.
    		_, err = objLayer.HealObject(ctx, bucket, object, "", hopts)
    		if err != nil {
    			t.Fatal(err)
    		}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  3. doc/next/5-toolchain.md

    this check, for debugging and experimenting purposes.
    
    <!-- CL 473495 -->
    When building a dynamically linked ELF binary (including PIE binary), the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 17:18:10 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  4. platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Codec.kt

        val sharedIdentities: ReadIdentities
    
        override val isolate: ReadIsolate
    
        val classLoader: ClassLoader
    
        fun beanStateReaderFor(beanType: Class<*>): BeanStateReader
    
        /**
         * When in immediate mode, [read] calls are NOT suspending.
         * Useful for bridging with non-suspending serialization protocols such as [java.io.Serializable].
         */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 23:09:56 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  5. src/time/tick_test.go

    		tim.Reset(1)
    		assertTick()
    		Sleep(sched)
    		tim.Reset(10000 * Second)
    		drainAsync()
    		noTick()
    
    		// Test that len sees an immediate tick arrive
    		// for Reset of timer in heap.
    		tim.Reset(1)
    		assertLen()
    		assertTick()
    
    		// Test that len sees an immediate tick arrive
    		// for Reset of timer NOT in heap.
    		tim.Stop()
    		drainAsync()
    		tim.Reset(1)
    		assertLen()
    		assertTick()
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 17:10:37 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  6. cmd/erasure-multipart.go

    			_ = storageDisks[index].Delete(context.TODO(), minioMetaMultipartBucket, curpartPath, DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    			_ = storageDisks[index].Delete(context.TODO(), minioMetaMultipartBucket, curpartPath+".meta", DeleteOptions{
    				Recursive: false,
    				Immediate: false,
    			})
    
    			return nil
    		}, index)
    	}
    	g.Wait()
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  7. pkg/envoy/proxy.go

    	if network.AllIPv6(e.NodeIPs) {
    		proxyLocalAddressType = "v6"
    	}
    	startupArgs := []string{
    		"-c", fname,
    		"--drain-time-s", fmt.Sprint(int(e.DrainDuration.AsDuration().Seconds())),
    		"--drain-strategy", "immediate", // Clients are notified as soon as the drain process starts.
    		"--local-address-ip-version", proxyLocalAddressType,
    		// Reduce default flush interval from 10s to 1s. The access log buffer size is 64k and each log is ~256 bytes
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 10:02:56 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. cmd/erasure-healing-common_test.go

    					// appears in outDatedDisks.
    					tamperedIndex = index
    					dErr := erasureDisks[index].Delete(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{
    						Recursive: false,
    						Immediate: false,
    					})
    					if dErr != nil {
    						t.Fatalf("Failed to delete %s - %v", filepath.Join(object, "part.1"), dErr)
    					}
    					break
    				}
    			case corruptPart:
    				for index, err := range test.errs {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 23K bytes
    - Viewed (0)
  9. cmd/storage-rest-client.go

    }
    
    // DeleteFile - deletes a file.
    func (client *storageRESTClient) Delete(ctx context.Context, volume string, path string, deleteOpts DeleteOptions) error {
    	if !deleteOpts.Immediate {
    		// add deadlines for all non-immediate purges
    		var cancel context.CancelFunc
    		ctx, cancel = context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    		defer cancel()
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 27.4K bytes
    - Viewed (0)
  10. cmd/xl-storage.go

    	} else {
    		err = Rename(filePath, targetPath)
    	}
    
    	var targetPath2 string
    	if immediatePurge && HasSuffix(filePath, SlashSeparator) {
    		// With immediate purge also attempt deleting for `__XL_DIR__` folder/directory objects.
    		targetPath2 = pathutil.Join(s.drivePath, minioMetaTmpDeletedBucket, mustGetUUID())
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
Back to top