unit-x/kcp-cpp

C++ Wrapper around KCP

kcp-cpp's Issues

When receiving a relatively large data packet (larger than 8192), the last packet will block for 8 to 10 seconds at mKissnetSocket.recv(receiveBuffer).

When receiving a relatively large data packet (larger than 8192), the last packet will block for 8 to 10 seconds at mKissnetSocket.recv(receiveBuffer).

        const uint64_t tickStart = GetTickCount64(); 
        auto[received_bytes, status] = mKissnetSocket.recv(receiveBuffer); 
        const auto tick = GetTickCount64() - tickStart;
        if (tick > 1000) {
            KCP_LOGGER(false, LOGG_NOTIFY, "Recv Time:  " << tick);   // <----------  10 Second !!!!
        }

The server is developed using kcp-go with the following parameters:

    kcpConn.SetNoDelay(1, 10,2,1)
    kcpConn.SetWindowSize(128, 128)

kcp-cpp:

	KCPSettings lSettingsClient;
	lSettingsClient.mNoDelay = true;
	lSettingsClient.mInterval = 10;
	lSettingsClient.mResend = 2;
	lSettingsClient.mFlow = false;
	lSettingsClient.mMtu = 1400;
	lSettingsClient.mSndWnd = 128;
	lSettingsClient.mRcvWnd = 128;

VS2022 Run Test Error

KCP-cpp test
Connecting IP:port > 127.0.0.1:61263
The server is not active.
The server timed out a client.

Can't this project communicate with kcp-go in go?

Does it support communication as a client and kcp-go server? My own test results are not good.

can support kcp-go?

I try to use this main.cpp to connect kcp-go(golang) server,But failed

kcp-go can't accept any data from client

and kcp-go send data to client,but client can't get any data

main.cpp:
`KCPNetClient lKcpClient;

KCPSettings lSettingsClient;
if(lKcpClient.configureKCP(lSettingsClient,
                           gotDataClient,
                           noConnectionClient,
                           "127.0.0.1",
                           12345,
                           10,
                           nullptr)) {
    std::cout << "Failed to configure the KCP Client" << std::endl;
}

lKcpClient.sendData((const char*)lData.data(), 4000);`

main.go:
`package main

import (
"log"

"github.com/xtaci/kcp-go/v5"

)

func main() {

if listener, err := kcp.ListenWithOptions("127.0.0.1:12345", nil, 10, 3); err == nil {
    // spin-up the client
    for {
        s, err := listener.AcceptKCP()
        s.SetNoDelay(1, 10, 2, 1)
        if err != nil {
            log.Fatal(err)
        }
        go handleEcho(s)
    }
} else {
    log.Fatal(err)
}

}

// handleEcho send back everything it received
func handleEcho(conn *kcp.UDPSession) {
buf := make([]byte, 4096)
for {
n, err := conn.Read(buf)
if err != nil {
log.Println(err)
return
}
println("get:" + string(buf[:n]))
n, err = conn.Write(buf[:n])
if err != nil {
log.Println(err)
return
}
}
}
`

How to auto reconnect to kcp server?

I found that after the kcpClient triggers the disconnection (noConnectionClient), when I call sendData again to send data, there is no response in the gotDataClient callback function after the server responds.

Network thread

In the KCP NetServer::netWorkerServer function, we start a network thread and exit if there are no incoming messages. That is, when the server starts, it will shut down. This is very strange, considering that the server must work constantly and wait for clients to connect

    while (true) {
        auto[received_bytes, status] = mKissnetSocket.recv(receiveBuffer,0, &receiveConnection);
        if (!received_bytes || status != kissnet::socket_status::valid) {
            KCP_LOGGER(false, LOGG_NOTIFY, "serverWorker quitting");
            break;
        }