Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for readHuff (0.11 sec)

  1. src/crypto/tls/quic.go

    	}
    	c.quic.readbuf = data
    	<-c.quic.signalc
    	_, ok := <-c.quic.blockedc
    	if ok {
    		// The handshake goroutine is waiting for more data.
    		return nil
    	}
    	// The handshake goroutine has exited.
    	c.handshakeMutex.Lock()
    	defer c.handshakeMutex.Unlock()
    	c.hand.Write(c.quic.readbuf)
    	c.quic.readbuf = nil
    	for q.conn.hand.Len() >= 4 && q.conn.handshakeErr == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 17:23:54 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  2. platforms/core-configuration/configuration-cache/src/test/kotlin/org/gradle/internal/cc/impl/serialization/codecs/JavaObjectSerializationCodecTest.kt

            }
    
            private
            fun readObject(objectInputStream: ObjectInputStream) {
                markRead("subclass")
                stringValue = objectInputStream.readUTF()
                writeOrder = objectInputStream.readObject().uncheckedCast()
            }
        }
    
        class SerializableRecursiveWriteReplaceBean(var value: Any? = null) : Serializable {
    
            @Suppress("unused")
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:25 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  3. src/compress/flate/flate_test.go

    		windowSize * 1, windowSize * 2, windowSize * 3,
    	}
    
    	var maxSize int
    	for _, n := range testSizes {
    		if maxSize < n {
    			maxSize = n
    		}
    	}
    
    	readBuf := make([]byte, 40)
    	data := make([]byte, maxSize)
    	for i := range data {
    		data[i] = byte(i)
    	}
    
    	for _, sz := range testSizes {
    		if testing.Short() && sz > windowSize {
    			continue
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 20 18:41:18 UTC 2020
    - 11K bytes
    - Viewed (1)
  4. internal/ringbuffer/ring_buffer_test.go

    	const debug = false
    
    	var readBytes int
    	var wroteBytes int
    	var readBuf bytes.Buffer
    	var wroteBuf bytes.Buffer
    	readHash := crc32.NewIEEE()
    	wroteHash := crc32.NewIEEE()
    	read := io.Writer(readHash)
    	wrote := io.Writer(wroteHash)
    	if debug {
    		read = io.MultiWriter(read, &readBuf)
    		wrote = io.MultiWriter(wrote, &wroteBuf)
    	}
    	debugln := func(args ...interface{}) {
    		if debug {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java

                }
            }
    
            if ((c == -1) && (input.length() == 0)) {
                return null;
            }
    
            return input.toString();
        }
    
        public final String readUTF() throws SmbException {
            int size = readUnsignedShort();
            byte[] b = new byte[size];
            read( b, 0, size );
            try {
                return Encdec.dec_utf8( b, 0, size );
    Registered: Wed Jun 12 15:45:55 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 10.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/io/ByteStreams.java

          try {
            return input.readLine();
          } catch (IOException e) {
            throw new IllegalStateException(e);
          }
        }
    
        @Override
        public String readUTF() {
          try {
            return input.readUTF();
          } catch (IOException e) {
            throw new IllegalStateException(e);
          }
        }
      }
    
      /** Returns a new {@link ByteArrayDataOutput} instance with a default size. */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Jan 17 18:59:58 UTC 2024
    - 29.7K bytes
    - Viewed (0)
  7. src/cmd/vendor/golang.org/x/term/terminal.go

    				err = ErrPasteIndicator
    			}
    			return
    		}
    
    		// t.remainder is a slice at the beginning of t.inBuf
    		// containing a partial key sequence
    		readBuf := t.inBuf[len(t.remainder):]
    		var n int
    
    		t.lock.Unlock()
    		n, err = t.c.Read(readBuf)
    		t.lock.Lock()
    
    		if err != nil {
    			return
    		}
    
    		t.remainder = t.inBuf[:n+len(t.remainder)]
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 22 17:16:14 UTC 2022
    - 22.5K bytes
    - Viewed (0)
  8. guava/src/com/google/common/io/ByteStreams.java

          try {
            return input.readLine();
          } catch (IOException e) {
            throw new IllegalStateException(e);
          }
        }
    
        @Override
        public String readUTF() {
          try {
            return input.readUTF();
          } catch (IOException e) {
            throw new IllegalStateException(e);
          }
        }
      }
    
      /** Returns a new {@link ByteArrayDataOutput} instance with a default size. */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Jan 17 18:59:58 UTC 2024
    - 29.7K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbRandomAccessFile.java

            }
    
            if ( ( c == -1 ) && ( input.length() == 0 ) ) {
                return null;
            }
    
            return input.toString();
        }
    
    
        @Override
        public final String readUTF () throws SmbException {
            int size = readUnsignedShort();
            byte[] b = new byte[size];
            read(b, 0, size);
            try {
                return Encdec.dec_utf8(b, 0, size);
            }
    Registered: Wed Jun 12 15:45:55 UTC 2024
    - Last Modified: Wed Jan 08 12:01:33 UTC 2020
    - 18.5K bytes
    - Viewed (1)
  10. android/guava-tests/test/com/google/common/io/ByteStreamsTest.java

        data[1] = 15;
        System.arraycopy("Kilroy was here".getBytes(Charsets.UTF_8), 0, data, 2, 15);
        ByteArrayDataInput in = ByteStreams.newDataInput(data);
        assertEquals("Kilroy was here", in.readUTF());
      }
    
      public void testNewDataInput_readChar() {
        byte[] data = "qed".getBytes(Charsets.UTF_16BE);
        ByteArrayDataInput in = ByteStreams.newDataInput(data);
        assertEquals('q', in.readChar());
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 21.9K bytes
    - Viewed (0)
Back to top