receiverbased.c

Path MPICH-V for MPICH the MPI Implementation

/** @file senderbased.c implements the sender based message logging strutcure */

#include "config.h"
#include "debug.h"

#include "vtypes.h"
#include "receiverbased.h"
#include "otherdaemoncomm.h"
#include "simple_list.h"
#include "daemonCsched.h"
#include <string.h>


void initReceiverBased(listeMessages * rb, int size)
{
  if (rb == NULL)
    printe("null pointer in initReceiverBased");

  rb->peersize = size;
  ll_create(&(rb->messages));
}

void add_message_to_log(listeMessages * rb, pkt_header * message)
{
  pkt_header * mess;

  printi("rbased", "add message %s to log", format_packet(message));

  mess = malloc(sizeof(pkt_header) + ntohl(message->iSize));
  memcpy(mess, message,sizeof(pkt_header) + ntohl(message->iSize));

  ll_add_tail(&(rb->messages), mess);
}

void push_message_to_log(listeMessages * rb, pkt_header * message)
{
  pkt_header * mess;

  printi("rbased", "push message %s to log", format_packet(message));

  mess = malloc(sizeof(pkt_header) + ntohl(message->iSize));
  memcpy(mess, message,sizeof(pkt_header) + ntohl(message->iSize));

  ll_add_head(&(rb->messages), mess);
}

void remove_message_from_log(listeMessages * rb)
{
  sElement_t * elem;
  pkt_header * pkt;
  elem = rb->messages.head;
  while(elem != NULL )
    {
      pkt = (pkt_header *)ll_remove_head(&(rb->messages));
      free(pkt);
      elem = rb->messages.head;
    }
}