]> 127.0.0.1 Git - forward/.git/commitdiff
1 main origin/HEAD origin/main
authorqydysky <qydysky@foxmail.com>
Sun, 20 Apr 2025 07:21:30 +0000 (15:21 +0800)
committerqydysky <qydysky@foxmail.com>
Sun, 20 Apr 2025 07:21:30 +0000 (15:21 +0800)
main_test.go

index 20e8ad894d7a80b0d08bb1e5f5447c538030ceef..1039abfbb4db34af9eb1ac8273411543bcffb79b 100755 (executable)
@@ -4,13 +4,10 @@ import (
        "bufio"
        "bytes"
        "context"
-       "crypto/rand"
        "errors"
        "net"
        "testing"
        "time"
-
-       "github.com/qydysky/part"
 )
 
 func Test(t *testing.T) {
@@ -84,9 +81,9 @@ func Test(t *testing.T) {
        // if e := udp2tcpSer("127.0.0.1:20006", "127.0.0.1:20007"); e != nil {
        //      t.Fatal(e)
        // }
-       if e := u2t2u("127.0.0.1:20014", "127.0.0.1:20013"); e != nil {
-               t.Fatal(e)
-       }
+       // if e := u2t2u("127.0.0.1:20014", "127.0.0.1:20013"); e != nil {
+       //      t.Fatal(e)
+       // }
        cancle()
        wait()
 }
@@ -386,71 +383,72 @@ func udpSer(lis, to string) error {
 //     }
 // }
 
-func genData(size int) []byte {
-       data := make([]byte, size)
-       if _, e := rand.Read(data); e != nil {
-               panic(e)
-       }
-       data = bytes.ReplaceAll(data, []byte{'\n'}, []byte{' '})
-       data[size-1] = '\n'
-       return data
-}
+// func genData(size int) []byte {
+//     data := make([]byte, size)
+//     if _, e := rand.Read(data); e != nil {
+//             panic(e)
+//     }
+//     data = bytes.ReplaceAll(data, []byte{'\n'}, []byte{' '})
+//     data[size-1] = '\n'
+//     return data
+// }
 
-func u2t2u(lis, to string) error {
-       ec := make(chan error, 10)
-       {
-               listener, err := part.NewUdpListener("udp", to)
+// func u2t2u(lis, to string) error {
+//     ec := make(chan error, 10)
+//     {
+//             listener, err := part.NewUdpListener("udp", to)
 
-               if err != nil {
-                       return err
-               }
+//             if err != nil {
+//                     return err
+//             }
 
-               defer listener.Close()
+//             defer listener.Close()
 
-               go func() {
-                       conn, err := listener.Accept()
-                       if err != nil {
-                               ec <- err
-                               return
-                       }
+//             go func() {
+//                     conn, err := listener.Accept()
+//                     if err != nil {
+//                             ec <- err
+//                             return
+//                     }
 
-                       data := make([]byte, 10000)
-                       n, err := conn.Read(data)
-                       if err != nil {
-                               ec <- err
-                       } else {
-                               _, err := conn.Write(data[:n])
-                               if err != nil {
-                                       ec <- err
-                               }
-                       }
-               }()
-       }
+//                     data := make([]byte, 10000)
+//                     n, err := conn.Read(data)
+//                     if err != nil {
+//                             ec <- err
+//                     } else {
+//                             _, err := conn.Write(data[:n])
+//                             if err != nil {
+//                                     ec <- err
+//                             }
+//                     }
+//             }()
+//     }
 
-       conn1, err := net.Dial("udp", lis)
+//     conn1, err := net.Dial("udp", lis)
 
-       if err != nil {
-               return err
-       }
+//     if err != nil {
+//             return err
+//     }
 
-       size := 8888
-       data := genData(size)
+//     size := 8888
+//     data := genData(size)
 
-       if n, err := conn1.Write(data); err != nil || n != size {
-               return err
-       }
+//     if n, err := conn1.Write(data); err != nil || n != size {
+//             return err
+//     }
 
-       // Read from the connection untill a new line is send
-       buf2 := make([]byte, 10000)
-       n, _ := conn1.Read(buf2)
-       if !bytes.Equal(data, buf2[:n]) {
-               return errors.New("no match")
-       }
+//     // Read from the connection untill a new line is send
+//     buf2 := make([]byte, 10000)
+//     n, e := conn1.Read(buf2)
+//     if !bytes.Equal(data, buf2[:n]) {
+//             fmt.Println(e)
+//             return errors.New("no match1")
+//     }
 
-       select {
-       case err := <-ec:
-               return err
-       default:
-               return nil
-       }
-}
+//     select {
+//     case err := <-ec:
+//             return err
+//     default:
+//             return nil
+//     }
+// }