-
Notifications
You must be signed in to change notification settings - Fork 13
/
MessageTable.cpp
109 lines (101 loc) · 3.72 KB
/
MessageTable.cpp
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
/*
* Copyright 2009,2010 Reality Jockey, Ltd.
* info@rjdj.me
* http://rjdj.me/
*
* This file is part of ZenGarden.
*
* ZenGarden is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* ZenGarden is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with ZenGarden. If not, see <http://www.gnu.org/licenses/>.
*
*/
#include "ArrayArithmetic.h"
#include "MessageTable.h"
#include "PdGraph.h"
#define DEFAULT_BUFFER_LENGTH 1024
MessageObject *MessageTable::newObject(PdMessage *initMessage, PdGraph *graph) {
return new MessageTable(initMessage, graph);
}
MessageTable::MessageTable(PdMessage *initMessage, PdGraph *graph) : RemoteMessageReceiver(0, 0, graph) {
if (initMessage->isSymbol(0)) {
name = StaticUtils::copyString(initMessage->getSymbol(0));
// by default, the buffer length is 1024. The buffer should never be NULL.
bufferLength = initMessage->isFloat(1) ? (int) initMessage->getFloat(1) : DEFAULT_BUFFER_LENGTH;
buffer = (float *) calloc(bufferLength, sizeof(float));
} else {
name = NULL;
buffer = NULL;
bufferLength = 0;
graph->printErr("Object \"table\" must be initialised with a name.");
}
}
MessageTable::~MessageTable() {
free(name);
free(buffer);
}
float *MessageTable::getBuffer(int *bufferLength) {
*bufferLength = this->bufferLength;
return buffer;
}
float *MessageTable::resizeBuffer(int newBufferLength) {
if (newBufferLength > 0) {
// the new buffer length must be positive
buffer = (float *) realloc(buffer, newBufferLength * sizeof(float));
if (newBufferLength > bufferLength) {
// clear the new portion of the buffer
memset(buffer+bufferLength, 0, (newBufferLength-bufferLength) * sizeof(float));
}
bufferLength = newBufferLength;
// NOTE(mhroth): this code does not check to see if the returned buffer from realloc
// is non-NULL. It assumes that realloc is always successful. This is slightly dangerous and
// could lead to problems.
}
return buffer;
}
void MessageTable::processMessage(int inletIndex, PdMessage *message) {
// TODO(mhroth): process all of the commands which can be sent to tables
if (message->isSymbol(0, "read")) {
if (message->isSymbol(1)) {
// read the file and fill the table
}
} else if (message->isSymbol(0, "write")) {
// write the contents of the table to file
} else if (message->isSymbol(0, "normalize")) {
// normalise the contents of the table to the given value. Default to 1.
#if __APPLE__
float sum = 0.0f;
vDSP_sve(buffer, 1, &sum, bufferLength);
if (sum != 0.0f) {
// ensure that element do not change sign during normalisation
sum = fabsf(sum) / (message->isFloat(1) ? message->getFloat(1) : 1.0f);
vDSP_vsdiv(buffer, 1, &sum, buffer, 1, bufferLength);
}
#else
float sum = 0.0f;
for (int i = 0; i < bufferLength; i++) {
sum += buffer[i];
}
if (sum != 0.0f) {
sum = fabsf(sum) / (message->isFloat(1) ? message->getFloat(1) : 1.0f);
for (int i = 0; i < bufferLength; i++) {
buffer[i] /= sum;
}
}
#endif
} else if (message->isSymbol(0, "resize")) {
if (message->isFloat(1)) {
int newBufferLength = (int) message->getFloat(1);
resizeBuffer(newBufferLength);
}
}
}