summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/cam/capture.cpp17
-rw-r--r--src/cam/capture.h2
2 files changed, 16 insertions, 3 deletions
diff --git a/src/cam/capture.cpp b/src/cam/capture.cpp
index 113ea49d..7b55fc67 100644
--- a/src/cam/capture.cpp
+++ b/src/cam/capture.cpp
@@ -18,7 +18,7 @@ using namespace libcamera;
Capture::Capture(std::shared_ptr<Camera> camera, CameraConfiguration *config,
EventLoop *loop)
: camera_(camera), config_(config), writer_(nullptr), last_(0), loop_(loop),
- captureCount_(0), captureLimit_(0)
+ queueCount_(0), captureCount_(0), captureLimit_(0)
{
}
@@ -26,6 +26,7 @@ int Capture::run(const OptionsParser::Options &options)
{
int ret;
+ queueCount_ = 0;
captureCount_ = 0;
captureLimit_ = options[OptCapture].toInteger();
@@ -128,7 +129,7 @@ int Capture::capture(FrameBufferAllocator *allocator)
}
for (std::unique_ptr<Request> &request : requests_) {
- ret = camera_->queueRequest(request.get());
+ ret = queueRequest(request.get());
if (ret < 0) {
std::cerr << "Can't queue request" << std::endl;
camera_->stop();
@@ -152,6 +153,16 @@ int Capture::capture(FrameBufferAllocator *allocator)
return ret;
}
+int Capture::queueRequest(Request *request)
+{
+ if (captureLimit_ && queueCount_ >= captureLimit_)
+ return 0;
+
+ queueCount_++;
+
+ return camera_->queueRequest(request);
+}
+
void Capture::requestComplete(Request *request)
{
if (request->status() == Request::RequestCancelled)
@@ -213,5 +224,5 @@ void Capture::processRequest(Request *request)
}
request->reuse(Request::ReuseBuffers);
- camera_->queueRequest(request);
+ queueRequest(request);
}
diff --git a/src/cam/capture.h b/src/cam/capture.h
index d21c95a2..c7c9dc00 100644
--- a/src/cam/capture.h
+++ b/src/cam/capture.h
@@ -32,6 +32,7 @@ public:
private:
int capture(libcamera::FrameBufferAllocator *allocator);
+ int queueRequest(libcamera::Request *request);
void requestComplete(libcamera::Request *request);
void processRequest(libcamera::Request *request);
@@ -43,6 +44,7 @@ private:
uint64_t last_;
EventLoop *loop_;
+ unsigned int queueCount_;
unsigned int captureCount_;
unsigned int captureLimit_;