File: flowlist.c

package info (click to toggle)
ns2 2.35%2Bdfsg-2.1
  • links: PTS, VCS
  • area: main
  • in suites: stretch
  • size: 78,780 kB
  • ctags: 27,490
  • sloc: cpp: 172,923; tcl: 107,130; perl: 6,391; sh: 6,143; ansic: 5,846; makefile: 816; awk: 525; csh: 355
file content (95 lines) | stat: -rw-r--r-- 2,142 bytes parent folder | download | duplicates (8)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
#include "flowlist.h"
#include<stdlib.h>
#include<stdio.h>

struct flow_list *create_new_flow_event(double time, double bw){  
    struct flow_list *new_node;
    new_node = (struct flow_list*)malloc(sizeof(struct flow_list));
    new_node->time = time;
    new_node->bw = bw;
    new_node->next = NULL;
    return(new_node);
}



void flow_list_insert(double time,double bw, struct flow_list **root){
struct flow_list* node;
struct flow_list *new_node;

  if(*root==NULL){
    new_node = create_new_flow_event(time,bw);
    *root = new_node;
  }
  else if((*root)->time > time){
    new_node = create_new_flow_event(time,bw);
    new_node->next = (*root);
    *root = new_node;
  }
  else if((*root)->time == time){
    (*root)->bw+=bw;
  }
  else{
    for(node = (*root); node->next != NULL && node->next->time < time ;node = node->next);    
    
    if(node->next == NULL){
      new_node = create_new_flow_event(time,bw);
      node->next = new_node;
    }
    else if(node->next->time==time){
      node->next->bw += bw;
    }
    else{
      new_node = create_new_flow_event(time,bw);
      new_node->next=node->next;
      node->next = new_node;
    }
  }
return;
}


void dump_flow_list_to_file(FILE* file, struct flow_list* root){
  struct flow_list *node;
  double total_bw = 0;
  for(node=root;node!=NULL;node=node->next){
    total_bw+=node->bw;
    fprintf(file,"%lf %lf %lf\n",node->time,node->bw,total_bw);
  }
}


int get_no_events(struct flow_list *root){
  int NoNodes;
  struct flow_list *node;
  for(node=root,NoNodes=0;node!=NULL;node=node->next,NoNodes++);
  return(NoNodes);
}

struct flow_event* get_all_events(struct flow_list *root){
  int NoNodes=0;
  int i;
  struct flow_event *allEvents;
  struct flow_list *node;

  NoNodes = get_no_events(root);

  allEvents = (struct flow_event*)malloc(NoNodes*sizeof(struct flow_event));
  for(node=root,i=0;node!=NULL;node=node->next,i++){
    allEvents[i].delay = node->time;
    allEvents[i].deltaCBR = node->bw;
    if(i==0)
      allEvents[i].NetCBR = node->bw;
    else
      allEvents[i].NetCBR = allEvents[i-1].NetCBR + node->bw;
  }
  return(allEvents);
}