Search Options

Results per page
Sort
Preferred Languages
Advance

Results 851 - 860 of 1,075 for depleted (3.84 sec)

  1. cmd/bucket-stats_gen.go

    				err = msgp.WrapError(err, "Stats")
    				return
    			}
    			if z.Stats == nil {
    				z.Stats = make(map[string]*BucketReplicationStat, zb0002)
    			} else if len(z.Stats) > 0 {
    				for key := range z.Stats {
    					delete(z.Stats, key)
    				}
    			}
    			for zb0002 > 0 {
    				zb0002--
    				var za0001 string
    				var za0002 *BucketReplicationStat
    				za0001, err = dc.ReadString()
    				if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 57.5K bytes
    - Viewed (0)
  2. cmd/xl-storage-format-v2_test.go

    	xl := xlMetaV2{}
    	fi := FileInfo{
    		Volume:           "volume",
    		Name:             "object-name",
    		VersionID:        "756100c6-b393-4981-928a-d49bbc164741",
    		IsLatest:         true,
    		Deleted:          false,
    		TransitionStatus: "",
    		DataDir:          "bffea160-ca7f-465f-98bc-9b4f1c3ba1ef",
    		XLV1:             false,
    		ModTime:          time.Now(),
    		Size:             0,
    		Mode:             0,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/server.go

    func (s *meshDataplane) addPodToHostNSIpset(pod *corev1.Pod, podIPs []netip.Addr) ([]netip.Addr, error) {
    	// Add the pod UID as an ipset entry comment, so we can (more) easily find and delete
    	// all relevant entries for a pod later.
    	podUID := string(pod.ObjectMeta.UID)
    	ipProto := uint8(unix.IPPROTO_TCP)
    
    	var ipsetAddrErrs []error
    	var addedIps []netip.Addr
    
    	// For each pod IP
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  4. cmd/storage-interface.go

    	RenamePart(ctx context.Context, srcVolume, srcPath, dstVolume, dstPath string, meta []byte) error
    	CheckParts(ctx context.Context, volume string, path string, fi FileInfo) (*CheckPartsResp, error)
    	Delete(ctx context.Context, volume string, path string, opts DeleteOptions) (err error)
    	VerifyFile(ctx context.Context, volume, path string, fi FileInfo) (*CheckPartsResp, error)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/TreeMultiset.java

          for (AvlNode<E> current = header.succ(); current != header; ) {
            AvlNode<E> next = current.succ();
    
            current.elemCount = 0;
            // Also clear these fields so that one deleted Entry doesn't retain all elements.
            current.left = null;
            current.right = null;
            current.pred = null;
            current.succ = null;
    
            current = next;
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  6. cmd/admin-handlers-idp-config.go

    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	writeSuccessResponseJSON(w, econfigData)
    }
    
    // DeleteIdentityProviderCfg:
    //
    // DELETE <admin-prefix>/idp-cfg/openid/dex_test
    func (a adminAPIHandlers) DeleteIdentityProviderCfg(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  7. internal/event/target/kafka.go

    				return nil
    			}
    			return err
    		}
    		err = target.sendMultiple(events)
    	}
    	if err != nil {
    		if isKafkaConnErr(err) {
    			return store.ErrNotConnected
    		}
    		return err
    	}
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    func (target *KafkaTarget) toProducerMessage(eventData event.Event) (*sarama.ProducerMessage, error) {
    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  8. cni/pkg/cmd/root.go

    	// Repair
    	registerBooleanParameter(constants.RepairEnabled, true, "Whether to enable race condition repair or not")
    	registerBooleanParameter(constants.RepairDeletePods, false, "Controller will delete pods when detecting pod broken by race condition")
    	registerBooleanParameter(constants.RepairLabelPods, false, "Controller will label pods when detecting pod broken by race condition")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 15:33:47 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  9. cmd/prepare-storage.go

    		storageLogIf(GlobalContext, fmt.Errorf("unable to create (%s) %w, drive may be faulty, please investigate",
    			pathJoin(diskPath, minioMetaTmpBucket),
    			err))
    	}
    
    	// Delete all temporary files created for DirectIO write check
    	files, _ := filepath.Glob(filepath.Join(diskPath, ".writable-check-*.tmp"))
    	for _, file := range files {
    		go removeAll(file)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  10. src/main/java/jcifs/smb1/smb1/SmbConstants.java

        static final int FILE_DELETE           = 0x00000040; // 7
        static final int FILE_READ_ATTRIBUTES  = 0x00000080; // 8
        static final int FILE_WRITE_ATTRIBUTES = 0x00000100; // 9
        static final int DELETE                = 0x00010000; // 16
        static final int READ_CONTROL          = 0x00020000; // 17
        static final int WRITE_DAC             = 0x00040000; // 18
        static final int WRITE_OWNER           = 0x00080000; // 19
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 8.4K bytes
    - Viewed (0)
Back to top