Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 311 - 320 of 573 for readPing (0.27 seconds)

  1. src/main/java/jcifs/pac/PacDataInputStream.java

         */
        public int readInt() throws IOException {
            align(4);
            return Integer.reverseBytes(this.dis.readInt());
        }
    
        /**
         * Reads a 64-bit long value with proper alignment and byte order.
         * @return the long value in little-endian format
         * @throws IOException if an I/O error occurs
         */
        public long readLong() throws IOException {
            align(8);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  2. cmd/erasure-coding.go

    	lastShardSize := ceilFrac(lastBlockSize, int64(e.dataBlocks))
    	return numShards*e.ShardSize() + lastShardSize
    }
    
    // ShardFileOffset - returns the effective offset where erasure reading begins.
    func (e *Erasure) ShardFileOffset(startOffset, length, totalLength int64) int64 {
    	shardSize := e.ShardSize()
    	shardFileSize := e.ShardFileSize(totalLength)
    	endShard := (startOffset + length) / e.blockSize
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  3. internal/mountinfo/mountinfo_linux_test.go

    		`
    	var err error
    	dir := t.TempDir()
    
    	mountsPath := filepath.Join(dir, "mounts")
    	if err = os.WriteFile(mountsPath, []byte(successCase), 0o666); err != nil {
    		t.Fatal(err)
    	}
    	// Verifies if reading each line worked properly.
    	{
    		var mounts mountInfos
    		mounts, err = readProcMounts(mountsPath)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if len(mounts) != 3 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 7.3K bytes
    - Click Count (0)
  4. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt

      }
    
      @Throws(IOException::class)
      private fun completeEvent(
        id: String?,
        type: String?,
        data: Buffer,
      ) {
        if (data.size != 0L) {
          lastId = id
          data.skip(1L) // Leading newline.
          callback.onEvent(id, type, data.readUtf8())
        }
      }
    
      companion object {
        val options =
          Options.of(
            // 0
            "\r\n".encodeUtf8(),
            // 1
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 4.3K bytes
    - Click Count (0)
  5. cmd/storage-rest-client.go

    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    	// Use websocket when not reading data.
    	if !opts.ReadData {
    		resp, err := storageReadVersionRPC.Call(ctx, client.gridConn, grid.NewMSSWith(map[string]string{
    			storageRESTDiskID:           *client.diskID.Load(),
    			storageRESTOrigVolume:       origvolume,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 08 02:38:41 GMT 2025
    - 30.4K bytes
    - Click Count (0)
  6. architecture/standards/0004-use-a-platform-architecture.md

    See the [discovery document](https://docs.google.com/document/d/1-oKG23gLdx2D2uJvzir31AhDFyqSf81LDESfKKCU28c/edit#heading=h.pps74pn68uvk) (internal document) for more context.
    
    ### Platforms
    
    The platforms and their architecture modules are:
    
    #### Core automation platform
    
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Mar 05 12:39:41 GMT 2026
    - 4.5K bytes
    - Click Count (0)
  7. cmd/bitrot-streaming.go

    		// Offset should always be aligned to b.shardSize
    		// Can never happen unless there are programmer bugs
    		return 0, errUnexpected
    	}
    	if b.rc == nil {
    		// For the first ReadAt() call we need to open the stream for reading.
    		b.currOffset = offset
    		streamOffset := (offset/b.shardSize)*int64(b.h.Size()) + offset
    		if len(b.data) == 0 && b.tillOffset != streamOffset {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jan 17 19:19:30 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/io/ByteSourceTest.java

        // Append 10 more bytes to the source.
        source.append(newPreFilledByteArray(5, 10));
    
        // The stream reports no bytes... importantly, it doesn't read the byte at index 5 when it
        // should be reading the byte at index 10.
        // We could use a custom InputStream instead to make the read start at index 10, but since this
        // is a racy situation anyway, this behavior seems reasonable.
        assertEquals(-1, in.read());
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 15.6K bytes
    - Click Count (0)
  9. src/test/java/jcifs/internal/smb2/tree/Smb2TreeConnectResponseTest.java

            assertEquals(0xFFFFFFFF, response.getCapabilities());
            assertEquals(0xFFFFFFFF, response.getMaximalAccess());
        }
    
        @Test
        @DisplayName("Should handle buffer too small for reading")
        void testBufferTooSmall() {
            // Given
            byte[] buffer = new byte[15]; // Too small for 16-byte structure
            SMBUtil.writeInt2(16, buffer, 0);
    
            // When & Then
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 19.3K bytes
    - Click Count (0)
  10. docs/de/docs/advanced/settings.md

    Dann können wir testen, ob das verwendet wird.
    
    ## Lesen einer `.env`-Datei { #reading-a-env-file }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 17:58:09 GMT 2026
    - 12.5K bytes
    - Click Count (0)
Back to Top