- Sort Score
- Num 10 results
- Language All
Results 161 - 170 of 1,662 for wrote (0.1 seconds)
-
build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/SortAcceptedApiChangesTask.kt
loadChanges().mapValues { gson.toJson(AcceptedApiChanges(sortChanges(it.value))) }.forEach { it.key.bufferedWriter().use { out -> out.write(it.value) out.write("\n") } } }
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Apr 09 14:09:16 GMT 2025 - 1.5K bytes - Click Count (0) -
cmd/metrics-v3-cluster-erasure-set.go
"Overall write quorum across pools and sets") erasureSetOverallHealthMD = NewGaugeMD(erasureSetOverallHealth, "Overall health across pools and sets (1=healthy, 0=unhealthy)") erasureSetReadQuorumMD = NewGaugeMD(erasureSetReadQuorum, "Read quorum for the erasure set in a pool", poolIDL, setIDL) erasureSetWriteQuorumMD = NewGaugeMD(erasureSetWriteQuorum, "Write quorum for the erasure set in a pool", poolIDL, setIDL)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 14 07:25:56 GMT 2024 - 4.4K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/notify/Smb2ChangeNotifyResponseTest.java
setHeaderStart(response, 64); // Write structure header (9 bytes) SMBUtil.writeInt2(9, buffer, offset); // Structure size SMBUtil.writeInt2(80 - 64, buffer, offset + 2); // Buffer offset (relative to header) SMBUtil.writeInt4(50, buffer, offset + 4); // Total length of notification data // Write notification data at buffer offset 80 int notifyOffset = 80;
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 18.8K bytes - Click Count (0) -
docs/contribute/concurrency.md
### Threads #### Application's calling thread The application-layer must block on writing I/O. We can't return from a write until we've pushed its bytes onto the socket. Otherwise, if the write fails we are unable to deliver its IOException to the application. We would have told the application layer that the write succeeded, but it didn't!
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Click Count (0) -
cmd/bootstrap-peer-server_gen.go
// map header, size 4 // write "NEndpoints" err = en.Append(0x84, 0xaa, 0x4e, 0x45, 0x6e, 0x64, 0x70, 0x6f, 0x69, 0x6e, 0x74, 0x73) if err != nil { return } err = en.WriteInt(z.NEndpoints) if err != nil { err = msgp.WrapError(err, "NEndpoints") return } // write "CmdLines" err = en.Append(0xa8, 0x43, 0x6d, 0x64, 0x4c, 0x69, 0x6e, 0x65, 0x73)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6.9K bytes - Click Count (0) -
src/test/java/jcifs/pac/PacSignatureTest.java
*/ class PacSignatureTest { /** * Helper method to write integer in little-endian format. */ private void writeLittleEndianInt(ByteArrayOutputStream baos, int value) { ByteBuffer buffer = ByteBuffer.allocate(4); buffer.order(ByteOrder.LITTLE_ENDIAN); buffer.putInt(value); baos.write(buffer.array(), 0, 4); } /**Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 5.3K bytes - Click Count (0) -
compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/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.getDelegate()); }Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 4.2K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/tree/Smb2TreeDisconnectRequestTest.java
// size8 method aligns to 8-byte boundary int alignedSize = (expectedSize + 7) & ~7; assertEquals(alignedSize, size); } @Test @DisplayName("Should write correct bytes to wire format") void testWriteBytesWireFormat() { // Given Configuration mockConfig = mock(Configuration.class);Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 14.1K bytes - Click Count (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/util/TemporaryFileInputStreamTest.java
// Create a temporary file with test data File tempFile = File.createTempFile("test-", ".tmp"); try (FileOutputStream fos = new FileOutputStream(tempFile)) { fos.write("Test data".getBytes()); } // Read from TemporaryFileInputStream try (TemporaryFileInputStream stream = new TemporaryFileInputStream(tempFile)) { assertEquals('T', stream.read());Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Sat Nov 22 13:28:22 GMT 2025 - 7.2K bytes - Click Count (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)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 151.7K bytes - Click Count (0)