- Sort Score
- Result 10 results
- Languages All
Results 251 - 260 of 298 for getDfs (0.06 sec)
-
src/archive/tar/reader.go
return err } buf.Write(blk[:]) for _, c := range blk { if c == '\n' { cntNewline++ } } } return nil } // nextToken gets the next token delimited by a newline. This assumes that // at least one newline exists in the buffer. nextToken := func() string { cntNewline-- tok, _ := buf.ReadString('\n') return strings.TrimRight(tok, "\n")
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Mar 08 01:59:14 UTC 2024 - 26.8K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
func extendFQDN(host string) string { if host[0] == '*' { return host } if strings.HasSuffix(host, k8sSuffix) { return host } return host + k8sSuffix } // getDestRuleSubsets gets names of subsets that match any pod labels (also, ones that don't match). func getDestRuleSubsets(subsets []*v1alpha3.Subset, podsLabels []klabels.Set) ([]string, []string) { matchingSubsets := make([]string, 0, len(subsets))
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Oct 24 17:36:49 UTC 2024 - 50.6K bytes - Viewed (0) -
configure.py
write_action_env_to_bazelrc('ANDROID_SDK_API_LEVEL', android_api_level) write_action_env_to_bazelrc('ANDROID_SDK_HOME', android_sdk_home_path) def get_ndk_api_level(environ_cp, android_ndk_home_path): """Gets the appropriate NDK API level to use for the provided Android NDK path. """ # First check to see if we're using a blessed version of the NDK. properties_path = '%s/source.properties' % android_ndk_home_path
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Wed Oct 02 22:16:02 UTC 2024 - 48.2K bytes - Viewed (0) -
cmd/server-main.go
logger.Fatal(err, "Unable to start the server") } }) } if globalEnableSyncBoot { // Freeze the services until the bucket notification subsystem gets initialized. bootstrapTrace("freezeServices", freezeServices) } var newObject ObjectLayer bootstrapTrace("newObjectLayer", func() { var err error
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 24 21:50:11 UTC 2024 - 35.2K bytes - Viewed (1) -
CHANGELOG/CHANGELOG-1.4.md
* etcd3: pass SelectionPredicate instead of Filter to storage layer ([#31190](https://github.com/kubernetes/kubernetes/pull/31190), [@hongchaodeng](https://github.com/hongchaodeng)) * etcd3: make gets for previous value in watch serialize-able ([#34089](https://github.com/kubernetes/kubernetes/pull/34089), [@wojtek-t](https://github.com/wojtek-t))
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Thu Dec 24 02:28:26 UTC 2020 - 133.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
val requestBodyDelay = 250L val responseHeadersStartDelay = 250L val responseBodyStartDelay = 250L val responseBodyEndDelay = 250L // Warm up the client so the timing part of the test gets a pooled connection. server.enqueue(MockResponse()) val warmUpCall = client.newCall( Request.Builder() .url(server.url("/")) .build(), )
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 56.9K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
assertThat(rstStream.errorCode).isEqualTo(ErrorCode.CANCEL) } /** * When writing a set of headers fails due to an `IOException`, make sure the writer is left * in a consistent state so the next writer also gets an `IOException` also instead of * something worse (like an [IllegalStateException]. * * * See https://github.com/square/okhttp/issues/1651 */ @Test fun socketExceptionWhileWritingHeaders() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.32.md
## Urgent Upgrade Notes ### (No, really, you MUST read this before you upgrade) - ACTION REQUIRED for custom scheduler plugin developers: `PodEligibleToPreemptOthers` in the `preemption` interface gets `ctx` in the parameters. Please change your plugins' implementation accordingly. ([#126465](https://github.com/kubernetes/kubernetes/pull/126465), [@googs1025](https://github.com/googs1025)) [SIG Scheduling]
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Tue Oct 29 20:17:52 UTC 2024 - 121.6K bytes - Viewed (0) -
cmd/bucket-replication.go
// ReplicationSsecChecksumHeader - the encrypted checksum of the SSE-C encrypted object. ReplicationSsecChecksumHeader = "X-Minio-Replication-Ssec-Crc" ) // gets replication config associated to a given bucket name. func getReplicationConfig(ctx context.Context, bucketName string) (rc *replication.Config, err error) { rCfg, _, err := globalBucketMetadataSys.GetReplicationConfig(ctx, bucketName)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 06:49:55 UTC 2024 - 116.1K bytes - Viewed (0) -
cmd/object-handlers.go
}) if err != nil { return nil, err } core.SetAppInfo("minio-federated", ReleaseTag) return core, nil } // Check if the destination bucket is on a remote site, this code only gets executed // when federation is enabled, ie when globalDNSConfig is non 'nil'. // // This function is similar to isRemoteCallRequired but specifically for COPY object API
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 05 05:16:15 UTC 2024 - 117.4K bytes - Viewed (0)