Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for setReadBuffer (0.29 sec)

  1. src/net/sockopt_fake.go

    	return nil
    }
    
    func setDefaultListenerSockopts(s int) error {
    	return nil
    }
    
    func setDefaultMulticastSockopts(s int) error {
    	return nil
    }
    
    func setReadBuffer(fd *netFD, bytes int) error {
    	if fd.fakeNetFD != nil {
    		return fd.fakeNetFD.setReadBuffer(bytes)
    	}
    	return syscall.ENOPROTOOPT
    }
    
    func setWriteBuffer(fd *netFD, bytes int) error {
    	if fd.fakeNetFD != nil {
    		return fd.fakeNetFD.setWriteBuffer(bytes)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 955 bytes
    - Viewed (0)
  2. src/net/protoconn_test.go

    	}
    	defer c.Close()
    	c.LocalAddr()
    	c.RemoteAddr()
    	c.SetDeadline(time.Now().Add(someTimeout))
    	c.SetReadDeadline(time.Now().Add(someTimeout))
    	c.SetWriteDeadline(time.Now().Add(someTimeout))
    	c.SetReadBuffer(2048)
    	c.SetWriteBuffer(2048)
    
    	wb := []byte("UDPCONN TEST")
    	rb := make([]byte, 128)
    	if _, err := c.WriteToUDP(wb, c.LocalAddr().(*UDPAddr)); err != nil {
    		t.Fatal(err)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 18 17:20:52 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  3. src/net/sockopt_posix.go

    				copy(mreq.Interface[:], a)
    				goto done
    			}
    		}
    	}
    done:
    	if bytealg.Equal(mreq.Multiaddr[:], IPv4zero.To4()) {
    		return errNoSuchMulticastInterface
    	}
    	return nil
    }
    
    func setReadBuffer(fd *netFD, bytes int) error {
    	err := fd.pfd.SetsockoptInt(syscall.SOL_SOCKET, syscall.SO_RCVBUF, bytes)
    	runtime.KeepAlive(fd)
    	return wrapSyscallError("setsockopt", err)
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Aug 25 15:06:47 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  4. src/net/net_fake.go

    		p.clear()
    		packetPool.Put(p)
    	} else {
    		p.bufOffset += n
    	}
    
    	return n, from, nil
    }
    
    // setReadBuffer sets a soft limit on the number of bytes available to read
    // from the pipe.
    func (pq *packetQueue) setReadBuffer(bytes int) error {
    	if bytes <= 0 {
    		return os.NewSyscallError("setReadBuffer", syscall.EINVAL)
    	}
    	q := pq.get() // Use the queue as a lock.
    	q.readBufferBytes = bytes
    	pq.put(q)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Feb 27 19:24:21 UTC 2024
    - 26.4K bytes
    - Viewed (0)
  5. src/net/fd_plan9.go

    	dfd, err := syscall.Dup(int(f.Fd()), -1)
    	if err != nil {
    		return nil, os.NewSyscallError("dup", err)
    	}
    	return os.NewFile(uintptr(dfd), s), nil
    }
    
    func setReadBuffer(fd *netFD, bytes int) error {
    	return syscall.EPLAN9
    }
    
    func setWriteBuffer(fd *netFD, bytes int) error {
    	return syscall.EPLAN9
    }
    
    func (fd *netFD) SetDeadline(t time.Time) error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 04 16:01:50 UTC 2018
    - 3.6K bytes
    - Viewed (0)
  6. src/net/net.go

    	}
    	return nil
    }
    
    // SetReadBuffer sets the size of the operating system's
    // receive buffer associated with the connection.
    func (c *conn) SetReadBuffer(bytes int) error {
    	if !c.ok() {
    		return syscall.EINVAL
    	}
    	if err := setReadBuffer(c.fd, bytes); err != nil {
    		return &OpError{Op: "set", Net: c.fd.net, Source: nil, Addr: c.fd.laddr, Err: err}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  7. src/cmd/vendor/golang.org/x/tools/internal/stdlib/manifest.go

    		{"(*IPConn).ReadFrom", Method, 0},
    		{"(*IPConn).ReadFromIP", Method, 0},
    		{"(*IPConn).ReadMsgIP", Method, 1},
    		{"(*IPConn).RemoteAddr", Method, 0},
    		{"(*IPConn).SetDeadline", Method, 0},
    		{"(*IPConn).SetReadBuffer", Method, 0},
    		{"(*IPConn).SetReadDeadline", Method, 0},
    		{"(*IPConn).SetWriteBuffer", Method, 0},
    		{"(*IPConn).SetWriteDeadline", Method, 0},
    		{"(*IPConn).SyscallConn", Method, 9},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 534.2K bytes
    - Viewed (0)
  8. api/go1.txt

    pkg net, method (*IPConn) ReadFromIP([]uint8) (int, *IPAddr, error)
    pkg net, method (*IPConn) RemoteAddr() Addr
    pkg net, method (*IPConn) SetDeadline(time.Time) error
    pkg net, method (*IPConn) SetReadBuffer(int) error
    pkg net, method (*IPConn) SetReadDeadline(time.Time) error
    pkg net, method (*IPConn) SetWriteBuffer(int) error
    pkg net, method (*IPConn) SetWriteDeadline(time.Time) error
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Aug 14 18:58:28 UTC 2013
    - 1.7M bytes
    - Viewed (0)
Back to top