libcamera/libcamera.git - libcamera official repository

summary refs log tree commit diff

path: root/src/android/camera_buffer.h

Age	Commit message (Expand)	Author
2021-11-24	android: Convert to pragma once	Kieran Bingham
2021-08-27	android: camera_buffer: Add stride/offset/size function	Hirokazu Honda
2021-08-27	android: generic_camera_buffer: Correct buffer mapping	Hirokazu Honda
2021-08-16	libcamera: base: extensible: Pass private pointer as unique_ptr<>	Laurent Pinchart
2021-07-12	libcamera: Drop the LIBCAMERA_D_PTR macro in favour of the _d() function	Laurent Pinchart
2021-06-25	libcamera/base: Move span to base library	Kieran Bingham
2021-06-25	libcamera/base: Move class helpers to the base library	Kieran Bingham
2021-04-21	libcamera: Drop argument from LIBCAMERA_DECLARE_PRIVATE	Jacopo Mondi
2021-03-03	android: mm: Provide helper macro for PIMPL	Jacopo Mondi
2021-03-03	android: camera_buffer: Add method to get the JPEG blob size	Jacopo Mondi
2021-03-03	android: post_processor: Use CameraBuffer API	Jacopo Mondi
2021-03-03	android: camera_buffer: Implement libcamera::Extensible	Jacopo Mondi
2021-03-03	android: camera_buffer: Drop 'const' from buffer_handle_t	Jacopo Mondi
2021-03-03	android: Introduce CameraBuffer interface	Jacopo Mondi

ss="hl com"> */ #include <chrono> #include <iostream> #include <thread> #include "message.h" #include "thread.h" #include "test.h" using namespace std; using namespace libcamera; class MessageReceiver : public Object { public: enum Status { NoMessage, InvalidThread, MessageReceived, }; MessageReceiver() : 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 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>(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>(Message::None)); this_thread::sleep_for(chrono::milliseconds(10)); delete slowReceiver; return TestPass; } void cleanup() { thread_.exit(0); thread_.wait(); } private: Thread thread_; }; TEST_REGISTER(MessageTest)