/*
 * Copyright (C) 2016 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.
 */

#define LOG_TAG "AAudioService"
//#define LOG_NDEBUG 0
#include <utils/Log.h>

#include <pthread.h>

#include <aaudio/AAudioDefinitions.h>

#include "AAudioThread.h"

using namespace aaudio;


AAudioThread::AAudioThread() {
    // mThread is a pthread_t of unknown size so we need memset.
    memset(&mThread, 0, sizeof(mThread));
}

void AAudioThread::dispatch() {
    if (mRunnable != nullptr) {
        mRunnable->run();
    } else {
        run();
    }
}

// This is the entry point for the new thread created by createThread().
// It converts the 'C' function call to a C++ method call.
static void * AAudioThread_internalThreadProc(void *arg) {
    AAudioThread *aaudioThread = (AAudioThread *) arg;
    aaudioThread->dispatch();
    return nullptr;
}

aaudio_result_t AAudioThread::start(Runnable *runnable) {
    if (mHasThread) {
        return AAUDIO_ERROR_INVALID_STATE;
    }
    mRunnable = runnable; // TODO use atomic?
    int err = pthread_create(&mThread, nullptr, AAudioThread_internalThreadProc, this);
    if (err != 0) {
        ALOGE("AAudioThread::pthread_create() returned %d", err);
        // TODO convert errno to aaudio_result_t
        return AAUDIO_ERROR_INTERNAL;
    } else {
        mHasThread = true;
        return AAUDIO_OK;
    }
}

aaudio_result_t AAudioThread::stop() {
    if (!mHasThread) {
        return AAUDIO_ERROR_INVALID_STATE;
    }
    int err = pthread_join(mThread, nullptr);
    mHasThread = false;
    // TODO convert errno to aaudio_result_t
    return err ? AAUDIO_ERROR_INTERNAL : AAUDIO_OK;
}