robotux
/
rt_benchs
1
0
Fork 0
Code Issues Pull Requests Releases Activity

Communication techniques bench: act more like a WB 

* Send addresses of place in memory where another addresses has been
  stored
This commit is contained in:
Thomas Preud'homme 2009-06-16 13:22:08 +02:00 committed by Thomas Preud'homme
parent 85f383fd7d
commit 0a4da54fec
5 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
communication_techniques/include/asm_cache_comm.h
View File

@ -31,7 +31,7 @@ extern struct communication_assoc assoc_root;
__BEGIN_DECLS
struct communication_assoc *create_comm_assoc(void);
static inline void send(void *addr) {
static inline void send(void **addr) {
asm volatile("mov %%gs:channel@NTPOFF + 2 *" toString(BUF_SIZE) " + " toString(CACHE_LINE_SIZE) ", %%eax\n\t"
"mov %0, %%gs:channel@NTPOFF(%%eax)\n\t"
"addl $4, %%eax\n\t"

2
communication_techniques/include/pipe_comm.h
View File

@ -26,7 +26,7 @@ extern __thread int pipefd[];
extern struct communication_assoc assoc_root;
struct communication_assoc *create_comm_assoc(void);
static inline void send(void *addr) {
static inline void send(void **addr) {
write(pipefd[WRITE_IDX], &addr, sizeof(void *));
}

2
communication_techniques/include/shared_mem_comm.h
View File

@ -28,7 +28,7 @@ extern __thread volatile int prod_idx;
extern __thread volatile int cons_idx;
struct communication_assoc *create_comm_assoc(void);
static inline void send(void *addr) {
static inline void send(void **addr) {
while ((prod_idx + 1) % SHARED_SPACE_VOIDPTR == cons_idx);
shared_space[prod_idx] = addr;
prod_idx = (prod_idx + 1) % SHARED_SPACE_VOIDPTR;

2
communication_techniques/include/shared_mem_opt_comm.h
View File

@ -28,7 +28,7 @@ extern __thread volatile int prod_idx;
extern __thread volatile int cons_idx;
struct communication_assoc *create_comm_assoc(void);
static inline void send(void *addr) {
static inline void send(void **addr) {
static __thread int local_cons_idx = 0;
if (likely(((prod_idx + 1) % SHARED_SPACE_VOIDPTR) == local_cons_idx))

4
communication_techniques/src/main.c
View File

@ -148,7 +148,7 @@ int analyse_options(int argc, char *argv[])
void *producer(void *cont_ptr_void)
{
int i, j;
uintptr_t k;
void *k;
volatile int *cont;
cont = *((volatile int **) cont_ptr_void);
@ -168,7 +168,7 @@ void *producer(void *cont_ptr_void)
}
printf("Registering: %p !\n", (void*) pthread_self());
add_sender();
k = (uintptr_t) pthread_self();
k = cont_ptr_void;
if (initialize_papi() != -1)
{
for(i = 0; i < nb_cache_lines; i++) {