This source file includes following definitions.
- compress_block
- decompress_block
- pmix_compress_base_register
- pmix_compress_base_open
- pmix_compress_base_close
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 #include "pmix_config.h"
18
19 #include "src/mca/base/base.h"
20 #include "src/mca/pcompress/base/base.h"
21
22 #include "src/mca/pcompress/base/static-components.h"
23
24
25
26
27 static bool compress_block(char *instring,
28 uint8_t **outbytes,
29 size_t *nbytes)
30 {
31 return false;
32 }
33
34 static bool decompress_block(char **outstring,
35 uint8_t *inbytes, size_t len)
36 {
37 return false;
38 }
39
40 pmix_compress_base_module_t pmix_compress = {
41 NULL,
42 NULL,
43 NULL,
44 NULL,
45 NULL,
46 NULL,
47 compress_block,
48 decompress_block
49 };
50 pmix_compress_base_t pmix_compress_base = {0};
51
52 pmix_compress_base_component_t pmix_compress_base_selected_component = {{0}};
53
54 static int pmix_compress_base_register(pmix_mca_base_register_flag_t flags)
55 {
56 pmix_compress_base.compress_limit = 4096;
57 (void) pmix_mca_base_var_register("pmix", "compress", "base", "limit",
58 "Threshold beyond which data will be compressed",
59 PMIX_MCA_BASE_VAR_TYPE_SIZE_T, NULL, 0, 0, PMIX_INFO_LVL_3,
60 PMIX_MCA_BASE_VAR_SCOPE_READONLY, &pmix_compress_base.compress_limit);
61
62 return PMIX_SUCCESS;
63 }
64
65
66
67
68
69 static int pmix_compress_base_open(pmix_mca_base_open_flag_t flags)
70 {
71
72 return pmix_mca_base_framework_components_open(&pmix_pcompress_base_framework, flags);
73 }
74
75 static int pmix_compress_base_close(void)
76 {
77
78 if( NULL != pmix_compress.finalize ) {
79 pmix_compress.finalize();
80 }
81
82
83 return pmix_mca_base_framework_components_close (&pmix_pcompress_base_framework, NULL);
84 }
85
86 PMIX_MCA_BASE_FRAMEWORK_DECLARE(pmix, pcompress, "PCOMPRESS MCA",
87 pmix_compress_base_register, pmix_compress_base_open,
88 pmix_compress_base_close, mca_pcompress_base_static_components, 0);
89