gr1ffon/quic-go
1
0
Fork 0
forked from quic-go/quic-go
Code Pull Requests Activity

remove unneeded streamsMutex from Session

Browse Source
This commit is contained in:
Marten Seemann
2016-08-06 17:45:21 +07:00
parent 71dcad29b5
commit 100f04f242
1 changed files with 0 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
session.go
View File

@@ -3,7 +3,6 @@ package quic
import (
"errors"
"fmt"
"sync"
"sync/atomic"
"time"
@@ -50,7 +49,6 @@ type Session struct {
streamsMap *streamsMap
openStreamsCount uint32
streamsMutex sync.RWMutex
sentPacketHandler ackhandler.SentPacketHandler
receivedPacketHandler ackhandler.ReceivedPacketHandler
@@ -332,8 +330,6 @@ func (s *Session) handlePacket(remoteAddr interface{}, hdr *PublicHeader, data [
}
func (s *Session) handleStreamFrame(frame *frames.StreamFrame) error {
s.streamsMutex.Lock()
defer s.streamsMutex.Unlock()
str, strExists := s.streamsMap.GetStream(frame.StreamID)
var err error
@@ -366,8 +362,6 @@ func (s *Session) isValidStreamID(streamID protocol.StreamID) bool {
}
func (s *Session) handleWindowUpdateFrame(frame *frames.WindowUpdateFrame) error {
s.streamsMutex.RLock()
defer s.streamsMutex.RUnlock()
if frame.StreamID != 0 {
str, strExists := s.streamsMap.GetStream(frame.StreamID)
if strExists && str == nil {
@@ -386,9 +380,7 @@ func (s *Session) handleWindowUpdateFrame(frame *frames.WindowUpdateFrame) error
// TODO: Handle frame.byteOffset
func (s *Session) handleRstStreamFrame(frame *frames.RstStreamFrame) error {
s.streamsMutex.RLock()
str, streamExists := s.streamsMap.GetStream(frame.StreamID)
s.streamsMutex.RUnlock()
if !streamExists || str == nil {
return errRstStreamOnInvalidStream
}
@@ -446,9 +438,6 @@ func (s *Session) closeImpl(e error, remoteClose bool) error {
}
func (s *Session) closeStreamsWithError(err error) {
s.streamsMutex.Lock()
defer s.streamsMutex.Unlock()
fn := func(str *stream) (bool, error) {
s.closeStreamWithError(str, err)
return true, nil
@@ -590,15 +579,11 @@ func (s *Session) logPacket(packet *packedPacket) {
// OpenStream creates a new stream open for reading and writing
func (s *Session) OpenStream(id protocol.StreamID) (utils.Stream, error) {
s.streamsMutex.Lock()
defer s.streamsMutex.Unlock()
return s.newStreamImpl(id)
}
// GetOrOpenStream returns an existing stream with the given id, or opens a new stream
func (s *Session) GetOrOpenStream(id protocol.StreamID) (utils.Stream, error) {
s.streamsMutex.Lock()
defer s.streamsMutex.Unlock()
stream, strExists := s.streamsMap.GetStream(id)
if strExists {
return stream, nil
@@ -606,7 +591,6 @@ func (s *Session) GetOrOpenStream(id protocol.StreamID) (utils.Stream, error) {
return s.newStreamImpl(id)
}
// The streamsMutex is locked by OpenStream or GetOrOpenStream before calling this function.
func (s *Session) newStreamImpl(id protocol.StreamID) (*stream, error) {
maxAllowedStreams := uint32(protocol.MaxStreamsMultiplier * float32(s.connectionParametersManager.GetMaxStreamsPerConnection()))
if atomic.LoadUint32(&s.openStreamsCount) >= maxAllowedStreams {
@@ -685,9 +669,6 @@ func (s *Session) tryDecryptingQueuedPackets() {
}
func (s *Session) getWindowUpdateFrames() ([]*frames.WindowUpdateFrame, error) {
s.streamsMutex.RLock()
defer s.streamsMutex.RUnlock()
var res []*frames.WindowUpdateFrame
fn := func(str *stream) (bool, error) {