scheduler_stats.pony

  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
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
use @pony_scheduler_stats[_SchedulerStats]()

primitive SchedulerStats
  """
  Provides functions that expose statistics about the current scheduler. All
  methods will return '0' if the runtime used the program wasn't compiled with
  runtime statistics turned on.
  """

  fun total_mem_allocated(auth: SchedulerStatsAuth): I64 =>
    """
    Returns the total memory currently allocated by the current
    scheduler thread (note: this is an approximate value and it can be
    negative as it represents only a partial view across all the
    scheduler threads)
    """
    ifdef runtimestats then
      @pony_scheduler_stats().mem_allocated +
        @pony_scheduler_stats().mem_allocated_actors
    else 0
    end

  fun total_mem_used(auth: SchedulerStatsAuth): I64 =>
    """
    Returns the total memory currently used by the current scheduler
    thread (note: this is an approximate value and it can be negative
    as it represents only a partial view across all the scheduler
    threads)
    """
    ifdef runtimestats then
      @pony_scheduler_stats().mem_used +
        @pony_scheduler_stats().mem_used_actors
    else 0
    end

  fun created_actors_counter(auth: SchedulerStatsAuth): USize =>
    """
    Returns the number of actors created by the current schedule
    thread (note: this is an approximate value and it can be negative
    as it represents only a partial view across all the scheduler
    threads)
    """
    ifdef runtimestats then
      @pony_scheduler_stats().created_actors_counter
    else 0
    end

  fun destroyed_actors_counter(auth: SchedulerStatsAuth): USize =>
    """
    Returns the number of actors destroyed by the current schedule
    thread
    """
    ifdef runtimestats then
      @pony_scheduler_stats().destroyed_actors_counter
    else 0
    end

  fun actor_app_cpu(auth: SchedulerStatsAuth): USize =>
    """
    Returns the amount of cpu the current scheduler has used to
    process actor app messages
    """
    ifdef runtimestats then
      @pony_scheduler_stats().actor_app_cpu
    else 0
    end

  fun actor_gc_mark_cpu(auth: SchedulerStatsAuth): USize =>
    """
    Returns the amount of cpu the current scheduler has used for mark
    phase to garbage collect actor heaps
    """
    ifdef runtimestats then
      @pony_scheduler_stats().actor_gc_mark_cpu
    else 0
    end

  fun actor_gc_sweep_cpu(auth: SchedulerStatsAuth): USize =>
    """
    Returns the amount of cpu the current scheduler has used for sweep
    phase to garbage collect actor heaps
    """
    ifdef runtimestats then
      @pony_scheduler_stats().actor_gc_sweep_cpu
    else 0
    end

  fun actor_system_cpu(auth: SchedulerStatsAuth): USize =>
    """
    Returns the amount of cpu the current scheduler has used to
    process actor system messages
    """
    ifdef runtimestats then
      @pony_scheduler_stats().actor_system_cpu
    else 0
    end

  fun msg_cpu(auth: SchedulerStatsAuth): USize =>
    """
    Returns the amount of cpu the current scheduler has used to
    process scheduler system messages
    """
    ifdef runtimestats then
      @pony_scheduler_stats().msg_cpu
    else 0
    end

  fun misc_cpu(auth: SchedulerStatsAuth): USize =>
    """
    Returns the amount of cpu the current scheduler has used while
    waiting to do work
    """
    ifdef runtimestats then
      @pony_scheduler_stats().misc_cpu
    else 0
    end

  fun mem_used_inflight_messages(auth: SchedulerStatsAuth): I64 =>
    """
    Returns the number of memory used by inflight messages created by
    the current scheduler thread (note: this is an approximate value
    and it can be negative if the current thread receives more messages
    than it sends)
    """
    ifdef runtimestatsmessages then
      @pony_scheduler_stats().mem_used_inflight_messages
    else 0
    end

  fun mem_allocated_inflight_messages(auth: SchedulerStatsAuth): I64 =>
    """
    Returns the number of memory allocated by inflight messages
    created by the current scheduler thread (note: this is an
    approximate value and it can be negative if the current thread
    receives more messages than it sends)
    """
    ifdef runtimestatsmessages then
      @pony_scheduler_stats().mem_allocated_inflight_messages
    else 0
    end

  fun num_inflight_messages(auth: SchedulerStatsAuth): I64 =>
    """
    Returns the number of inflight messages by the current scheduler
    thread (note: this is an approximate value and it can be negative
    if the current thread receives more messages than it sends)
    """
    ifdef runtimestatsmessages then
      @pony_scheduler_stats().num_inflight_messages
    else 0
    end