- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 923 for read1 (0.05 sec)
-
pkg/kube/kclient/client_test.go
return len(wasm.List("", klabels.Everything())) }, 1) tracker.WaitOrdered("add/name") }) t.Run("CRD fully ready", func(t *testing.T) { stop := test.NewStop(t) c := kube.NewFakeClient() // Only CRD is ready to go by the time we start informers clienttest.MakeCRD(t, c, gvr.WasmPlugin) c.RunAndWait(stop) // Now that CRD is synced, we create the client
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
type MonitorReaderOptions struct { BucketOptions HeaderSize int } // Read implements a throttled read func (r *MonitoredReader) Read(buf []byte) (n int, err error) { if r.throttle == nil { return r.r.Read(buf) } if r.lastErr != nil { err = r.lastErr return } b := r.throttle.Burst() // maximum available tokens
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Sep 06 03:21:59 UTC 2023 - 3.1K bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/proxy-override.yaml.injected
proxy.istio.io/overrides: '{"containers":[{"name":"istio-proxy","resources":{"limits":{"cpu":"3"},"requests":{"cpu":"123m"}},"volumeMounts":[{"name":"certs","mountPath":"/etc/certs"}],"livenessProbe":{"httpGet":{"path":"/healthz/ready","port":15021},"initialDelaySeconds":10,"timeoutSeconds":3,"periodSeconds":2,"failureThreshold":30},"lifecycle":{"preStop":{"exec":{"command":["sleep","10"]}}},"terminationMessagePath":"/foo/bar","securityContext":{"runAsUser":1234,"runAsGroup":12...
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 16:55:16 UTC 2024 - 7.3K bytes - Viewed (0) -
tensorflow/compiler/jit/resource_operation_safety_analysis.cc
// ================== // // An XLA cluster hoists all resource reads to be beginning of the cluster // execution and all the resource writes to the end. This means it cannot // enforce arbitrary ordering dependencies (via control or data edges) between // resource operations. Since all resource reads happen before all resource // writes, edges constraining resource reads to happen before resource writes
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Feb 09 11:36:41 UTC 2024 - 11.2K bytes - Viewed (0) -
pkg/printers/internalversion/printers_test.go
{Ready: true, RestartCount: 3, State: api.ContainerState{Running: &api.ContainerStateRunning{}}}, {Ready: true, RestartCount: 3}, }, }, }, []metav1.TableRow{{Cells: []interface{}{"test5", "1/2", "podReason", "6", "<unknown>"}}}, }, { // Test pod has 2 containers, one is running and the other is completed, w/o ready condition api.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 218.6K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbCopyUtil.java
private byte[] b; private int n; private boolean ready; private SmbFileOutputStream out; private SmbException e = null; WriterThread () { super("JCIFS-WriterThread"); this.ready = false; } /** * @return the ready */ boolean isReady () { return this.ready; } /** * @throws SmbException
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Tue Jul 07 10:52:42 UTC 2020 - 17.1K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheGroovyClosureIntegrationTest.groovy
import org.gradle.internal.serialize.codecs.core.ClosureCodec class ConfigurationCacheGroovyClosureIntegrationTest extends AbstractConfigurationCacheIntegrationTest { def "from-cache build fails when task action closure reads a project property"() { given: buildFile << """ tasks.register("some") { doFirst { println(name) // task property is ok
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 9.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/transform/TransformExecutionResultSerializerTest.groovy
def serializer = new TransformExecutionResultSerializer() def "reads and writes transformation results"() { expect: assertCanWriteAndReadResult( inputArtifact.file("inside"), inputArtifact, outputDir.file("first"), outputDir.file("second"), outputDir ) } def "reads and writes output only transformation results"() { expect:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 22 09:41:31 UTC 2023 - 5.3K bytes - Viewed (0) -
src/cmd/internal/buildid/rewrite.go
r = excludeMachoCodeSignature(r) // The strategy is to read the file through buf, looking for id, // but we need to worry about what happens if id is broken up // and returned in parts by two different reads. // We allocate a tiny buffer (at least len(id)) and a big buffer (bufSize bytes) // next to each other in memory and then copy the tail of // one read into the tiny buffer before reading new data into the big buffer.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Dec 13 18:45:54 UTC 2021 - 5.1K bytes - Viewed (0) -
src/encoding/binary/varint.go
if ux&1 != 0 { x = ^x } return x, n } var errOverflow = errors.New("binary: varint overflows a 64-bit integer") // ReadUvarint reads an encoded unsigned integer from r and returns it as a uint64. // The error is [io.EOF] only if no bytes were read. // If an [io.EOF] happens after reading some but not all the bytes, // ReadUvarint returns [io.ErrUnexpectedEOF]. func ReadUvarint(r io.ByteReader) (uint64, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 4.8K bytes - Viewed (0)