Commit 2cb647b5 authored by jan.koester's avatar jan.koester
Browse files

fixed

parent 936b9894

src/event/epoll.cpp

+0 −3
Original line number Diff line number Diff line
@@ -50,9 +50,6 @@ SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 


namespace netplus {



    std::atomic<bool> event::Running(true);

    std::atomic<bool> event::Restart(false);



    static std::vector<socket*> SSOCKETS;

    static std::map<int, std::shared_ptr<con>> CONNECTIONS;

src/event/iocp.cpp

+0 −4
Original line number Diff line number Diff line
@@ -53,10 +53,6 @@ SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 


namespace netplus {



    // required by eventapi.h

    std::atomic<bool> event::Restart(false);

    std::atomic<bool> event::Running(true);



    // -------------------------------------------------------------------------

    // AcceptContext matches socket.h concept: keep accept socket + buffer

    // -------------------------------------------------------------------------

src/event/kqueue.cpp

+0 −2
Original line number Diff line number Diff line
@@ -55,8 +55,6 @@ SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 
#define BLOCKSIZE 16384



namespace netplus {

    std::atomic<bool> event::Running(true);

    std::atomic<bool> event::Restart(false);



    std::mutex POLL_HANDLER_MUTEX;

src/event/poll.cpp

+0 −3
Original line number Diff line number Diff line
@@ -109,9 +109,6 @@ SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 


namespace netplus {



    std::atomic<bool> event::Running(true);

    std::atomic<bool> event::Restart(false);



    std::vector<socket*> SSOCKETS;

    std::map<int,con*>   CONNECTIONS;

src/eventapi.h

+2 −2
Original line number Diff line number Diff line
@@ -59,8 +59,8 @@ namespace netplus { 


            virtual ~event();



            static std::atomic<bool> Restart;

	        static std::atomic<bool> Running;

            static inline std::atomic<bool> Restart{false};

	        static inline std::atomic<bool> Running{true};



            int                      threads;

        protected: