Commit 7e7f40a3 authored by jan.koester's avatar jan.koester
Browse files

test

parent b8b24cf7

src/event/kqueue.cpp

+5 −5
Original line number Diff line number Diff line
@@ -718,8 +718,8 @@ namespace netplus { 
        signal(SIGPIPE, SIG_IGN);



    MAINWORKERLOOP:

        _kqfd = kqueue();

        if (_kqfd < 0) {

        _pollFD = kqueue();

        if (_pollFD < 0) {

            NetException e;

            e[NetException::Critical] << "runEventloop: can't create kqueue";

            throw e;
@@ -728,7 +728,7 @@ namespace netplus { 
        struct kevent setevent;

        EV_SET(&setevent, _ServerSocket->fd(), EVFILT_READ, EV_ADD, 0, 0, nullptr);



        if (kevent(_kqfd, &setevent, 1, nullptr, 0, nullptr) < 0) {

        if (kevent(_pollFD, &setevent, 1, nullptr, 0, nullptr) < 0) {

            NetException e;

            e[NetException::Critical] << "runEventloop: kevent ADD server failed";

            throw e;
@@ -736,7 +736,7 @@ namespace netplus { 


        EventWorkerArgs eargs;

        eargs.ssocket = _ServerSocket;

        eargs.kqfd = _kqfd;

        eargs.kqfd = _pollFD;

        eargs.timeout = _Timeout;

        eargs.event = this;
@@ -765,7 +765,7 @@ namespace netplus { 
        for (auto& t : threadpool)

            pthread_join(t, nullptr);



        close(_kqfd);

        close(_pollFD);



        if (event::Restart) {

            event::Restart = false;

src/socket.h

+1 −1
Original line number Diff line number Diff line
@@ -365,7 +365,7 @@ namespace netplus { 
		std::shared_ptr<netplus::x509cert> getCert() const { return _cert; }



		// Check if there's buffered data waiting to be processed

		bool hasBufferedData() const { return !_rx_tcp_buf.empty(); }

		bool hasBufferedData() const override { return !_rx_tcp_buf.empty(); }



		// Push received data directly into the buffer (called by IOCP)

		// Caller must hold con::event_mutex