- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 3,233 for Write (0.05 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn_test.go
} // verify that a read from a Write channel doesn't block data = make([]byte, 1024) if n, err := conn.channels[4].Read(data); n != 0 || err != io.EOF { t.Errorf("reads should be ignored") } // verify that a client write to a Write channel doesn't block (is dropped) if n, err := client.Write(append([]byte{4}, []byte("ignored")...)); err != nil || n != 8 { t.Fatalf("%d: %v", n, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 11.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/responsewriters/writers.go
err = w.Close() if err != nil { // we cannot write an error to the writer anymore as the Encode call was successful. utilruntime.HandleError(fmt.Errorf("apiserver was unable to close cleanly the response writer: %v", err)) } return } // make a best effort to write the object if a failure is detected utilruntime.HandleError(fmt.Errorf("apiserver was unable to write a JSON response: %v", err)) status := ErrorToAPIStatus(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 18:21:43 UTC 2023 - 10.6K bytes - Viewed (0) -
src/net/http/internal/chunked_test.go
t.Skip("skipping in short mode") } var buf bytes.Buffer w := NewChunkedWriter(&buf) a, b, c := []byte("aaaaaa"), []byte("bbbbbbbbbbbb"), []byte("cccccccccccccccccccccccc") w.Write(a) w.Write(b) w.Write(c) w.Close() readBuf := make([]byte, len(a)+len(b)+len(c)+1) byter := bytes.NewReader(buf.Bytes()) bufr := bufio.NewReader(byter) mallocs := testing.AllocsPerRun(100, func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 04 20:45:19 UTC 2024 - 8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CountingOutputStreamTest.java
assertEquals(written, counter.getCount()); counter.write(0); written += 1; assertEquals(written, out.size()); assertEquals(written, counter.getCount()); byte[] data = new byte[10]; counter.write(data); written += 10; assertEquals(written, out.size()); assertEquals(written, counter.getCount()); counter.write(data, 0, 5); written += 5; assertEquals(written, out.size());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 1.9K bytes - Viewed (0) -
test/nowritebarrier.go
//go:noinline func d3() { x.f = y // ERROR "write barrier prohibited by caller" d4() } //go:yeswritebarrierrec func d4() { d2() } //go:noinline func systemstack(func()) {} //go:nowritebarrierrec func e1() { systemstack(e2) systemstack(func() { x.f = y // ERROR "write barrier prohibited by caller" }) } func e2() { x.f = y // ERROR "write barrier prohibited by caller"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 22 19:18:21 UTC 2023 - 1.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/tensorflow/gen_quantized_function_library.py
""") for namespace in namespaces: f.write('namespace {0} {{\n'.format(namespace)) for tag, module in modules: f.write('constexpr char {0}[] ='.format(module_prefix + tag.upper())) for line in module.splitlines(): f.write('\n "') f.write(line.rstrip().replace('"', r'\"')) f.write('\\n"') f.write(';\n') for namespace in reversed(namespaces):
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Dec 20 01:38:06 UTC 2022 - 8.4K bytes - Viewed (0) -
src/image/gif/writer.go
b.e.buf[0]++ b.e.buf[b.e.buf[0]] = c if b.e.buf[0] < 255 { return nil } // Flush block b.e.write(b.e.buf[:256]) b.e.buf[0] = 0 return b.e.err } // blockWriter must be an io.Writer for lzw.NewWriter, but this is never // actually called. func (b blockWriter) Write(data []byte) (int, error) { for i, c := range data { if err := b.WriteByte(c); err != nil { return i, err } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 21:38:09 UTC 2024 - 11.9K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteArrayDataOutput.java
* @since 1.0 */ @J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault public interface ByteArrayDataOutput extends DataOutput { @Override void write(int b); @Override void write(byte b[]); @Override void write(byte b[], int off, int len); @Override void writeBoolean(boolean v); @Override void writeByte(int v); @Override void writeShort(int v);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 2K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/internal/snapshot/impl/ImplementationSnapshotSerializer.java
return serializer.read(decoder); } @Override public void write(Encoder encoder, ImplementationSnapshot implementationSnapshot) throws Exception { Impl serializer = determineSerializer(implementationSnapshot); encoder.writeSmallInt(serializer.ordinal()); serializer.write(encoder, implementationSnapshot); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 12:33:49 UTC 2024 - 6K bytes - Viewed (0) -
src/image/jpeg/writer.go
case *image.Gray: nComponent = 1 } // Write the Start Of Image marker. e.buf[0] = 0xff e.buf[1] = 0xd8 e.write(e.buf[:2]) // Write the quantization tables. e.writeDQT() // Write the image dimensions. e.writeSOF0(b.Size(), nComponent) // Write the Huffman tables. e.writeDHT(nComponent) // Write the image data. e.writeSOS(m) // Write the End Of Image marker. e.buf[0] = 0xff
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 12:02:45 UTC 2023 - 17.1K bytes - Viewed (0)