Commit 9a12dbb5 authored by jan.koester's avatar jan.koester
Browse files

wait lock removed

parent 313249b8
Loading
Loading
Loading
Loading
+1 −6
Original line number Diff line number Diff line
@@ -112,13 +112,8 @@ namespace netplus {
    unsigned int poll::waitEventHandler() {
        bool expected = false;

        if(!_WaitLock.compare_exchange_strong(expected,true))
            return 0;

        int ret = epoll_wait(_pollFD, (struct epoll_event*)_Events, _ServerSocket->getMaxconnections(), -1);

        _WaitLock.store(false);

        if (ret <0 ) {
            NetException exception;
            exception[NetException::Error] << "waitEventHandler: epoll wait failure";
@@ -280,8 +275,8 @@ namespace netplus {
                try {
                    int wfd = eventptr->waitEventHandler();
                    for (int i = 0; i < wfd; ++i) {
                        try {
                        int lock=eventptr->trylockCon(i);
                        try {
                            if(lock == poll::LockState::LOCKED){
                                try{
                                    switch (eventptr->pollState(i)) {