system.h

// Copyright 2024 The Pigweed Authors
//
// Licensed under the Apache License, Version 2.0 (the "License"); you may not
// use this file except in compliance with the License. You may obtain a copy of
// the License at
//
//     https://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
// License for the specific language governing permissions and limitations under
// the License.
#pragma once
 
#include <tuple>
 
#include "pw_allocator/allocator.h"
#include "pw_channel/channel.h"
#include "pw_function/function.h"
#include "pw_rpc/server.h"
 
namespace pw {
namespace system {
 
class AsyncCore;  // Forward declaration for function declaration.
 
}  // namespace system
 
system::AsyncCore& System();
 
[[noreturn]] void SystemStart(channel::ByteReaderWriter& io_channel);
 
namespace system {
 
class AsyncCore {
 public:
  Allocator& allocator();
 
  async2::Dispatcher& dispatcher();
 
  rpc::Server& rpc_server() { return rpc_server_; }
 
  [[nodiscard]] bool RunOnce(Function<void()>&& function);
 
 private:
  friend AsyncCore& pw::System();
  friend void pw::SystemStart(channel::ByteReaderWriter&);
 
  explicit _PW_RPC_CONSTEXPR AsyncCore()
      : rpc_channels_{}, rpc_server_(rpc_channels_) {}
 
  void Init(channel::ByteReaderWriter& io_channel);
 
  static async2::Poll<> InitTask(async2::Context&);
 
  rpc::Channel rpc_channels_[1];
  rpc::Server rpc_server_;
};
 
}  // namespace system
 
inline system::AsyncCore& System() {
  _PW_RPC_CONSTINIT static system::AsyncCore system_core;
  return system_core;
}
 
}  // namespace pw