hsha.cc

#include <handy/handy.h>

using namespace std;
using namespace handy;

int main(int argc, const char* argv[]) {
    setloglevel("TRACE");
    EventBase base;
    HSHAPtr hsha = HSHA::startServer(&base, "", 99, 4);
    exitif(!hsha, "bind failed");
    Signal::signal(SIGINT, [&, hsha]{ base.exit(); hsha->exit(); signal(SIGINT, SIG_DFL);});

    hsha->onMsg(new LineCodec, [](const TcpConnPtr& con, const string& input){
        int ms = rand() % 1000;
        info("processing a msg");
        usleep(ms * 1000);
        return util::format("%s used %d ms", input.c_str(), ms);
    });
    for (int i = 0; i < 5; i ++) {
        TcpConnPtr con = TcpConn::createConnection(&base, "localhost", 99);
        con->onMsg(new LineCodec, [](const TcpConnPtr& con, Slice msg) {
            info("%.*s recved", (int)msg.size(), msg.data());
            con->close();
        });
        con->onState([](const TcpConnPtr& con) {
            if (con->getState() == TcpConn::Connected) {
                con->sendMsg("hello");
            }
        });
    }
    base.runAfter(1000, [&, hsha]{base.exit(); hsha->exit(); });
    base.loop();
    info("program exited");
}