Search Options

Results per page
Sort
Preferred Languages
Advance

Results 371 - 380 of 527 for Once (0.02 sec)

  1. guava/src/com/google/common/primitives/ImmutableIntArray.java

    1. * Returns an immutable <i>view</i> of this array's values as a {@code List}; note that {@code
    2. * int} values are boxed into {@link Integer} instances on demand, which can be very expensive.
    3. * The returned list should be used once and discarded. For any usages beyond that, pass the
    4. * returned list to {@link com.google.common.collect.ImmutableList#copyOf(Collection)
    5. * ImmutableList.copyOf} and use that list instead.
    6. */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

    1. cache.close()
    2. createNewCache()
    3.  
    4. // The journal will have no record that 'a' was removed. It will have an entry for 'a', but when
    5. // it tries to read the cache files, it will find they were deleted. Once it encounters an entry
    6. // with missing cache files, it should remove it from the cache entirely.
    7. assertThat(cache.size()).isEqualTo(4)
    8. assertThat(cache["a"]).isNull()
    9. assertThat(cache.size()).isEqualTo(2)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 14:55:09 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  3. common-protos/k8s.io/apimachinery/pkg/apis/meta/v1/generated.proto

    1. // directly settable by a client. The resource is expected to be deleted (no longer visible
    2. // from resource lists, and not reachable by name) after the time in this field, once the
    3. // finalizers list is empty. As long as the finalizers list contains items, deletion is blocked.
    4. // Once the deletionTimestamp is set, this value may not be unset or be set further into the
    5. // future, although it may be shortened or the resource may be deleted prior to this time.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  4. cmd/object-api-interface.go

    1. }
    2.  
    3. // GetObject - TODO(aead): This function just acts as an adapter for GetObject tests and benchmarks
    4. // since the GetObject method of the ObjectLayer interface has been removed. Once, the
    5. // tests are adjusted to use GetObjectNInfo this function can be removed.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  5. cmd/local-locker_test.go

    1. }
    2. // A UID is added for every resource
    3. if len(l.lockUID) != len(rResources)*2+len(wResources)*m {
    4. t.Fatalf("lockUID len, got %d, want %d + %d", len(l.lockUID), len(rResources)*2, len(wResources)*m)
    5. }
    6. // RUnlock once...
    7. for i, name := range rResources {
    8. arg := dsync.LockArgs{
    9. UID: rUIDs[i*2],
    10. Resources: []string{name},
    11. Source: t.Name(),
    12. Owner: "owner",
    13. Quorum: &quorum,
    14. }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  6. internal/rest/client.go

    1. req.Header.Set(xhttp.AmzRequestID, tc.AmzReqID)
    2. }
    3.  
    4. return req, nil
    5. }
    6.  
    7. type respBodyMonitor struct {
    8. io.ReadCloser
    9. expectTimeouts bool
    10. errorStatusOnce sync.Once
    11. }
    12.  
    13. func (r *respBodyMonitor) Read(p []byte) (n int, err error) {
    14. n, err = r.ReadCloser.Read(p)
    15. r.errorStatus(err)
    16. return
    17. }
    18.  
    19. func (r *respBodyMonitor) Close() (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/collect/ImmutableRangeSetTest.java

    1. assertEquals(expected.contains(i), subRangeSet.contains(i));
    2. }
    3. }
    4. }
    5. }
    6. }
    7. }
    8.  
    9. // TODO(b/172823566): Use mainline testToImmutableRangeSet once CollectorTester is usable to java7
    10. public void testToImmutableRangeSet_java7_combine() {
    11. Range<Integer> rangeOne = Range.closedOpen(1, 3);
    12. Range<Integer> rangeTwo = Range.closedOpen(7, 9);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/ImmutableSortedMultiset.java

    1. * ordering. To create a copy of a {@code SortedMultiset} that preserves the comparator, call
    2. * {@link #copyOfSorted} instead. This method iterates over {@code elements} at most once.
    3. *
    4. * <p>Note that if {@code s} is a {@code Multiset<String>}, then {@code
    5. * ImmutableSortedMultiset.copyOf(s)} returns an {@code ImmutableSortedMultiset<String>}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 21:21:17 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  9. tensorflow/c/eager/parallel_device/parallel_device.cc

    1. }
    2. result.emplace(std::move(result_content));
    3. return result;
    4. }
    5.  
    6. // Used as an argument to TFE_NewCustomDeviceTensorHandle, indicating how
    7. // ParallelTensors wrapped in TFE_TensorHandles should be cleaned up once their
    8. // reference counts drop to zero.
    9. void ParallelTensorDeallocator(void* data) {
    10. delete reinterpret_cast<ParallelTensor*>(data);
    11. }
    12.  
    13. // Used as an argument to TFE_NewCustomDeviceTensorHandle, for computing the
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/ztunnelserver.go

    1. context.AfterFunc(ctx, func() { _ = z.Close() })
    2.  
    3. // Allow at most 5 requests per second. This is still a ridiculous amount; at most we should have 2 ztunnels on our node,
    4. // and they will only connect once and persist.
    5. // However, if they do get in a state where they call us in a loop, we will quickly OOM
    6. limit := rate.NewLimiter(rate.Limit(5), 1)
    7. for {
    8. log.Debug("accepting conn")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
Back to top