main_thread_rpc.hpp

Go to the documentation of this file.

#pragma once
 
#include <pulp/inspect/protocol.hpp>
 
#include <chrono>
#include <cstddef>
#include <functional>
#include <memory>
 
namespace pulp::inspect {

class InspectorMainThreadRpc {
  public:
    using Operation = std::function<InspectorMessage()>;
    using Completion = std::function<void()>;
    using Post = std::function<bool(std::function<void()>)>;
    using IsMainThread = std::function<bool()>;
 
    struct Config {
        std::chrono::milliseconds timeout = std::chrono::seconds(2);
        std::size_t max_pending = 64;
    };
 
    InspectorMainThreadRpc();
    explicit InspectorMainThreadRpc(Config config);
    InspectorMainThreadRpc(Config config, Post post, IsMainThread is_main_thread);
    ~InspectorMainThreadRpc();
 
    InspectorMainThreadRpc(const InspectorMainThreadRpc&) = delete;
    InspectorMainThreadRpc& operator=(const InspectorMainThreadRpc&) = delete;
 
    InspectorMessage call(std::int64_t request_id, Operation operation);
    InspectorMessage call(std::int64_t request_id, Operation operation, Completion completion);
    InspectorMessage call(std::int64_t request_id, Operation operation, Completion completion,
                          std::chrono::milliseconds timeout);
    InspectorMessage call_queued_only(std::int64_t request_id, Operation operation,
                                      Completion completion, std::chrono::milliseconds timeout);

    void cancel();
    void cancel_and_wait();
    bool set_posted_lifetime_callbacks(Completion begin, Completion end);
    bool executing_on_current_thread() const;
    bool after_current_operation(Completion completion);
    bool active() const;
    std::chrono::milliseconds default_timeout() const;
 
  private:
    InspectorMessage call_with_inline_policy(std::int64_t request_id, Operation operation,
                                             Completion completion,
                                             std::chrono::milliseconds timeout, bool allow_inline);
 
    class Impl;
    std::shared_ptr<Impl> impl_;
};
 
} // namespace pulp::inspect