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 its `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 |
---|---|---|---|---|
.hash | Folder | 0755 |
|
|
__pycache__ | Folder | 0755 |
|
|
__init__.py | File | 6.71 KB | 0644 |
|
_cparser.pxd | File | 4.88 KB | 0644 |
|
_find_header.pxd | File | 68 B | 0644 |
|
_headers.pxi | File | 1.96 KB | 0644 |
|
_helpers.cpython-311-x86_64-linux-gnu.so | File | 60.2 KB | 0755 |
|
_helpers.pyi | File | 202 B | 0644 |
|
_helpers.pyx | File | 1.02 KB | 0644 |
|
_http_parser.cpython-311-x86_64-linux-gnu.so | File | 489.45 KB | 0755 |
|
_http_parser.pyx | File | 26.7 KB | 0644 |
|
_http_writer.cpython-311-x86_64-linux-gnu.so | File | 61.22 KB | 0755 |
|
_http_writer.pyx | File | 4.47 KB | 0644 |
|
_websocket.cpython-311-x86_64-linux-gnu.so | File | 34.41 KB | 0755 |
|
_websocket.pyx | File | 1.52 KB | 0644 |
|
abc.py | File | 5.38 KB | 0644 |
|
base_protocol.py | File | 2.68 KB | 0644 |
|
client.py | File | 43.98 KB | 0644 |
|
client_exceptions.py | File | 9.05 KB | 0644 |
|
client_proto.py | File | 7.98 KB | 0644 |
|
client_reqrep.py | File | 36.11 KB | 0644 |
|
client_ws.py | File | 10.27 KB | 0644 |
|
connector.py | File | 49.98 KB | 0644 |
|
cookiejar.py | File | 13.33 KB | 0644 |
|
formdata.py | File | 5.96 KB | 0644 |
|
hdrs.py | File | 4.61 KB | 0644 |
|
helpers.py | File | 25.78 KB | 0644 |
|
http.py | File | 1.76 KB | 0644 |
|
http_exceptions.py | File | 2.53 KB | 0644 |
|
http_parser.py | File | 32.32 KB | 0644 |
|
http_websocket.py | File | 24.71 KB | 0644 |
|
http_writer.py | File | 5.79 KB | 0644 |
|
locks.py | File | 1.11 KB | 0644 |
|
log.py | File | 325 B | 0644 |
|
multipart.py | File | 31.56 KB | 0644 |
|
payload.py | File | 13.31 KB | 0644 |
|
payload_streamer.py | File | 2.06 KB | 0644 |
|
py.typed | File | 7 B | 0644 |
|
pytest_plugin.py | File | 11.5 KB | 0644 |
|
resolver.py | File | 4.97 KB | 0644 |
|
streams.py | File | 20.27 KB | 0644 |
|
tcp_helpers.py | File | 961 B | 0644 |
|
test_utils.py | File | 20.93 KB | 0644 |
|
tracing.py | File | 14.82 KB | 0644 |
|
typedefs.py | File | 1.72 KB | 0644 |
|
web.py | File | 17.66 KB | 0644 |
|
web_app.py | File | 16.77 KB | 0644 |
|
web_exceptions.py | File | 9.86 KB | 0644 |
|
web_fileresponse.py | File | 10.53 KB | 0644 |
|
web_log.py | File | 7.38 KB | 0644 |
|
web_middlewares.py | File | 4.04 KB | 0644 |
|
web_protocol.py | File | 21.87 KB | 0644 |
|
web_request.py | File | 27.53 KB | 0644 |
|
web_response.py | File | 26.83 KB | 0644 |
|
web_routedef.py | File | 6.01 KB | 0644 |
|
web_runner.py | File | 10.9 KB | 0644 |
|
web_server.py | File | 2 KB | 0644 |
|
web_urldispatcher.py | File | 38.56 KB | 0644 |
|
web_ws.py | File | 16.74 KB | 0644 |
|
worker.py | File | 8.56 KB | 0644 |
|