Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 842 for buffers (0.04 sec)

  1. cni/pkg/util/executil.go

    	return &ExecList{
    		Cmd:  cmd,
    		Args: args,
    	}
    }
    
    func ExecuteOutput(cmd string, args ...string) (string, error) {
    	externalCommand := exec.Command(cmd, args...)
    	stdout := &bytes.Buffer{}
    	stderr := &bytes.Buffer{}
    	externalCommand.Stdout = stdout
    	externalCommand.Stderr = stderr
    
    	err := externalCommand.Run()
    
    	if err != nil || len(stderr.Bytes()) != 0 {
    		return stderr.String(), err
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/Queues.java

      @J2ktIncompatible
      @GwtIncompatible // BlockingQueue
      public static <E> int drain(
          BlockingQueue<E> q, Collection<? super E> buffer, int numElements, Duration timeout)
          throws InterruptedException {
        // TODO(b/126049426): Consider using saturateToNanos(timeout) instead.
        return drain(q, buffer, numElements, timeout.toNanos(), NANOSECONDS);
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  3. internal/s3select/jstream/scanner.go

    	nullByte = byte(0)
    )
    
    type scanner struct {
    	pos       int64 // position in reader
    	ipos      int64 // internal buffer position
    	ifill     int64 // internal buffer fill
    	end       int64
    	buf       [chunk + 1]byte // internal buffer (with a lookback size of 1)
    	nbuf      [chunk]byte     // next internal buffer
    	fillReq   chan struct{}
    	fillReady chan int64
    	readerErr error // underlying reader error, if any
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  4. src/archive/zip/writer_test.go

    		testReadFile(t, r.File[i], &wt)
    	}
    }
    
    func TestWriterFlush(t *testing.T) {
    	var buf bytes.Buffer
    	w := NewWriter(struct{ io.Writer }{&buf})
    	_, err := w.Create("foo")
    	if err != nil {
    		t.Fatal(err)
    	}
    	if buf.Len() > 0 {
    		t.Fatalf("Unexpected %d bytes already in buffer", buf.Len())
    	}
    	if err := w.Flush(); err != nil {
    		t.Fatal(err)
    	}
    	if buf.Len() == 0 {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/fscc/FileBothDirectoryInfo.java

            bufferIndex += 8;
            this.lastWriteTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            this.changeTime = SMBUtil.readTime(buffer, bufferIndex);
            bufferIndex += 8;
            this.endOfFile = SMBUtil.readInt8(buffer, bufferIndex);
            bufferIndex += 8;
            this.allocationSize = SMBUtil.readInt8(buffer, bufferIndex);
            bufferIndex += 8;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 5.6K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/ws/MessageDeflater.kt

      private val deflaterSink = DeflaterSink(deflatedBytes, deflater)
    
      /** Deflates [buffer] in place as described in RFC 7692 section 7.2.1. */
      @Throws(IOException::class)
      fun deflate(buffer: Buffer) {
        require(deflatedBytes.size == 0L)
    
        if (noContextTakeover) {
          deflater.reset()
        }
    
        deflaterSink.write(buffer, buffer.size)
        deflaterSink.flush()
    
        if (deflatedBytes.endsWith(EMPTY_DEFLATE_BLOCK)) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  7. src/main/java/jcifs/internal/smb2/notify/Smb2ChangeNotifyResponse.java

        protected int readBytesWireFormat ( byte[] buffer, int bufferIndex ) throws SMBProtocolDecodingException {
            int start = bufferIndex;
    
            int structureSize = SMBUtil.readInt2(buffer, bufferIndex);
            if ( structureSize != 9 ) {
                throw new SMBProtocolDecodingException("Expected structureSize = 9");
            }
    
            int bufferOffset = SMBUtil.readInt2(buffer, bufferIndex + 2) + getHeaderStart();
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 05 07:13:17 UTC 2018
    - 3.6K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/fscc/FileStandardInfo.java

         */
        @Override
        public int decode ( byte[] buffer, int bufferIndex, int len ) throws SMBProtocolDecodingException {
            int start = bufferIndex;
            this.allocationSize = SMBUtil.readInt8(buffer, bufferIndex);
            bufferIndex += 8;
            this.endOfFile = SMBUtil.readInt8(buffer, bufferIndex);
            bufferIndex += 8;
            this.numberOfLinks = SMBUtil.readInt4(buffer, bufferIndex);
            bufferIndex += 4;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 3.3K bytes
    - Viewed (0)
  9. guava/src/com/google/common/io/Java8Compatibility.java

    import java.nio.Buffer;
    
    /**
     * Wrappers around {@link Buffer} methods that are covariantly overridden in Java 9+. See
     * https://github.com/google/guava/issues/3990
     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    final class Java8Compatibility {
      static void clear(Buffer b) {
        b.clear();
      }
    
      static void flip(Buffer b) {
        b.flip();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 28 20:13:02 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  10. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt

        mockResponse.headers = headersOf()
        mockResponse.trailers = headersOf()
        mockResponse = mockResponse.removeHeader("")
        var body: Buffer? = mockResponse.getBody()
        mockResponse = mockResponse.setBody(Buffer())
        mockResponse = mockResponse.setChunkedBody(Buffer(), 0)
        mockResponse = mockResponse.setChunkedBody("", 0)
        var socketPolicy: SocketPolicy = mockResponse.socketPolicy
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.3K bytes
    - Viewed (0)
Back to top