Fix FutureStream memory usage (#17395) [backport:1.2] - Nim - This repository contains the Nim compiler, Nim's stdlib, tools, and documentation. (mirror)

diff options

author	Igor Ribeiro de Assis <igor.assis@gmail.com>	2021-03-16 21:46:22 +0100
committer	GitHub <noreply@github.com>	2021-03-16 21:46:22 +0100
commit	9bb0e557497c6d66ef7bdcda765098fd0271726f (patch)
tree	6b606cacbbf53e7a3de3800d58d1718140635e9b /tests/stdlib/tmemory.nim
parent	895a40d1ac305171b8581bed9a951901f5b73328 (diff)
download	Nim-9bb0e557497c6d66ef7bdcda765098fd0271726f.tar.gz

Fix FutureStream memory usage (#17395) [backport:1.2]

Diffstat (limited to 'tests/stdlib/tmemory.nim')

0 files changed, 0 insertions, 0 deletions

//: Calls can take ingredients just like primitives. To access a recipe's //: ingredients, use 'next-ingredient'. :(scenario next_ingredient) recipe main [ f 2:literal ] recipe f [ 12:number <- next-ingredient 13:number <- add 1:literal, 12:number ] +run: instruction f/1 +mem: location 12 is 2 +mem: storing 3 in location 13 :(scenario next_ingredient_missing) recipe main [ f ] recipe f [ _, 12:number <- next-ingredient ] +mem: storing 0 in location 12 :(before "End call Fields") vector<vector<double> > ingredient_atoms; long long int next_ingredient_to_process; :(replace{} "call(recipe_number r)") call(recipe_number r) :running_recipe(r), running_step_index(0), next_ingredient_to_process(0) {} :(replace "Current_routine->calls.push_front(call(current_instruction().operation))" following "End Primitive Recipe Implementations") call callee(current_instruction().operation); for (long long int i = 0; i < SIZE(ingredients); ++i) { callee.ingredient_atoms.push_back(ingredients.at(i)); } Current_routine->calls.push_front(callee); :(before "End Primitive Recipe Declarations") NEXT_INGREDIENT, :(before "End Primitive Recipe Numbers") Recipe_number["next-ingredient"] = NEXT_INGREDIENT; :(before "End Primitive Recipe Implementations") case NEXT_INGREDIENT: { assert(!Current_routine->calls.empty()); if (Current_routine->calls.front().next_ingredient_to_process < SIZE(Current_routine->calls.front().ingredient_atoms)) { products.push_back( Current_routine->calls.front().ingredient_atoms.at(Current_routine->calls.front().next_ingredient_to_process)); assert(SIZE(products) == 1); products.resize(2); // push a new vector products.at(1).push_back(1); ++Current_routine->calls.front().next_ingredient_to_process; } else { products.resize(2); products.at(0).push_back(0); // todo: will fail noisily if we try to read a compound value products.at(1).push_back(0); } break; } :(scenario rewind_ingredients) recipe main [ f 2:literal ] recipe f [ 12:number <- next-ingredient # consume ingredient _, 1:boolean <- next-ingredient # will not find any ingredients rewind-ingredients 13:number, 2:boolean <- next-ingredient # will find ingredient again ] +mem: storing 2 in location 12 +mem: storing 0 in location 1 +mem: storing 2 in location 13 +mem: storing 1 in location 2 :(before "End Primitive Recipe Declarations") REWIND_INGREDIENTS, :(before "End Primitive Recipe Numbers") Recipe_number["rewind-ingredients"] = REWIND_INGREDIENTS; :(before "End Primitive Recipe Implementations") case REWIND_INGREDIENTS: { Current_routine->calls.front().next_ingredient_to_process = 0; break; } :(scenario ingredient) recipe main [ f 1:literal, 2:literal ] recipe f [ 12:number <- ingredient 1:literal # consume second ingredient first 13:number, 1:boolean <- next-ingredient # next-ingredient tries to scan past that ] +mem: storing 2 in location 12 +mem: storing 0 in location 1 :(before "End Primitive Recipe Declarations") INGREDIENT, :(before "End Primitive Recipe Numbers") Recipe_number["ingredient"] = INGREDIENT; :(before "End Primitive Recipe Implementations") case INGREDIENT: { assert(isa_literal(current_instruction().ingredients.at(0))); assert(scalar(ingredients.at(0))); if (static_cast<long long int>(ingredients.at(0).at(0)) < SIZE(Current_routine->calls.front().ingredient_atoms)) { Current_routine->calls.front().next_ingredient_to_process = ingredients.at(0).at(0); products.push_back( Current_routine->calls.front().ingredient_atoms.at(Current_routine->calls.front().next_ingredient_to_process)); assert(SIZE(products) == 1); products.resize(2); // push a new vector products.at(1).push_back(1); ++Current_routine->calls.front().next_ingredient_to_process; } else { if (SIZE(current_instruction().products) > 1) { products.resize(2); products.at(0).push_back(0); // todo: will fail noisily if we try to read a compound value products.at(1).push_back(0); } } break; }


context:
space:
mode: