#include"net.h"#include<stdio.h>#include<pthread.h>#include<sys/types.h>#include<netinet/in.h>#include<sys/socket.h>#include<unistd.h>#include<fcntl.h>#include<sys/stat.h>#include<netdb.h>#include<string.h>#define SERVPORT  3333#define SERVPORT_V 3334#define IMG_LEN 4000#define BACKLOG 3#define filename "shot.jpeg"net * n;char  audio_play_buf[AUDIO_BUF_SIZE];char  audio_rec_buf [AUDIO_BUF_SIZE];int sockfd;int sockfd_v;bool receive_stop;bool receive_v_stop;void * receiver(void * data){	data = data;	int count;	while(!receive_stop)	{		if((count = recv(sockfd,audio_play_buf,AUDIO_BUF_SIZE,0))>0)		{			n->emit_play(count);		}		else 		{			//printf("audio receive error \n");			return NULL;		}	}	return NULL;}void net::emit_play(int count){	emit sig_play(count);}void senda(char * a,int len){	send(sockfd,a,len,0);}void net::send_audio(int count){	senda(audio_rec_buf,count);}char img[IMG_LEN];char send_ins[]="one send is ended";void * receive_v(void * data){	data = data;	int  fd;	int count;	while(!receive_v_stop)	{		if((fd = open(filename,O_WRONLY))<0)				printf("open img file error \n");		while(1)		{			if((count=recv(sockfd_v,img,IMG_LEN,0))>0)			{				//printf("received bytes %d \n",count);			}			if(strstr(img,send_ins)!=NULL)			{				break;			}			if((count = write(fd,img,count))<0)				printf("write imge error \n");					}		//printf("one img received \n");		close(fd);		n->emit_refresh_img();			}	return NULL;}void net::emit_refresh_img(){	emit sig_refresh_img();}void net::start_receive_v(){	receive_v_stop = false;	pthread_create(&th_v_receiver,NULL,receive_v,NULL);}void net::stop_receive_v(){	receive_v_stop = true;}net::net(){	n = this;	mpaudio_play_buf = audio_play_buf;	mpaudio_rec_buf= audio_rec_buf;	receive_stop = true;	receive_v_stop = true;}net::~net(){}void net::contact_consumer(){	emit s_contact_consumer(audio_play_buf,audio_rec_buf);}void init_connection(){       printf("connecting... \n");    int ser_fd,sin_size;    int ser_fd_v;    void * retval;    struct sockaddr_in my_addr,their_addr;    if((ser_fd = socket(AF_INET,SOCK_STREAM,0))==-1)	printf("ser socket create error ... \n");    my_addr.sin_family = AF_INET;    my_addr.sin_port = htons(SERVPORT);    my_addr.sin_addr.s_addr = INADDR_ANY;    bzero(&(my_addr.sin_zero),8);    if(bind(ser_fd,(struct sockaddr *)&my_addr,sizeof(struct sockaddr))==-1)	printf("audio bind error \n");    if(listen(ser_fd,BACKLOG)==-1)	printf("audio listen error \n");    if((sockfd = accept(ser_fd,(struct sockaddr *)&their_addr,(socklen_t*)&sin_size))==-1)	printf("audio accept error \n");    else printf("audio connected ...\n");        if((ser_fd_v = socket(AF_INET,SOCK_STREAM,0))==-1)	printf(" video ser socket create error ... \n");    my_addr.sin_family = AF_INET;    my_addr.sin_port = htons(SERVPORT_V);    my_addr.sin_addr.s_addr = INADDR_ANY;    bzero(&(my_addr.sin_zero),8);    if(bind(ser_fd_v,(struct sockaddr *)&my_addr,sizeof(struct sockaddr))==-1)	printf("video bind error \n");    if(listen(ser_fd_v,BACKLOG)==-1)	printf("video listen error \n");    if((sockfd_v = accept(ser_fd_v,(struct sockaddr *)&their_addr,(socklen_t*)&sin_size))==-1)	printf("video accept error \n");    else printf("video connected video ...\n");    }void net::init_net(){	init_connection();}void net::start_receive(){	receive_stop = false;	pthread_create(&th_receiver,NULL,receiver,NULL);}void net::stop_receive(){	receive_stop = true;}