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
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
|
''' Generated by OTF2 Template Engine '''
import ctypes
import traceback
import sys
from .Config import conf, StrParam, str_decode
from .ErrorCodes import ErrorCode, HandleErrorCode
from .GeneralDefinitions import *
from .AttributeValue import AttributeValue
from .Definitions import *
from .Callbacks import callback_wrapper
class GlobalDefReaderCallbacks(ctypes.Structure):
pass
def GlobalDefReaderCallbacks_New():
c_New = conf.lib.OTF2_GlobalDefReaderCallbacks_New
c_New.argtypes = []
c_New.restype = ctypes.POINTER(GlobalDefReaderCallbacks)
# NOTE: Do not errcheck here. This function returns a value, not an error code
return c_New()
def GlobalDefReaderCallbacks_Delete(globalDefReaderCallbacks):
c_Delete = conf.lib.OTF2_GlobalDefReaderCallbacks_Delete
c_Delete.argtypes = [ ctypes.POINTER(GlobalDefReaderCallbacks) ]
c_Delete.restype = None
return c_Delete(globalDefReaderCallbacks)
def GlobalDefReaderCallbacks_Clear(globalDefReaderCallbacks):
c_Clear = conf.lib.OTF2_GlobalDefReaderCallbacks_Clear
c_Clear.argtypes = [ ctypes.POINTER(GlobalDefReaderCallbacks) ]
c_Clear.restype = None
return c_Clear(globalDefReaderCallbacks)
def _callback_wrapper(type, func, convert_args=None):
def wrapper(userData, *args):
if userData:
py_userData = ctypes.cast(userData, ctypes.py_object).value
else:
py_userData = None
try:
if convert_args is not None:
args = convert_args(*args)
ret = func(py_userData, *args)
if ret is None:
ret = CALLBACK_SUCCESS
except:
sys.stderr.write("An unhandled python exception has occurred in an "
"OTF2_GlobalDefReaderCallback:\n")
sys.stderr.write(traceback.format_exc())
ret = CALLBACK_ERROR
return ret.value
return callback_wrapper(func, wrapper, type)
def _convert_property_union(refered_def, name, type, value):
union = AttributeValue()
union._arg_value = value
return refered_def, name, type, union
_GlobalDefReaderCallback_FP_Unknown = ctypes.CFUNCTYPE(CallbackCode, ctypes.c_void_p)
@otf2 for def in defs|global_defs:
_GlobalDefReaderCallback_FP_@@def.name@@ = ctypes.CFUNCTYPE(CallbackCode, ctypes.c_void_p@@def.py_funcargtypes(argtypes=false)@@)
@otf2 endfor
def GlobalDefReaderCallbacks_SetUnknownCallback(globalDefReaderCallbacks, unknownCallback):
c_SetUnknownCallback = conf.lib.OTF2_GlobalDefReaderCallbacks_SetUnknownCallback
c_SetUnknownCallback.argtypes = [ ctypes.POINTER(GlobalDefReaderCallbacks), _GlobalDefReaderCallback_FP_Unknown ]
c_SetUnknownCallback.restype = ErrorCode
c_SetUnknownCallback.errcheck = HandleErrorCode
wrapped_callback = _callback_wrapper(_GlobalDefReaderCallback_FP_Unknown,
unknownCallback)
c_SetUnknownCallback(globalDefReaderCallbacks, wrapped_callback)
@otf2 for def in defs|global_defs:
@otf2 if def == IoParadigm:
def GlobalDefReaderCallbacks_SetIoParadigmCallback(globalDefReaderCallbacks, ioParadigmCallback):
c_SetIoParadigmCallback = conf.lib.OTF2_GlobalDefReaderCallbacks_SetIoParadigmCallback
c_SetIoParadigmCallback.argtypes = [ ctypes.POINTER(GlobalDefReaderCallbacks), _GlobalDefReaderCallback_FP_IoParadigm ]
c_SetIoParadigmCallback.restype = ErrorCode
c_SetIoParadigmCallback.errcheck = HandleErrorCode
def convert_property(ref, identification, name, io_paradigm_class, io_paradigm_flags, \
number_of_properties, properties_array, types_array, values_array):
properties = [properties_array[i] for i in range(number_of_properties)]
types = [types_array[i] for i in range(number_of_properties)]
values = [values_array[i] for i in range(number_of_properties)]
return ref, identification, name, io_paradigm_class, io_paradigm_flags, properties, \
types, values
wrapped_callback = _callback_wrapper(_GlobalDefReaderCallback_FP_IoParadigm,
ioParadigmCallback, convert_property)
c_SetIoParadigmCallback(globalDefReaderCallbacks, wrapped_callback)
@otf2 elif def == String:
def GlobalDefReaderCallbacks_SetStringCallback(globalDefReaderCallbacks, stringCallback):
c_SetStringCallback = conf.lib.OTF2_GlobalDefReaderCallbacks_SetStringCallback
c_SetStringCallback.argtypes = [ ctypes.POINTER(GlobalDefReaderCallbacks), _GlobalDefReaderCallback_FP_String ]
c_SetStringCallback.restype = ErrorCode
c_SetStringCallback.errcheck = HandleErrorCode
def convert_string(ref, name):
return ref, str_decode(name)
wrapped_callback = _callback_wrapper(_GlobalDefReaderCallback_FP_String,
stringCallback, convert_string)
c_SetStringCallback(globalDefReaderCallbacks, wrapped_callback)
@otf2 elif def == Group:
def GlobalDefReaderCallbacks_SetGroupCallback(globalDefReaderCallbacks, groupCallback):
c_SetGroupCallback = conf.lib.OTF2_GlobalDefReaderCallbacks_SetGroupCallback
c_SetGroupCallback.argtypes = [ ctypes.POINTER(GlobalDefReaderCallbacks), _GlobalDefReaderCallback_FP_Group ]
c_SetGroupCallback.restype = ErrorCode
c_SetGroupCallback.errcheck = HandleErrorCode
def convert_group(ref, name, group_type, paradigm, group_flags, number_of_metrics,
members_array):
members = [members_array[i] for i in range(number_of_metrics)]
return ref, name, group_type, paradigm, group_flags, members
wrapped_callback = _callback_wrapper(_GlobalDefReaderCallback_FP_Group,
groupCallback, convert_group)
c_SetGroupCallback(globalDefReaderCallbacks, wrapped_callback)
@otf2 elif def == MetricClass:
def GlobalDefReaderCallbacks_SetMetricClassCallback(globalDefReaderCallbacks, metricClassCallback):
c_SetMetricClassCallback = conf.lib.OTF2_GlobalDefReaderCallbacks_SetMetricClassCallback
c_SetMetricClassCallback.argtypes = [ ctypes.POINTER(GlobalDefReaderCallbacks), _GlobalDefReaderCallback_FP_MetricClass ]
c_SetMetricClassCallback.restype = ErrorCode
c_SetMetricClassCallback.errcheck = HandleErrorCode
def convert_metric_class(ref, number_of_metrics, metric_members_array, metric_occurrence,
recorder_kind):
metric_members = [metric_members_array[i] for i in range(number_of_metrics)]
return ref, metric_members, metric_occurrence, recorder_kind
wrapped_callback = _callback_wrapper(_GlobalDefReaderCallback_FP_MetricClass,
metricClassCallback, convert_metric_class)
c_SetMetricClassCallback(globalDefReaderCallbacks, wrapped_callback)
@otf2 elif def == CartTopology:
def GlobalDefReaderCallbacks_SetCartTopologyCallback(globalDefReaderCallbacks, cartTopologyCallback):
c_SetCartTopologyCallback = conf.lib.OTF2_GlobalDefReaderCallbacks_SetCartTopologyCallback
c_SetCartTopologyCallback.argtypes = [ ctypes.POINTER(GlobalDefReaderCallbacks), _GlobalDefReaderCallback_FP_CartTopology ]
c_SetCartTopologyCallback.restype = ErrorCode
c_SetCartTopologyCallback.errcheck = HandleErrorCode
def convert_cart_topology(ref, name, communicator, number_of_dimensions,
cart_dimensions_array):
cart_dimensions = [cart_dimensions_array[i] for i in range(number_of_dimensions)]
return ref, name, communicator, cart_dimensions
wrapped_callback = _callback_wrapper(_GlobalDefReaderCallback_FP_CartTopology,
cartTopologyCallback, convert_cart_topology)
c_SetCartTopologyCallback(globalDefReaderCallbacks, wrapped_callback)
@otf2 elif def == CartCoordinate:
def GlobalDefReaderCallbacks_SetCartCoordinateCallback(globalDefReaderCallbacks, cartCoordinateCallback):
c_SetCartCoordinateCallback = conf.lib.OTF2_GlobalDefReaderCallbacks_SetCartCoordinateCallback
c_SetCartCoordinateCallback.argtypes = [ ctypes.POINTER(GlobalDefReaderCallbacks), _GlobalDefReaderCallback_FP_CartCoordinate ]
c_SetCartCoordinateCallback.restype = ErrorCode
c_SetCartCoordinateCallback.errcheck = HandleErrorCode
def convert_cart_coordinate(cart_topology, rank, number_of_dimensions, coordinates_array):
coordinates = [coordinates_array[i] for i in range(number_of_dimensions)]
return cart_topology, rank, coordinates
wrapped_callback = _callback_wrapper(_GlobalDefReaderCallback_FP_CartCoordinate,
cartCoordinateCallback, convert_cart_coordinate)
c_SetCartCoordinateCallback(globalDefReaderCallbacks, wrapped_callback)
@otf2 else:
def GlobalDefReaderCallbacks_Set@@def.name@@Callback(globalDefReaderCallbacks, @@def.lname@@Callback):
c_Set@@def.name@@Callback = conf.lib.OTF2_GlobalDefReaderCallbacks_Set@@def.name@@Callback
c_Set@@def.name@@Callback.argtypes = [ ctypes.POINTER(GlobalDefReaderCallbacks), _GlobalDefReaderCallback_FP_@@def.name@@ ]
c_Set@@def.name@@Callback.restype = ErrorCode
c_Set@@def.name@@Callback.errcheck = HandleErrorCode
@otf2 if def.name[-8:] == 'Property' or def.name == 'CallpathParameter':
convert = _convert_property_union
@otf2 else:
convert = None
@otf2 endif
wrapped_callback = _callback_wrapper(_GlobalDefReaderCallback_FP_@@def.name@@,
@@def.lname@@Callback,
convert)
c_Set@@def.name@@Callback(globalDefReaderCallbacks, wrapped_callback)
@otf2 endif
@otf2 endfor
__all__ = [
'GlobalDefReaderCallbacks',
'GlobalDefReaderCallbacks_New',
'GlobalDefReaderCallbacks_Delete',
'GlobalDefReaderCallbacks_Clear',
'GlobalDefReaderCallbacks_SetUnknownCallback',
@otf2 for def in defs|global_defs:
'GlobalDefReaderCallbacks_Set@@def.name@@Callback',
@otf2 endfor
]
|
