[Author Prev][Author Next][Thread Prev][Thread Next][Author Index][Thread Index]
[tor-commits] [flashproxy/master] Use a default MaxMessageSize.
commit 4122f3f3af02255dd6cea07eef1ee33fc9083195
Author: David Fifield <david@xxxxxxxxxxxxxxx>
Date: Mon Nov 26 22:25:22 2012 -0800
Use a default MaxMessageSize.
---
websocket-transport/websocket.go | 17 ++++++++---------
1 files changed, 8 insertions(+), 9 deletions(-)
diff --git a/websocket-transport/websocket.go b/websocket-transport/websocket.go
index 5409ea6..53c25f7 100644
--- a/websocket-transport/websocket.go
+++ b/websocket-transport/websocket.go
@@ -41,14 +41,6 @@ type WebsocketConfig struct {
MaxMessageSize int
}
-// Return the WebSocket's maximum message size, or a default maximum size.
-func (config *WebsocketConfig) maxMessageSize() int {
- if config.MaxMessageSize == 0 {
- return 64000
- }
- return config.MaxMessageSize
-}
-
// Representation of a WebSocket frame. The Payload is always without masking.
type WebsocketFrame struct {
Fin bool
@@ -89,6 +81,13 @@ func applyMask(payload []byte, maskKey [4]byte) {
}
}
+func (ws *Websocket) maxMessageSize() int {
+ if ws.MaxMessageSize == 0 {
+ return 64000
+ }
+ return ws.MaxMessageSize
+}
+
// Read a single frame from the WebSocket.
func (ws *Websocket) ReadFrame() (frame WebsocketFrame, err error) {
var b byte
@@ -120,7 +119,7 @@ func (ws *Websocket) ReadFrame() (frame WebsocketFrame, err error) {
}
payloadLen = long
}
- if payloadLen > uint64(ws.MaxMessageSize) {
+ if payloadLen > uint64(ws.maxMessageSize()) {
err = errors.New(fmt.Sprintf("frame payload length of %d exceeds maximum of %d", payloadLen, ws.MaxMessageSize))
return
}
_______________________________________________
tor-commits mailing list
tor-commits@xxxxxxxxxxxxxxxxxxxx
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits