ipc_pipe.h

Go to the documentation of this file.

/* SPDX-License-Identifier: LGPL-2.1-or-later */
/*
 * Copyright (C) 2020, Google Inc.
 *
 * Image Processing Algorithm IPC module for IPA proxies
 */

#pragma once

#include <vector>

#include <libcamera/base/shared_fd.h>
#include <libcamera/base/signal.h>

#include "libcamera/internal/ipc_unixsocket.h"

namespace libcamera {

class IPCMessage
{
public:
    struct Header {
        uint32_t cmd;
        uint32_t cookie;
    };

    IPCMessage();
    IPCMessage(uint32_t cmd);
    IPCMessage(const Header &header);
    IPCMessage(IPCUnixSocket::Payload &payload);

    IPCUnixSocket::Payload payload() const;

    Header &header() { return header_; }
    std::vector<uint8_t> &data() { return data_; }
    std::vector<SharedFD> &fds() { return fds_; }

    const Header &header() const { return header_; }
    const std::vector<uint8_t> &data() const { return data_; }
    const std::vector<SharedFD> &fds() const { return fds_; }

private:
    Header header_;

    std::vector<uint8_t> data_;
    std::vector<SharedFD> fds_;
};

class IPCPipe
{
public:
    IPCPipe();
    virtual ~IPCPipe();

    bool isConnected() const { return connected_; }

    virtual int sendSync(const IPCMessage &in,
                 IPCMessage *out) = 0;

    virtual int sendAsync(const IPCMessage &data) = 0;

    Signal<const IPCMessage &> recv;

protected:
    bool connected_;
};

} /* namespace libcamera */