Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for TestHookDidWritev (0.58 sec)

  1. src/net/writev_test.go

    			})
    		}
    	}
    }
    
    func testBuffer_writeTo(t *testing.T, chunks int, useCopy bool) {
    	oldHook := poll.TestHookDidWritev
    	defer func() { poll.TestHookDidWritev = oldHook }()
    	var writeLog struct {
    		sync.Mutex
    		log []int
    	}
    	poll.TestHookDidWritev = func(size int) {
    		writeLog.Lock()
    		writeLog.log = append(writeLog.log, size)
    		writeLog.Unlock()
    	}
    	var want bytes.Buffer
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 5K bytes
    - Viewed (0)
  2. src/internal/poll/fd.go

    	for len(*v) > 0 {
    		ln0 := int64(len((*v)[0]))
    		if ln0 > n {
    			(*v)[0] = (*v)[0][n:]
    			return
    		}
    		n -= ln0
    		(*v)[0] = nil
    		*v = (*v)[1:]
    	}
    }
    
    // TestHookDidWritev is a hook for testing writev.
    var TestHookDidWritev = func(wrote int) {}
    
    // String is an internal string definition for methods/functions
    // that is not intended for use outside the standard libraries.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Nov 17 23:16:28 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  3. src/internal/poll/writev.go

    			fd.iovecs = new([]syscall.Iovec)
    		}
    		*fd.iovecs = iovecs // cache
    
    		var wrote uintptr
    		wrote, err = writev(fd.Sysfd, iovecs)
    		if wrote == ^uintptr(0) {
    			wrote = 0
    		}
    		TestHookDidWritev(int(wrote))
    		n += int64(wrote)
    		consume(v, int64(wrote))
    		clear(iovecs)
    		if err != nil {
    			if err == syscall.EINTR {
    				continue
    			}
    			if err == syscall.EAGAIN {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 27 18:23:49 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  4. src/internal/poll/fd_windows.go

    	}
    	o := &fd.wop
    	o.InitBufs(buf)
    	n, err := execIO(o, func(o *operation) error {
    		return syscall.WSASend(o.fd.Sysfd, &o.bufs[0], uint32(len(o.bufs)), &o.qty, 0, &o.o, nil)
    	})
    	o.ClearBufs()
    	TestHookDidWritev(n)
    	consume(buf, int64(n))
    	return int64(n), err
    }
    
    // WriteTo wraps the sendto network call.
    func (fd *FD) WriteTo(buf []byte, sa syscall.Sockaddr) (int, error) {
    	if err := fd.writeLock(); err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 31 16:50:42 UTC 2024
    - 34.1K bytes
    - Viewed (0)
Back to top