X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/e8ff342894fb44f61acf7c48943824f87efb39be..eee4fd8a61935c3b7cbefe0768e040eeea1c9336:/src/mc/mc_ignore.cpp diff --git a/src/mc/mc_ignore.cpp b/src/mc/mc_ignore.cpp index a9f49f2c86..6017779fa2 100644 --- a/src/mc/mc_ignore.cpp +++ b/src/mc/mc_ignore.cpp @@ -1,17 +1,17 @@ -/* Copyright (c) 2008-2014. The SimGrid Team. +/* Copyright (c) 2008-2015. The SimGrid Team. * All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ -#include "internal_config.h" -#include "mc_object_info.h" -#include "mc_private.h" -#include "smpi/private.h" -#include "mc/mc_snapshot.h" -#include "mc_ignore.h" -#include "mc_protocol.h" -#include "mc_client.h" +#include "src/internal_config.h" +#include "src/mc/mc_object_info.h" +#include "src/mc/mc_private.h" +#include "src/smpi/private.h" +#include "src/mc/mc_snapshot.h" +#include "src/mc/mc_ignore.h" +#include "src/mc/mc_protocol.h" +#include "src/mc/mc_client.h" extern "C" { @@ -25,26 +25,25 @@ void MC_ignore_heap(void *address, size_t size) if (mc_mode != MC_MODE_CLIENT) return; - s_mc_heap_ignore_region_t region; - memset(®ion, 0, sizeof(region)); - region.address = address; - region.size = size; - region.block = + xbt_mheap_t heap = mmalloc_get_current_heap(); + + s_mc_ignore_heap_message_t message; + message.type = MC_MESSAGE_IGNORE_HEAP; + message.address = address; + message.size = size; + message.block = ((char *) address - - (char *) std_heap->heapbase) / BLOCKSIZE + 1; - if (std_heap->heapinfo[region.block].type == 0) { - region.fragment = -1; - std_heap->heapinfo[region.block].busy_block.ignore++; + (char *) heap->heapbase) / BLOCKSIZE + 1; + if (heap->heapinfo[message.block].type == 0) { + message.fragment = -1; + heap->heapinfo[message.block].busy_block.ignore++; } else { - region.fragment = - ((uintptr_t) (ADDR2UINT(address) % (BLOCKSIZE))) >> std_heap-> - heapinfo[region.block].type; - std_heap->heapinfo[region.block].busy_frag.ignore[region.fragment]++; + message.fragment = + ((uintptr_t) (ADDR2UINT(address) % (BLOCKSIZE))) >> + heap->heapinfo[message.block].type; + heap->heapinfo[message.block].busy_frag.ignore[message.fragment]++; } - s_mc_ignore_heap_message_t message; - message.type = MC_MESSAGE_IGNORE_HEAP; - message.region = region; if (MC_protocol_send(mc_client->fd, &message, sizeof(message))) xbt_die("Could not send ignored region to MCer"); } @@ -56,7 +55,7 @@ void MC_remove_ignore_heap(void *address, size_t size) s_mc_ignore_memory_message_t message; message.type = MC_MESSAGE_UNIGNORE_HEAP; - message.addr = address; + message.addr = (std::uintptr_t) address; message.size = size; MC_client_send_message(&message, sizeof(message)); } @@ -67,17 +66,6 @@ void MC_ignore_global_variable(const char *name) xbt_die("Unimplemented"); } -// ***** - -extern xbt_dynar_t stacks_areas; - -void MC_stack_area_add(stack_region_t stack_area) -{ - if (stacks_areas == NULL) - stacks_areas = xbt_dynar_new(sizeof(stack_region_t), NULL); - xbt_dynar_push(stacks_areas, &stack_area); -} - /** @brief Register a stack in the model checker * * The stacks are allocated in the heap. The MC handle them especially @@ -89,34 +77,32 @@ void MC_stack_area_add(stack_region_t stack_area) * @param context * @param size Size of the stack */ -void MC_new_stack_area(void *stack, smx_process_t process, void *context, size_t size) +void MC_register_stack_area(void *stack, smx_process_t process, ucontext_t* context, size_t size) { - xbt_mheap_t heap = mmalloc_set_current_heap(mc_heap); + if (mc_mode != MC_MODE_CLIENT) + return; + + xbt_mheap_t heap = mmalloc_get_current_heap(); - stack_region_t region = xbt_new0(s_stack_region_t, 1); - region->address = stack; - region->context = context; - region->size = size; - region->block = + s_stack_region_t region; + memset(®ion, 0, sizeof(region)); + region.address = stack; + region.context = context; + region.size = size; + region.block = ((char *) stack - - (char *) std_heap->heapbase) / BLOCKSIZE + 1; + (char *) heap->heapbase) / BLOCKSIZE + 1; #ifdef HAVE_SMPI if (smpi_privatize_global_variables && process) { - region->process_index = smpi_process_index_of_smx_process(process); + region.process_index = smpi_process_index_of_smx_process(process); } else #endif - region->process_index = -1; - - if (mc_mode == MC_MODE_CLIENT) { - s_mc_stack_region_message_t message; - message.type = MC_MESSAGE_STACK_REGION; - message.stack_region = *region; - MC_client_send_message(&message, sizeof(message)); - } - - MC_stack_area_add(region); + region.process_index = -1; - mmalloc_set_current_heap(heap); + s_mc_stack_region_message_t message; + message.type = MC_MESSAGE_STACK_REGION; + message.stack_region = region; + MC_client_send_message(&message, sizeof(message)); } }