kphp/runtime-light/runtime-light.cpp at 484a424394e92dc66e663313192327dc3f40d0ea · VKCOM/kphp · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
// Compiler for PHP (aka KPHP)
// Copyright (c) 2024 LLC «V Kontakte»
// Distributed under the GPL v3 License, see LICENSE.notice.txt

#include <utility>

#include "runtime-light/core/globals/php-init-scripts.h"
#include "runtime-light/coroutine/io-scheduler.h"
#include "runtime-light/k2-platform/k2-api.h"
#include "runtime-light/k2-platform/k2-header.h"
#include "runtime-light/state/component-state.h"
#include "runtime-light/state/image-state.h"
#include "runtime-light/state/instance-state.h"
#include "runtime-light/stdlib/diagnostics/logs.h"

#define VISIBILITY_DEFAULT __attribute__((visibility("default")))

VISIBILITY_DEFAULT ImageState* k2_create_image() {
  k2::details::image_state_ptr = nullptr;
  k2::details::component_state_ptr = nullptr;
  k2::details::instance_state_ptr = nullptr;
  return static_cast<ImageState*>(k2::alloc_align(sizeof(ImageState), alignof(ImageState)));
}

VISIBILITY_DEFAULT void k2_init_image() {
  k2::details::image_state_ptr = k2_image_state();
  k2::details::component_state_ptr = nullptr;
  k2::details::instance_state_ptr = nullptr;
  new (const_cast<ImageState*>(k2::image_state())) ImageState{};
  init_php_scripts_once_in_master();
}

VISIBILITY_DEFAULT ComponentState* k2_create_component() {
  k2::details::image_state_ptr = k2_image_state();
  k2::details::component_state_ptr = nullptr;
  k2::details::instance_state_ptr = nullptr;
  kphp::log::debug("start component state creation, requested {} bytes", sizeof(ComponentState));
  auto* component_state_ptr{static_cast<ComponentState*>(k2::alloc_align(sizeof(ComponentState), alignof(ComponentState)))};
  kphp::log::debug("finish component state creation");
  return component_state_ptr;
}

VISIBILITY_DEFAULT void k2_init_component() {
  k2::details::image_state_ptr = k2_image_state();
  k2::details::component_state_ptr = k2_component_state();
  k2::details::instance_state_ptr = nullptr;
  kphp::log::debug("start component state init");
  new (const_cast<ComponentState*>(k2::component_state())) ComponentState{};
  kphp::log::debug("finish component state init");
}

VISIBILITY_DEFAULT InstanceState* k2_create_instance() {
  k2::details::image_state_ptr = k2_image_state();
  k2::details::component_state_ptr = k2_component_state();
  k2::details::instance_state_ptr = nullptr;
  kphp::log::debug("start instance state creation, requested {} bytes", sizeof(InstanceState));
  auto* instance_state_ptr{static_cast<InstanceState*>(k2::alloc_align(sizeof(InstanceState), alignof(InstanceState)))};
  kphp::log::debug("finish instance state creation");
  return instance_state_ptr;
}

VISIBILITY_DEFAULT void k2_init_instance() {
  k2::details::image_state_ptr = k2_image_state();
  k2::details::component_state_ptr = k2_component_state();
  k2::details::instance_state_ptr = k2_instance_state();
  kphp::log::debug("start instance state init");
  new (k2::instance_state()) InstanceState{};

  auto& cpu_info_instance_state{CpuInfoInstanceState::get()};
  cpu_info_instance_state.init();
  cpu_info_instance_state.total_cycles = -CpuInfoInstanceState::rdtsc();

  k2::instance_state()->init_script_execution();
  kphp::log::debug("finish instance state init");
}

VISIBILITY_DEFAULT k2::PollStatus k2_poll() {
  k2::details::image_state_ptr = k2_image_state();
  k2::details::component_state_ptr = k2_component_state();
  k2::details::instance_state_ptr = k2_instance_state();
  kphp::log::debug("k2_poll started");
  const auto poll_status{kphp::coro::io_scheduler::get().process_events()};

  if (poll_status == k2::PollStatus::PollFinishedOk) {
    auto& cpu_info_instance_state{CpuInfoInstanceState::get()};
    cpu_info_instance_state.total_cycles += CpuInfoInstanceState::rdtsc();

    uint64_t coro_alloc_cycles{cpu_info_instance_state.coro_alloc_cycles};
    uint64_t coro_free_cycles{cpu_info_instance_state.coro_free_cycles};
    uint64_t coro_alloc_free_cycles{coro_alloc_cycles + coro_free_cycles};

    kphp::log::info("\ntotal cpu cycles -> {}\n"
                    "coro alloc cycles -> {} ({}%)\n"
                    "coro free cycles -> {} ({}%)\n"
                    "coro alloc+free cycles -> {} ({}%)\n",
                    cpu_info_instance_state.total_cycles, coro_alloc_cycles, cpu_info_instance_state.get_percent(coro_alloc_cycles), coro_free_cycles,
                    cpu_info_instance_state.get_percent(coro_free_cycles), coro_alloc_free_cycles, cpu_info_instance_state.get_percent(coro_alloc_free_cycles));
  }
  kphp::log::debug("k2_poll finished: {}", std::to_underlying(poll_status));
  return poll_status;
}