admin/mruby-mruby
1
0
Fork 0
mirror of https://github.com/mruby/mruby synced 2026-06-08 16:11:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #6105 from dearblue/fiber.to_s

Browse Source 
Implement `Fiber#to_s` method
This commit is contained in:
Yukihiro "Matz" Matsumoto
2023-12-08 09:00:05 +09:00
committed by GitHub
parent 658d5a51ac 9af6264d6b
commit cb54138b81
1 changed files with 55 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
mrbgems/mruby-fiber/src/fiber.c
+55
View File
@@ -1,8 +1,11 @@
#include <mruby.h>
#include <mruby/array.h>
#include <mruby/class.h>
#include <mruby/debug.h>
#include <mruby/error.h>
#include <mruby/numeric.h>
#include <mruby/proc.h>
#include <mruby/string.h>
#include <mruby/presym.h>
#define fiber_ptr(o) ((struct RFiber*)mrb_ptr(o))
@@ -348,6 +351,56 @@ fiber_eq(mrb_state *mrb, mrb_value self)
return mrb_bool_value(fiber_ptr(self) == fiber_ptr(other));
}
/*
* call-seq:
* fiber.to_s -> string
* fiber.inspect -> string
*
* Returns fiber object information as a string.
*
* If the file information cannot be obtained, it is replaced with `(unknown):1`.
* Also, if the fiber is terminated, it will be replaced in the same way (mruby limitation).
*/
static mrb_value
fiber_to_s(mrb_state *mrb, mrb_value self)
{
fiber_check(mrb, self);
const struct RFiber *f = fiber_ptr(self);
mrb_value s = mrb_any_to_s(mrb, self);
mrb_assert(RSTRING_END(s)[-1] == '>');
RSTRING_END(s)[-1] = ' ';
const char *file;
int32_t line;
if (f->cxt->ci > f->cxt->cibase &&
mrb_debug_get_position(mrb, f->cxt->cibase->proc->body.irep, 0, &line, &file)) {
mrb_str_cat_cstr(mrb, s, file);
mrb_str_cat_lit(mrb, s, ":");
char buf[16];
mrb_str_cat_cstr(mrb, s, mrb_int_to_cstr(buf, sizeof(buf), line, 10));
}
else {
mrb_str_cat_lit(mrb, s, "(unknown):1");
}
const char *st;
switch (fiber_ptr(self)->cxt->status) {
case MRB_FIBER_CREATED: st = "created"; break;
case MRB_FIBER_RUNNING: st = "resumed"; break;
case MRB_FIBER_RESUMED: st = "suspended by resuming"; break;
case MRB_FIBER_SUSPENDED: st = "suspended"; break;
case MRB_FIBER_TRANSFERRED: st = "suspended"; break;
case MRB_FIBER_TERMINATED: st = "terminated"; break;
default: st = "UNKNOWN STATUS (BUG)"; break;
}
mrb_str_cat_lit(mrb, s, " (");
mrb_str_cat_cstr(mrb, s, st);
mrb_str_cat_lit(mrb, s, ")>");
return s;
}
/*
* call-seq:
* fiber.transfer(args, ...) -> obj
@@ -485,6 +538,8 @@ mrb_mruby_fiber_gem_init(mrb_state* mrb)
mrb_define_method(mrb, c, "transfer", fiber_transfer, MRB_ARGS_ANY());
mrb_define_method(mrb, c, "alive?", fiber_alive_p, MRB_ARGS_NONE());
mrb_define_method(mrb, c, "==", fiber_eq, MRB_ARGS_REQ(1));
mrb_define_method(mrb, c, "to_s", fiber_to_s, MRB_ARGS_NONE());
mrb_define_alias(mrb, c, "inspect", "to_s");
mrb_define_class_method(mrb, c, "yield", fiber_yield, MRB_ARGS_ANY());
mrb_define_class_method(mrb, c, "current", fiber_current, MRB_ARGS_NONE());