123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185 |
- // Copyright 2016 fatedier, fatedier@gmail.com
- //
- // Licensed under the Apache License, Version 2.0 (the "License");
- // you may not use this file except in compliance with the License.
- // You may obtain a copy of the License at
- //
- // http://www.apache.org/licenses/LICENSE-2.0
- //
- // Unless required by applicable law or agreed to in writing, software
- // distributed under the License is distributed on an "AS IS" BASIS,
- // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- // See the License for the specific language governing permissions and
- // limitations under the License.
- package net
- import (
- "context"
- "errors"
- "io"
- "net"
- "sync/atomic"
- "time"
- "github.com/fatedier/frp/pkg/util/xlog"
- )
- type ContextGetter interface {
- Context() context.Context
- }
- type ContextSetter interface {
- WithContext(ctx context.Context)
- }
- func NewLogFromConn(conn net.Conn) *xlog.Logger {
- if c, ok := conn.(ContextGetter); ok {
- return xlog.FromContextSafe(c.Context())
- }
- return xlog.New()
- }
- func NewContextFromConn(conn net.Conn) context.Context {
- if c, ok := conn.(ContextGetter); ok {
- return c.Context()
- }
- return context.Background()
- }
- // ContextConn is the connection with context
- type ContextConn struct {
- net.Conn
- ctx context.Context
- }
- func NewContextConn(ctx context.Context, c net.Conn) *ContextConn {
- return &ContextConn{
- Conn: c,
- ctx: ctx,
- }
- }
- func (c *ContextConn) WithContext(ctx context.Context) {
- c.ctx = ctx
- }
- func (c *ContextConn) Context() context.Context {
- return c.ctx
- }
- type WrapReadWriteCloserConn struct {
- io.ReadWriteCloser
- underConn net.Conn
- }
- func WrapReadWriteCloserToConn(rwc io.ReadWriteCloser, underConn net.Conn) net.Conn {
- return &WrapReadWriteCloserConn{
- ReadWriteCloser: rwc,
- underConn: underConn,
- }
- }
- func (conn *WrapReadWriteCloserConn) LocalAddr() net.Addr {
- if conn.underConn != nil {
- return conn.underConn.LocalAddr()
- }
- return (*net.TCPAddr)(nil)
- }
- func (conn *WrapReadWriteCloserConn) RemoteAddr() net.Addr {
- if conn.underConn != nil {
- return conn.underConn.RemoteAddr()
- }
- return (*net.TCPAddr)(nil)
- }
- func (conn *WrapReadWriteCloserConn) SetDeadline(t time.Time) error {
- if conn.underConn != nil {
- return conn.underConn.SetDeadline(t)
- }
- return &net.OpError{Op: "set", Net: "wrap", Source: nil, Addr: nil, Err: errors.New("deadline not supported")}
- }
- func (conn *WrapReadWriteCloserConn) SetReadDeadline(t time.Time) error {
- if conn.underConn != nil {
- return conn.underConn.SetReadDeadline(t)
- }
- return &net.OpError{Op: "set", Net: "wrap", Source: nil, Addr: nil, Err: errors.New("deadline not supported")}
- }
- func (conn *WrapReadWriteCloserConn) SetWriteDeadline(t time.Time) error {
- if conn.underConn != nil {
- return conn.underConn.SetWriteDeadline(t)
- }
- return &net.OpError{Op: "set", Net: "wrap", Source: nil, Addr: nil, Err: errors.New("deadline not supported")}
- }
- type CloseNotifyConn struct {
- net.Conn
- // 1 means closed
- closeFlag int32
- closeFn func()
- }
- // closeFn will be only called once
- func WrapCloseNotifyConn(c net.Conn, closeFn func()) net.Conn {
- return &CloseNotifyConn{
- Conn: c,
- closeFn: closeFn,
- }
- }
- func (cc *CloseNotifyConn) Close() (err error) {
- pflag := atomic.SwapInt32(&cc.closeFlag, 1)
- if pflag == 0 {
- err = cc.Close()
- if cc.closeFn != nil {
- cc.closeFn()
- }
- }
- return
- }
- type StatsConn struct {
- net.Conn
- closed int64 // 1 means closed
- totalRead int64
- totalWrite int64
- statsFunc func(totalRead, totalWrite int64)
- }
- func WrapStatsConn(conn net.Conn, statsFunc func(total, totalWrite int64)) *StatsConn {
- return &StatsConn{
- Conn: conn,
- statsFunc: statsFunc,
- }
- }
- func (statsConn *StatsConn) Read(p []byte) (n int, err error) {
- n, err = statsConn.Conn.Read(p)
- statsConn.totalRead += int64(n)
- return
- }
- func (statsConn *StatsConn) Write(p []byte) (n int, err error) {
- n, err = statsConn.Conn.Write(p)
- statsConn.totalWrite += int64(n)
- return
- }
- func (statsConn *StatsConn) Close() (err error) {
- old := atomic.SwapInt64(&statsConn.closed, 1)
- if old != 1 {
- err = statsConn.Conn.Close()
- if statsConn.statsFunc != nil {
- statsConn.statsFunc(statsConn.totalRead, statsConn.totalWrite)
- }
- }
- return
- }
|