message.h

Go to the documentation of this file.

/* SPDX-License-Identifier: LGPL-2.1-or-later */
/*
 * Copyright (C) 2019, Google Inc.
 *
 * Message queue support
 */
 
#pragma once
 
#include <atomic>
 
#include <libcamera/base/private.h>
 
#include <libcamera/base/bound_method.h>
 
namespace libcamera {
 
class BoundMethodBase;
class Object;
class Semaphore;
class Thread;
 
class Message
{
public:
    enum Type {
        None = 0,
        InvokeMessage = 1,
        ThreadMoveMessage = 2,
        DeferredDelete = 3,
        UserMessage = 1000,
    };
 
    Message(Type type);
    virtual ~Message();
 
    Type type() const { return type_; }
    Object *receiver() const { return receiver_; }
 
    static Type registerMessageType();
 
private:
    friend class Thread;
 
    Type type_;
    Object *receiver_;
 
    static std::atomic_uint nextUserType_;
};
 
class InvokeMessage : public Message
{
public:
    InvokeMessage(BoundMethodBase *method,
              std::shared_ptr<BoundMethodPackBase> pack,
              Semaphore *semaphore = nullptr,
              bool deleteMethod = false);
    ~InvokeMessage();
 
    Semaphore *semaphore() const { return semaphore_; }
 
    void invoke();
 
private:
    BoundMethodBase *method_;
    std::shared_ptr<BoundMethodPackBase> pack_;
    Semaphore *semaphore_;
    bool deleteMethod_;
};
 
} /* namespace libcamera */