1 package projet.lasalle84.darts;
3 import android.os.Bundle;
4 import android.os.Handler;
5 import android.os.Message;
6 import android.util.Log;
8 import java.io.BufferedReader;
9 import java.io.IOException;
10 import java.io.InputStream;
11 import java.io.InputStreamReader;
22 class TReception
extends Thread 27 private final String TAG =
"TReception";
31 private Peripherique peripherique;
32 private Handler handler;
33 private boolean estFini;
34 private InputStream receiveStream;
43 TReception(Peripherique peripherique, Handler handler, InputStream flux)
45 Log.d(TAG,
"TReception() " + peripherique.getNom() +
"[" + peripherique.getAdresse() +
"]");
46 this.peripherique = peripherique;
47 this.handler = handler;
59 Log.d(TAG,
"début run() " + peripherique.getNom() +
"[" + peripherique.getAdresse() +
"]");
60 BufferedReader reception =
new BufferedReader(
new InputStreamReader(receiveStream));
68 trame = reception.readLine();
70 if(trame.length() > 0)
72 Log.d(TAG,
"run() trame reçue : " + trame);
73 Message msg = Message.obtain();
74 Bundle b =
new Bundle();
75 b.putString(
"nom", peripherique.getNom());
76 b.putString(
"adresse", peripherique.getAdresse());
77 b.putInt(
"etat", Peripherique.CODE_RECEPTION);
78 b.putString(
"donnees", trame);
80 handler.sendMessage(msg);
86 Log.d(TAG,
"run() Erreur socket read : " + peripherique.getNom());
87 Message msg = Message.obtain();
88 Bundle b =
new Bundle();
89 b.putString(
"nom", peripherique.getNom());
90 b.putString(
"adresse", peripherique.getAdresse());
91 b.putInt(
"etat", Peripherique.CODE_ERREUR_RECEVOIR);
93 handler.sendMessage(msg);
99 catch (InterruptedException e)
104 Message msg = Message.obtain();
105 Bundle b =
new Bundle();
106 b.putString(
"nom", peripherique.getNom());
107 b.putString(
"adresse", peripherique.getAdresse());
108 b.putInt(
"etat", Peripherique.CODE_DECONNEXION);
109 b.putString(
"donnees",
"");
111 handler.sendMessage(msg);
112 Log.d(TAG,
"fin run() " + peripherique.getNom() +
"[" + peripherique.getAdresse() +
"]");
119 public void arreter()
121 Log.d(TAG,
"arreter() " + peripherique.getNom() +
"[" + peripherique.getAdresse() +
"]");
130 catch (InterruptedException e)