mirror of
https://github.com/mruby/mruby
synced 2026-06-08 16:11:16 +00:00
Merge pull request #5045 from dearblue/memsize_of
Improve `mruby-os-memsize`
This commit is contained in:
+1
-1
@@ -21,7 +21,7 @@ struct mrb_state;
|
||||
#define MRB_EACH_OBJ_BREAK 1
|
||||
typedef int (mrb_each_object_callback)(struct mrb_state *mrb, struct RBasic *obj, void *data);
|
||||
void mrb_objspace_each_objects(struct mrb_state *mrb, mrb_each_object_callback *callback, void *data);
|
||||
const mrb_int mrb_objspace_page_slot_size();
|
||||
mrb_int mrb_objspace_page_slot_size(void);
|
||||
MRB_API void mrb_free_context(struct mrb_state *mrb, struct mrb_context *c);
|
||||
|
||||
#ifndef MRB_GC_ARENA_SIZE
|
||||
|
||||
@@ -173,223 +173,12 @@ os_each_object(mrb_state *mrb, mrb_value self)
|
||||
return mrb_fixnum_value(d.count);
|
||||
}
|
||||
|
||||
static mrb_int
|
||||
os_memsize_of_ivars(mrb_state* mrb, mrb_value obj)
|
||||
{
|
||||
return mrb_obj_iv_tbl_memsize(mrb, obj);
|
||||
}
|
||||
|
||||
static mrb_int
|
||||
os_memsize_of_irep(mrb_state* state, const struct mrb_irep *irep)
|
||||
{
|
||||
mrb_int size, i;
|
||||
size = (irep->slen * sizeof(mrb_sym)) +
|
||||
(irep->plen * sizeof(mrb_code)) +
|
||||
(irep->ilen * sizeof(mrb_code));
|
||||
|
||||
for(i = 0; i < irep->rlen; i++) {
|
||||
size += os_memsize_of_irep(state, irep->reps[i]);
|
||||
}
|
||||
return size;
|
||||
}
|
||||
|
||||
static mrb_int
|
||||
os_memsize_of_method(mrb_state* mrb, mrb_value method_obj)
|
||||
{
|
||||
mrb_int size;
|
||||
mrb_value proc_value = mrb_obj_iv_get(mrb, mrb_obj_ptr(method_obj),
|
||||
mrb_intern_lit(mrb, "_proc"));
|
||||
struct RProc *proc = mrb_proc_ptr(proc_value);
|
||||
|
||||
size = sizeof(struct RProc);
|
||||
if (!MRB_PROC_CFUNC_P(proc)) size += os_memsize_of_irep(mrb, proc->body.irep);
|
||||
return size;
|
||||
}
|
||||
|
||||
static mrb_int
|
||||
os_memsize_of_object(mrb_state* mrb, mrb_value obj)
|
||||
{
|
||||
mrb_int size = 0;
|
||||
|
||||
switch(mrb_type(obj)) {
|
||||
case MRB_TT_STRING:
|
||||
size += mrb_objspace_page_slot_size();
|
||||
if (!RSTR_EMBED_P(RSTRING(obj)) && !RSTR_SHARED_P(RSTRING(obj))) {
|
||||
size += RSTRING_CAPA(obj);
|
||||
}
|
||||
break;
|
||||
case MRB_TT_CLASS:
|
||||
case MRB_TT_MODULE:
|
||||
case MRB_TT_SCLASS:
|
||||
case MRB_TT_ICLASS:
|
||||
size += mrb_gc_mark_mt_size(mrb, mrb_class_ptr(obj)) * sizeof(mrb_method_t);
|
||||
/* fall through */
|
||||
case MRB_TT_EXCEPTION:
|
||||
case MRB_TT_OBJECT: {
|
||||
size += mrb_objspace_page_slot_size();
|
||||
size += os_memsize_of_ivars(mrb, obj);
|
||||
if (mrb_obj_is_kind_of(mrb, obj, mrb_class_get(mrb, "UnboundMethod")) ||
|
||||
mrb_obj_is_kind_of(mrb, obj, mrb_class_get(mrb, "Method"))){
|
||||
size += os_memsize_of_method(mrb, obj);
|
||||
}
|
||||
break;
|
||||
}
|
||||
case MRB_TT_HASH: {
|
||||
size += mrb_objspace_page_slot_size() +
|
||||
mrb_os_memsize_of_hash_table(obj);
|
||||
break;
|
||||
}
|
||||
case MRB_TT_ARRAY: {
|
||||
mrb_int len = RARRAY_LEN(obj);
|
||||
/* Arrays that do not fit within an RArray perform a heap allocation
|
||||
* storing an array of pointers to the original objects*/
|
||||
size += mrb_objspace_page_slot_size();
|
||||
if(len > MRB_ARY_EMBED_LEN_MAX) size += sizeof(mrb_value *) * len;
|
||||
break;
|
||||
}
|
||||
case MRB_TT_PROC: {
|
||||
struct RProc* proc = mrb_proc_ptr(obj);
|
||||
size += mrb_objspace_page_slot_size();
|
||||
size += MRB_ENV_LEN(proc->e.env) * sizeof(mrb_value);
|
||||
if(!MRB_PROC_CFUNC_P(proc)) size += os_memsize_of_irep(mrb, proc->body.irep);
|
||||
break;
|
||||
}
|
||||
case MRB_TT_DATA:
|
||||
size += mrb_objspace_page_slot_size();
|
||||
break;
|
||||
#ifndef MRB_WITHOUT_FLOAT
|
||||
case MRB_TT_FLOAT:
|
||||
#ifdef MRB_WORD_BOXING
|
||||
size += mrb_objspace_page_slot_size() +
|
||||
sizeof(struct RFloat);
|
||||
#endif
|
||||
break;
|
||||
#endif
|
||||
case MRB_TT_RANGE:
|
||||
#ifndef MRB_RANGE_EMBED
|
||||
size += mrb_objspace_page_slot_size() +
|
||||
sizeof(struct mrb_range_edges);
|
||||
#endif
|
||||
break;
|
||||
case MRB_TT_FIBER: {
|
||||
struct RFiber* f = (struct RFiber *)mrb_ptr(obj);
|
||||
ptrdiff_t stack_size = f->cxt->stend - f->cxt->stbase;
|
||||
ptrdiff_t ci_size = f->cxt->ciend - f->cxt->cibase;
|
||||
|
||||
size += mrb_objspace_page_slot_size() +
|
||||
sizeof(struct RFiber) +
|
||||
sizeof(struct mrb_context) +
|
||||
sizeof(struct RProc *) * f->cxt->esize +
|
||||
sizeof(uint16_t *) * f->cxt->rsize +
|
||||
sizeof(mrb_value) * stack_size +
|
||||
sizeof(mrb_callinfo) * ci_size;
|
||||
break;
|
||||
}
|
||||
case MRB_TT_ISTRUCT:
|
||||
size += mrb_objspace_page_slot_size();
|
||||
break;
|
||||
/* zero heap size types.
|
||||
* immediate VM stack values, contained within mrb_state, or on C stack */
|
||||
case MRB_TT_TRUE:
|
||||
case MRB_TT_FALSE:
|
||||
case MRB_TT_FIXNUM:
|
||||
case MRB_TT_BREAK:
|
||||
case MRB_TT_CPTR:
|
||||
case MRB_TT_SYMBOL:
|
||||
case MRB_TT_FREE:
|
||||
case MRB_TT_UNDEF:
|
||||
case MRB_TT_ENV:
|
||||
/* never used, silences compiler warning
|
||||
* not having a default: clause lets the compiler tell us when there is a new
|
||||
* TT not accounted for */
|
||||
case MRB_TT_MAXDEFINE:
|
||||
break;
|
||||
}
|
||||
return size;
|
||||
}
|
||||
|
||||
/*
|
||||
* call-seq:
|
||||
* ObjectSpace.memsize_of(obj, recurse: false) -> Numeric
|
||||
*
|
||||
* Returns the amount of heap memory allocated for object in size_t units.
|
||||
*
|
||||
* The return value depends on the definition of size_t on that platform,
|
||||
* therefore the value is not comparable across platform types.
|
||||
*
|
||||
* Immediate values such as integers, booleans, symbols and unboxed float numbers
|
||||
* return 0. Additionally special objects which are small enough to fit inside an
|
||||
* object pointer, termed embedded objects, will return the size of the object pointer.
|
||||
* Strings and arrays below a compile-time defined size may be embedded.
|
||||
*
|
||||
* Setting recurse: true descends into instance variables, array members,
|
||||
* hash keys and hash values recursively, calculating the child objects and adding to
|
||||
* the final sum. It avoids infinite recursion and over counting objects by
|
||||
* internally tracking discovered object ids.
|
||||
*
|
||||
*/
|
||||
|
||||
static mrb_value
|
||||
os_memsize_of(mrb_state *mrb, mrb_value self)
|
||||
{
|
||||
mrb_int total;
|
||||
mrb_value obj;
|
||||
|
||||
mrb_get_args(mrb, "o", &obj);
|
||||
|
||||
total = os_memsize_of_object(mrb, obj);
|
||||
return mrb_fixnum_value(total);
|
||||
}
|
||||
|
||||
struct os_memsize_of_all_cb_data {
|
||||
mrb_int t;
|
||||
struct RClass *type;
|
||||
};
|
||||
|
||||
static int
|
||||
os_memsize_of_all_cb(mrb_state *mrb, struct RBasic *obj, void *d)
|
||||
{
|
||||
struct os_memsize_of_all_cb_data *data = (struct os_memsize_of_all_cb_data *)d;
|
||||
switch (obj->tt) {
|
||||
case MRB_TT_FREE: case MRB_TT_ENV:
|
||||
case MRB_TT_BREAK: case MRB_TT_ICLASS:
|
||||
/* internal objects that should not be counted */
|
||||
return MRB_EACH_OBJ_OK;
|
||||
default:
|
||||
break;
|
||||
}
|
||||
/* skip Proc objects for methods */
|
||||
if (obj->c == NULL) return 0;
|
||||
if (data->type == NULL || mrb_obj_is_kind_of(mrb, mrb_obj_value(obj), data->type))
|
||||
data->t += os_memsize_of_object(mrb, mrb_obj_value(obj));
|
||||
return MRB_EACH_OBJ_OK;
|
||||
}
|
||||
|
||||
/*
|
||||
* call-seq:
|
||||
* ObjectSpace.memsize_of_all([klass]) -> Numeric
|
||||
*
|
||||
* Return consuming memory size of all living objects of type klass.
|
||||
*
|
||||
*/
|
||||
|
||||
static mrb_value
|
||||
os_memsize_of_all(mrb_state *mrb, mrb_value self)
|
||||
{
|
||||
struct os_memsize_of_all_cb_data data = { 0 };
|
||||
mrb_get_args(mrb, "|c", &data.type);
|
||||
mrb_objspace_each_objects(mrb, os_memsize_of_all_cb, &data);
|
||||
return mrb_fixnum_value(data.t);
|
||||
}
|
||||
|
||||
void
|
||||
mrb_mruby_objectspace_gem_init(mrb_state *mrb)
|
||||
{
|
||||
struct RClass *os = mrb_define_module(mrb, "ObjectSpace");
|
||||
mrb_define_class_method(mrb, os, "count_objects", os_count_objects, MRB_ARGS_OPT(1));
|
||||
mrb_define_class_method(mrb, os, "each_object", os_each_object, MRB_ARGS_OPT(1));
|
||||
mrb_define_class_method(mrb, os, "memsize_of", os_memsize_of, MRB_ARGS_REQ(1));
|
||||
mrb_define_class_method(mrb, os, "memsize_of_all", os_memsize_of_all, MRB_ARGS_OPT(1));
|
||||
}
|
||||
|
||||
void
|
||||
|
||||
@@ -44,6 +44,19 @@ os_memsize_of_method(mrb_state* mrb, mrb_value method_obj)
|
||||
return size;
|
||||
}
|
||||
|
||||
static mrb_bool
|
||||
obj_is_kind_of_checked(mrb_state *mrb, mrb_value obj, const char *classname)
|
||||
{
|
||||
mrb_value objclass = mrb_obj_value(mrb->object_class);
|
||||
|
||||
if (mrb_const_defined(mrb, objclass, mrb_intern_cstr(mrb, classname))) {
|
||||
struct RClass *klass = mrb_class_get(mrb, classname);
|
||||
return mrb_obj_is_kind_of(mrb, obj, klass);
|
||||
}
|
||||
|
||||
return FALSE;
|
||||
}
|
||||
|
||||
static mrb_int
|
||||
os_memsize_of_object(mrb_state* mrb, mrb_value obj)
|
||||
{
|
||||
@@ -54,6 +67,7 @@ os_memsize_of_object(mrb_state* mrb, mrb_value obj)
|
||||
size += mrb_objspace_page_slot_size();
|
||||
if (!RSTR_EMBED_P(RSTRING(obj)) && !RSTR_SHARED_P(RSTRING(obj))) {
|
||||
size += RSTRING_CAPA(obj);
|
||||
size++; /* NUL terminator */
|
||||
}
|
||||
break;
|
||||
case MRB_TT_CLASS:
|
||||
@@ -66,8 +80,8 @@ os_memsize_of_object(mrb_state* mrb, mrb_value obj)
|
||||
case MRB_TT_OBJECT: {
|
||||
size += mrb_objspace_page_slot_size();
|
||||
size += os_memsize_of_ivars(mrb, obj);
|
||||
if (mrb_obj_is_kind_of(mrb, obj, mrb_class_get(mrb, "UnboundMethod")) ||
|
||||
mrb_obj_is_kind_of(mrb, obj, mrb_class_get(mrb, "Method"))){
|
||||
if (obj_is_kind_of_checked(mrb, obj, "UnboundMethod") ||
|
||||
obj_is_kind_of_checked(mrb, obj, "Method")) {
|
||||
size += os_memsize_of_method(mrb, obj);
|
||||
}
|
||||
break;
|
||||
|
||||
@@ -12,7 +12,7 @@ assert 'ObjectSpace.memsize_of' do
|
||||
assert_not_equal ObjectSpace.memsize_of('a'), 0, 'memsize of str'
|
||||
|
||||
if __ENCODING__ == "UTF-8"
|
||||
assert_not_equal ObjectSpace.memsize_of("縺薙s縺ォ縺。縺ッ荳也阜"), 0, 'memsize of utf8 str'
|
||||
assert_not_equal ObjectSpace.memsize_of("こんにちは世界"), 0, 'memsize of utf8 str'
|
||||
end
|
||||
|
||||
# class defs
|
||||
@@ -22,20 +22,6 @@ assert 'ObjectSpace.memsize_of' do
|
||||
empty_class_def_size = ObjectSpace.memsize_of Class.new
|
||||
assert_not_equal empty_class_def_size, 0, 'Class def not zero'
|
||||
|
||||
class_without_methods = Class.new do
|
||||
@a = 1
|
||||
@b = 2
|
||||
end
|
||||
class_total_size = empty_class_def_size + (int_size * 2)
|
||||
assert_equal ObjectSpace.memsize_of(class_without_methods), class_total_size, 'class without methods size'
|
||||
|
||||
module_without_methods = Module.new do
|
||||
@a = 1
|
||||
@b = 2
|
||||
end
|
||||
module_total_size = empty_class_def_size + (int_size * 2)
|
||||
assert_equal ObjectSpace.memsize_of(module_without_methods), module_total_size, 'module without methods size'
|
||||
|
||||
proc_size = ObjectSpace.memsize_of Proc.new { x = 1; x }
|
||||
assert_not_equal proc_size, 0
|
||||
|
||||
|
||||
@@ -1601,8 +1601,8 @@ mrb_objspace_each_objects(mrb_state *mrb, mrb_each_object_callback *callback, vo
|
||||
}
|
||||
}
|
||||
|
||||
const mrb_int
|
||||
mrb_objspace_page_slot_size()
|
||||
mrb_int
|
||||
mrb_objspace_page_slot_size(void)
|
||||
{
|
||||
const mrb_int i = sizeof(RVALUE);
|
||||
return i;
|
||||
|
||||
+3
-4
@@ -4,7 +4,6 @@
|
||||
** See Copyright Notice in mruby.h
|
||||
*/
|
||||
|
||||
#include <math.h>
|
||||
#include <mruby.h>
|
||||
#include <mruby/array.h>
|
||||
#include <mruby/class.h>
|
||||
@@ -1132,9 +1131,9 @@ mrb_class_find_path(mrb_state *mrb, struct RClass *c)
|
||||
mrb_int
|
||||
mrb_obj_iv_tbl_memsize(mrb_state* mrb, mrb_value obj)
|
||||
{
|
||||
return sizeof(iv_tbl) +
|
||||
(sizeof(segment) * ceil(iv_size(mrb, mrb_obj_ptr(obj)->iv)/
|
||||
MRB_IV_SEGMENT_SIZE));
|
||||
size_t ivsize = iv_size(mrb, mrb_obj_ptr(obj)->iv);
|
||||
size_t ivsegs = (ivsize + MRB_IV_SEGMENT_SIZE - 1) / MRB_IV_SEGMENT_SIZE;
|
||||
return sizeof(iv_tbl) + (sizeof(segment) * ivsegs);
|
||||
}
|
||||
|
||||
#define identchar(c) (ISALNUM(c) || (c) == '_' || !ISASCII(c))
|
||||
|
||||
Reference in New Issue
Block a user