Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 680 for Written (0.18 sec)

  1. src/cmd/internal/pgo/serialize.go

    		written += int64(n)
    		if err != nil {
    			return written, err
    		}
    
    		n, err = fmt.Fprintf(bw, "%d %d\n", edge.CallSiteOffset, weight)
    		written += int64(n)
    		if err != nil {
    			return written, err
    		}
    	}
    
    	if err := bw.Flush(); err != nil {
    		return written, err
    	}
    
    	// No need to serialize TotalWeight, it can be trivially recomputed
    	// during parsing.
    
    	return written, nil
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 27 20:20:01 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go

    	expectedStatusCode := 201
    	assert.False(t, trw.written, "Written field originally false in delegate response writer")
    	trw.WriteHeader(expectedStatusCode)
    	assert.Equal(t, expectedStatusCode, trw.w.(*mockResponseWriter).statusCode, "Expected written status code is correct")
    	assert.True(t, trw.written, "Written field set to true after writing delegate response writer")
    	// Response writer already written to does not write status.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 02:21:50 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  3. platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/Decoder.java

         */
        void skipBytes(long count) throws EOFException, IOException;
    
        /**
         * Reads a byte stream written using {@link Encoder#encodeChunked(Encoder.EncodeAction)}.
         */
        <T> T decodeChunked(DecodeAction<Decoder, T> decodeAction) throws EOFException, Exception;
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 15 16:06:56 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  4. src/net/splice_linux.go

    		s = v.fd
    	case *UnixConn:
    		if v.fd.net != "unix" {
    			return 0, nil, false
    		}
    		s = v.fd
    	default:
    		return 0, nil, false
    	}
    
    	written, handled, err = pollSplice(&c.pfd, &s.pfd, remain)
    	if lr != nil {
    		lr.N -= written
    	}
    	return written, wrapSyscallError("splice", err), handled
    }
    
    // spliceTo transfers data from c to w using the splice system call to minimize
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 21:49:26 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  5. src/internal/poll/sendfile_windows.go

    package poll
    
    import (
    	"io"
    	"syscall"
    )
    
    // SendFile wraps the TransmitFile call.
    func SendFile(fd *FD, src syscall.Handle, n int64) (written int64, err error) {
    	defer func() {
    		TestHookDidSendFile(fd, 0, written, err, written > 0)
    	}()
    	if fd.kind == kindPipe {
    		// TransmitFile does not work with pipes
    		return 0, syscall.ESPIPE
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 18:12:56 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  6. src/os/zero_copy_linux.go

    	if pfd == nil || !pfd.IsStream {
    		return
    	}
    
    	written, handled, err = pollSplice(&f.pfd, pfd, remain)
    
    	if lr != nil {
    		lr.N = remain - written
    	}
    
    	return written, handled, wrapSyscallError("splice", err)
    }
    
    func (f *File) copyFileRange(r io.Reader) (written int64, handled bool, err error) {
    	var (
    		remain int64
    		lr     *io.LimitedReader
    	)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 18:12:56 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  7. src/internal/poll/copy_file_range_linux.go

    				if written == 0 {
    					return 0, false, nil
    				}
    				// Otherwise src is at EOF, which means
    				// we are done.
    				return written, true, nil
    			}
    			remain -= n
    			written += n
    		default:
    			return written, true, err
    		}
    	}
    	return written, true, nil
    }
    
    // copyFileRange performs one round of copy_file_range(2).
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 04 17:40:10 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. src/internal/poll/sendfile_linux.go

    // at a time.
    const maxSendfileSize int = 4 << 20
    
    // SendFile wraps the sendfile system call.
    func SendFile(dstFD *FD, src int, remain int64) (written int64, err error, handled bool) {
    	defer func() {
    		TestHookDidSendFile(dstFD, src, written, err, handled)
    	}()
    	if err := dstFD.writeLock(); err != nil {
    		return 0, err, false
    	}
    	defer dstFD.writeUnlock()
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 18:12:56 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  9. internal/ioutil/ioutil_test.go

    	defer ODirectPoolSmall.Put(bufp)
    
    	written, err := CopyAligned(f, io.LimitReader(r, 5), *bufp, r.Size(), f)
    	if !errors.Is(err, io.ErrUnexpectedEOF) {
    		t.Errorf("Expected io.ErrUnexpectedEOF, but got %v", err)
    	}
    	if written != 5 {
    		t.Errorf("Expected written to be '5', but got %v", written)
    	}
    
    	f.Seek(0, io.SeekStart)
    	r.Seek(0, io.SeekStart)
    
    	written, err = CopyAligned(f, r, *bufp, r.Size(), f)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. src/net/sendfile_unix_alt.go

    	var werr error
    	err = sc.Read(func(fd uintptr) bool {
    		written, werr, handled = poll.SendFile(&c.pfd, int(fd), pos, remain)
    		return true
    	})
    	if err == nil {
    		err = werr
    	}
    
    	if lr != nil {
    		lr.N = remain - written
    	}
    
    	_, err1 := f.Seek(written, io.SeekCurrent)
    	if err1 != nil && err == nil {
    		return written, err1, handled
    	}
    
    	return written, wrapSyscallError("sendfile", err), handled
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 18:12:56 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top