File: iofunction.C

package info (click to toggle)
mixviews 1.20-10.1
  • links: PTS
  • area: main
  • in suites: potato
  • size: 2,928 kB
  • ctags: 5,960
  • sloc: cpp: 32,879; ansic: 2,110; makefile: 445; sh: 17
file content (124 lines) | stat: -rw-r--r-- 3,717 bytes parent folder | download | duplicates (3)
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
// iofunction.C

/******************************************************************************
 *
 *  MiXViews - an X window system based sound & data editor/processor
 *
 *  Copyright (c) 1993, 1994 Regents of the University of California
 *
 *  Author:     Douglas Scott
 *  Date:       December 13, 1994
 *
 *  Permission to use, copy and modify this software and its documentation
 *  for research and/or educational purposes and without fee is hereby granted,
 *  provided that the above copyright notice appear in all copies and that
 *  both that copyright notice and this permission notice appear in
 *  supporting documentation. The author reserves the right to distribute this
 *  software and its documentation.  The University of California and the author
 *  make no representations about the suitability of this software for any 
 *  purpose, and in no event shall University of California be liable for any
 *  damage, loss of data, or profits resulting from its use.
 *  It is provided "as is" without express or implied warranty.
 *
 ******************************************************************************/


#ifdef __GNUG__
#pragma implementation
#endif

#include "iofunction.h"
#include <InterViews/resource.h>
#include "data.h"

InputOutputFunction::InputOutputFunction(
	Data* input, Data* output, int inQueueSize, int outQueueSize)
		: QueuedOutputFunction(output, outQueueSize),
		  myInput(nil), inputQueue(inQueueSize),
		  queueStatus(Q_MORE_INPUT | Q_MORE_OUTPUT) {
	setInput(input);
}

InputOutputFunction::~InputOutputFunction() {
	Resource::unref(myInput);
}

void
InputOutputFunction::setInput(Data* newinput) {
	if(newinput != myInput) {
		Resource::unref(myInput);
		myInput = newinput;
		if(myInput != nil)
			myInput->ref();
	}
}

void
InputOutputFunction::initialize() {
	int new_length = newLength(myInput->length());
	int status = true;
	// make sure that output is set to the correct length
	if(!areCompatibleLengths(target()->length(), new_length)) {
		okIf(status = target()->changeLength(new_length));
	}	
	if(status)
		Super::initialize();
}

void
InputOutputFunction::restoreState() {
	Super::restoreState();
	inputQueue.reset();
	myIndex.reset();
	queueStatus = Q_MORE_INPUT | Q_MORE_OUTPUT;
}

// this routine returns Stop when all input data has been processed

RunStatus
InputOutputFunction::runProcess() {
	BUG("InputOutputFunction::runProcess()");
	if(inQueueEmpty()) {
		if(moreInput())
			readFromInput();
		else
			needToFlushIf(moreOutput());  // no more input; flush if more outpt
	}
	int status = doProcessing();
	boolean more = (moreInput() || moreOutput());
	return (status == -1) ? Error : more ? Run : Stop;
}

// this routine loops while input is available or while 
// processor still has output to write to the queue

int
InputOutputFunction::doProcessing() {
	BUG("InputOutputFunction::doProcessing()");
	int status = true;
	int flushing = needToFlush();
	while((!inQueueEmpty() || flushing) && status == true) {
		status = processInput(flushing);	// true if outqueue not full
		// if no more pending and we were flushing, turn off flushing
		flushing = (flushing && (status != true));
	}
	needToFlushIf(flushing);	// update based on last loop
	moreOutputIf(status == false);
	// false if output queue full or if we just need to fill the input queue
	return status;
}

// giveSamplesTo() returns false when myInput has no more samples to give

void
InputOutputFunction::readFromInput() {
	BUG("InputOutputFunction::readFromInput()");
	moreInputIf(myInput->giveSamplesTo(*this) == true);
}

//********

int
SimpleInputOutputFunction::processInput(boolean flushing) {
	return addToOutQueue(doSimpleProcess(flushing ? 0.0 : takeFromInQueue()));
}