- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 2,455 for we (0.14 sec)
-
android/guava/src/com/google/common/escape/Platform.java
return requireNonNull(DEST_TL.get()); } /** * A thread-local destination buffer to keep us from creating new buffers. The starting size is * 1024 characters. If we grow past this we don't put it back in the threadlocal, we just keep * going and grow as needed. */ private static final ThreadLocal<char[]> DEST_TL = new ThreadLocal<char[]>() { @Override protected char[] initialValue() {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Dec 15 19:31:54 GMT 2023 - 1.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
* * ## Upstream * * In this case the current thread is assigned as the upstream reader. We read bytes from * upstream and copy them to both the file and to the buffer. Finally we release the upstream * reader lock and return the new bytes. * * ## The file * * In this case we copy bytes from the file to the [sink]. * * ## The buffer *
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
cmd/metacache-server-pool.go
if !HasPrefix(o.Marker, o.Prefix) { return entries, io.EOF } } // With max keys of zero we have reached eof, return right here. if o.Limit == 0 { return entries, io.EOF } // For delimiter and prefix as '/' we do not list anything at all // along // with the prefix. On a flat namespace with 'prefix' // as '/' we don't have any entries, since all the keys are // of form 'keyName/...'
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/AndroidIncompatible.java
* under all environments. We could fight this by fully qualifying the annotation, but the * result will be verbose and attention-grabbing. * <li>We need to be careful about how we suppress {@code suite()} methods in {@code common.io}. * The generated suite for {@code FooTest} ends up containing {@code FooTest} itself plus some * other tests. We want to exclude the other tests (which Android can't handle) while
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Jul 07 15:40:13 GMT 2023 - 3.9K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
switch event.Event { case controllers.EventAdd: // pod was added to our cache // we get here in 2 cases: // 1. new pod was created on our node // 2. we were restarted and current existing pods are added to our cache // We have no good way to distinguish between these two cases from here. But we don't need to! // Existing pods will be handled by the dataplane using `GetAmbientPods`,
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 9.9K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
cfg: cfg, } // By detecting iptables versions *here* once-for-all we are // committing to using the same binary/variant (legacy or nft) // within all pods as we do on the host. // // This should be fine, as the host binaries are all we have to work with here anyway, // as we are running within a privileged container - and we don't want to take the time to // redetect for each pod anyway. // // Extreme corner case:
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 01:42:30 GMT 2024 - 19.2K bytes - Viewed (0) -
cmd/os-reliable.go
package cmd import ( "fmt" "os" "path" ) // Wrapper functions to os.RemoveAll, which calls reliableRemoveAll // this is to ensure that if there is a racy parent directory // create in between we can simply retry the operation. func removeAll(dirPath string) (err error) { if dirPath == "" { return errInvalidArgument } if err = checkPathLength(dirPath); err != nil { return err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Sep 13 15:14:36 GMT 2023 - 5.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* cost as fresh ones (1/QPS is the cost for each). We use this trick later. * * If we pick a function that goes /below/ that horizontal line, it means that we reduce the area * of the function, thus time. Thus, the RateLimiter becomes /faster/ after a period of * underutilization. If, on the other hand, we pick a function that goes /above/ that horizontal
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 19.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
* * We get plan0 and plan1 from the route planner. * We get plan2 as a follow-up to plan1, typically retry the same IP but different TLS. * We get plan3 as a retry of plan0, which was canceled when it lost the race. * * This test confirms that we prefer to do the TLS follow-up (plan2) before the TCP retry (plan3). * It also confirms we enforce the 250 ms delay in each race. */ @Test
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/EndpointPairIterator.java
* visited twice if there is an edge connecting them. To avoid returning duplicate {@link * EndpointPair}s, we keep track of the nodes that we have visited. When processing endpoint * pairs, we skip if the "other node" is in the visited set, as shown below: * * <pre> * Nodes = {N1, N2, N3, N4} * N2 __ * / \ | |
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Jul 09 17:31:04 GMT 2021 - 5K bytes - Viewed (0)