various bug fix for gun:grpc transport

infra/conf/transport_internet.go

@@ -336,6 +336,8 @@ func (p TransportProtocol) Build() (string, error) {
 		return "domainsocket", nil
 	case "quic":
 		return "quic", nil
+	case "gun":
+		return "gun", nil
 	default:
 		return "", newError("Config: unknown transport protocol: ", p)
 	}

main/distro/all/all.go

@@ -40,6 +40,7 @@ import (
 
 	// Transports
 	_ "github.com/v2fly/v2ray-core/v4/transport/internet/domainsocket"
+	_ "github.com/v2fly/v2ray-core/v4/transport/internet/grpc"
 	_ "github.com/v2fly/v2ray-core/v4/transport/internet/http"
 	_ "github.com/v2fly/v2ray-core/v4/transport/internet/kcp"
 	_ "github.com/v2fly/v2ray-core/v4/transport/internet/quic"

transport/internet/grpc/config.go

@@ -1,3 +1,14 @@
 package grpc
 
+import (
+	"github.com/v2fly/v2ray-core/v4/common"
+	"github.com/v2fly/v2ray-core/v4/transport/internet"
+)
+
 const protocolName = "gun"
+
+func init() {
+	common.Must(internet.RegisterProtocolConfigCreator(protocolName, func() interface{} {
+		return new(Config)
+	}))
+}

transport/internet/grpc/encoding/clientConn.go

@@ -26,9 +26,10 @@ func (s *ClientConn) Read(b []byte) (n int, err error) {
 	}
 	n, err = s.reader.Read(b)
 	if err == io.EOF {
-		return 0, nil
+		s.reader = nil
+		return n, nil
 	}
-	return 0, err
+	return n, err
 }
 
 func (s *ClientConn) Write(b []byte) (n int, err error) {

transport/internet/grpc/encoding/serverconn.go

@@ -26,9 +26,10 @@ func (s *ServerConn) Read(b []byte) (n int, err error) {
 	}
 	n, err = s.reader.Read(b)
 	if err == io.EOF {
-		return 0, nil
+		s.reader = nil
+		return n, nil
 	}
-	return 0, err
+	return n, err
 }
 
 func (s *ServerConn) Write(b []byte) (n int, err error) {
@@ -49,19 +50,23 @@ func (s ServerConn) LocalAddr() net.Addr {
 }
 
 func (s ServerConn) RemoteAddr() net.Addr {
-	panic("implement me")
+	newError("gun transport do not support get remote address").AtWarning().WriteToLog()
+	return &net.UnixAddr{
+		Name: "@placeholder",
+		Net:  "unix",
+	}
 }
 
 func (s ServerConn) SetDeadline(t time.Time) error {
-	panic("implement me")
+	return nil
 }
 
 func (s ServerConn) SetReadDeadline(t time.Time) error {
-	panic("implement me")
+	return nil
 }
 
 func (s ServerConn) SetWriteDeadline(t time.Time) error {
-	panic("implement me")
+	return nil
 }
 
 func NewServerConn(server GunService_TunServer, over context.CancelFunc) *ServerConn {