socket_to_server.c

Ad-hoc的路由协议

#include <stdio.h>
#include<sys/types.h>
#include<sys/socket.h>
#include<sys/un.h>
#include<netdb.h>
#include<unistd.h>

#include "socket_to_server.h"
#include "timer_queue.h"
static int connect_fd;

void socket_to_server_init()
{
	int retval;
	struct sockaddr_in server_addr;
	connect_fd=socket(PF_INET,SOCK_STREAM,0);
	if(connect_fd<0)
	{
		perror("cannot create communication socket");
	} 
	memset(&server_addr, 0, sizeof(server_addr));
	server_addr.sin_family = AF_INET;
	server_addr.sin_port = htons(CS_PORT);
	server_addr.sin_addr.s_addr =inet_addr("192.168.111.10");
	retval =connect(connect_fd, (struct sockaddr *) &server_addr,sizeof(struct sockaddr));

	if (retval < 0) {
	    perror("connect failed ");
	    exit(-1);
	}
}

void socket_to_server_send(struct routing_table  rt_tb,struct in_addr src, int len)
{
	struct timeval now;
	char send_buf[MAX_SENDBUF];
	int i;
	struct data_to_server data;
		
	/*if ((send_buf = (struct data_to_server *) malloc(sizeof(data_to_server))) == NULL) {
		fprintf(stderr, "Malloc failed!\n");
	}*/
	memset(send_buf,0,sizeof(struct data_to_server));
	//get the struct data_to_server data value  from the system time,local address and the current route table 
	gettimeofday(&now, NULL);
	data.now=now;
	data.src =src;
	for (i = 0; i < RT_TABLESIZE; i++) 
	{
			memset(&data.rt_tb.tbl[i], 0, sizeof(rt_table_t));
			memcpy(&data.rt_tb.tbl[i],& rt_tb.tbl[i] ,sizeof(rt_table_t ));
	}
	len=sizeof(data);
	memcpy(send_buf,&data,len);
	write(connect_fd,send_buf,sizeof(send_buf));
	//timer_set_timeout(&server_timer, SERVER_TIMEOUT);
}
	
void socket_to_server_cleanup(void)
{
	close(connect_fd);
}