Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for bufwrt (2.15 sec)

  1. 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)
  2. src/net/http/example_test.go

    			return
    		}
    		conn, bufrw, err := hj.Hijack()
    		if err != nil {
    			http.Error(w, err.Error(), http.StatusInternalServerError)
    			return
    		}
    		// Don't forget to close the connection:
    		defer conn.Close()
    		bufrw.WriteString("Now we're speaking raw TCP. Say hi: ")
    		bufrw.Flush()
    		s, err := bufrw.ReadString('\n')
    		if err != nil {
    			log.Printf("error reading string: %v", err)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 19 16:12:45 UTC 2021
    - 5.4K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. src/net/http/internal/chunked_test.go

    	w.Write(b)
    	w.Write(c)
    	w.Close()
    
    	readBuf := make([]byte, len(a)+len(b)+len(c)+1)
    	byter := bytes.NewReader(buf.Bytes())
    	bufr := bufio.NewReader(byter)
    	mallocs := testing.AllocsPerRun(100, func() {
    		byter.Seek(0, io.SeekStart)
    		bufr.Reset(byter)
    		r := NewChunkedReader(bufr)
    		n, err := io.ReadFull(r, readBuf)
    		if n != len(readBuf)-1 {
    			t.Fatalf("read %d bytes; want %d", n, len(readBuf)-1)
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jan 04 20:45:19 UTC 2024
    - 8K bytes
    - Viewed (0)
  8. src/net/http/cgi/child_test.go

    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			var buf bytes.Buffer
    			resp := response{
    				req:    httptest.NewRequest("GET", "/", nil),
    				header: http.Header{},
    				bufw:   bufio.NewWriter(&buf),
    			}
    			n, err := resp.Write([]byte(tt.body))
    			if err != nil {
    				t.Errorf("Write: unexpected %v", err)
    			}
    			if want := len(tt.body); n != want {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 14 15:42:03 UTC 2020
    - 5.2K bytes
    - Viewed (0)
Back to top