- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 629 for Write (1.04 sec)
-
internal/ioutil/ioutil_test.go
timeout time.Duration } func (w *sleepWriter) Write(p []byte) (n int, err error) { time.Sleep(w.timeout) return len(p), nil } func (w *sleepWriter) Close() error { return nil } func TestDeadlineWriter(t *testing.T) { w := NewDeadlineWriter(&sleepWriter{timeout: 500 * time.Millisecond}, 450*time.Millisecond) _, err := w.Write([]byte("1")) if err != context.DeadlineExceeded {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 02 11:02:31 GMT 2024 - 5.1K bytes - Viewed (0) -
cmd/storage-datatypes_gen.go
func (z *CheckPartsHandlerParams) EncodeMsg(en *msgp.Writer) (err error) { // map header, size 4 // write "id" err = en.Append(0x84, 0xa2, 0x69, 0x64) if err != nil { return } err = en.WriteString(z.DiskID) if err != nil { err = msgp.WrapError(err, "DiskID") return } // write "v" err = en.Append(0xa1, 0x76) if err != nil { return } err = en.WriteString(z.Volume)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 127.5K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/configdump.go
return nil } func (c *ConfigWriter) PrintFullSummary() error { _, _ = c.Stdout.Write([]byte("\n")) if err := c.PrintWorkloadSummary(WorkloadFilter{Verbose: true}); err != nil { return err } _, _ = c.Stdout.Write([]byte("\n")) if err := c.PrintServiceSummary(ServiceFilter{}); err != nil { return err } _, _ = c.Stdout.Write([]byte("\n")) if err := c.PrintPolicySummary(PolicyFilter{}); err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/DefaultToolchainsXmlFactory.java
} try { if (writer != null) { new MavenToolchainsStaxWriter().write(writer, content); } else { new MavenToolchainsStaxWriter().write(outputStream, content); } } catch (Exception e) { throw new XmlWriterException("Unable to write toolchains", e); } }
Java - Registered: Sun Mar 24 03:35:10 GMT 2024 - Last Modified: Thu Dec 07 20:05:02 GMT 2023 - 3.7K bytes - Viewed (0) -
docs/metrics/healthcheck/README.md
## Cluster probe ### Cluster-writeable probe The reply is '200 OK' if cluster has write quorum if not it returns '503 Service Unavailable'. ``` curl http://minio1:9001/minio/health/cluster HTTP/1.1 503 Service Unavailable Accept-Ranges: bytes Content-Length: 0 Server: MinIO Vary: Origin X-Amz-Bucket-Region: us-east-1 X-Minio-Write-Quorum: 3 X-Amz-Request-Id: 16239D6AB80EBECF X-Xss-Protection: 1; mode=block
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jul 06 16:18:38 GMT 2023 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CharSourceTest.java
static final CharSource BROKEN_CLOSE_SOURCE = new TestCharSource("ABC", CLOSE_THROWS); static final CharSource BROKEN_OPEN_SOURCE = new TestCharSource("ABC", OPEN_THROWS); static final CharSink BROKEN_WRITE_SINK = new TestCharSink(WRITE_THROWS); static final CharSink BROKEN_CLOSE_SINK = new TestCharSink(CLOSE_THROWS); static final CharSink BROKEN_OPEN_SINK = new TestCharSink(OPEN_THROWS);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/base/FessAdminAction.java
runtime.registerData("forumLink", forumLink); } } protected abstract String getActionRole(); protected void write(final String path, final byte[] data) { LdiFileUtil.write(path, data); } protected ServletContext getServletContext() { return LaServletContextUtil.getServletContext(); }
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/ByteSinkTest.java
assertFalse(sink.wasStreamClosed()); out.write(new byte[] {1, 2, 3, 4}); out.close(); assertTrue(sink.wasStreamClosed()); assertArrayEquals(new byte[] {1, 2, 3, 4}, sink.getBytes()); } public void testWrite_bytes() throws IOException { assertArrayEquals(new byte[0], sink.getBytes()); sink.write(bytes); assertTrue(sink.wasStreamOpened() && sink.wasStreamClosed());
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.7K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultToolchainsXmlFactory.java
} try { if (writer != null) { new MavenToolchainsStaxWriter().write(writer, content); } else { new MavenToolchainsStaxWriter().write(outputStream, content); } } catch (Exception e) { throw new XmlWriterException("Unable to write toolchains: " + getMessage(e), getLocation(e), e); } }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Mar 25 10:50:01 GMT 2024 - 3.9K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/MavenMetadata.java
} } private void write(Path metadataPath, Metadata metadata) throws RepositoryException { try { Files.createDirectories(metadataPath.getParent()); try (OutputStream output = Files.newOutputStream(metadataPath)) { new MetadataStaxWriter().write(output, metadata); } } catch (IOException | XMLStreamException e) {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 16:33:18 GMT 2024 - 4.4K bytes - Viewed (0)