notepad::CmdQueue Class Reference

#include <notepad_commandqueue.h>

Collaboration diagram for notepad::CmdQueue:

[legend]

Public Member Functions
	CmdQueue ()
	~CmdQueue ()
bool	start ()
void	stop ()
void	add (Command *new_command)
void	flush ()

---

Detailed Description

Definition at line 131 of file notepad_commandqueue.h.

---

Constructor & Destructor Documentation

notepad::CmdQueue::CmdQueue

(

)

Definition at line 35 of file notepad_commandqueue.cpp.

    : thread(0)
    , current_command(0)
    , stop_flag(false)
    , flush_flag(false)
{
}

notepad::CmdQueue::~CmdQueue

(

)

Definition at line 43 of file notepad_commandqueue.cpp.

{
    empty_queue();
}

---

Member Function Documentation

void notepad::CmdQueue::add

(

Command *

new_command

)

Definition at line 162 of file notepad_commandqueue.cpp.

References LOGPRINTF, and notepad::CSemaphore::v().

Referenced by notepad::CNotepadPages::get_page().

{
    LOGPRINTF("entry");
    g_assert(thread); // cmd can only be added when an workerthread is active

    // if being flushed wait for flush to ready
    while (flush_flag) 
    {
        g_thread_yield(); 
    }

    // Append task to the end of the task queue.
    {
        MutexLocker ml(&queue_mutex); //guard
        the_queue.push_back(new_command);
        sem.v();
    }
    LOGPRINTF("exit");
}

Here is the call graph for this function:

Here is the caller graph for this function:

void notepad::CmdQueue::flush

(

)

Definition at line 116 of file notepad_commandqueue.cpp.

References LOGPRINTF, and notepad::CSemaphore::v().

Referenced by notepad::CNotepadPages::delete_page(), notepad::CNotepadPages::get_page(), and notepad::CNotepadPages::insert_page().

{
    LOGPRINTF("entry");
    if (thread == 0)
    {
        return;
    }
    flush_flag = true;
    sem.v();

    LOGPRINTF("exit");
}

Here is the call graph for this function:

Here is the caller graph for this function:

bool notepad::CmdQueue::start

(

)

Definition at line 129 of file notepad_commandqueue.cpp.

References LOGPRINTF.

Referenced by notepad::CNotepadPages::init().

{
    LOGPRINTF("entry");
    if (thread != 0)
    {
        // The thread has been started.
        return false;
    }

    thread = g_thread_create(thread_func, this, TRUE, 0);
    LOGPRINTF("exit");
    return thread != 0;
}

Here is the caller graph for this function:

void notepad::CmdQueue::stop

(

void

)

Definition at line 143 of file notepad_commandqueue.cpp.

References LOGPRINTF, and notepad::CSemaphore::v().

Referenced by notepad::CNotepadPages::stop().

{
    LOGPRINTF("entry");
    if (thread == 0)
    {
        return;
    }
    stop_flag = true;
    sem.v();

    // Wait for worker thread to die.
    g_thread_join(thread);
    LOGPRINTF("thread is stopped");

    // Set the thread to be NULL
    thread = 0;
    LOGPRINTF("exit");
}

Here is the call graph for this function:

Here is the caller graph for this function:

---

The documentation for this class was generated from the following files:

• notepad_commandqueue.h
• notepad_commandqueue.cpp