From af522c1538c92b840589090b535b817c527ac913 Mon Sep 17 00:00:00 2001 From: Lucas Clemente Date: Sun, 15 May 2016 18:50:04 +0200 Subject: [PATCH] privatize session.updateReceiveFlowControlWindow ref #60 --- session.go | 4 ++-- session_test.go | 4 ++-- stream.go | 4 ++-- stream_test.go | 2 +- 4 files changed, 7 insertions(+), 7 deletions(-) diff --git a/session.go b/session.go index 497abf9f6..3ccf2ec7b 100644 --- a/session.go +++ b/session.go @@ -530,8 +530,8 @@ func (s *Session) queueStreamFrame(frame *frames.StreamFrame) error { return nil } -// UpdateReceiveFlowControlWindow updates the flow control window for a stream -func (s *Session) UpdateReceiveFlowControlWindow(streamID protocol.StreamID, byteOffset protocol.ByteCount) error { +// updateReceiveFlowControlWindow updates the flow control window for a stream +func (s *Session) updateReceiveFlowControlWindow(streamID protocol.StreamID, byteOffset protocol.ByteCount) error { s.windowUpdateManager.SetStreamOffset(streamID, byteOffset) return nil } diff --git a/session_test.go b/session_test.go index 34d8fdeb2..cb56779d4 100644 --- a/session_test.go +++ b/session_test.go @@ -378,7 +378,7 @@ var _ = Describe("Session", func() { It("sends a WindowUpdate frame", func() { _, err := session.NewStream(5) Expect(err).ToNot(HaveOccurred()) - err = session.UpdateReceiveFlowControlWindow(5, 0xDECAFBAD) + err = session.updateReceiveFlowControlWindow(5, 0xDECAFBAD) Expect(err).ToNot(HaveOccurred()) err = session.sendPacket() Expect(err).NotTo(HaveOccurred()) @@ -389,7 +389,7 @@ var _ = Describe("Session", func() { It("repeats a WindowUpdate frame in WindowUpdateNumRepitions packets", func() { _, err := session.NewStream(5) Expect(err).ToNot(HaveOccurred()) - err = session.UpdateReceiveFlowControlWindow(5, 0xDECAFBAD) + err = session.updateReceiveFlowControlWindow(5, 0xDECAFBAD) Expect(err).ToNot(HaveOccurred()) for i := uint8(0); i < protocol.WindowUpdateNumRepitions; i++ { err = session.sendPacket() diff --git a/stream.go b/stream.go index 854baa16a..c54044719 100644 --- a/stream.go +++ b/stream.go @@ -13,7 +13,7 @@ import ( type streamHandler interface { queueStreamFrame(*frames.StreamFrame) error - UpdateReceiveFlowControlWindow(streamID protocol.StreamID, byteOffset protocol.ByteCount) error + updateReceiveFlowControlWindow(streamID protocol.StreamID, byteOffset protocol.ByteCount) error } // A Stream assembles the data from StreamFrames and provides a super-convenient Read-Interface @@ -140,7 +140,7 @@ func (s *stream) ReadByte() (byte, error) { func (s *stream) updateReceiveFlowControlWindow() { n := s.receiveFlowControlWindow + s.receiveFlowControlWindowIncrement s.receiveFlowControlWindow = n - s.session.UpdateReceiveFlowControlWindow(s.streamID, n) + s.session.updateReceiveFlowControlWindow(s.streamID, n) } func (s *stream) UpdateSendFlowControlWindow(n protocol.ByteCount) { diff --git a/stream_test.go b/stream_test.go index a10743aaa..69328ad35 100644 --- a/stream_test.go +++ b/stream_test.go @@ -22,7 +22,7 @@ func (m *mockStreamHandler) queueStreamFrame(f *frames.StreamFrame) error { return nil } -func (m *mockStreamHandler) UpdateReceiveFlowControlWindow(streamID protocol.StreamID, byteOffset protocol.ByteCount) error { +func (m *mockStreamHandler) updateReceiveFlowControlWindow(streamID protocol.StreamID, byteOffset protocol.ByteCount) error { return nil }