rofisys 0.2.6

This system crate provides Rust language bindings (via the use of Bindgen) to the Rust-OFI library.
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

#include <unistd.h>
#include <stdio.h>

#include <rofi.h>
#include "utils.h"

#define N 1
#define SIZE 128
//#define VERBOSE

int main(void)
{
	unsigned int me, np;
	unsigned int i;
	int ret = 0;
	char* addr1;
	char* addr2;
	char* addr3;
	
	rofi_init("verbs");
	
	np = rofi_get_size();
	me = rofi_get_id();

	if(!me)
		rofi_banner("Heap Alloc Test");

	printf("Process %d/%d allocating memory region of size %d\n", 
	       me, np, SIZE);
	
	ret = rofi_alloc(SIZE, 0x0, (void**) &addr1);
	if(ret){
		printf("Error allocating memory region! Aborting.");
	  goto out;
	}
	rofi_barrier();
	printf("Added memory region at %p size %d\n", addr1, SIZE);

	if(!me){
		printf("Address Mappig on all nodes:\n");
		for(i=0; i<np; i++)
			printf("\t Node %u: %d\n", i, rofi_get_remote_addr((void*) addr1, i));
	}

	ret = rofi_alloc(2 * SIZE, 0x0, (void**) &addr2);
	if(ret){
		printf("Error allocating memory region! Aborting.");
		goto out;
	}

	rofi_barrier();
	printf("Added memory region at %p size %d\n", addr2, SIZE);

	ret = rofi_release((void*) addr2);
	if(ret){
		printf("Error removing region %p!", addr2);
		goto out;
	}
	rofi_barrier();
	printf("Removed memory region at %p\n", addr2);

	ret = rofi_alloc(3 * SIZE, 0x0, (void**) &addr3);
	if(ret){
		printf("Error allocating memory region! Aborting.");
	  goto out;
	}

	rofi_barrier();
	printf("Added memory region at %p size %d\n", addr3, SIZE);

	ret = rofi_release((void*) addr1);
	if(ret){
		printf("Error removing region %p!", addr1);
		goto out;
	}
	rofi_barrier();
	printf("Removed memory region at %p\n", addr1);


	//Leave addr3 to be removed by ROFI

 out:	
	if(!me)
		rofi_verify(ret);
	rofi_finit();
	
	return 0;
}