|
@@ -179,7 +179,7 @@ def read_audio_video(source, duration=60):
|
|
return bytes(a ^ b for a, b in zip(data_a, data_b))
|
|
return bytes(a ^ b for a, b in zip(data_a, data_b))
|
|
|
|
|
|
|
|
|
|
-def read_rdseed(source, amount=16):
|
|
|
|
|
|
+def read_rdseed(_, amount=16):
|
|
data = rdrand.rdseed_get_bytes(amount)
|
|
data = rdrand.rdseed_get_bytes(amount)
|
|
if len(data) != amount or data.count(0) == amount:
|
|
if len(data) != amount or data.count(0) == amount:
|
|
raise ValueError("bad data")
|
|
raise ValueError("bad data")
|
|
@@ -229,7 +229,7 @@ def push(pool_url, data, secret):
|
|
|
|
|
|
|
|
|
|
resp = requests.post(
|
|
resp = requests.post(
|
|
- f"{pool_url}/api/pool", data=data[: 1024**2], headers={"X-Secret": secret}
|
|
|
|
|
|
+ f"{pool_url}/api/pool", data=data, headers={"X-Secret": secret}
|
|
)
|
|
)
|
|
|
|
|
|
(logger.success if resp.status_code == 200 else logger.error)(
|
|
(logger.success if resp.status_code == 200 else logger.error)(
|
|
@@ -250,7 +250,7 @@ def puller(queue, source, source_type, multiplier):
|
|
|
|
|
|
continue
|
|
continue
|
|
|
|
|
|
- for piece in chunks(data, 512):
|
|
|
|
|
|
+ for piece in chunks(data, 1024 * 500):
|
|
queue.put(piece)
|
|
queue.put(piece)
|
|
|
|
|
|
|
|
|