fazekasgy@37
|
1 /*
|
fazekasgy@37
|
2
|
fazekasgy@37
|
3 * Vampy : This plugin is a wrapper around the Vamp plugin API.
|
fazekasgy@37
|
4 * It allows for writing Vamp plugins in Python.
|
fazekasgy@37
|
5
|
fazekasgy@37
|
6 * Centre for Digital Music, Queen Mary University of London.
|
fazekasgy@37
|
7 * Copyright (C) 2008-2009 Gyorgy Fazekas, QMUL. (See Vamp sources
|
fazekasgy@37
|
8 * for licence information.)
|
fazekasgy@37
|
9
|
fazekasgy@37
|
10 */
|
fazekasgy@37
|
11
|
fazekasgy@37
|
12 #include <Python.h>
|
fazekasgy@37
|
13 #include "PyPlugin.h"
|
fazekasgy@37
|
14 #include "PyTypeInterface.h"
|
fazekasgy@37
|
15 #include <stdlib.h>
|
fazekasgy@37
|
16 #include "PyExtensionModule.h"
|
fazekasgy@37
|
17
|
fazekasgy@37
|
18
|
fazekasgy@37
|
19 #ifdef _WIN32
|
fazekasgy@37
|
20 #define PATHSEP ('\\')
|
fazekasgy@37
|
21 #else
|
fazekasgy@37
|
22 #define PATHSEP ('/')
|
fazekasgy@37
|
23 #endif
|
fazekasgy@37
|
24
|
fazekasgy@37
|
25 using std::string;
|
fazekasgy@37
|
26 using std::vector;
|
fazekasgy@37
|
27 using std::cerr;
|
fazekasgy@37
|
28 using std::endl;
|
fazekasgy@37
|
29 using std::map;
|
fazekasgy@37
|
30
|
fazekasgy@37
|
31 Mutex PyPlugin::m_pythonInterpreterMutex;
|
fazekasgy@37
|
32
|
fazekasgy@37
|
33 PyPlugin::PyPlugin(std::string pluginKey, float inputSampleRate, PyObject *pyClass, int &instcount) :
|
fazekasgy@37
|
34 Plugin(inputSampleRate),
|
fazekasgy@37
|
35 m_pyClass(pyClass),
|
fazekasgy@37
|
36 m_instcount(instcount),
|
fazekasgy@37
|
37 m_stepSize(0),
|
fazekasgy@37
|
38 m_blockSize(0),
|
fazekasgy@37
|
39 m_channels(0),
|
fazekasgy@37
|
40 m_plugin(pluginKey),
|
fazekasgy@37
|
41 m_class(pluginKey.substr(pluginKey.rfind(':')+1,pluginKey.size()-1)),
|
fazekasgy@37
|
42 m_path((pluginKey.substr(0,pluginKey.rfind(PATHSEP)))),
|
fazekasgy@37
|
43 m_processType(not_implemented),
|
fazekasgy@37
|
44 m_pyProcess(NULL),
|
fazekasgy@37
|
45 m_inputDomain(TimeDomain),
|
fazekasgy@37
|
46 m_quitOnErrorFlag(false),
|
fazekasgy@37
|
47 m_debugFlag(false)
|
fazekasgy@37
|
48 {
|
fazekasgy@37
|
49 m_ti.setInputSampleRate(inputSampleRate);
|
fazekasgy@37
|
50 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
51 cerr << "Creating instance " << m_instcount << " of " << pluginKey << endl;
|
fazekasgy@37
|
52
|
fazekasgy@37
|
53 // Create an instance
|
fazekasgy@37
|
54 Py_INCREF(m_pyClass);
|
fazekasgy@37
|
55 PyObject *pyInputSampleRate = PyFloat_FromDouble(inputSampleRate);
|
fazekasgy@37
|
56 PyObject *args = PyTuple_Pack(1, pyInputSampleRate);
|
fazekasgy@37
|
57 m_pyInstance = PyObject_Call(m_pyClass, args, NULL);
|
fazekasgy@37
|
58
|
fazekasgy@37
|
59 if (!m_pyInstance || PyErr_Occurred()) {
|
fazekasgy@37
|
60 if (PyErr_Occurred()) { PyErr_Print(); PyErr_Clear(); }
|
fazekasgy@37
|
61 Py_DECREF(m_pyClass);
|
fazekasgy@37
|
62 Py_CLEAR(args);
|
fazekasgy@37
|
63 Py_CLEAR(pyInputSampleRate);
|
fazekasgy@37
|
64 cerr << "PyPlugin::PyPlugin: Failed to create Python plugin instance for key \""
|
fazekasgy@37
|
65 << pluginKey << "\" (is the 1-arg class constructor from sample rate correctly provided?)" << endl;
|
fazekasgy@37
|
66 throw std::string("Constructor failed");
|
fazekasgy@37
|
67 }
|
fazekasgy@37
|
68 Py_INCREF(m_pyInstance);
|
fazekasgy@37
|
69 Py_DECREF(args);
|
fazekasgy@37
|
70 Py_DECREF(pyInputSampleRate);
|
fazekasgy@37
|
71
|
fazekasgy@37
|
72 m_instcount++;
|
fazekasgy@37
|
73
|
fazekasgy@37
|
74 // query and decode vampy flags
|
fazekasgy@37
|
75 m_vampyFlags = getBinaryFlags("vampy_flags",vf_NULL);
|
fazekasgy@37
|
76
|
fazekasgy@37
|
77 m_debugFlag = (bool) (m_vampyFlags & vf_DEBUG);
|
fazekasgy@37
|
78 m_quitOnErrorFlag = (bool) (m_vampyFlags & vf_QUIT);
|
fazekasgy@37
|
79 bool st_flag = (bool) (m_vampyFlags & vf_STRICT);
|
fazekasgy@37
|
80 m_useRealTimeFlag = (bool) (m_vampyFlags & vf_REALTIME);
|
fazekasgy@37
|
81
|
fazekasgy@37
|
82 if (m_debugFlag) cerr << "Debug messages ON for Vampy plugin: " << m_class << endl;
|
fazekasgy@37
|
83 else cerr << "Debug messages OFF for Vampy plugin: " << m_class << endl;
|
fazekasgy@37
|
84
|
fazekasgy@37
|
85 if (m_debugFlag && m_quitOnErrorFlag) cerr << "Quit on type error ON for: " << m_class << endl;
|
fazekasgy@37
|
86
|
fazekasgy@37
|
87 if (m_debugFlag && st_flag) cerr << "Strict type conversion ON for: " << m_class << endl;
|
fazekasgy@37
|
88 m_ti.setStrictTypingFlag(st_flag);
|
fazekasgy@37
|
89
|
fazekasgy@37
|
90 }
|
fazekasgy@37
|
91
|
fazekasgy@37
|
92 PyPlugin::~PyPlugin()
|
fazekasgy@37
|
93 {
|
fazekasgy@37
|
94 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
95 m_instcount--;
|
fazekasgy@37
|
96 // cerr << "Deleting plugin instance. Count: " << m_instcount << endl;
|
fazekasgy@37
|
97
|
fazekasgy@37
|
98 if (m_pyInstance) Py_DECREF(m_pyInstance);
|
fazekasgy@37
|
99 //we increase the class refcount before creating an instance
|
fazekasgy@37
|
100 if (m_pyClass) Py_DECREF(m_pyClass);
|
fazekasgy@37
|
101 if (m_pyProcess) Py_CLEAR(m_pyProcess);
|
fazekasgy@37
|
102
|
fazekasgy@37
|
103 #ifdef _DEBUG
|
fazekasgy@37
|
104 cerr << "PyPlugin::PyPlugin:" << m_class << " instance " << m_instcount << " deleted." << endl;
|
fazekasgy@37
|
105 #endif
|
fazekasgy@37
|
106 }
|
fazekasgy@37
|
107
|
fazekasgy@37
|
108 string
|
fazekasgy@37
|
109 PyPlugin::getIdentifier() const
|
fazekasgy@37
|
110 {
|
fazekasgy@37
|
111 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
112 string rString="vampy-xxx";
|
fazekasgy@37
|
113 if (!m_debugFlag) return genericMethodCall("getIdentifier",rString);
|
fazekasgy@37
|
114
|
fazekasgy@37
|
115 rString = genericMethodCall("getIdentifier",rString);
|
fazekasgy@37
|
116 if (rString == "vampy-xxx")
|
fazekasgy@37
|
117 cerr << "Warning: Plugin must return a unique identifier." << endl;
|
fazekasgy@37
|
118 return rString;
|
fazekasgy@37
|
119 }
|
fazekasgy@37
|
120
|
fazekasgy@37
|
121 string
|
fazekasgy@37
|
122 PyPlugin::getName() const
|
fazekasgy@37
|
123 {
|
fazekasgy@37
|
124 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
125 string rString="VamPy Plugin (Noname)";
|
fazekasgy@37
|
126 return genericMethodCall("getName",rString);
|
fazekasgy@37
|
127 }
|
fazekasgy@37
|
128
|
fazekasgy@37
|
129 string
|
fazekasgy@37
|
130 PyPlugin::getDescription() const
|
fazekasgy@37
|
131 {
|
fazekasgy@37
|
132 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
133 string rString="Not given. (Hint: Implement getDescription method.)";
|
fazekasgy@37
|
134 return genericMethodCall("getDescription",rString);
|
fazekasgy@37
|
135 }
|
fazekasgy@37
|
136
|
fazekasgy@37
|
137
|
fazekasgy@37
|
138 string
|
fazekasgy@37
|
139 PyPlugin::getMaker() const
|
fazekasgy@37
|
140 {
|
fazekasgy@37
|
141 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
142 string rString="VamPy Plugin.";
|
fazekasgy@37
|
143 return genericMethodCall("getMaker",rString);
|
fazekasgy@37
|
144 }
|
fazekasgy@37
|
145
|
fazekasgy@37
|
146 int
|
fazekasgy@37
|
147 PyPlugin::getPluginVersion() const
|
fazekasgy@37
|
148 {
|
fazekasgy@37
|
149 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
150 size_t rValue=2;
|
fazekasgy@37
|
151 return genericMethodCall("getPluginVersion",rValue);
|
fazekasgy@37
|
152 }
|
fazekasgy@37
|
153
|
fazekasgy@37
|
154 string
|
fazekasgy@37
|
155 PyPlugin::getCopyright() const
|
fazekasgy@37
|
156 {
|
fazekasgy@37
|
157 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
158 string rString="Licence information not available.";
|
fazekasgy@37
|
159 return genericMethodCall("getCopyright",rString);
|
fazekasgy@37
|
160 }
|
fazekasgy@37
|
161
|
fazekasgy@37
|
162
|
fazekasgy@37
|
163 bool
|
fazekasgy@37
|
164 PyPlugin::initialise(size_t channels, size_t stepSize, size_t blockSize)
|
fazekasgy@37
|
165 {
|
fazekasgy@37
|
166
|
fazekasgy@37
|
167 if (channels < getMinChannelCount() ||
|
fazekasgy@37
|
168 channels > getMaxChannelCount()) return false;
|
fazekasgy@37
|
169
|
fazekasgy@37
|
170 m_inputDomain = getInputDomain();
|
fazekasgy@37
|
171
|
fazekasgy@37
|
172 //Note: placing Mutex before the calls above causes deadlock !!
|
fazekasgy@37
|
173 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
174
|
fazekasgy@37
|
175 m_stepSize = stepSize;
|
fazekasgy@37
|
176 m_blockSize = blockSize;
|
fazekasgy@37
|
177 m_channels = channels;
|
fazekasgy@37
|
178
|
fazekasgy@37
|
179 //query the process implementation type
|
fazekasgy@37
|
180 //two optional flags can be used: 'use_numpy_interface' or 'use_legacy_interface'
|
fazekasgy@37
|
181 //if they are not provided, we fall back to the original method
|
fazekasgy@37
|
182 setProcessType();
|
fazekasgy@37
|
183
|
fazekasgy@37
|
184 return genericMethodCallArgs<bool>("initialise",channels,stepSize,blockSize);
|
fazekasgy@37
|
185 }
|
fazekasgy@37
|
186
|
fazekasgy@37
|
187 void
|
fazekasgy@37
|
188 PyPlugin::reset()
|
fazekasgy@37
|
189 {
|
fazekasgy@37
|
190 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
191 genericMethodCall("reset");
|
fazekasgy@37
|
192 }
|
fazekasgy@37
|
193
|
fazekasgy@37
|
194 PyPlugin::InputDomain
|
fazekasgy@37
|
195 PyPlugin::getInputDomain() const
|
fazekasgy@37
|
196 {
|
fazekasgy@37
|
197 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
198 return genericMethodCall("getInputDomain",m_inputDomain);
|
fazekasgy@37
|
199 }
|
fazekasgy@37
|
200
|
fazekasgy@37
|
201 size_t
|
fazekasgy@37
|
202 PyPlugin::getPreferredBlockSize() const
|
fazekasgy@37
|
203 {
|
fazekasgy@37
|
204 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
205 size_t rValue = 0;
|
fazekasgy@37
|
206 return genericMethodCall("getPreferredBlockSize",rValue);
|
fazekasgy@37
|
207 }
|
fazekasgy@37
|
208
|
fazekasgy@37
|
209 size_t
|
fazekasgy@37
|
210 PyPlugin::getPreferredStepSize() const
|
fazekasgy@37
|
211 {
|
fazekasgy@37
|
212 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
213 size_t rValue = 0;
|
fazekasgy@37
|
214 return genericMethodCall("getPreferredStepSize",rValue);
|
fazekasgy@37
|
215 }
|
fazekasgy@37
|
216
|
fazekasgy@37
|
217 size_t
|
fazekasgy@37
|
218 PyPlugin::getMinChannelCount() const
|
fazekasgy@37
|
219 {
|
fazekasgy@37
|
220 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
221 size_t rValue = 1;
|
fazekasgy@37
|
222 return genericMethodCall("getMinChannelCount",rValue);
|
fazekasgy@37
|
223 }
|
fazekasgy@37
|
224
|
fazekasgy@37
|
225 size_t
|
fazekasgy@37
|
226 PyPlugin::getMaxChannelCount() const
|
fazekasgy@37
|
227 {
|
fazekasgy@37
|
228 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
229 size_t rValue = 1;
|
fazekasgy@37
|
230 return genericMethodCall("getMaxChannelCount",rValue);
|
fazekasgy@37
|
231 }
|
fazekasgy@37
|
232
|
fazekasgy@37
|
233 PyPlugin::OutputList
|
fazekasgy@37
|
234 PyPlugin::getOutputDescriptors() const
|
fazekasgy@37
|
235 {
|
fazekasgy@37
|
236 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
237 OutputList list;
|
fazekasgy@37
|
238 return genericMethodCall("getOutputDescriptors",list);
|
fazekasgy@37
|
239 }
|
fazekasgy@37
|
240
|
fazekasgy@37
|
241 PyPlugin::ParameterList
|
fazekasgy@37
|
242 PyPlugin::getParameterDescriptors() const
|
fazekasgy@37
|
243 {
|
fazekasgy@37
|
244 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
245 ParameterList list;
|
fazekasgy@37
|
246 #ifdef _DEBUG
|
fazekasgy@37
|
247 ///Note: This function is often called first by the host.
|
fazekasgy@37
|
248 if (!m_pyInstance) {cerr << "Error: pyInstance is NULL" << endl; return list;}
|
fazekasgy@37
|
249 #endif
|
fazekasgy@37
|
250
|
fazekasgy@37
|
251 return genericMethodCall("getParameterDescriptors",list);
|
fazekasgy@37
|
252 }
|
fazekasgy@37
|
253
|
fazekasgy@37
|
254 void PyPlugin::setParameter(std::string paramid, float newval)
|
fazekasgy@37
|
255 {
|
fazekasgy@37
|
256 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
257 genericMethodCallArgs<NoneType>("setParameter",paramid,newval);
|
fazekasgy@37
|
258 }
|
fazekasgy@37
|
259
|
fazekasgy@37
|
260 float PyPlugin::getParameter(std::string paramid) const
|
fazekasgy@37
|
261 {
|
fazekasgy@37
|
262 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
263 return genericMethodCallArgs<float>("getParameter",paramid);
|
fazekasgy@37
|
264 }
|
fazekasgy@37
|
265
|
fazekasgy@37
|
266 #ifdef _DEBUG_VALUES
|
fazekasgy@37
|
267 static int proccounter = 0;
|
fazekasgy@37
|
268 #endif
|
fazekasgy@37
|
269
|
fazekasgy@37
|
270 PyPlugin::FeatureSet
|
fazekasgy@37
|
271 PyPlugin::process(const float *const *inputBuffers,Vamp::RealTime timestamp)
|
fazekasgy@37
|
272 {
|
fazekasgy@37
|
273 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
274
|
fazekasgy@37
|
275 #ifdef _DEBUG_VALUES
|
fazekasgy@37
|
276 /// we only need this if we'd like to see what frame a set of values belong to
|
fazekasgy@37
|
277 cerr << "[Vampy::call] process, frame:" << proccounter << endl;
|
fazekasgy@37
|
278 proccounter++;
|
fazekasgy@37
|
279 #endif
|
fazekasgy@37
|
280
|
fazekasgy@37
|
281 if (m_blockSize == 0 || m_channels == 0) {
|
fazekasgy@37
|
282 cerr << "ERROR: PyPlugin::process: "
|
fazekasgy@37
|
283 << "Plugin has not been initialised" << endl;
|
fazekasgy@37
|
284 return FeatureSet();
|
fazekasgy@37
|
285 }
|
fazekasgy@37
|
286
|
fazekasgy@37
|
287 if (m_processType == not_implemented) {
|
fazekasgy@37
|
288 cerr << "ERROR: In Python plugin [" << m_class
|
fazekasgy@37
|
289 << "] No process implementation found. Returning empty feature set." << endl;
|
fazekasgy@37
|
290 return FeatureSet();
|
fazekasgy@37
|
291 }
|
fazekasgy@37
|
292
|
fazekasgy@37
|
293 return processMethodCall(inputBuffers,timestamp);
|
fazekasgy@37
|
294
|
fazekasgy@37
|
295 }
|
fazekasgy@37
|
296
|
fazekasgy@37
|
297 PyPlugin::FeatureSet
|
fazekasgy@37
|
298 PyPlugin::getRemainingFeatures()
|
fazekasgy@37
|
299 {
|
fazekasgy@37
|
300 MutexLocker locker(&m_pythonInterpreterMutex);
|
fazekasgy@37
|
301 FeatureSet rValue;
|
fazekasgy@37
|
302 return genericMethodCall("getRemainingFeatures",rValue);
|
fazekasgy@37
|
303 }
|
fazekasgy@37
|
304
|
fazekasgy@37
|
305 bool
|
fazekasgy@37
|
306 PyPlugin::getBooleanFlag(char flagName[], bool defValue = false) const
|
fazekasgy@37
|
307 {
|
fazekasgy@37
|
308 bool rValue = defValue;
|
fazekasgy@37
|
309 if (PyObject_HasAttrString(m_pyInstance,flagName))
|
fazekasgy@37
|
310 {
|
fazekasgy@37
|
311 PyObject *pyValue = PyObject_GetAttrString(m_pyInstance,flagName);
|
fazekasgy@37
|
312 if (!pyValue)
|
fazekasgy@37
|
313 {
|
fazekasgy@37
|
314 if (PyErr_Occurred()) {PyErr_Print(); PyErr_Clear();}
|
fazekasgy@37
|
315 } else {
|
fazekasgy@37
|
316 rValue = m_ti.PyValue_To_Bool(pyValue);
|
fazekasgy@37
|
317 if (m_ti.error) {
|
fazekasgy@37
|
318 Py_CLEAR(pyValue);
|
fazekasgy@37
|
319 typeErrorHandler(flagName);
|
fazekasgy@37
|
320 rValue = defValue;
|
fazekasgy@37
|
321 } else Py_DECREF(pyValue);
|
fazekasgy@37
|
322 }
|
fazekasgy@37
|
323 }
|
fazekasgy@37
|
324 if (m_debugFlag) cerr << FLAG_VALUE << endl;
|
fazekasgy@37
|
325 return rValue;
|
fazekasgy@37
|
326 }
|
fazekasgy@37
|
327
|
fazekasgy@37
|
328 int
|
fazekasgy@37
|
329 PyPlugin::getBinaryFlags(char flagName[], eVampyFlags defValue = vf_NULL) const
|
fazekasgy@37
|
330 {
|
fazekasgy@37
|
331 int rValue = defValue;
|
fazekasgy@37
|
332 if (PyObject_HasAttrString(m_pyInstance,flagName))
|
fazekasgy@37
|
333 {
|
fazekasgy@37
|
334 PyObject *pyValue = PyObject_GetAttrString(m_pyInstance,flagName);
|
fazekasgy@37
|
335 if (!pyValue)
|
fazekasgy@37
|
336 {
|
fazekasgy@37
|
337 if (PyErr_Occurred()) {PyErr_Print(); PyErr_Clear();}
|
fazekasgy@37
|
338 } else {
|
fazekasgy@37
|
339 rValue |= (int) m_ti.PyValue_To_Size_t(pyValue);
|
fazekasgy@37
|
340 if (m_ti.error) {
|
fazekasgy@37
|
341 Py_CLEAR(pyValue);
|
fazekasgy@37
|
342 typeErrorHandler(flagName);
|
fazekasgy@37
|
343 rValue = defValue;
|
fazekasgy@37
|
344 } else Py_DECREF(pyValue);
|
fazekasgy@37
|
345 }
|
fazekasgy@37
|
346 }
|
fazekasgy@37
|
347 if (m_debugFlag) cerr << FLAG_VALUE << endl;
|
fazekasgy@37
|
348 return rValue;
|
fazekasgy@37
|
349 }
|
fazekasgy@37
|
350
|
fazekasgy@37
|
351
|
fazekasgy@37
|
352 void
|
fazekasgy@37
|
353 PyPlugin::setProcessType()
|
fazekasgy@37
|
354 {
|
fazekasgy@37
|
355 //quering process implementation type
|
fazekasgy@37
|
356 char legacyMethod[]="process";
|
fazekasgy@37
|
357 char numpyMethod[]="processN";
|
fazekasgy@37
|
358
|
fazekasgy@37
|
359 if (PyObject_HasAttrString(m_pyInstance,legacyMethod) &&
|
fazekasgy@37
|
360 m_processType == 0)
|
fazekasgy@37
|
361 {
|
fazekasgy@37
|
362 m_processType = legacyProcess;
|
fazekasgy@37
|
363 m_pyProcess = PyString_FromString(legacyMethod);
|
fazekasgy@37
|
364 m_pyProcessCallable = PyObject_GetAttr(m_pyInstance,m_pyProcess);
|
fazekasgy@37
|
365 }
|
fazekasgy@37
|
366
|
fazekasgy@37
|
367 if (PyObject_HasAttrString(m_pyInstance,numpyMethod) &&
|
fazekasgy@37
|
368 m_processType == 0)
|
fazekasgy@37
|
369 {
|
fazekasgy@37
|
370 m_processType = numpy_bufferProcess;
|
fazekasgy@37
|
371 m_pyProcess = PyString_FromString(numpyMethod);
|
fazekasgy@37
|
372 m_pyProcessCallable = PyObject_GetAttr(m_pyInstance,m_pyProcess);
|
fazekasgy@37
|
373 }
|
fazekasgy@37
|
374
|
fazekasgy@37
|
375 // These flags are optional. If provided, they override the
|
fazekasgy@37
|
376 // implementation type making the use of the odd processN()
|
fazekasgy@37
|
377 // function redundant.
|
fazekasgy@37
|
378 // However, the code above provides backward compatibility.
|
fazekasgy@37
|
379
|
fazekasgy@37
|
380 if (m_vampyFlags & vf_BUFFER) {
|
fazekasgy@37
|
381 m_processType = numpy_bufferProcess;
|
fazekasgy@37
|
382 if (m_debugFlag) cerr << "Process using (numpy) buffer interface." << endl;
|
fazekasgy@37
|
383 }
|
fazekasgy@37
|
384
|
fazekasgy@37
|
385 if (m_vampyFlags & vf_ARRAY) {
|
fazekasgy@37
|
386 #ifdef HAVE_NUMPY
|
fazekasgy@37
|
387 m_processType = numpy_arrayProcess;
|
fazekasgy@37
|
388 if (m_debugFlag) cerr << "Process using numpy array interface." << endl;
|
fazekasgy@37
|
389 #else
|
fazekasgy@37
|
390 cerr << "Error: This version of vampy was compiled without numpy support, "
|
fazekasgy@37
|
391 << "however the vf_ARRAY flag is set for plugin: " << m_class << endl
|
fazekasgy@37
|
392 << "The default behaviour is: passing a python list of samples for each channel in process() "
|
fazekasgy@37
|
393 << "or a list of memory buffers in processN(). " << endl
|
fazekasgy@37
|
394 << "This can be used create numpy arrays using the numpy.frombuffer() command." << endl;
|
fazekasgy@37
|
395 #endif
|
fazekasgy@37
|
396 }
|
fazekasgy@37
|
397
|
fazekasgy@37
|
398 if (!m_processType)
|
fazekasgy@37
|
399 {
|
fazekasgy@37
|
400 m_processType = not_implemented;
|
fazekasgy@37
|
401 m_pyProcess = NULL;
|
fazekasgy@37
|
402 m_pyProcessCallable = NULL;
|
fazekasgy@37
|
403 char method[]="initialise::setProcessType";
|
fazekasgy@37
|
404 cerr << PLUGIN_ERROR << " No process implementation found. Plugin will do nothing." << endl;
|
fazekasgy@37
|
405 }
|
fazekasgy@37
|
406 }
|
fazekasgy@37
|
407
|
fazekasgy@37
|
408 void
|
fazekasgy@37
|
409 PyPlugin::typeErrorHandler(char *method) const
|
fazekasgy@37
|
410 {
|
fazekasgy@37
|
411 bool strict = false;
|
fazekasgy@37
|
412 while (m_ti.error) {
|
fazekasgy@37
|
413 PyTypeInterface::ValueError e = m_ti.getError();
|
fazekasgy@37
|
414 cerr << PLUGIN_ERROR << e.str() << endl;
|
fazekasgy@37
|
415 if (e.strict) strict = true;
|
fazekasgy@37
|
416 // e.print();
|
fazekasgy@37
|
417 }
|
fazekasgy@37
|
418 /// quit on hard errors like accessing NULL pointers or strict type conversion
|
fazekasgy@37
|
419 /// errors IF the user sets the quitOnErrorFlag in the plugin.
|
fazekasgy@37
|
420 /// Otherwise most errors will go unnoticed apart from
|
fazekasgy@37
|
421 /// a messages in the terminal.
|
fazekasgy@37
|
422 /// It would be best if hosts could catch an exception instead
|
fazekasgy@37
|
423 /// and display something meaningful to the user.
|
fazekasgy@37
|
424 if (strict && m_quitOnErrorFlag) exit(EXIT_FAILURE);
|
fazekasgy@37
|
425 }
|
fazekasgy@37
|
426
|