---

no_prop_channel.h

Go to the documentation of this file.

/**********************************************************************************************/
/*************************** UDP GROUP CHANNEL CLASS  *************************/
/**************************** Jean FANCHON. LAAS-CNRS*************************/
/**********************************************************************************************/
#include <stdio.h>  
#include <stdlib.h>
#include <sys/types.h>  
#include <sys/socket.h>  
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <iostream.h>
#include <string.h>
#include <fstream.h>
#include <pthread.h>
#include <unistd.h>
#include <errno.h>

// #include "channel.h"
// #include "channeluser.h"

#define MAX_MEMBER 15 

#define BASEPORT 18131

/*******************************************************************************/
/******************************************************************************/
 
class total_order_channel;

class group_admin;
        
class no_prop_channel { // :public channel {

/********************************************************************/  
/*interface*/

public:         

        no_prop_channel(total_order_channel *, const char * , group_admin  *);
        
        no_prop_channel(total_order_channel * pt, int id , char * file, group_admin  *);
        
        ~no_prop_channel();
        
/********************************************************************/  
/* communication */     

        int read_socket() ;     // code for the reading thread on UDP port      

        int broadcast(char *, int);
        
        int multicast(int , int *, char* , int ) ; 
        
        int unicast(int , char *, int);

/********************************************************************/  
/* membership */        
                
        int init_membership(char *, char * , int);
        
        int get_mynode();
        
        int get_myport();
        
        int my_ident;           /* local member ident */
        
private :  
        
        total_order_channel *my_user;           // user's address       

/********************************************************************/  
/* networking */                

        int sServ;   //local socket file number
        
        pthread_t read_thread;  // struct for the reading thread on UDP port 


/********************************************************************/  
/*   Group data */      

        group_admin  *my_group;

        char hostname[15];
        
        int my_nodeid;
        
        int my_port;
           

};

---