Commit 21db13a6 authored by Stanislav Bohm's avatar Stanislav Bohm

FIX: Fixed invalid reference in scheduler

parent be9b000f
......@@ -3,7 +3,7 @@
static void
data_wrapper_dealloc(DataWrapper* self)
{
self->data.~__shared_ptr();
self->data.~shared_ptr();
Py_TYPE(self)->tp_free((PyObject*)self);
}
......
......@@ -348,8 +348,8 @@ void Scheduler::create_derived_units()
// Create pairs
for (size_t i = 0; i < initial_size; i++) {
const SUnit &u1 = s_units[i];
for (size_t j = i + 1; j < initial_size; j++) {
const SUnit &u1 = s_units[i];
const SUnit &u2 = s_units[j];
if (intersects(u1.inputs.begin(), u1.inputs.end(),
u2.inputs.begin(), u2.inputs.end())) {
......
......@@ -245,3 +245,13 @@ def test_size_and_length(loom_env):
u64 = struct.Struct("<Q")
[25, 0, 50, 2] == map(lambda x: u64.unpack(x)[0],
loom_env.submit((b1, c1, b2, c2)))
def test_hostname(loom_env):
loom_env.start(1)
TASKS_COUNT = 100
ts = [tasks.run("hostname") for i in range(TASKS_COUNT)]
array = tasks.array_make(ts)
loom_env.submit(array)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment