/* SPDX-License-Identifier: GPL-2.0-or-later */ /* * Copyright (C) 2019, Google Inc. * * message.cpp - Messages test */ #include #include #include #include #include #include #include "test.h" using namespace std; using namespace libcamera; class MessageReceiver : public Object { public: enum Status { NoMessage, InvalidThread, MessageReceived, }; MessageReceiver(Object *parent = nullptr) : Object(parent), status_(NoMessage) { } Status status() const { return status_; } void reset() { status_ = NoMessage; } protected: void message(Message *msg) { if (msg->type() != Message::None) { Object::message(msg); return; } if (thread() != Thread::current()) status_ = InvalidThread; else status_ = MessageReceived; } private: Status status_; }; class RecursiveMessageReceiver : public Object { public: RecursiveMessageReceiver() : child_(this), success_(false) { } bool success() const { return success_; } protected: void message([[maybe_unused]] Message *msg) { if (msg->type() != Message::None) { Object::message(msg); return; } child_.postMessage(std::make_unique(Message::None)); /* * If the child has already received the message, something is * wrong. */ if (child_.status() != MessageReceiver::NoMessage) return; Thread::current()->dispatchMessages(Message::None); /* The child should now have received the message. */ if (child_.status() == MessageReceiver::MessageReceived) success_ = true; } private: MessageReceiver child_; bool success_; }; class SlowMessageReceiver : public Object { protected: void message(Message *msg) { if (msg->type() != Message::None) { Object::message(msg); return; } /* * Don't access any member of the object here (including the * vtable) as the object will be deleted by the main thread * while we're sleeping. */ this_thread::sleep_for(chrono::milliseconds(100)); } }; class MessageTest : public Test { protected: int run() { Message::Type msgType[2] = { Message::registerMessageType(), Message::registerMessageType(), }; if (msgType[0] != Message::UserMessage || msgType[1] != Message::UserMessage + 1) { cout << "Failed to register message types" << endl; return TestFail; } MessageReceiver receiver; receiver.moveToThread(&thread_); thread_.start(); receiver.postMessage(std::make_unique(Message::None)); this_thread::sleep_for(chrono::milliseconds(100)); switch (receiver.status()) { case MessageReceiver::NoMessage: cout << "No message received" << endl; return TestFail; case MessageReceiver::InvalidThread: cout << "Message received in incorrect thread" << endl; return TestFail; default: break; } /* * Test for races between message delivery and object deletion. * Failures result in assertion errors, there is no need for * explicit checks. */ SlowMessageReceiver *slowReceiver = new SlowMessageReceiver(); slowReceiver->moveToThread(&thread_); slowReceiver->postMessage(std::make_unique(Message::None)); this_thread::sleep_for(chrono::milliseconds(10)); delete slowReceiver; this_thread::sleep_for(chrono::milliseconds(100)); /* * Test recursive calls to Thread::dispatchMessages(). Messages * should be delivered correctly, without crashes or memory * leaks. Two messages need to be posted to ensure we don't only * test the simple case of a queue containing a single message. */ std::unique_ptr recursiveReceiver = std::make_unique(); recursiveReceiver->moveToThread(&thread_); recursiveReceiver->postMessage(std::make_unique(Message::None)); recursiveReceiver->postMessage(std::make_unique(Message::UserMessage)); this_thread::sleep_for(chrono::milliseconds(10)); if (!recursiveReceiver->success()) { cout << "Recursive message delivery failed" << endl; return TestFail; } return TestPass; } void cleanup() { thread_.exit(0); thread_.wait(); } private: Thread thread_; }; TEST_REGISTER(MessageTest) '#n22'>22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54

/* SPDX-License-Identifier: BSD-2-Clause */
/*
 * Copyright (C) 2019, Raspberry Pi (Trading) Limited
 *
 * controller.hpp - ISP controller interface
 */
#pragma once

// The Controller is simply a container for a collecting together a number of
// "control algorithms" (such as AWB etc.) and for running them all in a
// convenient manner.

#include <vector>
#include <string>

#include <linux/bcm2835-isp.h>

#include "camera_mode.h"
#include "device_status.h"
#include "metadata.hpp"

namespace RPiController {

class Algorithm;
typedef std::unique_ptr<Algorithm> AlgorithmPtr;
typedef std::shared_ptr<bcm2835_isp_stats> StatisticsPtr;

// The Controller holds a pointer to some global_metadata, which is how
// different controllers and control algorithms within them can exchange
// information. The Prepare method returns a pointer to metadata for this
// specific image, and which should be passed on to the Process method.

class Controller
{
public:
	Controller();
	Controller(char const *json_filename);
	~Controller();
	Algorithm *CreateAlgorithm(char const *name);
	void Read(char const *filename);
	void Initialise();
	void SwitchMode(CameraMode const &camera_mode, Metadata *metadata);
	void Prepare(Metadata *image_metadata);
	void Process(StatisticsPtr stats, Metadata *image_metadata);
	Metadata &GetGlobalMetadata();
	Algorithm *GetAlgorithm(std::string const &name) const;

protected:
	Metadata global_metadata_;
	std::vector<AlgorithmPtr> algorithms_;
	bool switch_mode_called_;
};

} // namespace RPiController