/src/main/java/org/distorted/library/effectqueue/EffectQueue.java - Annotate - Distorted Android

library / src / main / java / org / distorted / library / effectqueue / EffectQueue.java @ f046b159

1	d333eb6b	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
2			// Copyright 2016 Leszek Koltunski //
3			// //
4	46b572b5	Leszek Koltunski	// This file is part of Distorted. //
5	d333eb6b	Leszek Koltunski	// //
6	46b572b5	Leszek Koltunski	// Distorted is free software: you can redistribute it and/or modify //
7	d333eb6b	Leszek Koltunski	// it under the terms of the GNU General Public License as published by //
8			// the Free Software Foundation, either version 2 of the License, or //
9			// (at your option) any later version. //
10			// //
11	46b572b5	Leszek Koltunski	// Distorted is distributed in the hope that it will be useful, //
12	d333eb6b	Leszek Koltunski	// but WITHOUT ANY WARRANTY; without even the implied warranty of //
13			// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the //
14			// GNU General Public License for more details. //
15			// //
16			// You should have received a copy of the GNU General Public License //
17	46b572b5	Leszek Koltunski	// along with Distorted. If not, see <http://www.gnu.org/licenses/>. //
18	d333eb6b	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
19
20	809dcae3	Leszek Koltunski	package org.distorted.library.effectqueue;
21	6a06a912	Leszek Koltunski
22	fe82a979	Leszek Koltunski	import org.distorted.library.effect.Effect;
23	da9b3f07	Leszek Koltunski	import org.distorted.library.effect.EffectName;
24			import org.distorted.library.effect.EffectType;
25	7602a827	Leszek Koltunski	import org.distorted.library.main.DistortedLibrary;
26			import org.distorted.library.main.InternalMaster;
27	23b733db	Leszek Koltunski	import org.distorted.library.mesh.MeshBase;
28	a4835695	Leszek Koltunski
29	26a4e5f6	leszek	import java.util.ArrayList;
30	3417ab4e	leszek	import java.util.HashMap;
31	6a06a912	Leszek Koltunski
32			///////////////////////////////////////////////////////////////////////////////////////////////////
33	809dcae3	Leszek Koltunski	/**
34			* Not part of public API, do not document
35			*
36			* @y.exclude
37			*/
38	7602a827	Leszek Koltunski	public abstract class EffectQueue implements InternalMaster.Slave
39	6a06a912	Leszek Koltunski	{
40	f046b159	Leszek Koltunski	static final int MAIN_VARIANTS = 4; // Number of Main program variants (ATM 4: MAIN, MAIN OIT, PREPROCESS, FULL)
41	809dcae3	Leszek Koltunski
42	1418a5eb	Leszek Koltunski	private static final int CREATE = 0;
43			private static final int ATTACH = 1;
44			private static final int DETACH = 2;
45			private static final int DETALL = 3;
46	26a4e5f6	leszek
47	8bfefd68	Leszek Koltunski	int mNumEffects; // 'ToBe' will be more than mNumEffects if doWork() hasn't
48			private int mNumEffectsToBe; // added them yet (or less if it hasn't removed some yet)
49	13981586	Leszek Koltunski	float[] mUniforms;
50	f046b159	Leszek Koltunski	private int mNumUniforms;
51	13981586	Leszek Koltunski	long[] mCurrentDuration;
52			Effect[] mEffects;
53			int[] mName;
54	f046b159	Leszek Koltunski	long mTime;
55	71887484	Leszek Koltunski
56	13981586	Leszek Koltunski	private static int[] mMax = new int[EffectType.LENGTH];
57	3417ab4e	leszek	private static long mNextID;
58			private static HashMap<ArrayList<Long>,Long> mMapID = new HashMap<>(); // maps lists of Effect IDs (longs) to a
59			// single long - the queue ID.
60	26a4e5f6	leszek	private long mID;
61	15aa7d94	Leszek Koltunski	private int mIndex;
62	06dbccad	Leszek Koltunski	private boolean mCreated;
63	71887484	Leszek Koltunski
64	f046b159	Leszek Koltunski	private static class Job
65	26a4e5f6	leszek	{
66			int type;
67	1418a5eb	Leszek Koltunski	int num;
68	26a4e5f6	leszek	boolean notify;
69			Effect effect;
70
71	1418a5eb	Leszek Koltunski	Job(int t, int m, boolean n, Effect e)
72	26a4e5f6	leszek	{
73			type = t;
74	1418a5eb	Leszek Koltunski	num = m;
75	26a4e5f6	leszek	notify= n;
76			effect= e;
77			}
78			}
79
80			private ArrayList<Job> mJobs = new ArrayList<>();
81
82	6a06a912	Leszek Koltunski	static
83			{
84	7b8086eb	Leszek Koltunski	onDestroy();
85	6a06a912	Leszek Koltunski	}
86
87			///////////////////////////////////////////////////////////////////////////////////////////////////
88
89	20dbec0e	Leszek Koltunski	EffectQueue(int numUniforms, int index)
90	6a06a912	Leszek Koltunski	{
91	06dbccad	Leszek Koltunski	mCreated = false;
92	f046b159	Leszek Koltunski	mTime = 0;
93	26a4e5f6	leszek	mID = 0;
94	fe6fe99a	leszek	mNumEffects = 0;
95	26a4e5f6	leszek	mNumEffectsToBe = 0;
96	fe6fe99a	leszek	mIndex = index;
97	f046b159	Leszek Koltunski	mNumUniforms = numUniforms;
98	1e438fc7	Leszek Koltunski
99	f046b159	Leszek Koltunski	mJobs.add(new Job(CREATE,numUniforms,false,null)); // create the stuff that depends on max number
100	7602a827	Leszek Koltunski	InternalMaster.newSlave(this); // of uniforms later, on first render.
101	6a06a912	Leszek Koltunski	}
102
103	f046b159	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
104
105			EffectQueue(EffectQueue source)
106			{
107			if( !source.mCreated )
108			{
109			mCreated = false;
110			mTime = 0;
111			mID = 0;
112			mNumEffects = 0;
113			mNumEffectsToBe = 0;
114			mIndex = source.mIndex;
115			mNumUniforms = source.mNumUniforms;
116
117			int numJobs = source.mJobs.size();
118
119			for(int i=0; i<numJobs; i++)
120			{
121			Job job = source.mJobs.get(i);
122			mJobs.add(job);
123			}
124
125			InternalMaster.newSlave(this);
126			}
127			else
128			{
129			mCreated = true;
130			mTime = source.mTime;
131			mID = source.mID;
132			mNumEffects = source.mNumEffects;
133			mNumEffectsToBe = source.mNumEffectsToBe;
134			mIndex = source.mIndex;
135			mNumUniforms = source.mNumUniforms;
136
137			int max = mMax[mIndex];
138			if( max>0 )
139			{
140			mUniforms = new float[max*source.mNumUniforms];
141			mCurrentDuration = new long[max];
142			mEffects = new Effect[max];
143			mName = new int[max];
144			}
145
146			for(int i=0; i<mNumEffects; i++ )
147			{
148			mEffects[i] = source.mEffects[i];
149			mCurrentDuration[i] = source.mCurrentDuration[i];
150			mName[i] = source.mName[i];
151			}
152			}
153			}
154
155	a0397f32	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
156
157	20dbec0e	Leszek Koltunski	public static void allocateQueues(EffectQueue[] queues, EffectQueue[] from, int flags)
158	a0397f32	Leszek Koltunski	{
159	20dbec0e	Leszek Koltunski	queues[0] = (flags & DistortedLibrary.CLONE_MATRIX ) != 0 ? from[0] : new EffectQueueMatrix();
160			queues[1] = (flags & DistortedLibrary.CLONE_VERTEX ) != 0 ? from[1] : new EffectQueueVertex();
161			queues[2] = (flags & DistortedLibrary.CLONE_FRAGMENT ) != 0 ? from[2] : new EffectQueueFragment();
162			queues[3] = (flags & DistortedLibrary.CLONE_POSTPROCESS) != 0 ? from[3] : new EffectQueuePostprocess();
163	a0397f32	Leszek Koltunski	}
164
165			///////////////////////////////////////////////////////////////////////////////////////////////////
166
167	644c21f2	Leszek Koltunski	public static void compute(EffectQueue[] queues, long currTime)
168	a0397f32	Leszek Koltunski	{
169			((EffectQueueMatrix )queues[0]).compute(currTime);
170	644c21f2	Leszek Koltunski	((EffectQueueVertex )queues[1]).compute(currTime);
171			((EffectQueueFragment )queues[2]).compute(currTime);
172	a0397f32	Leszek Koltunski	((EffectQueuePostprocess)queues[3]).compute(currTime);
173			}
174
175			///////////////////////////////////////////////////////////////////////////////////////////////////
176
177	23b733db	Leszek Koltunski	public static void send(EffectQueue[] queues, float distance, float mipmap,
178			float[] projection, float inflate, MeshBase mesh, int variant )
179	a0397f32	Leszek Koltunski	{
180	23b733db	Leszek Koltunski	((EffectQueueMatrix )queues[0]).send(distance, mipmap, projection, mesh, variant);
181	a0397f32	Leszek Koltunski	((EffectQueueVertex )queues[1]).send(inflate, variant);
182			((EffectQueueFragment)queues[2]).send(variant);
183			}
184
185			///////////////////////////////////////////////////////////////////////////////////////////////////
186
187	809dcae3	Leszek Koltunski	public static float[] getMVP(EffectQueue[] queues)
188	a0397f32	Leszek Koltunski	{
189	d5b709df	Leszek Koltunski	return ((EffectQueueMatrix)queues[0]).getMVP();
190	a0397f32	Leszek Koltunski	}
191
192			///////////////////////////////////////////////////////////////////////////////////////////////////
193	f046b159	Leszek Koltunski	// variant: 0 --> MAIN 1 --> OIT 2 --> prePOST 3 --> FULL
194	a0397f32	Leszek Koltunski
195	809dcae3	Leszek Koltunski	public static void getUniforms(int programH, int variant)
196	a0397f32	Leszek Koltunski	{
197	809dcae3	Leszek Koltunski	EffectQueueFragment.uniforms(programH,variant);
198			EffectQueueVertex .uniforms(programH,variant);
199			EffectQueueMatrix .uniforms(programH,variant);
200	a0397f32	Leszek Koltunski	}
201
202	26a4e5f6	leszek	///////////////////////////////////////////////////////////////////////////////////////////////////
203	9455da17	Leszek Koltunski	// Every effect queue has an ID, which should be the same iff two queues hold the same effects.
204			// (this is a speedup: then both queues can be applied once, which seriously speeds up stuff -
205			// especially important in case of postprocessing)
206	26a4e5f6	leszek
207	d5b709df	Leszek Koltunski	private void regenerateID()
208	26a4e5f6	leszek	{
209	3417ab4e	leszek	if( mNumEffects>0 )
210			{
211			ArrayList<Long> list = new ArrayList<>();
212			for (int i = 0; i < mNumEffects; i++) list.add(mEffects[i].getID());
213			Long id = mMapID.get(list);
214
215			if( id!=null )
216			{
217			mID = id;
218			}
219			else
220			{
221			mMapID.put(list,mNextID);
222			mID = mNextID++;
223			}
224			}
225			else
226			{
227			mID = 0;
228			}
229	c43abe6c	Leszek Koltunski	}
230
231	6a06a912	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
232
233	809dcae3	Leszek Koltunski	public long getID()
234	26a4e5f6	leszek	{
235			return mID;
236			}
237
238			///////////////////////////////////////////////////////////////////////////////////////////////////
239	71887484	Leszek Koltunski
240	809dcae3	Leszek Koltunski	public static boolean setMax(int index, int m)
241	71887484	Leszek Koltunski	{
242	7602a827	Leszek Koltunski	if( !DistortedLibrary.isInitialized() \|\| m<=mMax[index] )
243	71887484	Leszek Koltunski	{
244	26a4e5f6	leszek	mMax[index] = m<0 ? 0:m;
245	71887484	Leszek Koltunski	return true;
246			}
247
248			return false;
249			}
250
251			///////////////////////////////////////////////////////////////////////////////////////////////////
252
253	809dcae3	Leszek Koltunski	public static int getMax(int index)
254	71887484	Leszek Koltunski	{
255			return mMax[index];
256			}
257
258	6a06a912	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
259
260	809dcae3	Leszek Koltunski	public static void onDestroy()
261	6a06a912	Leszek Koltunski	{
262	3417ab4e	leszek	mNextID = 1;
263			mMapID.clear();
264	da9b3f07	Leszek Koltunski	EffectType.reset(mMax);
265	6a06a912	Leszek Koltunski	}
266
267			///////////////////////////////////////////////////////////////////////////////////////////////////
268	26a4e5f6	leszek	// this assumes 0<=effect<mNumEffects
269	6a06a912	Leszek Koltunski
270	26a4e5f6	leszek	protected void remove(int effect)
271	6bb59aad	Leszek Koltunski	{
272	26a4e5f6	leszek	mNumEffects--;
273
274			for(int j=effect; j<mNumEffects; j++ )
275			{
276			mEffects[j] = mEffects[j+1];
277			mCurrentDuration[j] = mCurrentDuration[j+1];
278			mName[j] = mName[j+1];
279			}
280
281			mEffects[mNumEffects] = null;
282			}
283	6bb59aad	Leszek Koltunski
284	26a4e5f6	leszek	///////////////////////////////////////////////////////////////////////////////////////////////////
285
286	809dcae3	Leszek Koltunski	public synchronized int removeByName(EffectName name)
287	26a4e5f6	leszek	{
288	6b0b4f60	leszek	int ret = 0;
289
290	6bb59aad	Leszek Koltunski	for(int i=0; i<mNumEffects; i++)
291			{
292			if( mEffects[i].getName() == name )
293			{
294	1418a5eb	Leszek Koltunski	mJobs.add(new Job(DETACH,0,true,mEffects[i]));
295	6b0b4f60	leszek	ret++;
296	6bb59aad	Leszek Koltunski	}
297			}
298
299	6b0b4f60	leszek	if( ret>0 )
300			{
301	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
302	6b0b4f60	leszek	mNumEffectsToBe-=ret;
303			}
304
305			return ret;
306	6bb59aad	Leszek Koltunski	}
307
308	2ef5dd9e	leszek	///////////////////////////////////////////////////////////////////////////////////////////////////
309
310	809dcae3	Leszek Koltunski	public synchronized int removeById(long id)
311	2ef5dd9e	leszek	{
312			for(int i=0; i<mNumEffects; i++)
313			{
314			if( mEffects[i].getID() == id )
315			{
316	1418a5eb	Leszek Koltunski	mJobs.add(new Job(DETACH,0,true,mEffects[i]));
317	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
318	26a4e5f6	leszek	mNumEffectsToBe--;
319			return 1;
320	2ef5dd9e	leszek	}
321			}
322
323	26a4e5f6	leszek	return 0;
324	2ef5dd9e	leszek	}
325
326	6bb59aad	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
327
328	809dcae3	Leszek Koltunski	public synchronized int removeEffect(Effect effect)
329	6a06a912	Leszek Koltunski	{
330			for(int i=0; i<mNumEffects; i++)
331			{
332	15aa7d94	Leszek Koltunski	if( mEffects[i]==effect )
333	6a06a912	Leszek Koltunski	{
334	1418a5eb	Leszek Koltunski	mJobs.add(new Job(DETACH,0,true,mEffects[i]));
335	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
336	26a4e5f6	leszek	mNumEffectsToBe--;
337			return 1;
338	6a06a912	Leszek Koltunski	}
339			}
340
341	26a4e5f6	leszek	return 0;
342	6a06a912	Leszek Koltunski	}
343
344			///////////////////////////////////////////////////////////////////////////////////////////////////
345	0df17fad	Leszek Koltunski	// we do want to notify Listeners if they called 'abortAll' themselves but don't want to notify
346			// them if it is the library itself which is releasing resources.
347
348	809dcae3	Leszek Koltunski	public synchronized int abortAll(boolean notify)
349	6a06a912	Leszek Koltunski	{
350	1418a5eb	Leszek Koltunski	mJobs.add(new Job(DETALL,0,notify,null));
351	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
352	26a4e5f6	leszek	mNumEffectsToBe = 0;
353			return mNumEffects;
354			}
355	d07f2950	Leszek Koltunski
356	26a4e5f6	leszek	///////////////////////////////////////////////////////////////////////////////////////////////////
357
358	809dcae3	Leszek Koltunski	public boolean add(Effect effect)
359	26a4e5f6	leszek	{
360	06dbccad	Leszek Koltunski	if( mMax[mIndex]>mNumEffectsToBe \|\| !mCreated )
361	6a06a912	Leszek Koltunski	{
362	34e43b0a	Leszek Koltunski	mJobs.add(new Job(ATTACH,-1,false,effect));
363			InternalMaster.newSlave(this);
364			mNumEffectsToBe++;
365			return true;
366			}
367
368			return false;
369			}
370
371			///////////////////////////////////////////////////////////////////////////////////////////////////
372
373			public boolean add(Effect effect, int position)
374			{
375			if( mMax[mIndex]>mNumEffectsToBe \|\| !mCreated )
376			{
377			mJobs.add(new Job(ATTACH,position,false,effect));
378	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
379	26a4e5f6	leszek	mNumEffectsToBe++;
380			return true;
381	d07f2950	Leszek Koltunski	}
382
383	26a4e5f6	leszek	return false;
384	6a06a912	Leszek Koltunski	}
385
386	106ae28d	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
387
388			public int getNumEffects()
389			{
390			return mNumEffects;
391			}
392
393	9dacabea	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
394
395			public Effect getEffect(int position)
396			{
397			if( position>=0 && position< mNumEffects )
398			{
399			return mEffects[position];
400			}
401			else
402			{
403			android.util.Log.e("queue", "getEffect: out of range "+position);
404			return null;
405			}
406			}
407
408	6a06a912	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
409	809dcae3	Leszek Koltunski
410	26a4e5f6	leszek	public void doWork()
411	6a06a912	Leszek Koltunski	{
412	11845a9e	Leszek Koltunski	boolean changed = false;
413	26a4e5f6	leszek	int num = mJobs.size();
414			Job job;
415	15aa7d94	Leszek Koltunski
416	26a4e5f6	leszek	for(int i=0; i<num; i++)
417	6a06a912	Leszek Koltunski	{
418	26a4e5f6	leszek	job = mJobs.remove(0);
419	15aa7d94	Leszek Koltunski
420	26a4e5f6	leszek	switch(job.type)
421			{
422	1418a5eb	Leszek Koltunski	case CREATE: int max = mMax[mIndex];
423			if( max>0 )
424			{
425			mUniforms = new float[max*job.num];
426			mCurrentDuration = new long[max];
427			mEffects = new Effect[max];
428			mName = new int[max];
429			}
430	06dbccad	Leszek Koltunski	mCreated = true;
431
432	1418a5eb	Leszek Koltunski	break;
433			case ATTACH: if( mMax[mIndex]>mNumEffects ) // it is possible that we have first
434			{ // added effects and then lowered mMax
435	34e43b0a	Leszek Koltunski	int position = job.num;
436
437			if( position==-1 )
438			{
439			mCurrentDuration[mNumEffects] = 0;
440			mEffects[mNumEffects] = job.effect;
441			mName[mNumEffects] = job.effect.getName().ordinal();
442	106ae28d	Leszek Koltunski
443			mNumEffects++;
444			changed = true;
445	34e43b0a	Leszek Koltunski	}
446			else if( position>=0 && position<=mNumEffects )
447			{
448			for(int j=mNumEffects; j>position; j--)
449			{
450			mCurrentDuration[j] = mCurrentDuration[j-1];
451			mEffects[j] = mEffects[j-1];
452			mName[j] = mName[j-1];
453			}
454
455			mCurrentDuration[position] = 0;
456			mEffects[position] = job.effect;
457			mName[position] = job.effect.getName().ordinal();
458
459	106ae28d	Leszek Koltunski	mNumEffects++;
460			changed = true;
461			}
462	1418a5eb	Leszek Koltunski	}
463			else
464			{
465			android.util.Log.e("queue", "failed to add effect "+job.effect.getName());
466			}
467	26a4e5f6	leszek	break;
468	1418a5eb	Leszek Koltunski	case DETACH: for(int j=0; j<mNumEffects; j++)
469	6b0b4f60	leszek	{
470			if (mEffects[j] == job.effect)
471			{
472			remove(j);
473	11845a9e	Leszek Koltunski	changed = true;
474	6b0b4f60	leszek	break;
475			}
476			}
477	26a4e5f6	leszek	break;
478			case DETALL: for(int j=0; j<mNumEffects; j++ )
479			{
480	11845a9e	Leszek Koltunski	changed = true;
481	26a4e5f6	leszek	mEffects[j] = null;
482			}
483
484			mNumEffects= 0;
485			break;
486			}
487	6a06a912	Leszek Koltunski	}
488	d425545a	Leszek Koltunski
489	d5b709df	Leszek Koltunski	if( changed && mIndex==EffectType.POSTPROCESS.ordinal() ) regenerateID();
490	6a06a912	Leszek Koltunski	}
491			}

Project

General

Profile

Distorted Android

library / src / main / java / org / distorted / library / effectqueue / EffectQueue.java @ f046b159