CloneRepos/CYD-Klipper
2
0
Fork 0
mirror of https://github.com/suchmememanyskill/CYD-Klipper.git synced 2026-03-21 05:33:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

Lower cpu usage

Browse Source
This commit is contained in:
suchmememanyskill
2024-11-27 22:53:35 +01:00
parent 8521664a69
commit 0c364ec597
1 changed files with 45 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

91
serial/serial_server.py
View File

@@ -105,58 +105,57 @@ def write(text : str, write : bool):
def main():
while True:
# Read a line from the serial port
if ser.in_waiting > 0:
line = ser.readline().decode('utf-8').strip()
if line.startswith("HTTP_REQUEST") or line.startswith("HTTP_BINARY"):
print(f">>> {line}")
# Parse the parameters
try:
parts = line.split(' ', 3)
timeout_ms, request_type, url_path = int(parts[1]), parts[2], parts[3]
line = ser.readline().decode('utf-8').strip()
if line.startswith("HTTP_REQUEST") or line.startswith("HTTP_BINARY"):
print(f">>> {line}")
# Parse the parameters
try:
parts = line.split(' ', 3)
timeout_ms, request_type, url_path = int(parts[1]), parts[2], parts[3]
ignore_timeout = timeout_ms <= 0
binary = line.startswith("HTTP_BINARY")
ignore_timeout = timeout_ms <= 0
binary = line.startswith("HTTP_BINARY")
if ignore_timeout:
timeout_ms = 1000;
if ignore_timeout:
timeout_ms = 1000;
# Construct the full URL
full_url = f"{PROTOCOL}://{HOSTNAME}:{PORT}{url_path}"
# Construct the full URL
full_url = f"{PROTOCOL}://{HOSTNAME}:{PORT}{url_path}"
# Make the HTTP request based on the type
response = None
if request_type.upper() == "GET":
response = requests.get(full_url, timeout=timeout_ms / 1000)
elif request_type.upper() == "POST":
response = requests.post(full_url, timeout=timeout_ms / 1000)
else:
write("400 Unsupported request type", not ignore_timeout)
continue
# Make the HTTP request based on the type
response = None
if request_type.upper() == "GET":
response = requests.get(full_url, timeout=timeout_ms / 1000)
elif request_type.upper() == "POST":
response = requests.post(full_url, timeout=timeout_ms / 1000)
else:
write("400 Unsupported request type", not ignore_timeout)
continue
# Send response back over serial
if response != None:
if binary:
if response.status_code != 200:
write("00000000", not ignore_timeout)
else:
length = len(response.content)
ser.write(f"{length:>08}".encode('utf-8'))
ser.write(response.content)
print(f"<<< (Binary data of {length} bytes)")
# Send response back over serial
if response != None:
if binary:
if response.status_code != 200:
write("00000000", not ignore_timeout)
else:
status_code = response.status_code
body = response.text.replace('\n', ' ') # Trim and sanitize body for serial
message = f"{status_code} {body}"
write(message, not ignore_timeout)
except (IndexError, ValueError) as e:
write(f"400 Malformed request {str(e)}", not ignore_timeout)
except requests.exceptions.ReadTimeout as e:
print("Request timed out.")
pass
except requests.exceptions.RequestException as e:
write("500 Request failed", not ignore_timeout)
else:
print(f"[LOG] {line}")
length = len(response.content)
ser.write(f"{length:>08}".encode('utf-8'))
ser.write(response.content)
print(f"<<< (Binary data of {length} bytes)")
else:
status_code = response.status_code
body = response.text.replace('\n', ' ') # Trim and sanitize body for serial
message = f"{status_code} {body}"
write(message, not ignore_timeout)
except (IndexError, ValueError) as e:
write(f"400 Malformed request {str(e)}", not ignore_timeout)
except requests.exceptions.ReadTimeout as e:
print("Request timed out.")
pass
except requests.exceptions.RequestException as e:
write("500 Request failed", not ignore_timeout)
else:
print(f"[LOG] {line}")
if __name__ == "__main__":
while True: