소스 검색

Wait for send to prevent race on control buffer

Armon Dadgar 10 년 전
부모
커밋
922f7ff3fb
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      stream.go

+ 1 - 1
stream.go

@@ -278,7 +278,7 @@ func (s *Stream) sendClose() error {
 	flags := s.sendFlags()
 	flags |= flagFIN
 	s.controlHdr.encode(typeWindowUpdate, flags, s.id, 0)
-	if err := s.session.sendNoWait(s.controlHdr); err != nil {
+	if err := s.session.waitForSendErr(s.controlHdr, nil, s.controlErr); err != nil {
 		return err
 	}
 	return nil