Commit ec1bcf8b authored by Hicham Brahimi's avatar Hicham Brahimi

connexion & envoi 4G

parent 39c7be9c
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
zerzerfà))))))éç"'àç&è'àçè(
&"'''''_-àç='"-&"')àà
&"'(-=&"'-tç"'à,dk'r
# PYTHON 3.5+
import socket
import sys
import time
from datetime import datetime
CHUNK_SIZE = 2048
PORT = 12345
log = open("log.txt", "w")
file = None
while True:
try:
print("Attente Client")
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(("", PORT))
server.listen(10)
client, addr = server.accept()
print("Client acceptee : ", addr)
name = datetime.now().strftime("%d-%m-%Y_%H.%M.%S")
file = open("data/"+name, "wb")
while True:
data = client.recv(CHUNK_SIZE)
file.write(data)
if len(data) == 0:
print("Fichier recu")
log.write(str(datetime.now())+" => Fichier Recu\n")
file.close()
client.close()
server.close()
time.sleep(1) # Laisse le temps au port de se liberer
break
print(" -> chunk")
except KeyboardInterrupt:
if file is not None:
file.close()
client.close()
print("Deconnexion")
server.close()
log.write(str(datetime.now())+" ==> End Keyboard\n")
log.close()
sys.exit(0)
except Exception as ex:
print("Exception ", type(ex))
log.write(str(datetime.now())+" ==> Exception "+str(type(ex))+" ("+str(ex.args)+")\n")
#Python 3.5
# A executer avec SUDO
# PYTHON 3.5+
import subprocess
import time
import socket
import sys
import os
import os.path
from datetime import datetime
import psutil
def check_pid(pid):
# Verifie l'existence d'un pid
if psutil.pid_exists(pid):
p = psutil.Process(pid)
if p.status() != psutil.STATUS_ZOMBIE:
return True
return False
# Verifie qu'il n'y a pas d'autres processus d'envoi en verifiant le fichier lock
if os.path.isfile("./.lockprocess"): print("Locked")
while os.path.isfile("./.lockprocess"): time.sleep(1)
# Creer un nouveau fichier lock pour verrouiller les autres processus
if not os.path.isfile("./.lockprocess"):
open(".lockprocess", "a").close()
subprocess.Popen(["chmod", "777", ".lockprocess"])
else: # Si un processus s'est activée entre la 1ere boucle et la condition
while os.path.isfile("./.lockprocess"): time.sleep(1)
open(".lockprocess", "a").close()
subprocess.Popen(["chmod", "777", ".lockprocess"])
IP_PC = "91.162.19.165"
PORT = 20000
nomFichier = sys.argv[1]
print(nomFichier)
sock = socket.socket()
sock.connect(('localhost', 3400))
print("Debut processus envoi")
with open(nomFichier, 'rb') as f:
print("SEND")
sock.sendfile(f, 0)
sock.close()
print("Fin processus emvoi")
chemin = nomFichier.split("/")
log = open("log/"+chemin[1]+".log", "w")
f = None
try:
pid = subprocess.Popen(["wvdial"])
print("============ WVDIAL LANCE ==============")
print("PID = ",pid.pid)
time.sleep(10)
print("============ CORRECTION ROUTE ==============")
subprocess.Popen(["route", "add", "default", "dev", "ppp0"]) # Corrige la 4G au demarrage du raspberry
print("============ CONNEXION ==============")
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.connect((IP_PC, PORT))
f = open(nomFichier, "rb")
print("======== CALCUL TAILLE ========")
taille = os.path.getsize(nomFichier)
print("============ ENVOI FICHIER ==============")
totalEnvoyee = 0
with open(nomFichier, "rb") as f:
totalEnvoyee += server.sendfile(f, 0)
print(" => chunk %d/%d" % (totalEnvoyee, taille))
log.write(" => chunk "+str(totalEnvoyee)+"/"+str(taille)+"\n")
server.close()
except KeyboardInterrupt :
print("============= LIBERATION =============")
os.remove(".lockprocess")
print("============ WVDIAL ARRET ==============")
subprocess.Popen(["kill", "-1", pid.pid])
except Exception as ex:
print("Exception, voir log")
log.write(str(datetime.now())+" => Exception "+str(type(ex))+" ("+str(ex.args)+")\n")
time.sleep(1)
print("============= LIBERATION =============")
os.remove(".lockprocess")
print("============ WVDIAL ARRET ==============")
subprocess.Popen(["kill", "-1", pid.pid])
print("================ FIN =================")
if f is not None:
f.close()
server.close()
log.close()
if check_pid(pid.pid):
print("============ WVDIAL ARRET ==============")
subprocess.Popen(["kill", "-1", str(pid.pid)])
time.sleep(1)
if os.path.isfile("./.lockprocess"):
print("=========== LIBERATION ============")
os.remove(".lockprocess")
# PYTHON 3.5+
import socket
import sys
import time
from datetime import datetime
CHUNK_SIZE = 2048
PORT = 12345
log = open("log.txt", "w")
file = None
......@@ -11,7 +13,7 @@ while True:
try:
print("Attente Client")
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(("", 12345))
server.bind(("", PORT))
server.listen(10)
client, addr = server.accept()
......@@ -31,6 +33,8 @@ while True:
file.close()
client.close()
server.close()
time.sleep(1) # Laisse le temps au port de se liberer
break
print(" -> chunk")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment