|
| 1 | +// Copyright 2021 ETH Zurich |
| 2 | +// |
| 3 | +// Licensed under the Apache License, Version 2.0 (the "License"); |
| 4 | +// you may not use this file except in compliance with the License. |
| 5 | +// You may obtain a copy of the License at |
| 6 | +// |
| 7 | +// http://www.apache.org/licenses/LICENSE-2.0 |
| 8 | +// |
| 9 | +// Unless required by applicable law or agreed to in writing, software |
| 10 | +// distributed under the License is distributed on an "AS IS" BASIS, |
| 11 | +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 12 | +// See the License for the specific language governing permissions and |
| 13 | +// limitations under the License. |
| 14 | + |
| 15 | +package main |
| 16 | + |
| 17 | +import ( |
| 18 | + "context" |
| 19 | + "crypto/tls" |
| 20 | + "errors" |
| 21 | + "flag" |
| 22 | + "fmt" |
| 23 | + "io/ioutil" |
| 24 | + "os" |
| 25 | + "time" |
| 26 | + |
| 27 | + "github.com/lucas-clemente/quic-go" |
| 28 | + "inet.af/netaddr" |
| 29 | + |
| 30 | + "github.com/netsec-ethz/scion-apps/pkg/pan" |
| 31 | + "github.com/netsec-ethz/scion-apps/pkg/quicutil" |
| 32 | +) |
| 33 | + |
| 34 | +func main() { |
| 35 | + var err error |
| 36 | + // get local and remote addresses from program arguments: |
| 37 | + var listen pan.IPPortValue |
| 38 | + flag.Var(&listen, "listen", "[Server] local IP:port to listen on") |
| 39 | + remoteAddr := flag.String("remote", "", "[Client] Remote (i.e. the server's) SCION Address (e.g. 17-ffaa:1:1,[127.0.0.1]:12345)") |
| 40 | + count := flag.Uint("count", 1, "[Client] Number of messages to send") |
| 41 | + flag.Parse() |
| 42 | + |
| 43 | + if (listen.Get().Port() > 0) == (len(*remoteAddr) > 0) { |
| 44 | + check(fmt.Errorf("Either specify -port for server or -remote for client")) |
| 45 | + } |
| 46 | + |
| 47 | + if listen.Get().Port() > 0 { |
| 48 | + err = runServer(listen.Get()) |
| 49 | + check(err) |
| 50 | + } else { |
| 51 | + err = runClient(*remoteAddr, int(*count)) |
| 52 | + check(err) |
| 53 | + } |
| 54 | +} |
| 55 | + |
| 56 | +func runServer(listen netaddr.IPPort) error { |
| 57 | + tlsCfg := &tls.Config{ |
| 58 | + Certificates: quicutil.MustGenerateSelfSignedCert(), |
| 59 | + NextProtos: []string{"hello-quic"}, |
| 60 | + } |
| 61 | + listener, err := pan.ListenQUIC(context.Background(), listen, nil, tlsCfg, nil) |
| 62 | + if err != nil { |
| 63 | + return err |
| 64 | + } |
| 65 | + defer listener.Close() |
| 66 | + fmt.Println(listener.Addr()) |
| 67 | + |
| 68 | + for { |
| 69 | + session, err := listener.Accept(context.Background()) |
| 70 | + if err != nil { |
| 71 | + return err |
| 72 | + } |
| 73 | + fmt.Println("New session", session.RemoteAddr()) |
| 74 | + go func() { |
| 75 | + err := workSession(session) |
| 76 | + if err != nil && !errors.Is(err, &quic.ApplicationError{}) { |
| 77 | + fmt.Println("Error in session", session.RemoteAddr(), err) |
| 78 | + } |
| 79 | + }() |
| 80 | + } |
| 81 | +} |
| 82 | + |
| 83 | +func workSession(session quic.Session) error { |
| 84 | + for { |
| 85 | + stream, err := session.AcceptStream(context.Background()) |
| 86 | + if err != nil { |
| 87 | + return err |
| 88 | + } |
| 89 | + defer stream.Close() |
| 90 | + data, err := ioutil.ReadAll(stream) |
| 91 | + if err != nil { |
| 92 | + return err |
| 93 | + } |
| 94 | + fmt.Printf("%s\n", data) |
| 95 | + _, err = stream.Write([]byte("gotcha: ")) |
| 96 | + _, err = stream.Write(data) |
| 97 | + if err != nil { |
| 98 | + return err |
| 99 | + } |
| 100 | + stream.Close() |
| 101 | + } |
| 102 | +} |
| 103 | + |
| 104 | +func runClient(address string, count int) error { |
| 105 | + addr, err := pan.ResolveUDPAddr(address) |
| 106 | + if err != nil { |
| 107 | + return err |
| 108 | + } |
| 109 | + tlsCfg := &tls.Config{ |
| 110 | + InsecureSkipVerify: true, |
| 111 | + NextProtos: []string{"hello-quic"}, |
| 112 | + } |
| 113 | + // Set Pinging Selector with active probing on two paths |
| 114 | + selector := &pan.PingingSelector{ |
| 115 | + Interval: 2 * time.Second, |
| 116 | + Timeout: time.Second, |
| 117 | + } |
| 118 | + selector.SetActive(2) |
| 119 | + session, err := pan.DialQUIC(context.Background(), netaddr.IPPort{}, addr, nil, selector, "", tlsCfg, nil) |
| 120 | + if err != nil { |
| 121 | + return err |
| 122 | + } |
| 123 | + for i := 0; i < count; i++ { |
| 124 | + stream, err := session.OpenStream() |
| 125 | + if err != nil { |
| 126 | + return err |
| 127 | + } |
| 128 | + _, err = stream.Write([]byte(fmt.Sprintf("hi dude, %d", i))) |
| 129 | + if err != nil { |
| 130 | + return err |
| 131 | + } |
| 132 | + stream.Close() |
| 133 | + reply, err := ioutil.ReadAll(stream) |
| 134 | + fmt.Printf("%s\n", reply) |
| 135 | + } |
| 136 | + session.CloseWithError(quic.ApplicationErrorCode(0), "") |
| 137 | + return nil |
| 138 | +} |
| 139 | + |
| 140 | +// Check just ensures the error is nil, or complains and quits |
| 141 | +func check(e error) { |
| 142 | + if e != nil { |
| 143 | + fmt.Fprintln(os.Stderr, "Fatal error:", e) |
| 144 | + os.Exit(1) |
| 145 | + } |
| 146 | +} |
0 commit comments