1 files changed, 114 insertions, 0 deletions
diff --git a/source/blender/compositor/intern/COM_NodeOperation.cpp b/source/blender/compositor/intern/COM_NodeOperation.cpp
new file mode 100644
index 00000000000..b02bcb6676e
--- /dev/null
+++ b/source/blender/compositor/intern/COM_NodeOperation.cpp
@@ -0,0 +1,114 @@
+/*
+ * Copyright 2011, Blender Foundation.
+ *
+ * This program is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU General Public License
+ * as published by the Free Software Foundation; either version 2
+ * of the License, or (at your option) any later version.
+ *
+ * This program 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ *
+ * Contributor: 
+ *		Jeroen Bakker 
+ *		Monique Dewanchand
+ */
+
+#include "COM_NodeOperation.h"
+#include <typeinfo>
+#include "COM_InputSocket.h"
+#include "COM_SocketConnection.h"
+#include "COM_defines.h"
+#include "stdio.h"
+
+NodeOperation::NodeOperation() {
+	this->resolutionInputSocketIndex = 0;
+	this->complex = false;
+	this->width = 0;
+	this->height = 0;
+	this->openCL = false;
+}
+
+void NodeOperation::determineResolution(unsigned int resolution[], unsigned int preferredResolution[]) {
+	unsigned int temp[2];
+	unsigned int temp2[2];
+	vector<InputSocket*> &inputsockets = this->getInputSockets();
+	
+	for (unsigned int index = 0 ; index < inputsockets.size();index++) {
+		InputSocket* inputSocket = inputsockets[index];
+		if (inputSocket->isConnected()) {
+			if (index == this->resolutionInputSocketIndex) {
+				inputSocket->determineResolution(resolution, preferredResolution);
+				temp2[0] = resolution[0];
+				temp2[1] = resolution[1];
+				break;
+			}
+		}
+	}
+	for (unsigned int index = 0 ; index < inputsockets.size();index++) {
+		InputSocket* inputSocket = inputsockets[index];
+		if (inputSocket->isConnected()) {
+			if (index != resolutionInputSocketIndex) {
+				inputSocket->determineResolution(temp, temp2);
+			}
+		}
+	}
+}
+void NodeOperation::setResolutionInputSocketIndex(unsigned int index) {
+	this->resolutionInputSocketIndex = index;
+}
+void NodeOperation::initExecution() {
+}
+
+void NodeOperation::initMutex() {
+	BLI_mutex_init(&mutex);
+}
+void NodeOperation::deinitMutex() {
+	BLI_mutex_end(&mutex);
+}
+void NodeOperation::deinitExecution() {
+}
+SocketReader* NodeOperation::getInputSocketReader(unsigned int inputSocketIndex) {
+	return this->getInputSocket(inputSocketIndex)->getReader();
+}
+NodeOperation* NodeOperation::getInputOperation(unsigned int inputSocketIndex) {
+	return this->getInputSocket(inputSocketIndex)->getOperation();
+}
+
+void NodeOperation::getConnectedInputSockets(vector<InputSocket*> *sockets) {
+	vector<InputSocket*> &inputsockets = this->getInputSockets();
+	for (vector<InputSocket*>::iterator iterator = inputsockets.begin() ; iterator!= inputsockets.end() ; iterator++) {
+		InputSocket *socket = *iterator;
+		if (socket->isConnected()) {
+			sockets->push_back(socket);
+		}
+	}
+}
+
+bool NodeOperation::determineDependingAreaOfInterest(rcti * input, ReadBufferOperation *readOperation, rcti* output) {
+	if (this->isInputNode()) {
+		BLI_init_rcti(output, input->xmin, input->xmax, input->ymin, input->ymax);
+		return false;
+	} else {
+		unsigned int index;
+		vector<InputSocket*> &inputsockets = this->getInputSockets();
+	
+		for (index = 0 ; index < inputsockets.size() ; index++) {
+			InputSocket* inputsocket = inputsockets[index];
+			if (inputsocket->isConnected()) {
+				NodeOperation* inputoperation = (NodeOperation*)inputsocket->getConnection()->getFromNode();
+				bool result = inputoperation->determineDependingAreaOfInterest(input, readOperation, output);
+				if (result) {
+					return true;
+				}
+			}
+		}
+		return false;
+	}
+}