- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 183 for Channel (0.17 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache2/FileOperator.kt
import java.io.IOException import java.nio.channels.FileChannel import okio.Buffer /** * Read and write a target file. Unlike Okio's built-in `Okio.source(java.io.File file)` and `Okio.sink(java.io.File file)` * this class offers: * * * **Read/write:** read and write using the same operator. * * **Random access:** access any position within the file. * * **Shared channels:** read and write a file channel that's shared between
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.4K bytes - Viewed (0) -
maven-core/src/test/resources/apiv4-repo/org/codehaus/plexus/plexus/1.0.4/plexus-1.0.4.pom
</configuration> </notifier> <notifier> <type>irc</type> <configuration> <host>irc.codehaus.org</host> <port>6667</port> <channel>#plexus</channel> </configuration> </notifier> </notifiers> </ciManagement> <inceptionYear>2001</inceptionYear> <mailingLists> <mailingList> <name>Plexus Developer List</name>
Plain Text - Registered: Sun Apr 21 03:35:09 GMT 2024 - Last Modified: Sun Oct 02 08:41:25 GMT 2022 - 5.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/ntlmssp/NtlmFlags.java
/** * Specifies that communication across the authenticated channel * should carry a digital signature (message integrity). */ public static final int NTLMSSP_NEGOTIATE_SIGN = 0x00000010; /** * Specifies that communication across the authenticated channel * should be encrypted (message confidentiality). */
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Fri Mar 22 20:39:42 GMT 2019 - 5.3K bytes - Viewed (1) -
internal/ioutil/ioutil.go
dw := &DeadlineWorker{ timeout: timeout, } return dw } // Run runs the given function, passing it a stopper channel. If the deadline passes before // the function finishes executing, Run returns context.DeadlineExceeded to the caller. // channel so that the work function can attempt to exit gracefully. // Multiple calls to Run will run independently of each other.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
manifests/charts/istio-control/istio-discovery/files/grpc-agent.yaml
{{- if eq .Values.global.pilotCertProvider "istiod" }} - mountPath: /var/run/secrets/istio name: istiod-ca-cert {{- end }} - mountPath: /var/lib/istio/data name: istio-data # UDS channel between istioagent and gRPC client for XDS/SDS - mountPath: /etc/istio/proxy name: istio-xds - mountPath: /var/run/secrets/tokens name: istio-token {{- if .Values.global.mountMtlsCerts }}
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 26 16:51:17 GMT 2024 - 12.1K bytes - Viewed (0) -
maven-core/src/test/resources/apiv4-repo/org/codehaus/plexus/plexus-utils/1.0.4/plexus-utils-1.0.4.pom
<address>******@****.***</address> </configuration> </notifier> <notifier> <type>irc</type> <configuration> <port>6667</port> <channel>#plexus</channel> <host>irc.codehaus.org</host> </configuration> </notifier> </notifiers> </ciManagement> <inceptionYear>2001</inceptionYear> <mailingLists> <mailingList>
Plain Text - Registered: Sun Apr 21 03:35:09 GMT 2024 - Last Modified: Sun Oct 02 08:41:25 GMT 2022 - 6.7K bytes - Viewed (0) -
cmd/erasure.go
Info: dataUsageCacheInfo{ Name: dataUsageRoot, NextCycle: oldCache.Info.NextCycle, }, Cache: make(map[string]dataUsageEntry, len(oldCache.Cache)), } // Put all buckets into channel. bucketCh := make(chan BucketInfo, len(buckets)) // Shuffle buckets to ensure total randomness of buckets, being scanned. // Otherwise same set of buckets get scanned across erasure sets always.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
cmd/metacache-stream.go
if err != nil { return err } if w.reuseBlocks || o.reusable { metaDataPoolPut(o.metadata) } } return nil } // stream entries to the output. // The returned channel should be closed when done. // Any error is reported when closing the metacacheWriter. func (w *metacacheWriter) stream() (chan<- metaCacheEntry, error) { if w.creator != nil { err := w.creator() w.creator = nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 19.5K bytes - Viewed (0) -
manifests/charts/istio-control/istio-discovery/files/gateway-injection-template.yaml
{{- if eq .Values.global.pilotCertProvider "istiod" }} - mountPath: /var/run/secrets/istio name: istiod-ca-cert {{- end }} - mountPath: /var/lib/istio/data name: istio-data # SDS channel between istioagent and Envoy - mountPath: /etc/istio/proxy name: istio-envoy - mountPath: /var/run/secrets/tokens name: istio-token {{- if .Values.global.mountMtlsCerts }}
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 27 16:55:16 GMT 2024 - 8.6K bytes - Viewed (0) -
manifests/charts/istio-control/istio-discovery/files/grpc-simple.yaml
SERVER_URI="dns:///istiod.${ISTIO_NAMESPACE}.svc:15010" echo ' { "xds_servers": [ { "server_uri": "'${SERVER_URI}'", "channel_creds": [{"type": "insecure"}], "server_features" : ["xds_v3"] } ], "node": { "id": "'${NODE_ID}'", "metadata": {
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 10 20:56:20 GMT 2023 - 1.8K bytes - Viewed (0)