mirror of
https://github.com/kuitoi/kuitoi-Server.git
synced 2025-08-18 00:35:36 +00:00
Minor update
This commit is contained in:
parent
a5202edf83
commit
8feba0e085
@ -70,7 +70,7 @@ class Client:
|
|||||||
if len(data) == 10:
|
if len(data) == 10:
|
||||||
data += b"."
|
data += b"."
|
||||||
header = len(data).to_bytes(4, "little", signed=True)
|
header = len(data).to_bytes(4, "little", signed=True)
|
||||||
self.log.debug(f'len: {len(data)}; send: {header + data}')
|
self.log.debug(f'len: {len(data)}; send: {header + data!r}')
|
||||||
try:
|
try:
|
||||||
writer.write(header + data)
|
writer.write(header + data)
|
||||||
await writer.drain()
|
await writer.drain()
|
||||||
@ -116,6 +116,7 @@ class Client:
|
|||||||
self.alive = False
|
self.alive = False
|
||||||
return b""
|
return b""
|
||||||
|
|
||||||
|
# TODO: Speed limiter
|
||||||
async def _split_load(self, start, end, d_sock, filename):
|
async def _split_load(self, start, end, d_sock, filename):
|
||||||
real_size = end - start
|
real_size = end - start
|
||||||
writer = self.down_rw[1] if d_sock else self.writer
|
writer = self.down_rw[1] if d_sock else self.writer
|
||||||
|
Loading…
x
Reference in New Issue
Block a user