From eea6b1fffd2f7ad299c34c6ecaa15f1aeb04fd69 Mon Sep 17 00:00:00 2001
From: Yoshida Hiroshi <yoshida@shiguredo.jp>
Date: Tue, 26 Nov 2024 16:10:16 +0900
Subject: [PATCH] =?UTF-8?q?context,=20cancel=20=E3=82=92=E5=88=86=E3=81=91?=
 =?UTF-8?q?=E3=82=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 handler.go | 16 +++++-----------
 1 file changed, 5 insertions(+), 11 deletions(-)

diff --git a/handler.go b/handler.go
index 822c56b..4bc7559 100644
--- a/handler.go
+++ b/handler.go
@@ -146,8 +146,8 @@ func (s *Server) createSpeechHandler(serviceType string, onResultFunc func(conte
 				Msg("NEW-REQUEST")
 
 			// リトライ時にこれ以降の処理のみを cancel する
-			ctx, cancel := context.WithCancel(ctx)
-			defer cancel()
+			ctx1, cancel1 := context.WithCancel(ctx)
+			defer cancel1()
 
 			reader, err := serviceHandler.Handle(ctx, r)
 			if err != nil {
@@ -162,11 +162,11 @@ func (s *Server) createSpeechHandler(serviceType string, onResultFunc func(conte
 							serviceHandler.UpdateRetryCount()
 
 							// 切断検知のために、クライアントから送られてくるパケットは受信し続ける
-							ctx, cancelPacketDiscard := context.WithCancel(ctx)
+							ctx2, cancelPacketDiscard := context.WithCancel(ctx1)
 							defer cancelPacketDiscard()
 
 							errCh := make(chan error)
-							go discardPacket(ctx, r, errCh)
+							go discardPacket(ctx2, r, errCh)
 
 							// 連続のリトライを避けるために少し待つ
 							retryTimer := time.NewTimer(time.Duration(s.config.RetryIntervalMs) * time.Millisecond)
@@ -248,13 +248,7 @@ func (s *Server) createSpeechHandler(serviceType string, onResultFunc func(conte
 							serviceHandler.UpdateRetryCount()
 
 							// TODO: 必要な場合は連続のリトライを避けるために少し待つ処理を追加する
-							zlog.Debug().Err(err).
-								Str("channel_id", h.SoraChannelID).
-								Str("connection_id", h.SoraConnectionID).
-								Int("retry_count", serviceHandler.GetRetryCount()).
-								Msg("RETRYING")
-
-							cancel()
+							cancel1()
 							break
 						} else {
 							zlog.Error().