Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for bufwrt (1.76 sec)

  1. src/net/tcpsock_test.go

    		if err != nil {
    			t.Fatal(err)
    		}
    	})
    	if allocs > 0 {
    		t.Fatalf("got %v; want 0", allocs)
    	}
    
    	var bufwrt [128]byte
    	ch := make(chan bool)
    	defer close(ch)
    	go func() {
    		for <-ch {
    			_, err := server.Write(bufwrt[:])
    			errc <- err
    		}
    	}()
    	allocs = testing.AllocsPerRun(1000, func() {
    		ch <- true
    		if _, err = io.ReadFull(client, buf[:]); err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 20 06:04:31 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  2. src/internal/syscall/windows/net_windows.go

    //go:noescape
    func WSASendtoInet4(s syscall.Handle, bufs *syscall.WSABuf, bufcnt uint32, sent *uint32, flags uint32, to *syscall.SockaddrInet4, overlapped *syscall.Overlapped, croutine *byte) (err error)
    
    //go:linkname WSASendtoInet6 syscall.wsaSendtoInet6
    //go:noescape
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 07 16:46:10 UTC 2024
    - 1K bytes
    - Viewed (0)
  3. src/net/http/server.go

    func (c *conn) finalFlush() {
    	if c.bufr != nil {
    		// Steal the bufio.Reader (~4KB worth of memory) and its associated
    		// reader for a future connection.
    		putBufioReader(c.bufr)
    		c.bufr = nil
    	}
    
    	if c.bufw != nil {
    		c.bufw.Flush()
    		// Steal the bufio.Writer (~4KB worth of memory) and its associated
    		// writer for a future connection.
    		putBufioWriter(c.bufw)
    		c.bufw = nil
    	}
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 123.4K bytes
    - Viewed (0)
  4. src/cmd/link/internal/wasm/asm.go

    	"runtime.gcWriteBarrier5": {Results: []byte{I64}},                                     // -> bufptr
    	"runtime.gcWriteBarrier6": {Results: []byte{I64}},                                     // -> bufptr
    	"runtime.gcWriteBarrier7": {Results: []byte{I64}},                                     // -> bufptr
    	"runtime.gcWriteBarrier8": {Results: []byte{I64}},                                     // -> bufptr
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jan 22 16:17:48 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  5. src/syscall/syscall_openbsd.go

    	return -1, ENOSYS
    }
    
    func Getfsstat(buf []Statfs_t, flags int) (n int, err error) {
    	var bufptr *Statfs_t
    	var bufsize uintptr
    	if len(buf) > 0 {
    		bufptr = &buf[0]
    		bufsize = unsafe.Sizeof(Statfs_t{}) * uintptr(len(buf))
    	}
    	return getfsstat(bufptr, bufsize, flags)
    }
    
    /*
     * Exposed directly
     */
    //sys	Access(path string, mode uint32) (err error)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Nov 02 10:34:00 UTC 2023
    - 7K bytes
    - Viewed (0)
  6. src/net/http/cgi/child.go

    	if r.wroteCGIHeader {
    		return
    	}
    	r.wroteCGIHeader = true
    	fmt.Fprintf(r.bufw, "Status: %d %s\r\n", r.code, http.StatusText(r.code))
    	if _, hasType := r.header["Content-Type"]; !hasType {
    		r.header.Set("Content-Type", http.DetectContentType(p))
    	}
    	r.header.Write(r.bufw)
    	r.bufw.WriteString("\r\n")
    	r.bufw.Flush()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/upgrade.go

    	w.Header().Add(httpstream.HeaderUpgrade, HeaderSpdy31)
    	w.WriteHeader(http.StatusSwitchingProtocols)
    
    	conn, bufrw, err := hijacker.Hijack()
    	if err != nil {
    		runtime.HandleError(fmt.Errorf("unable to upgrade: error hijacking response: %v", err))
    		return nil
    	}
    
    	connWithBuf := &connWrapper{Conn: conn, bufReader: bufrw.Reader}
    	spdyConn, err := NewServerConnectionWithPings(connWithBuf, newStreamHandler, u.pingPeriod)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 28 08:02:09 UTC 2022
    - 4K bytes
    - Viewed (0)
  8. tensorflow/compiler/mlir/lite/sparsity/sparsify_model_test.cc

          "tensorflow/lite/testdata/sparse_tensor.bin");
      tflite::ModelT input_model;
      input_fbm->GetModel()->UnPackTo(&input_model);
    
      // Populate input metadata
      auto model_metadata_buffer = std::make_unique<tflite::BufferT>();
      model_metadata_buffer->data =
          std::vector<uint8_t>(expected_value.begin(), expected_value.end());
      input_model.buffers.push_back(std::move(model_metadata_buffer));
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Mon Jun 10 20:16:40 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  9. src/cmd/vendor/golang.org/x/sys/unix/syscall_openbsd.go

    	return -1, ENOSYS
    }
    
    func Getfsstat(buf []Statfs_t, flags int) (n int, err error) {
    	var bufptr *Statfs_t
    	var bufsize uintptr
    	if len(buf) > 0 {
    		bufptr = &buf[0]
    		bufsize = unsafe.Sizeof(Statfs_t{}) * uintptr(len(buf))
    	}
    	return getfsstat(bufptr, bufsize, flags)
    }
    
    //sysnb	getresuid(ruid *_C_int, euid *_C_int, suid *_C_int)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 29 21:28:33 UTC 2023
    - 11K bytes
    - Viewed (0)
  10. src/syscall/zsyscall_windows.go

    	if r1 == socket_error {
    		err = errnoErr(e1)
    	}
    	return
    }
    
    func WSARecv(s Handle, bufs *WSABuf, bufcnt uint32, recvd *uint32, flags *uint32, overlapped *Overlapped, croutine *byte) (err error) {
    	r1, _, e1 := Syscall9(procWSARecv.Addr(), 7, uintptr(s), uintptr(unsafe.Pointer(bufs)), uintptr(bufcnt), uintptr(unsafe.Pointer(recvd)), uintptr(unsafe.Pointer(flags)), uintptr(unsafe.Pointer(overlapped)), uintptr(unsafe.Pointer(croutine)), 0, 0)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Mar 21 11:49:46 UTC 2024
    - 56.3K bytes
    - Viewed (1)
Back to top