buffqueue Class Reference

Collaboration diagram for buffqueue:

Public Member Functions
	buffqueue ()
void	enqueue (testFile *f)
testFile *	dequeue ()
decltype(queue.size())	size ()
void	endOfInput ()

Private Attributes
std::deque< testFile * >	queue
std::mutex	queue_mutex
std::condition_variable	cv
bool	expectingInput

Detailed Description

Definition at line 51 of file fileopstest.cpp.

Constructor & Destructor Documentation

buffqueue()

buffqueue::buffqueue ( )

inline

Definition at line 58 of file fileopstest.cpp.

: expectingInput(true) {};

Member Function Documentation

dequeue()

testFile* buffqueue::dequeue ( )

inline

Definition at line 64 of file fileopstest.cpp.

                        {
        std::unique_lock<decltype(queue_mutex)> lock(queue_mutex);
 
        while (queue.empty()) {
            if (!expectingInput) {
                return nullptr;
            }
 
            cv.wait(lock);
        }
 
        auto f = queue.front();
        queue.pop_front();
        return f;
    }

References cv, expectingInput, f(), queue, and queue_mutex.

Referenced by collectStats(), and consumer().

Here is the call graph for this function:

Here is the caller graph for this function:

endOfInput()

void buffqueue::endOfInput ( )

inline

Definition at line 82 of file fileopstest.cpp.

                      {
        expectingInput = false;
        cv.notify_all();
    }

References cv, and expectingInput.

Referenced by main().

Here is the caller graph for this function:

enqueue()

void buffqueue::enqueue ( testFile *  f )

inline

Definition at line 59 of file fileopstest.cpp.

                              {
        std::unique_lock<decltype(queue_mutex)> lock(queue_mutex);
        queue.emplace_back(f);
        cv.notify_all();
    }

References cv, f(), queue, and queue_mutex.

Referenced by consumer(), and creator().

Here is the call graph for this function:

Here is the caller graph for this function:

size()

decltype(queue.size()) buffqueue::size ( )

inline

Definition at line 79 of file fileopstest.cpp.

                                  {
        return queue.size();
    }

References queue.

Referenced by creator().

Here is the caller graph for this function:

Member Data Documentation

cv

std::condition_variable buffqueue::cv

private

Definition at line 55 of file fileopstest.cpp.

Referenced by dequeue(), endOfInput(), and enqueue().

expectingInput

bool buffqueue::expectingInput

private

Definition at line 56 of file fileopstest.cpp.

Referenced by dequeue(), and endOfInput().

queue

std::deque<testFile*> buffqueue::queue

private

Definition at line 53 of file fileopstest.cpp.

Referenced by dequeue(), enqueue(), and size().

queue_mutex

std::mutex buffqueue::queue_mutex

private

Definition at line 54 of file fileopstest.cpp.

Referenced by dequeue(), and enqueue().

---

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

• src/fileopstest.cpp (v0.19-24-g0617ca1 with changes)