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
156
157
158
159
160
|
/* -*- C -*-
*
* Copyright (c) 2004-2005 The Trustees of Indiana University and Indiana
* University Research and Technology
* Corporation. All rights reserved.
* Copyright (c) 2004-2006 The University of Tennessee and The University
* of Tennessee Research Foundation. All rights
* reserved.
* Copyright (c) 2004-2005 High Performance Computing Center Stuttgart,
* University of Stuttgart. All rights reserved.
* Copyright (c) 2004-2005 The Regents of the University of California.
* All rights reserved.
* Copyright (c) 2007 Cisco Systems, Inc. All rights reserved.
* $COPYRIGHT$
*
* Additional copyrights may follow
*
* $HEADER$
*/
/**
* @file
*
* Buffer management types.
*/
#ifndef OPAL_DSS_TYPES_H_
#define OPAL_DSS_TYPES_H_
#include "opal_config.h"
#include "opal/class/opal_object.h"
#include "opal/class/opal_list.h"
BEGIN_C_DECLS
typedef uint8_t opal_data_type_t; /** data type indicators */
#define OPAL_DATA_TYPE_T OPAL_UINT8
#define OPAL_DSS_ID_MAX UINT8_MAX
#define OPAL_DSS_ID_INVALID OPAL_DSS_ID_MAX
/* define a structure to hold generic byte objects */
typedef struct {
int32_t size;
uint8_t *bytes;
} opal_byte_object_t;
/* Type defines for packing and unpacking */
#define OPAL_UNDEF (opal_data_type_t) 0 /**< type hasn't been defined yet */
#define OPAL_BYTE (opal_data_type_t) 1 /**< a byte of data */
#define OPAL_BOOL (opal_data_type_t) 2 /**< boolean */
#define OPAL_STRING (opal_data_type_t) 3 /**< a NULL terminated string */
#define OPAL_SIZE (opal_data_type_t) 4 /**< the generic size_t */
#define OPAL_PID (opal_data_type_t) 5 /**< process pid */
/* all the integer flavors */
#define OPAL_INT (opal_data_type_t) 6 /**< generic integer */
#define OPAL_INT8 (opal_data_type_t) 7 /**< an 8-bit integer */
#define OPAL_INT16 (opal_data_type_t) 8 /**< a 16-bit integer */
#define OPAL_INT32 (opal_data_type_t) 9 /**< a 32-bit integer */
#define OPAL_INT64 (opal_data_type_t) 10 /**< a 64-bit integer */
/* all the unsigned integer flavors */
#define OPAL_UINT (opal_data_type_t) 11 /**< generic unsigned integer */
#define OPAL_UINT8 (opal_data_type_t) 12 /**< an 8-bit unsigned integer */
#define OPAL_UINT16 (opal_data_type_t) 13 /**< a 16-bit unsigned integer */
#define OPAL_UINT32 (opal_data_type_t) 14 /**< a 32-bit unsigned integer */
#define OPAL_UINT64 (opal_data_type_t) 15 /**< a 64-bit unsigned integer */
/* we don't support floating point types */
/* General types */
#define OPAL_BYTE_OBJECT (opal_data_type_t) 16 /**< byte object structure */
#define OPAL_DATA_TYPE (opal_data_type_t) 17 /**< data type */
#define OPAL_NULL (opal_data_type_t) 18 /**< don't interpret data type */
#define OPAL_DATA_VALUE (opal_data_type_t) 19 /**< data value */
#define OPAL_PSTAT (opal_data_type_t) 20 /**< process statistics */
#define OPAL_HWLOC_TOPO (opal_data_type_t) 22 /**< hwloc topology */
#define OPAL_DSS_ID_DYNAMIC (opal_data_type_t) 30
/* define the results values for comparisons so we can change them in only one place */
#define OPAL_VALUE1_GREATER +1
#define OPAL_VALUE2_GREATER -1
#define OPAL_EQUAL 0
/* Data value object */
typedef struct {
opal_object_t super; /* required for this to be an object */
opal_data_type_t type; /* the type of value stored */
void *data;
} opal_dss_value_t;
OPAL_DECLSPEC OBJ_CLASS_DECLARATION(opal_dss_value_t);
#define OPAL_DATA_VALUE_EMPTY { OPAL_OBJ_STATIC_INIT(opal_dss_value_t), OPAL_UNDEF, NULL}
/* Process statistics object */
#define OPAL_PSTAT_MAX_STRING_LEN 32
typedef struct {
opal_list_item_t super; /* required for this to be on a list */
char node[OPAL_PSTAT_MAX_STRING_LEN];
int32_t rank;
pid_t pid;
char cmd[OPAL_PSTAT_MAX_STRING_LEN];
char state;
uint64_t time;
int32_t priority;
int16_t num_threads;
uint64_t vsize; /* in kBytes */
uint64_t rss; /* in kBytes */
uint64_t peak_vsize; /* in kBytes */
uint64_t shared_size; /* in kBytes */
int16_t processor;
} opal_pstats_t;
OPAL_DECLSPEC OBJ_CLASS_DECLARATION(opal_pstats_t);
/* structured-unstructured data flags */
#define OPAL_DSS_STRUCTURED true
#define OPAL_DSS_UNSTRUCTURED false
/**
* buffer type
*/
typedef uint8_t opal_dss_buffer_type_t;
#define OPAL_DSS_BUFFER_NON_DESC 0x00
#define OPAL_DSS_BUFFER_FULLY_DESC 0x01
#define OPAL_DSS_BUFFER_TYPE_HTON(h);
#define OPAL_DSS_BUFFER_TYPE_NTOH(h);
/**
* Structure for holding a buffer to be used with the RML or OOB
* subsystems.
*/
struct opal_buffer_t {
/** First member must be the object's parent */
opal_object_t parent;
/** type of buffer */
opal_dss_buffer_type_t type;
/** Start of my memory */
char *base_ptr;
/** Where the next data will be packed to (within the allocated
memory starting at base_ptr) */
char *pack_ptr;
/** Where the next data will be unpacked from (within the
allocated memory starting as base_ptr) */
char *unpack_ptr;
/** Number of bytes allocated (starting at base_ptr) */
size_t bytes_allocated;
/** Number of bytes used by the buffer (i.e., amount of data --
including overhead -- packed in the buffer) */
size_t bytes_used;
};
/**
* Convenience typedef
*/
typedef struct opal_buffer_t opal_buffer_t;
/** formalize the declaration */
OPAL_DECLSPEC OBJ_CLASS_DECLARATION (opal_buffer_t);
END_C_DECLS
#endif /* OPAL_DSS_TYPES_H */
|
