Distributed and decentralized pi calculation

fix?

Changed files
+17 -19
src
client
+17 -19
src/client/client.py
··· 43 43 return pi 44 44 45 45 def upload(): 46 + time.sleep(1) 46 47 while True: 47 - if str(pi_val).startswith("3.14") == True: 48 - print(">> checking and uploading latest calculation") 49 - response = requests.get(server + "/api/getpi") 48 + print(">> checking and uploading latest calculation") 49 + response = requests.get(server + "/api/getpi") 50 + print(response.text) 51 + replen = len(response.text) 52 + pilen = len(str(pi_val)) 53 + finalResult = pi_val * multiplier 54 + if response.text == "No clients have connected yet. Become one of the first!": 55 + print("server pi doesn't exist! uploading") 56 + data = {'pi': str(finalResult)} 57 + print(data) 58 + response = requests.post(server + "/api/postpi", data=data) 50 59 print(response.text) 51 - replen = len(response.text) 52 - pilen = len(str(pi_val)) 53 - finalResult = pi_val * multiplier 54 - if response.text == "No clients have connected yet. Become one of the first!": 55 - print("server pi doesn't exist! uploading") 60 + else: 61 + if replen > pilen: 62 + print("server pi length is greater than local pi length! not uploading") 63 + elif pilen > replen: 64 + print("local pi length longer than server pi length! uploading") 56 65 data = {'pi': str(finalResult)} 57 - print(data) 58 66 response = requests.post(server + "/api/postpi", data=data) 59 67 print(response.text) 60 - else: 61 - if replen > pilen: 62 - print("server pi length is greater than local pi length! not uploading") 63 - elif pilen > replen: 64 - print("local pi length longer than server pi length! uploading") 65 - data = {'pi': str(finalResult)} 66 - response = requests.post(server + "/api/postpi", data=data) 67 - print(response.text) 68 - else: 69 - print("pi_val not yet defined!") 70 68 time.sleep(60) 71 69 72 70 threading.Thread(target=upload, daemon=True).start()