/usr/include/mrmpi/cmapreduce.h is in libmrmpi-dev 1.0~20131122-1build1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 | /* ----------------------------------------------------------------------
MR-MPI = MapReduce-MPI library
http://www.cs.sandia.gov/~sjplimp/mapreduce.html
Steve Plimpton, sjplimp@sandia.gov, Sandia National Laboratories
Copyright (2009) Sandia Corporation. Under the terms of Contract
DE-AC04-94AL85000 with Sandia Corporation, the U.S. Government retains
certain rights in this software. This software is distributed under
the modified Berkeley Software Distribution (BSD) License.
See the README file in the top-level MapReduce directory.
------------------------------------------------------------------------- */
/* C or Fortran style interface to MapReduce library */
/* ifdefs allow this file to be included in a C program */
#include "mpi.h"
#include "stdint.h"
#ifdef __cplusplus
extern "C" {
#endif
void *MR_create(MPI_Comm comm);
void *MR_create_mpi();
void *MR_create_mpi_finalize();
void MR_destroy(void *MRptr);
void *MR_get_kv(void *MRptr);
void *MR_get_kmv(void *MRptr);
void *MR_copy(void *MRptr);
uint64_t MR_add(void *MRptr, void *MRptr2);
uint64_t MR_aggregate(void *MRptr, int (*myhash)(char *, int));
uint64_t MR_broadcast(void *MRptr, int);
uint64_t MR_clone(void *MRptr);
uint64_t MR_close(void *MRptr);
uint64_t MR_collapse(void *MRptr, char *key, int keybytes);
uint64_t MR_collate(void *MRptr, int (*myhash)(char *, int));
uint64_t MR_compress(void *MRptr,
void (*mycompress)(char *, int, char *, int, int *,
void *KVptr, void *APPptr),
void *APPptr);
uint64_t MR_convert(void *MRptr);
uint64_t MR_gather(void *MRptr, int numprocs);
uint64_t MR_map(void *MRptr, int nmap,
void (*mymap)(int, void *KVptr, void *APPptr),
void *APPptr);
uint64_t MR_map_add(void *MRptr, int nmap,
void (*mymap)(int, void *KVptr, void *APPptr),
void *APPptr, int addflag);
uint64_t MR_map_file(void *MRptr, int nstr, char **strings,
int self, int recurse, int readfile,
void (*mymap)(int, char *,
void *KVptr, void *APPptr),
void *APPptr);
uint64_t MR_map_file_add(void *MRptr, int nstr, char **strings,
int self, int recurse, int readfile,
void (*mymap)(int, char *,
void *KVptr, void *APPptr),
void *APPptr, int addflag);
uint64_t MR_map_file_char(void *MRptr, int nmap, int nstr, char **strings,
int recurse, int readflag,
char sepchar, int delta,
void (*mymap)(int, char *, int,
void *KVptr, void *APPptr),
void *APPptr);
uint64_t MR_map_file_char_add(void *MRptr, int nmap, int nstr, char **strings,
int recurse, int readflag,
char sepchar, int delta,
void (*mymap)(int, char *, int,
void *KVptr, void *APPptr),
void *APPptr, int addflag);
uint64_t MR_map_file_str(void *MRptr, int nmap, int nstr, char **strings,
int recurse, int readflag,
char *sepstr, int delta,
void (*mymap)(int, char *, int,
void *KVptr, void *APPptr),
void *APPptr);
uint64_t MR_map_file_str_add(void *MRptr, int nmap, int nstr, char **strings,
int recurse, int readflag,
char *sepstr, int delta,
void (*mymap)(int, char *, int,
void *KVptr, void *APPptr),
void *APPptr, int addflag);
uint64_t MR_map_mr(void *MRptr, void *MRptr2,
void (*mymap)(uint64_t, char *, int, char *, int,
void *KVptr, void *APPptr),
void *APPptr);
uint64_t MR_map_mr_add(void *MRptr, void *MRptr2,
void (*mymap)(uint64_t, char *, int, char *, int,
void *KVptr, void *APPptr),
void *APPptr, int addflag);
void MR_open(void *MRptr);
void MR_open_add(void *MRptr, int addflag);
void MR_print(void *MRptr, int proc, int nstride, int kflag, int vflag);
void MR_print_file(void *MRptr, char *file, int fflag,
int proc, int nstride, int kflag, int vflag);
uint64_t MR_reduce(void *MRptr,
void (*myreduce)(char *, int, char *,
int, int *, void *KVptr, void *APPptr),
void *APPptr);
uint64_t MR_multivalue_blocks(void *MRptr);
void MR_multivalue_block_select(void *MRptr, int which);
int MR_multivalue_block(void *MRptr, int iblock,
char **ptr_multivalue, int **ptr_valuesizes);
uint64_t MR_scan_kv(void *MRptr,
void (*myscan)(char *, int, char *, int, void *),
void *APPptr);
uint64_t MR_scan_kmv(void *MRptr,
void (*myscan)(char *, int, char *, int, int *, void *),
void *APPptr);
uint64_t MR_scrunch(void *MRptr, int numprocs, char *key, int keybytes);
uint64_t MR_sort_keys(void *MRptr,
int (*mycompare)(char *, int, char *, int));
uint64_t MR_sort_keys_flag(void *MRptr, int);
uint64_t MR_sort_values(void *MRptr,
int (*mycompare)(char *, int, char *, int));
uint64_t MR_sort_values_flag(void *MRptr, int);
uint64_t MR_sort_multivalues(void *MRptr,
int (*mycompare)(char *, int, char *, int));
uint64_t MR_sort_multivalues_flag(void *MRptr, int);
uint64_t MR_kv_stats(void *MRptr, int level);
uint64_t MR_kmv_stats(void *MRptr, int level);
void MR_cummulative_stats(void *MRptr, int level, int reset);
void MR_set_mapstyle(void *MRptr, int value);
void MR_set_all2all(void *MRptr, int value);
void MR_set_verbosity(void *MRptr, int value);
void MR_set_timer(void *MRptr, int value);
void MR_set_memsize(void *MRptr, int value);
void MR_set_minpage(void *MRptr, int value);
void MR_set_maxpage(void *MRptr, int value);
void MR_set_keyalign(void *MRptr, int value);
void MR_set_valuealign(void *MRptr, int value);
void MR_set_fpath(void *MRptr, char *str);
void MR_kv_add(void *KVptr, char *key, int keybytes,
char *value, int valuebytes);
void MR_kv_add_multi_static(void *KVptr, int n,
char *key, int keybytes,
char *value, int valuebytes);
void MR_kv_add_multi_dynamic(void *KVptr, int n,
char *key, int *keybytes,
char *value, int *valuebytes);
#ifdef __cplusplus
}
#endif
|