acl/lib_fiber/samples/server3/main.cpp

148 lines
2.9 KiB
C++

#include "stdafx.h"
#include <stdio.h>
#include <stdlib.h>
class fiber_client : public acl::fiber {
public:
fiber_client(acl::socket_stream* conn) : conn_(conn) {}
protected:
// @override
void run(void) {
printf("fiber-%d-%d running\r\n", get_id(), acl::fiber::self());
char buf[8192];
while (true) {
int ret = conn_->read(buf, sizeof(buf), false);
if (ret == -1) {
break;
}
if (conn_->write(buf, ret) == -1) {
break;
}
}
delete this;
}
private:
acl::socket_stream* conn_;
~fiber_client(void) {
delete conn_;
}
};
static void test_file(void) {
const char* path = "./Makefile";
acl::string buf;
acl::ifstream in;
if (in.open_read(path) == false) {
printf("open file %s error %s\r\n", path, acl::last_serror());
} else if (in.gets(buf) == false) {
printf("gets from %s error %s", path, acl::last_serror());
} else {
printf("gets ok: %s\r\n", buf.c_str());
}
}
class fiber_server : public acl::fiber {
public:
fiber_server(acl::server_socket& ss) : ss_(ss) {}
~fiber_server(void) {}
protected:
// @override
void run(void) {
test_file();
while (true) {
acl::socket_stream* conn = ss_.accept();
if (conn == NULL) {
printf("accept error %s\r\n", acl::last_serror());
break;
}
printf("accept ok, fd: %d\r\n", conn->sock_handle());
// create one fiber for one connection
fiber_client* fc = new fiber_client(conn);
// start the client fiber
fc->start();
}
}
private:
acl::server_socket& ss_;
};
class thread_server : public acl::thread {
public:
thread_server(acl::server_socket& ss) : ss_(ss) {}
~thread_server(void) {}
protected:
void* run(void) {
fiber_server fs(ss_);
fs.start(); // start listen fiber
acl::fiber::schedule(); // start fiber schedule
return NULL;
}
private:
acl::server_socket& ss_;
};
static void usage(const char* procname) {
printf("usage: %s -h [help] -s listen_addr -t nthreads\r\n", procname);
}
int main(int argc, char *argv[]) {
int ch, nthreads = 1;
acl::acl_cpp_init();
acl::string addr("127.0.0.1:9006");
acl::log::stdout_open(true);
while ((ch = getopt(argc, argv, "hs:t:")) > 0) {
switch (ch) {
case 'h':
usage(argv[0]);
return 0;
case 's':
addr = optarg;
break;
case 't':
nthreads = atoi(optarg);
break;
default:
break;
}
}
acl::server_socket ss;
if (ss.open(addr) == false) {
printf("listen %s error %s\r\n", addr.c_str(), acl::last_serror());
return 1;
}
printf("listen %s ok\r\n", addr.c_str());
std::vector<acl::thread*> threads;
for (int i = 0; i < nthreads; i++) {
acl::thread* thread = new thread_server(ss);
thread->start();
threads.push_back(thread);
}
for (std::vector<acl::thread*>::iterator it = threads.begin();
it != threads.end(); ++it) {
(*it)->wait(NULL);
delete *it;
}
return 0;
}