Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 527 for seen (0.02 sec)

  1. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

      /** Adds the chain to the seen set, and returns whether all the chain was new to us. */
      private static boolean addCausalChain(Set<Throwable> seen, Throwable param) {
        // Declare a "true" local variable so that the Checker Framework will infer nullness.
        Throwable t = param;
    
        for (; t != null; t = t.getCause()) {
          boolean firstTimeSeen = seen.add(t);
          if (!firstTimeSeen) {
            /*
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/io/CharStreamsTest.java

            new LineProcessor<Integer>() {
              int seen;
    
              @Override
              public boolean processLine(String line) {
                seen++;
                sb.append(line);
                return seen < 2;
              }
    
              @Override
              public Integer getResult() {
                return seen;
              }
            };
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/io/CharStreamsTest.java

            new LineProcessor<Integer>() {
              int seen;
    
              @Override
              public boolean processLine(String line) {
                seen++;
                sb.append(line);
                return seen < 2;
              }
    
              @Override
              public Integer getResult() {
                return seen;
              }
            };
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  4. docs/metrics/prometheus/list.md

    | `minio_node_replication_max_queued_count`               | Maximum number of objects queued for replication seen since server start                                 |
    | `minio_node_replication_recent_backlog_count`           | Total number of objects seen in replication backlog in the last 5 minutes                                |
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:48:51 UTC 2024
    - 43.3K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/collect/testing/google/MultisetTestSuiteBuilder.java

          for (Entry<E> entry : insertionOrder) {
            map.put(entry.getElement(), entry);
          }
    
          Set<E> seen = new HashSet<>();
          List<Entry<E>> order = new ArrayList<>();
          for (E e : gen.order(new ArrayList<E>(map.keySet()))) {
            if (seen.add(e)) {
              order.add(map.get(e));
            }
          }
          return order;
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

            return;
          }
          // Otherwise, it's the first time seeing this lock relationship. Look for
          // a path from the acquiredLock to this.
          Set<LockGraphNode> seen = Sets.newIdentityHashSet();
          ExampleStackTrace path = acquiredLock.findPathTo(this, seen);
    
          if (path == null) {
            // this can be safely acquired after the acquiredLock.
            //
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 35.9K bytes
    - Viewed (0)
  7. istioctl/pkg/injector/injector-list.go

    	retval := make([]corev1.Namespace, 0, len(namespaces))
    	seen := sets.String{}
    	for _, webhook := range hook.Webhooks {
    		nsSelector, err := metav1.LabelSelectorAsSelector(webhook.NamespaceSelector)
    		if err != nil {
    			return retval
    		}
    
    		for _, namespace := range namespaces {
    			if !seen.Contains(namespace.Name) && nsSelector.Matches(api_pkg_labels.Set(namespace.Labels)) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Oct 18 11:39:52 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/podcgroupns.go

    }
    
    func (p *PodNetnsProcFinder) FindNetnsForPods(pods map[types.UID]*corev1.Pod) (PodToNetns, error) {
    	/*
    		for each process, find its netns inode,
    		if we already seen the inode, skip it
    		if we haven't seen the inode, check the process cgroup and see if we
    		can extract a pod uid from it.
    		if we can, open the netns, and save a map of uid->netns-fd
    	*/
    
    	podUIDNetns := make(PodToNetns)
    	netnsObserved := sets.New[uint64]()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 11K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/google/MultisetTestSuiteBuilder.java

          for (Entry<E> entry : insertionOrder) {
            map.put(entry.getElement(), entry);
          }
    
          Set<E> seen = new HashSet<>();
          List<Entry<E>> order = new ArrayList<>();
          for (E e : gen.order(new ArrayList<E>(map.keySet()))) {
            if (seen.add(e)) {
              order.add(map.get(e));
            }
          }
          return order;
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  10. internal/config/config.go

    						filterMap[k] = envVarPrefix
    					}
    				} else {
    					filterMap[k] = envVarPrefix
    				}
    			}
    		}
    	}
    
    	for k, v := range filterMap {
    		seen.Add(strings.TrimPrefix(k, v))
    	}
    
    	seen.Remove(Default)
    	targets := seen.ToSlice()
    	sort.Strings(targets)
    	targets = append([]string{Default}, targets...)
    
    	return targets, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
Back to top