from cpython cimport PyBytes_AsString #from cpython cimport PyByteArray_AsString # cython still not exports that cdef extern from "Python.h": char* PyByteArray_AsString(bytearray ba) except NULL from libc.stdint cimport uint32_t, uint64_t, uintmax_t def _websocket_mask_cython(object mask, object data): """Note, this function mutates it's `data` argument """ cdef: Py_ssize_t data_len, i # bit operations on signed integers are implementation-specific unsigned char * in_buf const unsigned char * mask_buf uint32_t uint32_msk uint64_t uint64_msk assert len(mask) == 4 if not isinstance(mask, bytes): mask = bytes(mask) if isinstance(data, bytearray): data = <bytearray>data else: data = bytearray(data) data_len = len(data) in_buf = <unsigned char*>PyByteArray_AsString(data) mask_buf = <const unsigned char*>PyBytes_AsString(mask) uint32_msk = (<uint32_t*>mask_buf)[0] # TODO: align in_data ptr to achieve even faster speeds # does it need in python ?! malloc() always aligns to sizeof(long) bytes if sizeof(size_t) >= 8: uint64_msk = uint32_msk uint64_msk = (uint64_msk << 32) | uint32_msk while data_len >= 8: (<uint64_t*>in_buf)[0] ^= uint64_msk in_buf += 8 data_len -= 8 while data_len >= 4: (<uint32_t*>in_buf)[0] ^= uint32_msk in_buf += 4 data_len -= 4 for i in range(0, data_len): in_buf[i] ^= mask_buf[i]
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
__pycache__ | Folder | 0755 |
|
|
__init__.py | File | 1.35 KB | 0644 |
|
_cparser.pxd | File | 3.87 KB | 0644 |
|
_frozenlist.c | File | 279.05 KB | 0644 |
|
_frozenlist.cpython-35m-x86_64-linux-gnu.so | File | 63.73 KB | 0755 |
|
_frozenlist.pyx | File | 2.54 KB | 0644 |
|
_http_parser.c | File | 592.13 KB | 0644 |
|
_http_parser.cpython-35m-x86_64-linux-gnu.so | File | 155.33 KB | 0755 |
|
_http_parser.pyx | File | 20.6 KB | 0644 |
|
_websocket.c | File | 125.34 KB | 0644 |
|
_websocket.cpython-35m-x86_64-linux-gnu.so | File | 24.38 KB | 0755 |
|
_websocket.pyx | File | 1.52 KB | 0644 |
|
abc.py | File | 3.31 KB | 0644 |
|
client.py | File | 31.81 KB | 0644 |
|
client_exceptions.py | File | 5.28 KB | 0644 |
|
client_proto.py | File | 5.74 KB | 0644 |
|
client_reqrep.py | File | 27.95 KB | 0644 |
|
client_ws.py | File | 8.69 KB | 0644 |
|
connector.py | File | 31.81 KB | 0644 |
|
cookiejar.py | File | 9.99 KB | 0644 |
|
formdata.py | File | 5.22 KB | 0644 |
|
frozenlist.py | File | 1.73 KB | 0644 |
|
hdrs.py | File | 3.28 KB | 0644 |
|
helpers.py | File | 22.36 KB | 0644 |
|
http.py | File | 1.26 KB | 0644 |
|
http_exceptions.py | File | 1.93 KB | 0644 |
|
http_parser.py | File | 23.77 KB | 0644 |
|
http_websocket.py | File | 21.49 KB | 0644 |
|
http_writer.py | File | 3.91 KB | 0644 |
|
locks.py | File | 946 B | 0644 |
|
log.py | File | 326 B | 0644 |
|
multipart.py | File | 28.89 KB | 0644 |
|
payload.py | File | 8.2 KB | 0644 |
|
payload_streamer.py | File | 1.49 KB | 0644 |
|
pytest_plugin.py | File | 9.54 KB | 0644 |
|
resolver.py | File | 3.23 KB | 0644 |
|
signals.py | File | 933 B | 0644 |
|
streams.py | File | 16.31 KB | 0644 |
|
tcp_helpers.py | File | 1.38 KB | 0644 |
|
test_utils.py | File | 15.75 KB | 0644 |
|
tracing.py | File | 9.32 KB | 0644 |
|
web.py | File | 7.03 KB | 0644 |
|
web_app.py | File | 9.88 KB | 0644 |
|
web_exceptions.py | File | 8.38 KB | 0644 |
|
web_fileresponse.py | File | 7.51 KB | 0644 |
|
web_middlewares.py | File | 2.6 KB | 0644 |
|
web_protocol.py | File | 17.57 KB | 0644 |
|
web_request.py | File | 20.42 KB | 0644 |
|
web_response.py | File | 20.97 KB | 0644 |
|
web_runner.py | File | 8.05 KB | 0644 |
|
web_server.py | File | 1.29 KB | 0644 |
|
web_urldispatcher.py | File | 32.67 KB | 0644 |
|
web_ws.py | File | 14.34 KB | 0644 |
|
worker.py | File | 6.92 KB | 0644 |
|