type net.Conn
177 uses
net (current package)
dial.go#L469: func Dial(network, address string) (Conn, error) {
dial.go#L484: func DialTimeout(network, address string, timeout time.Duration) (Conn, error) {
dial.go#L503: func (d *Dialer) Dial(network, address string) (Conn, error) {
dial.go#L525: func (d *Dialer) DialContext(ctx context.Context, network, address string) (Conn, error) {
dial.go#L585: func (sd *sysDialer) dialParallel(ctx context.Context, primaries, fallbacks addrList) (Conn, error) {
dial.go#L594: Conn
dial.go#L659: func (sd *sysDialer) dialSerial(ctx context.Context, ras addrList) (Conn, error) {
dial.go#L703: func (sd *sysDialer) dialSingle(ctx context.Context, ra Addr) (c Conn, err error) {
dnsclient_unix.go#L109: func dnsPacketRoundTrip(c Conn, id uint16, query dnsmessage.Question, b []byte) (dnsmessage.Parser, dnsmessage.Header, error) {
dnsclient_unix.go#L136: func dnsStreamRoundTrip(c Conn, id uint16, query dnsmessage.Question, b []byte) (dnsmessage.Parser, dnsmessage.Header, error) {
file.go#L21: func FileConn(f *os.File) (c Conn, err error) {
file_unix.go#L70: func fileConn(f *os.File) (Conn, error) {
lookup.go#L160: Dial func(ctx context.Context, network, address string) (Conn, error)
lookup.go#L681: func (r *Resolver) dial(ctx context.Context, network, server string) (Conn, error) {
lookup.go#L687: var c Conn
net.go#L124: type Conn interface {
net.go#L409: Accept() (Conn, error)
pipe.go#L113: func Pipe() (Conn, Conn) {
tcpsock.go#L376: func (l *TCPListener) Accept() (Conn, error) {
unixsock.go#L256: func (l *UnixListener) Accept() (Conn, error) {
net/http
h2_bundle.go#L886: func (p *http2clientConnPool) addConnIfNeeded(key string, t *http2Transport, c net.Conn) (used bool, err error) {
h2_bundle.go#L922: func (c *http2addConnCall) run(t *http2Transport, key string, nc net.Conn) {
h2_bundle.go#L3736: conn net.Conn // immutable
h2_bundle.go#L3741: func http2newBufferedWriter(group http2synctestGroupInterface, conn net.Conn, timeout time.Duration) *http2bufferedWriter {
h2_bundle.go#L3800: func http2writeWithByteTimeout(group http2synctestGroupInterface, conn net.Conn, timeout time.Duration, p []byte) (n int, err error) {
h2_bundle.go#L4357: protoHandler := func(hs *Server, c net.Conn, h Handler, sawClientPreface bool) {
h2_bundle.go#L4472: func (s *http2Server) ServeConn(c net.Conn, opts *http2ServeConnOpts) {
h2_bundle.go#L4476: func (s *http2Server) serveConn(c net.Conn, opts *http2ServeConnOpts, newf func(*http2serverConn)) {
h2_bundle.go#L4617: func http2serverConnBaseContext(c net.Conn, opts *http2ServeConnOpts) (ctx context.Context, cancel func()) {
h2_bundle.go#L4638: conn net.Conn
h2_bundle.go#L7496: DialTLSContext func(ctx context.Context, network, addr string, cfg *tls.Config) (net.Conn, error)
h2_bundle.go#L7506: DialTLS func(network, addr string, cfg *tls.Config) (net.Conn, error)
h2_bundle.go#L7720: upgradeFn := func(scheme, authority string, c net.Conn) RoundTripper {
h2_bundle.go#L7780: tconn net.Conn // usually *tls.Conn, except specialized impls
h2_bundle.go#L7966: conn net.Conn
h2_bundle.go#L8205: func (t *http2Transport) dialTLS(ctx context.Context, network, addr string, tlsCfg *tls.Config) (net.Conn, error) {
h2_bundle.go#L8239: func (t *http2Transport) NewClientConn(c net.Conn) (*http2ClientConn, error) {
h2_bundle.go#L8243: func (t *http2Transport) newClientConn(c net.Conn, singleUse bool) (*http2ClientConn, error) {
h2_bundle.go#L10991: func http2unencryptedNetConnFromTLSConn(tc *tls.Conn) (net.Conn, error) {
h2_bundle.go#L10993: UnencryptedNetConn() net.Conn
responsecontroller.go#L66: func (c *ResponseController) Hijack() (net.Conn, *bufio.ReadWriter, error) {
server.go#L206: Hijack() (net.Conn, *bufio.ReadWriter, error)
server.go#L266: rwc net.Conn
server.go#L317: func (c *conn) hijackLocked() (rwc net.Conn, buf *bufio.ReadWriter, err error) {
server.go#L631: func (s *Server) newConn(rwc net.Conn) *conn {
server.go#L1873: func (c *conn) setState(nc net.Conn, state ConnState, runHook bool) {
server.go#L2151: c net.Conn
server.go#L2170: net.Conn // panic on all net.Conn methods
server.go#L2171: conn net.Conn
server.go#L2174: func (c unencryptedNetConnInTLSConn) UnencryptedNetConn() net.Conn {
server.go#L2178: func unencryptedTLSConn(c net.Conn) *tls.Conn {
server.go#L2229: func (w *response) Hijack() (rwc net.Conn, buf *bufio.ReadWriter, err error) {
server.go#L3028: ConnState func(net.Conn, ConnState)
server.go#L3048: ConnContext func(ctx context.Context, c net.Conn) context.Context
server.go#L3980: net.Conn
server.go#L3988: func newLoggingConn(baseName string, c net.Conn) net.Conn {
socks_bundle.go#L27: func (d *socksDialer) connect(ctx context.Context, c net.Conn, address string) (_ net.Addr, ctxErr error) {
socks_bundle.go#L262: net.Conn
socks_bundle.go#L284: ProxyDial func(context.Context, string, string) (net.Conn, error)
socks_bundle.go#L307: func (d *socksDialer) DialContext(ctx context.Context, network, address string) (net.Conn, error) {
socks_bundle.go#L317: var c net.Conn
socks_bundle.go#L343: func (d *socksDialer) DialWithConn(ctx context.Context, c net.Conn, network, address string) (net.Addr, error) {
socks_bundle.go#L366: func (d *socksDialer) Dial(network, address string) (net.Conn, error) {
socks_bundle.go#L372: var c net.Conn
transport.go#L143: DialContext func(ctx context.Context, network, addr string) (net.Conn, error)
transport.go#L155: Dial func(network, addr string) (net.Conn, error)
transport.go#L167: DialTLSContext func(ctx context.Context, network, addr string) (net.Conn, error)
transport.go#L175: DialTLS func(network, addr string) (net.Conn, error)
transport.go#L1276: func (t *Transport) dial(ctx context.Context, network, addr string) (net.Conn, error) {
transport.go#L1468: func (t *Transport) customDialTLS(ctx context.Context, network, addr string) (conn net.Conn, err error) {
transport.go#L2073: conn net.Conn
transport_default_other.go#L14: func defaultTransportDialContext(dialer *net.Dialer) func(context.Context, string, string) (net.Conn, error) {
net/http/httptrace
trace.go#L242: Conn net.Conn
net/http/httputil
dump.go#L119: Dial: func(net, addr string) (net.Conn, error) {
persist.go#L39: c net.Conn
persist.go#L54: func NewServerConn(c net.Conn, r *bufio.Reader) *ServerConn {
persist.go#L65: func (sc *ServerConn) Hijack() (net.Conn, *bufio.Reader) {
persist.go#L232: c net.Conn
persist.go#L248: func NewClientConn(c net.Conn, r *bufio.Reader) *ClientConn {
persist.go#L265: func NewProxyClientConn(c net.Conn, r *bufio.Reader) *ClientConn {
persist.go#L275: func (cc *ClientConn) Hijack() (c net.Conn, r *bufio.Reader) {
crypto/tls
common.go#L465: Conn net.Conn
conn.go#L30: conn net.Conn
conn.go#L165: func (c *Conn) NetConn() net.Conn {
conn.go#L578: Conn net.Conn
conn.go#L583: func (c *Conn) newRecordHeaderError(conn net.Conn, msg string) (err RecordHeaderError) {
tls.go#L35: func Server(conn net.Conn, config *Config) *Conn {
tls.go#L48: func Client(conn net.Conn, config *Config) *Conn {
tls.go#L66: func (l *listener) Accept() (net.Conn, error) {
tls.go#L198: func (d *Dialer) Dial(network, addr string) (net.Conn, error) {
tls.go#L218: func (d *Dialer) DialContext(ctx context.Context, network, addr string) (net.Conn, error) {
go.pact.im/x/httptrack
conn.go#L23: func (c *ConnTracker) Track(_ net.Conn, state http.ConnState) {
stats.go#L124: conns map[net.Conn]http.ConnState
stats.go#L134: func (s *StatsTracker) Track(conn net.Conn, state http.ConnState) {
stats.go#L149: s.conns = make(map[net.Conn]http.ConnState)
stats.go#L164: func (s *StatsTracker) Connections() map[net.Conn]http.ConnState {
stats.go#L170: var conns map[net.Conn]http.ConnState
tracker.go#L12: Track(net.Conn, http.ConnState)
tracker.go#L18: type TrackerFunc func(net.Conn, http.ConnState)
tracker.go#L21: func (f TrackerFunc) Track(conn net.Conn, state http.ConnState) {
tracker.go#L33: return func(conn net.Conn, state http.ConnState) {
go.pact.im/x/netchan
netchan.go#L36: conn chan net.Conn
netchan.go#L51: conn: make(chan net.Conn),
netchan.go#L58: func (l *Listener) Accept() (net.Conn, error) {
netchan.go#L100: func (l *Listener) C() chan net.Conn {
netchan.go#L117: func (l *Listener) Dial(ctx context.Context) (net.Conn, error) {
golang.org/x/net/http2
client_conn_pool.go#L161: func (p *clientConnPool) addConnIfNeeded(key string, t *Transport, c net.Conn) (used bool, err error) {
client_conn_pool.go#L197: func (c *addConnCall) run(t *Transport, key string, nc net.Conn) {
http2.go#L259: conn net.Conn // immutable
http2.go#L264: func newBufferedWriter(group synctestGroupInterface, conn net.Conn, timeout time.Duration) *bufferedWriter {
http2.go#L323: func writeWithByteTimeout(group synctestGroupInterface, conn net.Conn, timeout time.Duration, p []byte) (n int, err error) {
server.go#L310: protoHandler := func(hs *http.Server, c net.Conn, h http.Handler, sawClientPreface bool) {
server.go#L425: func (s *Server) ServeConn(c net.Conn, opts *ServeConnOpts) {
server.go#L429: func (s *Server) serveConn(c net.Conn, opts *ServeConnOpts, newf func(*serverConn)) {
server.go#L570: func serverConnBaseContext(c net.Conn, opts *ServeConnOpts) (ctx context.Context, cancel func()) {
server.go#L591: conn net.Conn
transport.go#L74: DialTLSContext func(ctx context.Context, network, addr string, cfg *tls.Config) (net.Conn, error)
transport.go#L84: DialTLS func(network, addr string, cfg *tls.Config) (net.Conn, error)
transport.go#L298: upgradeFn := func(scheme, authority string, c net.Conn) http.RoundTripper {
transport.go#L358: tconn net.Conn // usually *tls.Conn, except specialized impls
transport.go#L545: conn net.Conn
transport.go#L783: func (t *Transport) dialTLS(ctx context.Context, network, addr string, tlsCfg *tls.Config) (net.Conn, error) {
transport.go#L817: func (t *Transport) NewClientConn(c net.Conn) (*ClientConn, error) {
transport.go#L821: func (t *Transport) newClientConn(c net.Conn, singleUse bool) (*ClientConn, error) {
unencrypted.go#L24: func unencryptedNetConnFromTLSConn(tc *tls.Conn) (net.Conn, error) {
unencrypted.go#L26: UnencryptedNetConn() net.Conn
google.golang.org/grpc
dialoptions.go#L484: func WithContextDialer(f func(context.Context, string) (net.Conn, error)) DialOption {
dialoptions.go#L497: func WithDialer(f func(string, time.Duration) (net.Conn, error)) DialOption {
dialoptions.go#L499: func(ctx context.Context, addr string) (net.Conn, error) {
server.go#L965: func (s *Server) handleRawConn(lisAddr string, rawConn net.Conn) {
server.go#L996: func (s *Server) newHTTP2Transport(c net.Conn) transport.ServerTransport {
server.go#L1036: func (s *Server) serveStreams(ctx context.Context, st transport.ServerTransport, rawConn net.Conn) {
google.golang.org/grpc/balancer
balancer.go#L203: Dialer func(context.Context, string) (net.Conn, error)
google.golang.org/grpc/credentials
credentials.go#L173: ClientHandshake(context.Context, string, net.Conn) (net.Conn, AuthInfo, error)
credentials.go#L180: ServerHandshake(net.Conn) (net.Conn, AuthInfo, error)
tls.go#L110: func (c *tlsCreds) ClientHandshake(ctx context.Context, authority string, rawConn net.Conn) (_ net.Conn, _ AuthInfo, err error) {
tls.go#L166: func (c *tlsCreds) ServerHandshake(rawConn net.Conn) (net.Conn, AuthInfo, error) {
google.golang.org/grpc/credentials/insecure
insecure.go#L43: func (insecureTC) ClientHandshake(_ context.Context, _ string, conn net.Conn) (net.Conn, credentials.AuthInfo, error) {
insecure.go#L47: func (insecureTC) ServerHandshake(conn net.Conn) (net.Conn, credentials.AuthInfo, error) {
google.golang.org/grpc/internal/credentials
syscallconn.go#L38: net.Conn
syscallconn.go#L49: func WrapSyscallConn(rawConn, newConn net.Conn) net.Conn {
google.golang.org/grpc/internal/resolver/dns
dns_resolver.go#L85: var addressDialer = func(address string) func(context.Context, string, string) (net.Conn, error) {
dns_resolver.go#L86: return func(ctx context.Context, network, _ string) (net.Conn, error) {
google.golang.org/grpc/internal/resolver/dns/internal
internal.go#L76: AddressDialer func(address string) func(context.Context, string, string) (net.Conn, error)
google.golang.org/grpc/internal/syscall
syscall_linux.go#L71: func SetTCPUserTimeout(conn net.Conn, timeout time.Duration) error {
syscall_linux.go#L92: func GetTCPUserTimeout(conn net.Conn) (opt int, err error) {
google.golang.org/grpc/internal/transport
controlbuf.go#L527: conn net.Conn
controlbuf.go#L535: func newLoopyWriter(s side, fr *framer, cbuf *controlBuffer, bdpEst *bdpEstimator, conn net.Conn, logger *grpclog.PrefixLogger, goAwayHandler func(*goAway) (bool, error), bufferPool mem.BufferPool) *loopyWriter {
http2_client.go#L80: conn net.Conn // underlying communication channel
http2_client.go#L157: func dial(ctx context.Context, fn func(context.Context, string) (net.Conn, error), addr resolver.Address, grpcUA string) (net.Conn, error) {
http2_client.go#L230: defer func(conn net.Conn) {
http2_client.go#L248: go func(conn net.Conn) {
http2_server.go#L76: conn net.Conn
http2_server.go#L148: func NewServerTransport(conn net.Conn, config *ServerConfig) (_ ServerTransport, err error) {
http2_server.go#L1498: func GetConnection(ctx context.Context) net.Conn {
http2_server.go#L1499: conn, _ := ctx.Value(connectionKey{}).(net.Conn)
http2_server.go#L1506: func SetConnection(ctx context.Context, conn net.Conn) context.Context {
http_util.go#L303: conn net.Conn
http_util.go#L307: func newBufWriter(conn net.Conn, batchSize int, pool *sync.Pool) *bufWriter {
http_util.go#L399: func newFramer(conn net.Conn, writeBufferSize, readBufferSize int, sharedWriteBuffer bool, maxHeaderListSize uint32) *framer {
proxy.go#L44: net.Conn
proxy.go#L57: func doHTTPConnectHandshake(ctx context.Context, conn net.Conn, grpcUA string, opts proxyattributes.Options) (_ net.Conn, err error) {
proxy.go#L102: func proxyDial(ctx context.Context, addr resolver.Address, grpcUA string, opts proxyattributes.Options) (net.Conn, error) {
proxy.go#L110: func sendHTTPRequest(ctx context.Context, req *http.Request, conn net.Conn) error {
transport.go#L477: Dialer func(context.Context, string) (net.Conn, error)
google.golang.org/grpc/resolver
resolver.go#L175: Dialer func(context.Context, string) (net.Conn, error)