/* SPDX-License-Identifier: GPL-2.0-or-later */ /* * Copyright (C) 2019, Google Inc. * * event-thread.cpp - Threaded event test */ #include #include #include #include #include #include #include #include "test.h" using namespace std; using namespace libcamera; class EventHandler : public Object { public: EventHandler() : notified_(false) { int ret = pipe(pipefd_); if (ret < 0) { ret = errno; cout << "pipe() failed: " << strerror(ret) << endl; } notifier_ = new EventNotifier(pipefd_[0], EventNotifier::Read, this); notifier_->activated.connect(this, &EventHandler::readReady); } ~EventHandler() { delete notifier_; close(pipefd_[0]); close(pipefd_[1]); } int notify() { std::string data("H2G2"); ssize_t ret; memset(data_, 0, sizeof(data_)); size_ = 0; ret = write(pipefd_[1], data.data(), data.size()); if (ret < 0) { cout << "Pipe write failed" << endl; return TestFail; } return TestPass; } bool notified() const { return notified_; } private: void readReady() { size_ = read(notifier_->fd(), data_, sizeof(data_)); notified_ = true; } EventNotifier *notifier_; int pipefd_[2]; bool notified_; char data_[16]; ssize_t size_; }; class EventThreadTest : public Test { protected: int run() { Thread thread; thread.start(); /* * Fire the event notifier and then move the notifier to a * different thread. The notifier will not notice the event * immediately as there is no event dispatcher loop running in * the main thread. This tests that a notifier being moved to a * different thread will correctly process already pending * events in the new thread. */ EventHandler handler; handler.notify(); handler.moveToThread(&thread); this_thread::sleep_for(chrono::milliseconds(100)); /* Must stop thread before destroying the handler. */ thread.exit(0); thread.wait(); if (!handler.notified()) { cout << "Thread event handling test failed" << endl; return TestFail; } return TestPass; } }; TEST_REGISTER(EventThreadTest) ep'>log msg
path: root/src/android/jpeg/post_processor_jpeg.h
blob: 98309b012a3beb46b87cda55a394604aa99078c9 (plain) 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

/* SPDX-License-Identifier: LGPL-2.1-or-later */
/*
 * Copyright (C) 2020, Google Inc.
 *
 * post_processor_jpeg.h - JPEG Post Processor
 */

#pragma once

#include "../post_processor.h"
#include "encoder_libjpeg.h"
#include "thumbnailer.h"

#include <libcamera/geometry.h>

class CameraDevice;

class PostProcessorJpeg : public PostProcessor
{
public:
	PostProcessorJpeg(CameraDevice *const device);

	int configure(const libcamera::StreamConfiguration &incfg,
		      const libcamera::StreamConfiguration &outcfg) override;
	void process(Camera3RequestDescriptor::StreamBuffer *streamBuffer) override;

private:
	void generateThumbnail(const libcamera::FrameBuffer &source,
			       const libcamera::Size &targetSize,
			       unsigned int quality,
			       std::vector<unsigned char> *thumbnail);

	CameraDevice *const cameraDevice_;
	std::unique_ptr<Encoder> encoder_;
	libcamera::Size streamSize_;
	EncoderLibJpeg thumbnailEncoder_;
	Thumbnailer thumbnailer_;
};
generated by cgit v1.2.1 (git 2.18.0) at 2025-06-01 08:59:44 +0000