echo_server.cpp

#include <mutex>
#include <string>
#include <thread>
#include <string.h> // for strlen
#include <iostream>

#include "include/cppnet.h"

using namespace cppnet;

static const int __buf_len = 2048;
static const char* __buf_spilt = "\r\n";

void ReadFunc(Handle handle, cppnet::BufferPtr data, uint32_t len) {
    char msg_buf[__buf_len] = {0};
    uint32_t need_len = 0;
    uint32_t find_len = (uint32_t)strlen(__buf_spilt);
    // get recv data to send back.
    uint32_t size = data->ReadUntil(msg_buf, __buf_len, __buf_spilt, find_len, need_len);
    handle->Write(msg_buf, size);
}

void ConnectFunc(Handle handle, uint32_t error) {
    static std::mutex mutex;
    std::lock_guard<std::mutex> lock(mutex);
    if (error == CEC_CLOSED) {
        std::cout << "remote closed connect : " << handle->GetSocket() << std::endl;
    } else if (error != CEC_SUCCESS) {
        std::cout << "something err while connect : " << error << std::endl;
    }
}


int main() {

    // start 4 threads
    cppnet::CppNet net;
    net.Init(4);

    net.SetAcceptCallback(ConnectFunc);
    net.SetReadCallback(ReadFunc);
    net.SetDisconnectionCallback(ConnectFunc);

    net.ListenAndAccept("0.0.0.0", 8921);

    net.Join();
}