- fixed #84
This commit is contained in:
@@ -143,6 +143,10 @@ example::
|
|||||||
ChangeLog
|
ChangeLog
|
||||||
============
|
============
|
||||||
|
|
||||||
|
- v0.15.0
|
||||||
|
|
||||||
|
- fixed exception when send a large message (#84)
|
||||||
|
|
||||||
- v0.14.1
|
- v0.14.1
|
||||||
|
|
||||||
- fixed to work on Python2.6 (#83)
|
- fixed to work on Python2.6 (#83)
|
||||||
|
2
setup.py
2
setup.py
@@ -1,7 +1,7 @@
|
|||||||
from setuptools import setup
|
from setuptools import setup
|
||||||
import sys
|
import sys
|
||||||
|
|
||||||
VERSION = "0.14.1"
|
VERSION = "0.15.0"
|
||||||
|
|
||||||
install_requires = ["six"]
|
install_requires = ["six"]
|
||||||
if sys.version_info[0] == 2:
|
if sys.version_info[0] == 2:
|
||||||
|
@@ -223,6 +223,8 @@ class WebSocketTest(unittest.TestCase):
|
|||||||
sock.send(u"こんにちは")
|
sock.send(u"こんにちは")
|
||||||
self.assertEqual(s.sent[1], six.b("\x81\x8fabcd\x82\xe3\xf0\x87\xe3\xf1\x80\xe5\xca\x81\xe2\xc5\x82\xe3\xcc"))
|
self.assertEqual(s.sent[1], six.b("\x81\x8fabcd\x82\xe3\xf0\x87\xe3\xf1\x80\xe5\xca\x81\xe2\xc5\x82\xe3\xcc"))
|
||||||
|
|
||||||
|
sock.send("x" * 127)
|
||||||
|
|
||||||
def testRecv(self):
|
def testRecv(self):
|
||||||
# TODO: add longer frame data
|
# TODO: add longer frame data
|
||||||
sock = ws.WebSocket()
|
sock = ws.WebSocket()
|
||||||
|
@@ -335,15 +335,16 @@ class ABNF(object):
|
|||||||
| self.opcode)
|
| self.opcode)
|
||||||
if length < ABNF.LENGTH_7:
|
if length < ABNF.LENGTH_7:
|
||||||
frame_header += chr(self.mask << 7 | length)
|
frame_header += chr(self.mask << 7 | length)
|
||||||
|
frame_header = six.b(frame_header)
|
||||||
elif length < ABNF.LENGTH_16:
|
elif length < ABNF.LENGTH_16:
|
||||||
frame_header += chr(self.mask << 7 | 0x7e)
|
frame_header += chr(self.mask << 7 | 0x7e)
|
||||||
|
frame_header = six.b(frame_header)
|
||||||
frame_header += struct.pack("!H", length)
|
frame_header += struct.pack("!H", length)
|
||||||
else:
|
else:
|
||||||
frame_header += chr(self.mask << 7 | 0x7f)
|
frame_header += chr(self.mask << 7 | 0x7f)
|
||||||
|
frame_header = six.b(frame_header)
|
||||||
frame_header += struct.pack("!Q", length)
|
frame_header += struct.pack("!Q", length)
|
||||||
|
|
||||||
frame_header = six.b(frame_header)
|
|
||||||
|
|
||||||
if not self.mask:
|
if not self.mask:
|
||||||
return frame_header + self.data
|
return frame_header + self.data
|
||||||
else:
|
else:
|
||||||
|
Reference in New Issue
Block a user