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

library / src / main / java / org / distorted / library / effectqueue / EffectQueue.java @ 9becf30e

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	a4835695	Leszek Koltunski
28	26a4e5f6	leszek	import java.util.ArrayList;
29	3417ab4e	leszek	import java.util.HashMap;
30	6a06a912	Leszek Koltunski
31			///////////////////////////////////////////////////////////////////////////////////////////////////
32	809dcae3	Leszek Koltunski	/**
33			* Not part of public API, do not document
34			*
35			* @y.exclude
36			*/
37	7602a827	Leszek Koltunski	public abstract class EffectQueue implements InternalMaster.Slave
38	6a06a912	Leszek Koltunski	{
39	36d65d88	Leszek Koltunski	public static final int MAIN_VARIANTS = 4; // Number of Main program variants (ATM 4: MAIN, MAIN OIT, PREPROCESS, FULL)
40	809dcae3	Leszek Koltunski
41	1418a5eb	Leszek Koltunski	private static final int CREATE = 0;
42			private static final int ATTACH = 1;
43			private static final int DETACH = 2;
44			private static final int DETALL = 3;
45	26a4e5f6	leszek
46	96e3b88a	Leszek Koltunski	long mTime;
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	96e3b88a	Leszek Koltunski	private int mNumFloatUniforms, mNumIntUniforms;
50	13981586	Leszek Koltunski	Effect[] mEffects;
51	71887484	Leszek Koltunski
52	96e3b88a	Leszek Koltunski	float[] mFloatUniforms;
53			int[] mIntUniforms;
54
55			static int[] mMax = new int[EffectType.LENGTH];
56	3417ab4e	leszek	private static long mNextID;
57			private static HashMap<ArrayList<Long>,Long> mMapID = new HashMap<>(); // maps lists of Effect IDs (longs) to a
58			// single long - the queue ID.
59	26a4e5f6	leszek	private long mID;
60	15aa7d94	Leszek Koltunski	private int mIndex;
61	06dbccad	Leszek Koltunski	private boolean mCreated;
62	71887484	Leszek Koltunski
63	f046b159	Leszek Koltunski	private static class Job
64	26a4e5f6	leszek	{
65			int type;
66	96e3b88a	Leszek Koltunski	int num1, num2;
67	26a4e5f6	leszek	boolean notify;
68			Effect effect;
69
70	96e3b88a	Leszek Koltunski	Job(int t, int m1, int m2, boolean n, Effect e)
71	26a4e5f6	leszek	{
72			type = t;
73	96e3b88a	Leszek Koltunski	num1 = m1;
74			num2 = m2;
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	96e3b88a	Leszek Koltunski	EffectQueue(int numFloatUniforms, int numIntUniforms, int index)
90	6a06a912	Leszek Koltunski	{
91	96e3b88a	Leszek Koltunski	mCreated = false;
92			mTime = 0;
93			mID = 0;
94			mNumEffects = 0;
95			mNumEffectsToBe = 0;
96			mIndex = index;
97			mNumFloatUniforms = numFloatUniforms;
98			mNumIntUniforms = numIntUniforms;
99
100			mJobs.add(new Job(CREATE,numFloatUniforms,numIntUniforms, false,null)); // create the stuff that depends on max number
101			InternalMaster.newSlave(this); // of uniforms later, on first render.
102	6a06a912	Leszek Koltunski	}
103
104	f046b159	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
105	0876b482	Leszek Koltunski	// this is not thread safe! The 'source' might change while we're copying it.
106	f046b159	Leszek Koltunski
107			EffectQueue(EffectQueue source)
108			{
109			if( !source.mCreated )
110			{
111	96e3b88a	Leszek Koltunski	mCreated = false;
112			mTime = 0;
113			mID = 0;
114			mNumEffects = 0;
115			mNumEffectsToBe = 0;
116			mIndex = source.mIndex;
117			mNumFloatUniforms = source.mNumFloatUniforms;
118			mNumIntUniforms = source.mNumIntUniforms;
119	f046b159	Leszek Koltunski
120			int numJobs = source.mJobs.size();
121
122			for(int i=0; i<numJobs; i++)
123			{
124			Job job = source.mJobs.get(i);
125			mJobs.add(job);
126			}
127
128			InternalMaster.newSlave(this);
129			}
130			else
131			{
132	96e3b88a	Leszek Koltunski	mCreated = true;
133			mTime = source.mTime;
134			mID = source.mID;
135			mNumEffects = source.mNumEffects;
136			mNumEffectsToBe = source.mNumEffectsToBe;
137			mIndex = source.mIndex;
138			mNumFloatUniforms = source.mNumFloatUniforms;
139			mNumIntUniforms = source.mNumIntUniforms;
140	f046b159	Leszek Koltunski
141			int max = mMax[mIndex];
142
143	96e3b88a	Leszek Koltunski	if( max>0 )
144	f046b159	Leszek Koltunski	{
145	96e3b88a	Leszek Koltunski	mEffects = new Effect[max];
146			mFloatUniforms = new float[max*source.mNumFloatUniforms];
147			mIntUniforms = new int[max*source.mNumIntUniforms];
148
149			if( mNumEffects>=0 )
150			{
151			System.arraycopy(source.mEffects, 0, mEffects, 0, mNumEffects);
152			}
153
154			if( mNumIntUniforms*mNumEffects>=0 )
155			{
156			System.arraycopy(source.mIntUniforms, 0, mIntUniforms, 0, mNumIntUniforms*mNumEffects);
157			}
158	f046b159	Leszek Koltunski	}
159			}
160			}
161
162	a0397f32	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
163
164	20dbec0e	Leszek Koltunski	public static void allocateQueues(EffectQueue[] queues, EffectQueue[] from, int flags)
165	a0397f32	Leszek Koltunski	{
166	20dbec0e	Leszek Koltunski	queues[0] = (flags & DistortedLibrary.CLONE_MATRIX ) != 0 ? from[0] : new EffectQueueMatrix();
167			queues[1] = (flags & DistortedLibrary.CLONE_VERTEX ) != 0 ? from[1] : new EffectQueueVertex();
168			queues[2] = (flags & DistortedLibrary.CLONE_FRAGMENT ) != 0 ? from[2] : new EffectQueueFragment();
169			queues[3] = (flags & DistortedLibrary.CLONE_POSTPROCESS) != 0 ? from[3] : new EffectQueuePostprocess();
170	a0397f32	Leszek Koltunski	}
171
172			///////////////////////////////////////////////////////////////////////////////////////////////////
173
174	644c21f2	Leszek Koltunski	public static void compute(EffectQueue[] queues, long currTime)
175	a0397f32	Leszek Koltunski	{
176			((EffectQueueMatrix )queues[0]).compute(currTime);
177	644c21f2	Leszek Koltunski	((EffectQueueVertex )queues[1]).compute(currTime);
178			((EffectQueueFragment )queues[2]).compute(currTime);
179	a0397f32	Leszek Koltunski	((EffectQueuePostprocess)queues[3]).compute(currTime);
180			}
181
182			///////////////////////////////////////////////////////////////////////////////////////////////////
183
184	23b733db	Leszek Koltunski	public static void send(EffectQueue[] queues, float distance, float mipmap,
185	62c869ad	Leszek Koltunski	float[] projection, float inflate, int variant )
186	a0397f32	Leszek Koltunski	{
187	62c869ad	Leszek Koltunski	((EffectQueueMatrix )queues[0]).send(distance, mipmap, projection, variant);
188	a0397f32	Leszek Koltunski	((EffectQueueVertex )queues[1]).send(inflate, variant);
189			((EffectQueueFragment)queues[2]).send(variant);
190			}
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	24804c15	Leszek Koltunski	// this assumes 0<=effect
269	6a06a912	Leszek Koltunski
270	9becf30e	Leszek Koltunski	private void removeNow(int pos)
271	6bb59aad	Leszek Koltunski	{
272	9becf30e	Leszek Koltunski	if( mNumEffects>pos )
273	26a4e5f6	leszek	{
274	24804c15	Leszek Koltunski	mNumEffects--;
275	9becf30e	Leszek Koltunski	System.arraycopy(mEffects, pos+1, mEffects, pos, mNumEffects-pos);
276			System.arraycopy(mIntUniforms, mNumIntUniforms(pos+1), mIntUniforms, mNumIntUniformspos, mNumIntUniforms*(mNumEffects-pos) );
277	24804c15	Leszek Koltunski	mEffects[mNumEffects] = null;
278	26a4e5f6	leszek	}
279			}
280	6bb59aad	Leszek Koltunski
281	9becf30e	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
282
283			private void addNow(int pos, Effect effect)
284			{
285			mEffects[pos] = effect;
286			mIntUniforms[mNumIntUniforms*pos] = effect.getName().ordinal();
287
288			if( mIndex==EffectType.VERTEX.ordinal() )
289			{
290			effect.writeAssociations(mIntUniforms, mNumIntUniformspos+1, mNumIntUniformspos+3);
291			}
292			}
293
294	26a4e5f6	leszek	///////////////////////////////////////////////////////////////////////////////////////////////////
295
296	809dcae3	Leszek Koltunski	public synchronized int removeByName(EffectName name)
297	26a4e5f6	leszek	{
298	6b0b4f60	leszek	int ret = 0;
299
300	6bb59aad	Leszek Koltunski	for(int i=0; i<mNumEffects; i++)
301			{
302			if( mEffects[i].getName() == name )
303			{
304	96e3b88a	Leszek Koltunski	mJobs.add(new Job(DETACH,0,0,true,mEffects[i]));
305	6b0b4f60	leszek	ret++;
306	6bb59aad	Leszek Koltunski	}
307			}
308
309	6b0b4f60	leszek	if( ret>0 )
310			{
311	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
312	6b0b4f60	leszek	mNumEffectsToBe-=ret;
313			}
314
315			return ret;
316	6bb59aad	Leszek Koltunski	}
317
318	2ef5dd9e	leszek	///////////////////////////////////////////////////////////////////////////////////////////////////
319
320	809dcae3	Leszek Koltunski	public synchronized int removeById(long id)
321	2ef5dd9e	leszek	{
322			for(int i=0; i<mNumEffects; i++)
323			{
324			if( mEffects[i].getID() == id )
325			{
326	96e3b88a	Leszek Koltunski	mJobs.add(new Job(DETACH,0,0,true,mEffects[i]));
327	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
328	26a4e5f6	leszek	mNumEffectsToBe--;
329			return 1;
330	2ef5dd9e	leszek	}
331			}
332
333	26a4e5f6	leszek	return 0;
334	2ef5dd9e	leszek	}
335
336	6bb59aad	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
337
338	809dcae3	Leszek Koltunski	public synchronized int removeEffect(Effect effect)
339	6a06a912	Leszek Koltunski	{
340			for(int i=0; i<mNumEffects; i++)
341			{
342	15aa7d94	Leszek Koltunski	if( mEffects[i]==effect )
343	6a06a912	Leszek Koltunski	{
344	96e3b88a	Leszek Koltunski	mJobs.add(new Job(DETACH,0,0,true,mEffects[i]));
345	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
346	26a4e5f6	leszek	mNumEffectsToBe--;
347			return 1;
348	6a06a912	Leszek Koltunski	}
349			}
350
351	26a4e5f6	leszek	return 0;
352	6a06a912	Leszek Koltunski	}
353
354			///////////////////////////////////////////////////////////////////////////////////////////////////
355	0df17fad	Leszek Koltunski	// we do want to notify Listeners if they called 'abortAll' themselves but don't want to notify
356			// them if it is the library itself which is releasing resources.
357
358	ceed2df6	Leszek Koltunski	public synchronized int removeAll(boolean notify)
359	6a06a912	Leszek Koltunski	{
360	96e3b88a	Leszek Koltunski	mJobs.add(new Job(DETALL,0,0,notify,null));
361	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
362	26a4e5f6	leszek	mNumEffectsToBe = 0;
363			return mNumEffects;
364			}
365	d07f2950	Leszek Koltunski
366	26a4e5f6	leszek	///////////////////////////////////////////////////////////////////////////////////////////////////
367
368	809dcae3	Leszek Koltunski	public boolean add(Effect effect)
369	26a4e5f6	leszek	{
370	06dbccad	Leszek Koltunski	if( mMax[mIndex]>mNumEffectsToBe \|\| !mCreated )
371	6a06a912	Leszek Koltunski	{
372	96e3b88a	Leszek Koltunski	mJobs.add(new Job(ATTACH,-1,0,false,effect));
373	34e43b0a	Leszek Koltunski	InternalMaster.newSlave(this);
374			mNumEffectsToBe++;
375			return true;
376			}
377
378			return false;
379			}
380
381			///////////////////////////////////////////////////////////////////////////////////////////////////
382
383			public boolean add(Effect effect, int position)
384			{
385			if( mMax[mIndex]>mNumEffectsToBe \|\| !mCreated )
386			{
387	96e3b88a	Leszek Koltunski	mJobs.add(new Job(ATTACH,position,0,false,effect));
388	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
389	26a4e5f6	leszek	mNumEffectsToBe++;
390			return true;
391	d07f2950	Leszek Koltunski	}
392
393	26a4e5f6	leszek	return false;
394	6a06a912	Leszek Koltunski	}
395
396	106ae28d	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
397
398			public int getNumEffects()
399			{
400			return mNumEffects;
401			}
402
403	1fad573e	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
404
405			public int getNumEffectsToBe()
406			{
407			return mNumEffectsToBe;
408			}
409
410	9dacabea	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
411
412			public Effect getEffect(int position)
413			{
414			if( position>=0 && position< mNumEffects )
415			{
416			return mEffects[position];
417			}
418			else
419			{
420			android.util.Log.e("queue", "getEffect: out of range "+position);
421			return null;
422			}
423			}
424
425	6a06a912	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
426	809dcae3	Leszek Koltunski
427	26a4e5f6	leszek	public void doWork()
428	6a06a912	Leszek Koltunski	{
429	11845a9e	Leszek Koltunski	boolean changed = false;
430	26a4e5f6	leszek	int num = mJobs.size();
431			Job job;
432	15aa7d94	Leszek Koltunski
433	26a4e5f6	leszek	for(int i=0; i<num; i++)
434	6a06a912	Leszek Koltunski	{
435	26a4e5f6	leszek	job = mJobs.remove(0);
436	15aa7d94	Leszek Koltunski
437	26a4e5f6	leszek	switch(job.type)
438			{
439	1418a5eb	Leszek Koltunski	case CREATE: int max = mMax[mIndex];
440			if( max>0 )
441			{
442	96e3b88a	Leszek Koltunski	mEffects = new Effect[max];
443			mFloatUniforms = new float[max*job.num1];
444			mIntUniforms = new int[max*job.num2];
445	1418a5eb	Leszek Koltunski	}
446	06dbccad	Leszek Koltunski	mCreated = true;
447
448	1418a5eb	Leszek Koltunski	break;
449			case ATTACH: if( mMax[mIndex]>mNumEffects ) // it is possible that we have first
450			{ // added effects and then lowered mMax
451	96e3b88a	Leszek Koltunski	int position = job.num1;
452	34e43b0a	Leszek Koltunski
453	9becf30e	Leszek Koltunski	if( position<0 )
454	34e43b0a	Leszek Koltunski	{
455	9becf30e	Leszek Koltunski	addNow(mNumEffects,job.effect);
456	106ae28d	Leszek Koltunski	mNumEffects++;
457			changed = true;
458	34e43b0a	Leszek Koltunski	}
459	9becf30e	Leszek Koltunski	else if( position<=mNumEffects )
460	34e43b0a	Leszek Koltunski	{
461	24804c15	Leszek Koltunski	System.arraycopy(mEffects , position, mEffects , position+1, mNumEffects-position);
462			System.arraycopy(mIntUniforms, mNumIntUniformsposition, mIntUniforms, mNumIntUniforms(position+1), mNumIntUniforms*(mNumEffects-position) );
463	9becf30e	Leszek Koltunski	addNow(position,job.effect);
464	106ae28d	Leszek Koltunski	mNumEffects++;
465			changed = true;
466			}
467	1418a5eb	Leszek Koltunski	}
468			else
469			{
470			android.util.Log.e("queue", "failed to add effect "+job.effect.getName());
471			}
472	26a4e5f6	leszek	break;
473	1418a5eb	Leszek Koltunski	case DETACH: for(int j=0; j<mNumEffects; j++)
474	6b0b4f60	leszek	{
475			if (mEffects[j] == job.effect)
476			{
477	9becf30e	Leszek Koltunski	removeNow(j);
478	11845a9e	Leszek Koltunski	changed = true;
479	6b0b4f60	leszek	break;
480			}
481			}
482	26a4e5f6	leszek	break;
483			case DETALL: for(int j=0; j<mNumEffects; j++ )
484			{
485	11845a9e	Leszek Koltunski	changed = true;
486	26a4e5f6	leszek	mEffects[j] = null;
487			}
488
489			mNumEffects= 0;
490			break;
491			}
492	6a06a912	Leszek Koltunski	}
493	d425545a	Leszek Koltunski
494	d5b709df	Leszek Koltunski	if( changed && mIndex==EffectType.POSTPROCESS.ordinal() ) regenerateID();
495	6a06a912	Leszek Koltunski	}
496			}

Project

General

Profile

Distorted Android

library / src / main / java / org / distorted / library / effectqueue / EffectQueue.java @ 9becf30e