:(before "End Mu Types Initialization")
type_ordinal shared = put(Type_ordinal, "shared", Next_type_ordinal++);
get_or_insert(Type, shared).name = "shared";
:(before "End Drop Address In lookup_memory(x)")
if (x.properties.at(0).second->value == "shared") {
trace(9999, "mem") << "skipping refcount at " << x.value << end();
x.set_value(x.value+1);
drop_from_type(x, "shared");
}
:(before "End Drop Address In canonize_type(r)")
if (r.properties.at(0).second->value == "shared") {
drop_from_type(r, "shared");
}
:(scenarios run)
:(scenario new)
recipe main [
1:address:shared:number/raw <- new number:type
2:address:shared:number/raw <- new number:type
3:boolean/raw <- equal 1:address:shared:number/raw, 2:address:shared:number/raw
]
+mem: storing 0 in location 3
:(before "End Globals")
long long int Memory_allocated_until = Reserved_for_tests;
long long int Initial_memory_per_routine = 100000;
:(before "End Setup")
Memory_allocated_until = Reserved_for_tests;
Initial_memory_per_routine = 100000;
:(before "End routine Fields")
long long int alloc, alloc_max;
:(before "End routine Constructor")
alloc = Memory_allocated_until;
Memory_allocated_until += Initial_memory_per_routine;
alloc_max = Memory_allocated_until;
trace(9999, "new") << "routine allocated memory from " << alloc << " to " << alloc_max << end();
:(before "End Mu Types Initialization")
put(Type_ordinal, "type", 0);
:(before "End Primitive Recipe Declarations")
NEW,
:(before "End Primitive Recipe Numbers")
put(Recipe_ordinal, "new", NEW);
:(before "End Primitive Recipe Checks")
case NEW: {
const recipe& caller = get(Recipe, r);
if (inst.ingredients.empty() || SIZE(inst.ingredients) > 2) {
raise_error << maybe(caller.name) << "'new' requires one or two ingredients, but got " << inst.to_string() << '\n' << end();
break;
}
reagent type = inst.ingredients.at(0);
if (!is_mu_type_literal(type)) {
raise_error << maybe(caller.name) << "first ingredient of 'new' should be a type, but got " << type.original_string << '\n' << end();
break;
}
if (inst.products.empty()) {
raise_error << maybe(caller.name) << "result of 'new' should never be ignored\n" << end();
break;
}
if (!product_of_new_is_valid(inst)) {
raise_error << maybe(caller.name) << "product of 'new' has incorrect type: " << inst.to_string() << '\n' << end();
break;
}
break;
}
:(code)
bool product_of_new_is_valid(const instruction& inst) {
reagent product = inst.products.at(0);
canonize_type(product);
if (!product.type || product.type->value != get(Type_ordinal, "address")) return false;
drop_from_type(product, "address");
if (!product.type || product.type->value != get(Type_ordinal, "shared")) return false;
drop_from_type(product, "shared");
if (SIZE(inst.ingredients) > 1) {
if (!product.type || product.type->value != get(Type_ordinal, "array")) return false;
drop_from_type(product, "array");
}
reagent expected_product("x:"+inst.ingredients.at(0).name);
return types_strictly_match(product, expected_product);
}
:(after "Transform.push_back(check_instruction)")
Transform.push_back(transform_new_to_allocate);
:(code)
void transform_new_to_allocate(const recipe_ordinal r) {
trace(9991, "transform") << "--- convert 'new' to 'allocate' for recipe " << get(Recipe, r).name << end();
for (long long int i = 0; i < SIZE(get(Recipe, r).steps); ++i) {
instruction& inst = get(Recipe, r).steps.at(i);
if (inst.name == "new") {
inst.operation = ALLOCATE;
string_tree* type_name = new string_tree(inst.ingredients.at(0).name);
type_tree* type = new_type_tree(type_name);
inst.ingredients.at(0).set_value(size_of(type));
trace(9992, "new") << "size of " << debug_string(type_name) << " is " << inst.ingredients.at(0).value << end();
delete type;
delete type_name;
}
}
}
:(before "End Primitive Recipe Declarations")
ALLOCATE,
:(before "End Primitive Recipe Numbers")
put(Recipe_ordinal, "allocate", ALLOCATE);
:(before "End Primitive Recipe Implementations")
case ALLOCATE: {
long long int size = ingredients.at(0).at(0);
if (SIZE(ingredients) > 1) {
trace(9999, "mem") << "array size is " << ingredients.at(1).at(0) << end();
size = 1 + size*ingredients.at(1).at(0);
}
size++;
trace(9999, "mem") << "allocating size " << size << end();
ensure_space(size);
const long long int result = Current_routine->alloc;
trace(9999, "mem") << "new alloc: " << result << end();
products.resize(1);
products.at(0).push_back(result);
for (long long int address = result; address < result+size; ++address)
put(Memory, address, 0);
if (SIZE(current_instruction().ingredients) > 1) {
trace(9999, "mem") << "storing " << ingredients.at(1).at(0) << " in location " << result+1 << end();
put(Memory, result+1, ingredients.at(1).at(0));
}
Current_routine->alloc += size;
assert(Current_routine->alloc <= Current_routine->alloc_max);
break;
}
:(before "End Primitive Recipe Checks")
case ALLOCATE: {
raise << "never call 'allocate' directly'; always use 'new'\n" << end();
break;
}
:(before "End Primitive Recipe Implementations")
case NEW: {
raise << "no implementation for 'new'; why wasn't it translated to 'allocate'?\n" << end();
break;
}
:(code)
void ensure_space(long long int size) {
if (size > Initial_memory_per_routine) {
tb_shutdown();
cerr << "can't allocate " << size << " locations, that's too much compared to " << Initial_memory_per_routine << ".\n";
exit(0);
}
if (Current_routine->alloc + size > Current_routine->alloc_max) {
Current_routine->alloc = Memory_allocated_until;
Memory_allocated_until += Initial_memory_per_routine;
Current_routine->alloc_max = Memory_allocated_until;
trace(9999, "new") << "routine allocated memory from " << Current_routine->alloc << " to " << Current_routine->alloc_max << end();
}
}
:(scenario new_initializes)
% Memory_allocated_until = 10;
% put(Memory, Memory_allocated_until, 1);
recipe main [
1:address:shared:number <- new number:type
2:number <- copy *1:address:shared:number
]
+mem: storing 0 in location 2
:(scenario new_error)
% Hide_errors = true;
recipe main [
1:address:number/raw <- new number:type
]
+error: main: product of 'new' has incorrect type: 1:address:number/raw <- new number:type
:(scenario new_array)
recipe main [
1:address:shared:array:number/raw <- new number:type, 5
2:address:shared:number/raw <- new number:type
3:number/raw <- subtract 2:address:shared:number/raw, 1:address:shared:array:number/raw
]
+run: 1:address:shared:array:number/raw <- new number:type, 5
+mem: array size is 5
+mem: storing 7 in location 3
:(scenario new_empty_array)
recipe main [
1:address:shared:array:number/raw <- new number:type, 0
2:address:shared:number/raw <- new number:type
3:number/raw <- subtract 2:address:shared:number/raw, 1:address:shared:array:number/raw
]
+run: 1:address:shared:array:number/raw <- new number:type, 0
+mem: array size is 0
+mem: storing 2 in location 3
:(scenario new_overflow)
% Initial_memory_per_routine = 3; // barely enough room for point allocation below
recipe main [
1:address:shared:number/raw <- new number:type
2:address:shared:point/raw <- new point:type
]
+new: routine allocated memory from 1000 to 1003
+new: routine allocated memory from 1003 to 1006
:(scenario new_reclaim)
recipe main [
1:address:shared:number <- new number:type
2:address:shared:number <- copy 1:address:shared:number
abandon 1:address:shared:number
3:address:shared:number <- new number:type
4:boolean <- equal 2:address:shared:number, 3:address:shared:number
]
+mem: storing 1 in location 4
:(before "End Globals")
map<long long int, long long int> Free_list;
:(before "End Setup")
Free_list.clear();
:(before "End Primitive Recipe Declarations")
ABANDON,
:(before "End Primitive Recipe Numbers")
put(Recipe_ordinal, "abandon", ABANDON);
:(before "End Primitive Recipe Checks")
case ABANDON: {
if (SIZE(inst.ingredients) != 1) {
raise_error << maybe(get(Recipe, r).name) << "'abandon' requires one ingredient, but got '" << inst.to_string() << "'\n" << end();
break;
}
reagent types = inst.ingredients.at(0);
canonize_type(types);
if (!types.type || types.type->value != get(Type_ordinal, "address") || types.type->right->value != get(Type_ordinal, "shared")) {
raise_error << maybe(get(Recipe, r).name) << "first ingredient of 'abandon' should be an address:shared:___, but got " << inst.ingredients.at(0).original_string << '\n' << end();
break;
}
break;
}
:(before "End Primitive Recipe Implementations")
case ABANDON: {
long long int address = ingredients.at(0).at(0);
trace(9999, "abandon") << "address to abandon is " << address << end();
reagent types = current_instruction().ingredients.at(0);
trace(9999, "abandon") << "value of ingredient is " << types.value << end();
canonize(types);
trace(9999, "abandon") << "value of ingredient after canonization is " << types.value << end();
long long int address_location = types.value;
types.set_value(get_or_insert(Memory, types.value)+1);
drop_from_type(types, "address");
drop_from_type(types, "shared");
abandon(address, size_of(types)+1);
trace(9999, "mem") << "resetting location " << address_location << end();
Memory[address_location] = 0;
break;
}
:(code)
void abandon(long long int address, long long int size) {
trace(9999, "abandon") << "saving in free-list of size " << size << end();
for (long long int curr = address; curr < address+size; ++curr)
put(Memory, curr, 0);
put(Memory, address, Free_list[size]);
Free_list[size] = address;
}
:(before "ensure_space(size)" following "case ALLOCATE")
if (Free_list[size]) {
trace(9999, "abandon") << "picking up space from free-list of size " << size << end();
long long int result = Free_list[size];
Free_list[size] = get_or_insert(Memory, result);
for (long long int curr = result+1; curr < result+size; ++curr) {
if (get_or_insert(Memory, curr) != 0) {
raise_error << maybe(current_recipe_name()) << "memory in free list was not zeroed out: " << curr << '/' << result << "; somebody wrote to us after free!!!\n" << end();
break;
}
}
if (SIZE(current_instruction().ingredients) > 1)
put(Memory, result+1, ingredients.at(1).at(0));
else
put(Memory, result, 0);
products.resize(1);
products.at(0).push_back(result);
break;
}
:(scenario new_differing_size_no_reclaim)
recipe main [
1:address:shared:number <- new number:type
2:address:shared:number <- copy 1:address:shared:number
abandon 1:address:shared:number
3:address:shared:array:number <- new number:type, 2
4:boolean <- equal 2:address:shared:number, 3:address:shared:array:number
]
+mem: storing 0 in location 4
:(scenario new_reclaim_array)
recipe main [
1:address:shared:array:number <- new number:type, 2
2:address:shared:array:number <- copy 1:address:shared:array:number
abandon 1:address:shared:array:number
3:address:shared:array:number <- new number:type, 2
4:boolean <- equal 2:address:shared:array:number, 3:address:shared:array:number
]
+mem: storing 1 in location 4
:(scenario reset_on_abandon)
recipe main [
1:address:shared:number <- new number:type
abandon 1:address:shared:number
]
+run: abandon 1:address:shared:number
+mem: resetting location 1
:(scenario refcounts)
recipe main [
1:address:shared:number <- copy 1000/unsafe
2:address:shared:number <- copy 1:address:shared:number
1:address:shared:number <- copy 0
2:address:shared:number <- copy 0
]
+run: 1:address:shared:number <- copy 1000/unsafe
+mem: incrementing refcount of 1000: 0 -> 1
+run: 2:address:shared:number <- copy 1:address:shared:number
+mem: incrementing refcount of 1000: 1 -> 2
+run: 1:address:shared:number <- copy 0
+mem: decrementing refcount of 1000: 2 -> 1
+run: 2:address:shared:number <- copy 0
+mem: decrementing refcount of 1000: 1 -> 0
+mem: automatically abandoning 1000
:(before "End write_memory(reagent x, long long int base) Special-cases")
if (x.type->value == get(Type_ordinal, "address")
&& x.type->right
&& x.type->right->value == get(Type_ordinal, "shared")) {
long long int old_address = get_or_insert(Memory, x.value);
assert(scalar(data));
long long int new_address = data.at(0);
if (old_address) {
long long int old_refcount = get_or_insert(Memory, old_address);
trace(9999, "mem") << "decrementing refcount of " << old_address << ": " << old_refcount << " -> " << (old_refcount-1) << end();
put(Memory, old_address, old_refcount-1);
}
trace(9999, "mem") << "storing " << no_scientific(data.at(0)) << " in location " << base << end();
put(Memory, base, new_address);
if (new_address) {
long long int new_refcount = get_or_insert(Memory, new_address);
trace(9999, "mem") << "incrementing refcount of " << new_address << ": " << new_refcount << " -> " << (new_refcount+1) << end();
put(Memory, new_address, new_refcount+1);
}
assert(get_or_insert(Memory, old_address) >= 0);
if (old_address && get_or_insert(Memory, old_address) == 0) {
trace(9999, "mem") << "automatically abandoning " << old_address << end();
trace(9999, "mem") << "computing size to abandon at " << x.value << end();
x.set_value(get_or_insert(Memory, x.value)+1);
drop_from_type(x, "address");
drop_from_type(x, "shared");
abandon(old_address, size_of(x)+1);
}
return;
}
:(scenario refcounts_2)
recipe main [
1:address:shared:number <- new number:type
1:address:shared:number <- new number:type
1:address:shared:number <- copy 0
]
+run: 1:address:shared:number <- new number:type
+mem: incrementing refcount of 1000: 0 -> 1
+run: 1:address:shared:number <- new number:type
+mem: automatically abandoning 1000
:(scenario refcounts_3)
recipe main [
1:address:shared:number <- new number:type
foo 1:address:shared:number
1:address:shared:number <- copy 0
]
recipe foo [
2:address:shared:number <- next-ingredient
2:address:shared:number <- copy 0
]
+run: 1:address:shared:number <- new number:type
+mem: incrementing refcount of 1000: 0 -> 1
+run: 2:address:shared:number <- next-ingredient
+mem: incrementing refcount of 1000: 1 -> 2
+run: 2:address:shared:number <- copy 0
+mem: decrementing refcount of 1000: 2 -> 1
+run: 1:address:shared:number <- copy 0
+mem: decrementing refcount of 1000: 1 -> 0
+mem: automatically abandoning 1000
:(scenario refcounts_4)
recipe main [
1:address:shared:number <- new number:type
1:address:shared:number <- copy 1:address:shared:number
]
+run: 1:address:shared:number <- new number:type
+mem: incrementing refcount of 1000: 0 -> 1
+run: 1:address:shared:number <- copy 1:address:shared:number
+mem: decrementing refcount of 1000: 1 -> 0
+mem: incrementing refcount of 1000: 0 -> 1
:(scenario refcounts_5)
recipe main [
1:address:shared:number <- new number:type
foo 1:address:shared:number
1:address:shared:number <- new number:type
]
recipe foo [
2:address:shared:number <- next-ingredient
]
+run: 1:address:shared:number <- new number:type
+mem: incrementing refcount of 1000: 0 -> 1
+run: 2:address:shared:number <- next-ingredient
+mem: incrementing refcount of 1000: 1 -> 2
+run: 1:address:shared:number <- new number:type
+mem: decrementing refcount of 1000: 2 -> 1
:(scenario new_string)
recipe main [
1:address:shared:array:character <- new [abc def]
2:character <- index *1:address:shared:array:character, 5
]
+mem: storing 101 in location 2
:(scenario new_string_handles_unicode)
recipe main [
1:address:shared:array:character <- new [a«c]
2:number <- length *1:address:shared:array:character
3:character <- index *1:address:shared:array:character, 1
]
+mem: storing 3 in location 2
+mem: storing 171 in location 3
:(before "End NEW Check Special-cases")
if (is_literal_string(inst.ingredients.at(0))) break;
:(before "Convert 'new' To 'allocate'")
if (inst.name == "new" && is_literal_string(inst.ingredients.at(0))) continue;
:(after "case NEW" following "Primitive Recipe Implementations")
if (is_literal_string(current_instruction().ingredients.at(0))) {
products.resize(1);
products.at(0).push_back(new_mu_string(current_instruction().ingredients.at(0).name));
break;
}
:(code)
long long int new_mu_string(const string& contents) {
long long int string_length = unicode_length(contents);
ensure_space(string_length+1);
long long int result = Current_routine->alloc;
put(Memory, Current_routine->alloc++, 0);
put(Memory, Current_routine->alloc++, string_length);
long long int curr = 0;
const char* raw_contents = contents.c_str();
for (long long int i = 0; i < string_length; ++i) {
uint32_t curr_character;
assert(curr < SIZE(contents));
tb_utf8_char_to_unicode(&curr_character, &raw_contents[curr]);
put(Memory, Current_routine->alloc, curr_character);
curr += tb_utf8_char_length(raw_contents[curr]);
++Current_routine->alloc;
}
return result;
}
:(scenario stash_string)
recipe main [
1:address:shared:array:character <- new [abc]
stash [foo:], 1:address:shared:array:character
]
+app: foo: abc
:(before "End print Special-cases(reagent r, data)")
if (is_mu_string(r)) {
assert(scalar(data));
return read_mu_string(data.at(0))+' ';
}
:(scenario unicode_string)
recipe main [
1:address:shared:array:character <- new [♠]
stash [foo:], 1:address:shared:array:character
]
+app: foo: ♠
:(scenario stash_space_after_string)
recipe main [
1:address:shared:array:character <- new [abc]
stash 1:address:shared:array:character, [foo]
]
+app: abc foo
:(scenario new_string_overflow)
% Initial_memory_per_routine = 2;
recipe main [
1:address:shared:number/raw <- new number:type
2:address:shared:array:character/raw <- new [a]
]
+new: routine allocated memory from 1000 to 1002
+new: routine allocated memory from 1002 to 1004
:(code)
long long int unicode_length(const string& s) {
const char* in = s.c_str();
long long int result = 0;
long long int curr = 0;
while (curr < SIZE(s)) {
++result;
curr += tb_utf8_char_length(in[curr]);
}
return result;
}
string read_mu_string(long long int address) {
if (address == 0) return "";
address++;
long long int size = get_or_insert(Memory, address);
if (size == 0) return "";
ostringstream tmp;
for (long long int curr = address+1; curr <= address+size; ++curr) {
tmp << to_unicode(static_cast<uint32_t>(get_or_insert(Memory, curr)));
}
return tmp.str();
}
bool is_mu_type_literal(reagent r) {
return is_literal(r) && !r.properties.empty() && r.properties.at(0).second && r.properties.at(0).second->value == "type";
}