modules/platforms/cpp/network/os/win/src/network/win_async_worker_thread.h

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#ifndef _IGNITE_NETWORK_WIN_ASYNC_WORKER_THREAD
#define _IGNITE_NETWORK_WIN_ASYNC_WORKER_THREAD

#include <stdint.h>

#include <ignite/ignite_error.h>

#include <ignite/common/concurrent.h>

namespace ignite
{
    namespace network
    {
        /** Windows async client pool. */
        class WinAsyncClientPool;

        /**
         * Async pool worker thread.
         */
        class WinAsyncWorkerThread : protected common::concurrent::Thread
        {
        public:
            /**
             * Constructor.
             */
            explicit WinAsyncWorkerThread();

            /**
             * Start thread.
             *
             * @param clientPool Client pool.
             * @param iocp Valid IOCP instance handle.
             */
            void Start(WinAsyncClientPool& clientPool, HANDLE iocp);

            /**
             * Stop thread.
             */
            void Stop();

        private:
            /**
             * Run thread.
             */
            virtual void Run();

            /** Flag to signal that thread should stop. */
            volatile bool stopping;

            /** Client pool. */
            WinAsyncClientPool* clientPool;

            /** IO Completion Port. Windows-specific primitive for asynchronous IO. */
            HANDLE iocp;
        };
    }
}

#endif //_IGNITE_NETWORK_WIN_ASYNC_WORKER_THREAD