---

appli.cpp

Go to the documentation of this file.

#include "total_order_channel.h"
#include <pthread.h>
#include <iostream.h>
#include <unistd.h>
#include <stdlib.h>

        
int cur = 0;
int last = 0;  
pthread_mutex_t  mumute;
char message[500];
int main(int argc, char* argv[]) {
//programme de test de la classe total_order_channel

  
        int i, j, k, opt, res;
        char * ch;
        
        char * file, * ipadd;

        int ident, nb_iter, nb_members;
        total_order_channel * com;
  
        if(argc!=5) {
        
                cout << " Parametre incorrects:  appli opt ipadd file nb_iteration " << endl;
                return(-1);
        }
        cout << "depart appli" << endl;
        
        opt =atoi(argv[1]);   // 0: initialiser a partir de fichier , 1: s'inscrire aupres de membre
        ipadd = argv[2];        // si flag = 0 : numero d'ident, si flag = 1 :adresse ip[15]
        file = argv[3] ;        // si flag = 0 : liste de triplets, si flag = 1 : ( port, host)
        nb_iter = atoi(argv[4]);
        
        com = new total_order_channel(opt , file , ipadd) ;   
        cout << "ds l'appli apres le constructeur" << endl;


        sprintf(message, " *** numero  ");

        j=strlen(message);

        for(i=0; i<nb_iter ; i++) {
                sprintf(&message[j], "%d !!!!!!!! ***", i);
                cout << "envoi n* " << i << endl ;
                
                res = com->broadcast(message, strlen(message));
                if ( i % 12 == 0 ) sleep( 1); 
                // if ( i % 3 == 0 ) for ( k=0 ; k< 1000*nb_iter ;k++) ; 
                
                if( res == -2) { 
                        i--; sleep( 1); }
        }
  
        sleep( 40);
        pthread_join(NULL, NULL);
  
        cout << "Fin du prog de test" << endl;
  
}

void receive( char * message, int size ) {

        cout << " HELLO  message recu: " << message << endl;

        }

        

        

---