// Copyright (C) 2014 The Android Open Source Project
//
// Licensed 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 EMUGL_CONDITION_VARIABLE_H
#define EMUGL_CONDITION_VARIABLE_H

#include "emugl/common/mutex.h"
#include "emugl/common/pod_vector.h"

#ifdef _WIN32
#include <windows.h>
#else
#include <pthread.h>
#endif

namespace emugl {

// A class that implements a condition variable, which can be used in
// association with a Mutex to blocking-wait for specific conditions.
// Useful to implement various synchronization data structures.
// For an example, see ::emugl::MessageChannel.
class ConditionVariable {
public:
#ifdef _WIN32

    // Default constructor.
    ConditionVariable();

    // Destructor.
    ~ConditionVariable();

    // Wait until the condition variable is signaled. Note that spurious
    // wakeups are always a possibility, so always check the condition
    // in a loop, i.e. do:
    //
    //    while (!condition) { condVar.wait(&lock); }
    //
    // instead of:
    //
    //    if (!condition) { condVar.wait(&lock); }
    //
    void wait(Mutex* userLock);

    // Signal that a condition was reached. This will wake at most one
    // waiting thread that is blocked on wait().
    void signal();

private:
    PodVector<HANDLE> mWaiters;
    Mutex mLock;

#else  // !_WIN32

    // Note: on Posix systems, make it a naive wrapper around pthread_cond_t.

    ConditionVariable() {
        pthread_cond_init(&mCond, NULL);
    }

    ~ConditionVariable() {
        pthread_cond_destroy(&mCond);
    }

    void wait(Mutex* userLock) {
        pthread_cond_wait(&mCond, &userLock->mLock);
    }

    void signal() {
        pthread_cond_signal(&mCond);
    }

private:
    pthread_cond_t mCond;

#endif  // !_WIN32
};

}  // namespace emugl

#endif  // EMUGL_CONDITION_VARIABLE_H