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

privatize closeCallback

Browse Source 
ref #60
This commit is contained in:
Lucas Clemente
2016-05-15 15:58:35 +02:00
parent 0cb0ce8ad8
commit ce1f7b2aaf
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server.go
View File

@@ -31,7 +31,7 @@ type Server struct {
streamCallback StreamCallback streamCallback StreamCallback
newSession func(conn connection, v protocol.VersionNumber, connectionID protocol.ConnectionID, sCfg *handshake.ServerConfig, streamCallback StreamCallback, closeCallback CloseCallback) packetHandler newSession func(conn connection, v protocol.VersionNumber, connectionID protocol.ConnectionID, sCfg *handshake.ServerConfig, streamCallback StreamCallback, closeCallback closeCallback) packetHandler
} }
// NewServer makes a new server // NewServer makes a new server

2
server_test.go
View File

@@ -25,7 +25,7 @@ func (s *mockSession) HandlePacket(addr interface{}, hdr *publicHeader, data []b
func (s *mockSession) Run() { func (s *mockSession) Run() {
} }
func newMockSession(conn connection, v protocol.VersionNumber, connectionID protocol.ConnectionID, sCfg *handshake.ServerConfig, streamCallback StreamCallback, closeCallback CloseCallback) packetHandler { func newMockSession(conn connection, v protocol.VersionNumber, connectionID protocol.ConnectionID, sCfg *handshake.ServerConfig, streamCallback StreamCallback, closeCallback closeCallback) packetHandler {
return &mockSession{ return &mockSession{
connectionID: connectionID, connectionID: connectionID,
} }

8
session.go
View File

@@ -32,15 +32,15 @@ var (
// StreamCallback gets a stream frame and returns a reply frame // StreamCallback gets a stream frame and returns a reply frame
type StreamCallback func(*Session, utils.Stream) type StreamCallback func(*Session, utils.Stream)
// CloseCallback is called when a session is closed // closeCallback is called when a session is closed
type CloseCallback func(id protocol.ConnectionID) type closeCallback func(id protocol.ConnectionID)
// A Session is a QUIC session // A Session is a QUIC session
type Session struct { type Session struct {
connectionID protocol.ConnectionID connectionID protocol.ConnectionID
streamCallback StreamCallback streamCallback StreamCallback
closeCallback CloseCallback closeCallback closeCallback
conn connection conn connection
@@ -76,7 +76,7 @@ type Session struct {
} }
// newSession makes a new session // newSession makes a new session
func newSession(conn connection, v protocol.VersionNumber, connectionID protocol.ConnectionID, sCfg *handshake.ServerConfig, streamCallback StreamCallback, closeCallback CloseCallback) packetHandler { func newSession(conn connection, v protocol.VersionNumber, connectionID protocol.ConnectionID, sCfg *handshake.ServerConfig, streamCallback StreamCallback, closeCallback closeCallback) packetHandler {
stopWaitingManager := ackhandler.NewStopWaitingManager() stopWaitingManager := ackhandler.NewStopWaitingManager()
session := &Session{ session := &Session{
connectionID: connectionID, connectionID: connectionID,