]> gitweb.factorcode.org Git - factor.git/commitdiff
VM: Refactor safepoints.cpp/hpp to Factor style
authorErik Charlebois <erikcharlebois@gmail.com>
Sun, 12 May 2013 02:27:37 +0000 (22:27 -0400)
committerErik Charlebois <erikcharlebois@gmail.com>
Sun, 12 May 2013 17:24:47 +0000 (13:24 -0400)
vm/safepoints.cpp
vm/safepoints.hpp

index 880f5a6bd09f4c06312b0d7fc343e80bdb42b9c0..65eb89508e23367806f2936189bb29f9cde95026 100644 (file)
@@ -1,61 +1,53 @@
 #include "master.hpp"
 
-namespace factor
-{
+namespace factor {
 
-void safepoint_state::enqueue_safepoint(factor_vm *parent) volatile
-{
-       parent->code->guard_safepoint();
+void safepoint_state::enqueue_safepoint(factor_vm* parent) volatile {
+  parent->code->guard_safepoint();
 }
 
-void safepoint_state::enqueue_fep(factor_vm *parent) volatile
-{
-       if (parent->fep_p)
-               fatal_error("Low-level debugger interrupted", 0);
-       atomic::store(&fep_p, true);
-       enqueue_safepoint(parent);
+void safepoint_state::enqueue_fep(factor_vm* parent) volatile {
+  if (parent->fep_p)
+    fatal_error("Low-level debugger interrupted", 0);
+  atomic::store(&fep_p, true);
+  enqueue_safepoint(parent);
 }
 
-void safepoint_state::enqueue_samples(factor_vm *parent, cell samples, cell pc, bool foreign_thread_p) volatile
-{
-       if (atomic::load(&parent->sampling_profiler_p))
-       {
-               atomic::fetch_add(&sample_counts.sample_count, samples);
-               if (foreign_thread_p)
-                       atomic::fetch_add(&sample_counts.foreign_thread_sample_count, samples);
-               else {
-                       if (atomic::load(&parent->current_gc_p))
-                               atomic::fetch_add(&sample_counts.gc_sample_count, samples);
-                       if (atomic::load(&parent->current_jit_count) > 0)
-                               atomic::fetch_add(&sample_counts.jit_sample_count, samples);
-                       if (!parent->code->seg->in_segment_p(pc))
-                               atomic::fetch_add(&sample_counts.foreign_sample_count, samples);
-               }
-               enqueue_safepoint(parent);
-       }
+void safepoint_state::enqueue_samples(factor_vm* parent, cell samples, cell pc,
+                                      bool foreign_thread_p) volatile {
+  if (atomic::load(&parent->sampling_profiler_p)) {
+    atomic::fetch_add(&sample_counts.sample_count, samples);
+    if (foreign_thread_p)
+      atomic::fetch_add(&sample_counts.foreign_thread_sample_count, samples);
+    else {
+      if (atomic::load(&parent->current_gc_p))
+        atomic::fetch_add(&sample_counts.gc_sample_count, samples);
+      if (atomic::load(&parent->current_jit_count) > 0)
+        atomic::fetch_add(&sample_counts.jit_sample_count, samples);
+      if (!parent->code->seg->in_segment_p(pc))
+        atomic::fetch_add(&sample_counts.foreign_sample_count, samples);
+    }
+    enqueue_safepoint(parent);
+  }
 }
 
-void safepoint_state::handle_safepoint(factor_vm *parent, cell pc) volatile
-{
-       parent->code->unguard_safepoint();
-       parent->faulting_p = false;
-
-       if (atomic::load(&fep_p))
-       {
-               if (atomic::load(&parent->sampling_profiler_p))
-                       parent->end_sampling_profiler();
-               std::cout << "Interrupted\n";
-               parent->factorbug();
-               atomic::store(&fep_p, false);
-       }
-       else if (atomic::load(&parent->sampling_profiler_p))
-       {
-               FACTOR_ASSERT(parent->code->seg->in_segment_p(pc));
-               code_block *block = parent->code->code_block_for_address(pc);
-               bool prolog_p = (cell)block->entry_point() == pc;
-
-               parent->record_sample(prolog_p);
-       }
+void safepoint_state::handle_safepoint(factor_vm* parent, cell pc) volatile {
+  parent->code->unguard_safepoint();
+  parent->faulting_p = false;
+
+  if (atomic::load(&fep_p)) {
+    if (atomic::load(&parent->sampling_profiler_p))
+      parent->end_sampling_profiler();
+    std::cout << "Interrupted\n";
+    parent->factorbug();
+    atomic::store(&fep_p, false);
+  } else if (atomic::load(&parent->sampling_profiler_p)) {
+    FACTOR_ASSERT(parent->code->seg->in_segment_p(pc));
+    code_block* block = parent->code->code_block_for_address(pc);
+    bool prolog_p = (cell) block->entry_point() == pc;
+
+    parent->record_sample(prolog_p);
+  }
 }
 
 }
index c30afd5fcf56f5aad01798c4938d238876259484..458faf6e52b587f167f28b7c45098b05f0de06bd 100644 (file)
@@ -1,22 +1,17 @@
-namespace factor
-{
+namespace factor {
 
-struct safepoint_state
-{
-       cell fep_p;
-       profiling_sample_count sample_counts;
+struct safepoint_state {
+  cell fep_p;
+  profiling_sample_count sample_counts;
 
-       safepoint_state() :
-               fep_p(false),
-               sample_counts()
-       {
-       }
+  safepoint_state() : fep_p(false), sample_counts() {}
 
-       void handle_safepoint(factor_vm *parent, cell pc) volatile;
+  void handle_safepoint(factor_vm* parent, cell pc) volatile;
 
-       void enqueue_safepoint(factor_vm *parent) volatile;
-       void enqueue_samples(factor_vm *parent, cell samples, cell pc, bool foreign_thread_p) volatile;
-       void enqueue_fep(factor_vm *parent) volatile;
+  void enqueue_safepoint(factor_vm* parent) volatile;
+  void enqueue_samples(factor_vm* parent, cell samples, cell pc,
+                       bool foreign_thread_p) volatile;
+  void enqueue_fep(factor_vm* parent) volatile;
 };
 
 }