udptomysql2.c

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <time.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/ip.h>
#include <netinet/tcp.h>
#include <linux/if.h>
#include <linux/if_ether.h>
#include <linux/if_packet.h>
#include <ctype.h>
#include "sock.h"

// #define DEBUG 1

#define MAXLEN 16384

#include "db.h"

#include "tomysql2.c"

void Process(int u_fd)
{
	char buff[MAXLEN];
	int n;

	while (1) {
		n = recv(u_fd, buff, MAXLEN, 0);
		if (n < 0) {
			err_sys("recv get %d from udp client\n", n);
			exit(0);
		}
		if (n == 0)
			continue;
		buff[n] = 0;
#ifdef DEBUG
		err_msg("C: %s", buff);
#endif
		ToMysql(buff, n);
	}
}

int main(int argc, char *argv[])
{
	int u_fd;
	int llen;

	signal(SIGCHLD, SIG_IGN);

	if (argc != 1)
		err_quit("usage:  udptomysql\n");

#ifndef DEBUG
	daemon_init("udptomysql", LOG_DAEMON);
	while (1) {
		int pid;
		pid = fork();
		if (pid == 0)	// i am child, will do the job
			break;
		else if (pid == -1)	// error
			exit(0);
		else
			wait(NULL);	// i am parent, wait for child
		sleep(2);	// if child exit, wait 2 second, and rerun
	}
#endif
	err_msg("starting\n");
	u_fd = Udp_server("127.0.0.1", "14583", (socklen_t *) & llen);

#ifdef DEBUG
	err_msg("u_fd=%d\n", u_fd);
#endif
	mysql = connectdb();
	Process(u_fd);
	return 0;
}