Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for data_buffer (0.09 sec)

  1. maven-compat/src/main/java/org/apache/maven/repository/ArtifactTransferEvent.java

            this.transferredBytes = transferredBytes;
        }
    
        public byte[] getDataBuffer() {
            return dataBuffer;
        }
    
        public void setDataBuffer(byte[] dataBuffer) {
            this.dataBuffer = dataBuffer;
        }
    
        public int getDataOffset() {
            return dataOffset;
        }
    
        public void setDataOffset(int dataOffset) {
    Registered: Wed Jun 12 09:55:16 UTC 2024
    - Last Modified: Wed Sep 06 08:39:32 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  2. pkg/probe/exec/exec.go

    // errors if any.
    func (pr execProber) Probe(e exec.Cmd) (probe.Result, string, error) {
    	var dataBuffer bytes.Buffer
    	writer := ioutils.LimitWriter(&dataBuffer, maxReadLength)
    
    	e.SetStderr(writer)
    	e.SetStdout(writer)
    	err := e.Start()
    	if err == nil {
    		err = e.Wait()
    	}
    	data := dataBuffer.Bytes()
    
    	klog.V(4).Infof("Exec probe response: %q", string(data))
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 08:58:18 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  3. pkg/kubelet/prober/prober_test.go

    		exec := prober.newExecInContainer(ctx, container, containerID, cmd, 0)
    
    		var dataBuffer bytes.Buffer
    		writer := ioutils.LimitWriter(&dataBuffer, int64(limit))
    		exec.SetStderr(writer)
    		exec.SetStdout(writer)
    		err := exec.Start()
    		if err == nil {
    			err = exec.Wait()
    		}
    		actualOutput := dataBuffer.Bytes()
    
    		if e, a := containerID, runner.ContainerID; e != a {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 07:17:35 UTC 2023
    - 9.7K bytes
    - Viewed (0)
Back to top