Function dataRequestFunction

src/test/test_databuffer.cpp:27–65

}

void dataRequestFunction() {
	std::cout << "Starting data request function..." << std::endl;
	
	// Create and share condition variable with DataBuffer class.
	std::mutex dataRequestMtx;
	DataBuffer::setDataRequestCondition(&dataRequestCv);
	
	std::cout << "Entering data request loop..." << std::endl;
	
	while (running) {
		// Wait for the condition to be signalled.
		std::unique_lock<std::mutex> lk(dataRequestMtx);
		dataRequestCv.wait(lk);
		
		if (!running) { 
			std::cout << "Shutting down data request function..." << std::endl;
			break;
		}
				
		// Write into the buffer. We use a 10 byte pattern.
		std::string data;
		for (uint32_t i = 0; i < 10; ++i) {
			data.append(1, (char) lastnum++);
		}
		
		uint32_t wrote = DataBuffer::write(data);
		
		std::cout << "Wrote " << wrote << " \t- ";
		for (uint32_t i = 0; i < wrote; ++i) {
			std::cout << (uint16_t) data[i] << " ";
		}
		
		std::cout << std::endl;
		
		if (lastnum >= 100) {
			DataBuffer::setEof(true);
		}
	}
}


int main() {