Use Background context for qstream and qsess

scionproto · Jan 20, 2020 · f549339 · f549339
1 parent 3b71373
commit f549339
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/go/examples/pingpong/pingpong.go b/go/examples/pingpong/pingpong.go
@@ -246,7 +246,7 @@ func (c *client) run() {
 		LogFatal("Unable to dial", "err", err)
 	}
 
-	qstream, err := c.qsess.OpenStreamSync(context.TODO())
+	qstream, err := c.qsess.OpenStreamSync(context.Background())
 	if err != nil {
 		LogFatal("quic OpenStream failed", "err", err)
 	}
@@ -372,7 +372,7 @@ func (s server) run() {
 	}
 	log.Info("Listening", "local", qsock.Addr())
 	for {
-		qsess, err := qsock.Accept(context.TODO())
+		qsess, err := qsock.Accept(context.Background())
 		if err != nil {
 			log.Error("Unable to accept quic session", "err", err)
 			// Accept failing means the socket is unusable.
@@ -388,7 +388,7 @@ func (s server) run() {
 
 func (s server) handleClient(qsess quic.Session) {
 	defer qsess.Close()
-	qstream, err := qsess.AcceptStream(context.TODO())
+	qstream, err := qsess.AcceptStream(context.Background())
 	if err != nil {
 		log.Error("Unable to accept quic stream", "err", err)
 		return

diff --git a/go/lib/infra/rpc/rpc.go b/go/lib/infra/rpc/rpc.go
@@ -63,7 +63,7 @@ func (s *Server) ListenAndServe() error {
 		return err
 	}
 	for {
-		session, err := s.listener.Accept(context.TODO())
+		session, err := s.listener.Accept(context.Background())
 		if err != nil {
 			if strings.Contains(err.Error(), "server closed") {
 				return err
@@ -105,7 +105,7 @@ func (s *Server) Close() error {
 }
 
 func (s *Server) handleQUICSession(session quic.Session) error {
-	stream, err := session.AcceptStream(context.TODO())
+	stream, err := session.AcceptStream(context.Background())
 	if err != nil {
 		return err
 	}