Search Options

Results per page
Sort
Preferred Languages
Advance

Results 2291 - 2300 of 2,475 for created (0.05 sec)

  1. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

        WaitOnRunService service = new WaitOnRunService();
        service.startAsync().awaitRunning();
        enterRun.await();
        service.stopAsync().awaitTerminated();
      }
    
      public void testTimeout() {
        // Create a service whose executor will never run its commands
        Service service =
            new AbstractExecutionThreadService() {
              @Override
              protected void run() throws Exception {}
    
              @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        }
      }
    
      public void testRejectedExecutionThrownWithMultipleCalls() throws Exception {
        final CountDownLatch latch = new CountDownLatch(1);
        final SettableFuture<?> future = SettableFuture.create();
        final Executor delegate =
            new Executor() {
              @Override
              public void execute(Runnable task) {
                if (future.set(null)) {
                  awaitUninterruptibly(latch);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  3. guava/src/com/google/common/collect/RegularImmutableBiMap.java

            checkNoConflictInValueBucket(value, entry, nextInValueBucket);
          } catch (BucketOverflowException e) {
            return JdkBackedImmutableBiMap.create(n, entryArray);
          }
          ImmutableMapEntry<K, V> newEntry =
              (nextInValueBucket == null && nextInKeyBucket == null)
                  ? RegularImmutableMap.makeImmutable(entry, key, value)
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  4. tensorflow/c/c_api_experimental_test.cc

          TFE_Op* op,
          const std::vector<absl::optional<std::vector<int64_t>>>& input_shapes_vec,
          const std::vector<TF_Tensor*>& input_tensors,
          const absl::optional<std::vector<int64_t>>& expected_shape) {
        // Create input_shapes.
        TF_ShapeAndTypeList* input_shapes =
            TF_NewShapeAndTypeList(input_shapes_vec.size());
        for (size_t i = 0; i < input_shapes_vec.size(); ++i) {
          const auto& input_shape = input_shapes_vec[i];
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Jan 17 22:27:52 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  5. istioctl/pkg/metrics/metrics.go

    	log.Debugf("metrics command invoked for workload(s): %v", args)
    
    	client, err := ctx.CLIClientWithRevision(metricsOpts.Revision)
    	if err != nil {
    		return fmt.Errorf("failed to create k8s client: %v", err)
    	}
    
    	pl, err := client.PodsForSelector(context.TODO(), ctx.IstioNamespace(), "app.kubernetes.io/name=prometheus")
    	if err != nil {
    		return fmt.Errorf("not able to locate Prometheus pod: %v", err)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultGraphConflictResolver.java

                        res.addEdge(sourceV, newV, edge);
                    }
                }
                // System.err.println("Original graph("+graph.getVertices().size()+"):\n"+graph.toString());
                // System.err.println("Cleaned("+requestedScope+") graph("+res.getVertices().size()+"):\n"+res.toString());
                // System.err.println("Linked("+requestedScope+")
                // subgraph("+linkedRes.getVertices().size()+"):\n"+linkedRes.toString());
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  7. internal/ioutil/ioutil.go

    				l = s.skipCount
    			}
    			n, err := s.Reader.Read(tmp[:l])
    			if err != nil {
    				return 0, err
    			}
    			s.skipCount -= int64(n)
    		}
    	}
    	return s.Reader.Read(p)
    }
    
    // NewSkipReader - creates a SkipReader
    func NewSkipReader(r io.Reader, n int64) io.Reader {
    	return &SkipReader{r, n}
    }
    
    // writerOnly hides an io.Writer value's optional ReadFrom method
    // from io.Copy.
    type writerOnly struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/graph/TraverserTest.java

      }
    
      private static SuccessorsFunction<Character> createUndirectedGraph(String... edges) {
        return createGraph(/* directed= */ false, edges);
      }
    
      /**
       * Creates a graph from a list of node pairs (encoded as strings, e.g. "ab" means that this graph
       * has an edge between 'a' and 'b').
       *
       * <p>The {@code successors} are always returned in alphabetical order.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 47.5K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/graph/TraverserTest.java

      }
    
      private static SuccessorsFunction<Character> createUndirectedGraph(String... edges) {
        return createGraph(/* directed= */ false, edges);
      }
    
      /**
       * Creates a graph from a list of node pairs (encoded as strings, e.g. "ab" means that this graph
       * has an edge between 'a' and 'b').
       *
       * <p>The {@code successors} are always returned in alphabetical order.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 47.5K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-rebalance.go

    			if z.checkIfRebalanceDone(poolIdx) {
    				return
    			}
    
    			fivs, err := entry.fileInfoVersions(bucket)
    			if err != nil {
    				return
    			}
    
    			// We need a reversed order for rebalance,
    			// to create the appropriate stack.
    			versionsSorter(fivs.Versions).reverse()
    
    			var rebalanced, expired int
    			for _, version := range fivs.Versions {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
Back to top