lechod.c

这是基于C语言开发的分布式搜索源代码

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sbase.h>
SBASE *sb = NULL;

void cb_packet_handler(const HANDLER *handler, const BUFFER *packet)
{
	if(handler)
		sb->push_chunk(handler, packet->data, packet->size);
}

int main(int argc, char **argv)
{
	int port = 1024;
	if(argc < 2)
	{
		fprintf(stderr, "Usage:%s port\n", argv[0]);
		_exit(-1);
	}	
	port = atoi(argv[1]);	

	 if((sb = sbase()) == NULL)
        {
                exit(EXIT_FAILURE);
                return -1;
        }
        /* base INET setting */
        sb->sock_t = TCP_T; /* socket type*/
        sb->domain = AF_INET;
        sb->family = AF_INET;
        sb->ip     = NULL;
        sb->port   = port;
        sb->backlog = 60000;
        sb->logfile = "/tmp/lechod_access_log";
        sb->packet_t = PACKET_T_C;
        sb->packet_len = 10240 ;
        sb->delimiter = "\r\n";
        sb->delimiter_len = 2 ;
        sb->buf_size  = 1024 * 1024 * 16;
        //sb->server_type = SERVER_FILE;
        sb->max_threads = 32 ;
        sb->max_connections = 65535;
        sb->heartbeat_interval  = 600000000u;
        sb->sleep_usec          = 10u;
        sb->conn_timeout        = 600000000u;
        //sb->packet_reader = &packet_reader;
        sb->packet_handler = &cb_packet_handler;
        //sb->data_handler = &data_handler;

        if(sb->init(sb) == 0 ){
                fprintf(stdout, "Initialized successed\n");
                sb->start(sb);
        }else{
                fprintf(stderr, "Initialized failed\n");
                _exit(-1);
        }
}