/*
 * Copyright (c) 2007-2014, Haiku, Inc.
 * Distributed under the terms of the MIT license.
 *
 * Author:
 *              Łukasz 'Sil2100' Zemczak <sil2100@vexillium.org>
 *              Stephan Aßmus <superstippi@gmx.de>
 */


#include "PackageImageViewer.h"


BlockingWindow::BlockingWindow(BRect frame, const char* title, uint32 flags)
        :
        BWindow(frame, title, B_MODAL_WINDOW,
                B_NOT_ZOOMABLE | B_NOT_RESIZABLE | B_NOT_CLOSABLE | flags),
        fSemaphore(-1),
        fReturnValue(0)
{
}


BlockingWindow::~BlockingWindow()
{
}


bool
BlockingWindow::QuitRequested()
{
        ReleaseSem(0);
        return true;
}


int32
BlockingWindow::Go()
{
        int32 returnValue = 0;

        // Since this class can be thought of as a modified BAlert window, no use
        // to reinvent a well fledged wheel. This concept has been borrowed from
        // the current BAlert implementation
        fSemaphore = create_sem(0, "PackageInstaller BlockingWindow");
        if (fSemaphore < B_OK) {
                Quit();
                return returnValue;
        }

        thread_id callingThread = find_thread(NULL);
        BWindow* window = dynamic_cast<BWindow*>(BLooper::LooperForThread(
                callingThread));
        Show();

        if (window != NULL) {
                // Make sure calling window thread, which is blocked here, is updating
                // the window from time to time.
                status_t ret;
                for (;;) {
                        do {
                                ret = acquire_sem_etc(fSemaphore, 1, B_RELATIVE_TIMEOUT, 50000);
                        } while (ret == B_INTERRUPTED);

                        if (ret == B_BAD_SEM_ID)
                                break;
                        window->UpdateIfNeeded();
                }
        } else {
                // Since there are no spinlocks, wait until the semaphore is free
                while (acquire_sem(fSemaphore) == B_INTERRUPTED) {
                }
        }

        returnValue = fReturnValue;

        if (Lock())
                Quit();

        return returnValue;
}


void
BlockingWindow::ReleaseSem(int32 returnValue)
{
        if (fSemaphore >= B_OK) {
                delete_sem(fSemaphore);
                fSemaphore = -1;
                fReturnValue = returnValue;
        }
}