1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164
|
#include "PcServeur.h"
using namespace std;
using namespace Outils;
using namespace cimg_library;
ReceiveImages::ReceiveImages(std::string p_nom, IProtocole *p_p,
unsigned long intsize, unsigned int p_width, unsigned int p_height,
ITache *p_tacheSendMessages){
nom=p_nom;
assert(p_p!= NULL && p_tacheSendMessages!= NULL);
p=p_p;
width=p_width;
height=p_height;
tacheSendMessages=p_tacheSendMessages;
this->intsize=intsize;
reception = new JOCTET[CENT_KILO];
if (reception == NULL)
throw COutOfMemory("L'allocation du buffer de reception des images a échouée.");
}
ReceiveImages::~ReceiveImages(){
delete[] reception;
}
void ReceiveImages::toDo(){
const unsigned char red[] = { 255,0,0 };
const unsigned char blue[] = { 0,155,255 };
int i=0;
size_t sz=0;
int jpegfilesize=0, datesize=0;
char date[50];
unsigned int dimX = width, dimY = height;
CImg<unsigned char> imageCourante, affichage(dimX, dimY, 1, 3, 255);
CImgDisplay disp(affichage,"Live view : ");
disp.close();
while(1){
//On attend des données pendant une 300 milliseconde. Si on a pas de
//données, on ferme la fenêtre d'affichage
if ( ! p->waitData(0,300) ) disp.close();
//et on attend infiniment des données :
if (p->waitData(-1) ){
disp.show();
//reception de la taille du fichier jpeg :
jpegfilesize=0;
p->receiveInteger( intsize, &jpegfilesize, &sz);
}
//reception du fichier :
if ( p->waitData(1) ){
p->receive(jpegfilesize, reception , &sz);
cout << "Image n°"<< i++ <<" Taille reçue : "<< sz <<
" Taille attendue : "<< jpegfilesize << endl;
//chargement de l'image jpeg recu, grace au plugin jpeg_buffer :
imageCourante.load_jpeg_buffer( reception, jpegfilesize);
}
//on passe l'image en 3 channels (RGB) pour avoir les couleurs..... :
affichage = imageCourante;
affichage.resize(dimX,dimY,1,3);
//affichage du nb de frames par secondes :
affichage.draw_text(5,5,"%u frames/s",red,0,1,18,
(unsigned int)disp.frames_per_second());
disp << affichage;
}
}
SendMessages::SendMessages(std::string p_nom, IProtocole *p_p, unsigned long intsize){
nom=p_nom;
assert(p_p != NULL );
p=p_p;
this->intsize=intsize;
}
void SendMessages::toDo(){
string mess;
do{
//tache d'envois des messages au client
cin >> mess;
p->sendInteger( mess.size(), intsize);
p->send( (const char *) mess.c_str(), mess.size() );
}
while(mess != "exit");
}
int main(int argc, char* argv[]) {
if (argc!=2) {
printf("Usage : %s <port>",argv[0]);
exit(EXIT_FAILURE);
}
ILogger *logger = new CLoggerConsole();
ILogger::SetLogger(logger);
//Etablissement du serveur
IProtocole *p = new ProtocoleTCP();
p->connect(std::string("tagada"), atoi(argv[1]) ,false);
p->printInfo();
//Attente de données pendant 30 secondes
p->waitData(30);
int width=0, height=0;
unsigned long intsize=0;
size_t recu=0;
//Reception de la taille d'un int, en octet
p->receive( sizeof(char), (unsigned char*) &intsize, &recu);
std::cout << "Taille d'un int en octets : " << intsize << std::endl;
recu=0;
//Reception de largeur des images:
p->waitData(1);
p->receiveInteger( intsize, &width, &recu);
std::cout << "Largeur des images à recevoir : " << width<< std::endl;
recu=0;
//Reception de hauteur des images :
p->waitData(1) ;
p->receiveInteger( intsize, &height, &recu);
std::cout << "Hauteur des images à recevoir : " << height<< std::endl;
recu=0;
/*-------------------------------------------------------------------------
* Création et lancement des deux taches :
*-------------------------------------------------------------------------*/
ITache *tacheStdin = new SendMessages("Tâche d'envois des messages",
p, intsize);
ITache *tacheReception = new ReceiveImages("Tâche de réception des images.",
p, intsize, width, height, tacheStdin);
tacheStdin->start();
tacheReception->start();
do {
MSLEEP(300);
}
while( tacheStdin->isRunning() );
tacheReception->stop();
delete tacheReception;
delete tacheStdin;
//laisse le tps au client de se déconnecter
sleep(2);
//fermer le serveur
p->disconnect();
delete p;
delete logger;
return EXIT_SUCCESS;
} |
Partager