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

library / src / main / java / org / distorted / library / effectqueue / EffectQueue.java @ 96e3b88a

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	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	96e3b88a	Leszek Koltunski	int max = mMax[mIndex];
275
276			for(int i=effect; i<mNumEffects; i++ )
277	26a4e5f6	leszek	{
278	96e3b88a	Leszek Koltunski	mEffects[i]= mEffects[i+1];
279
280			for(int j=0; j<mNumIntUniforms; j++)
281			{
282			mIntUniforms[jmax + i] = mIntUniforms[jmax + i+1];
283			}
284	26a4e5f6	leszek	}
285
286			mEffects[mNumEffects] = null;
287			}
288	6bb59aad	Leszek Koltunski
289	26a4e5f6	leszek	///////////////////////////////////////////////////////////////////////////////////////////////////
290
291	809dcae3	Leszek Koltunski	public synchronized int removeByName(EffectName name)
292	26a4e5f6	leszek	{
293	6b0b4f60	leszek	int ret = 0;
294
295	6bb59aad	Leszek Koltunski	for(int i=0; i<mNumEffects; i++)
296			{
297			if( mEffects[i].getName() == name )
298			{
299	96e3b88a	Leszek Koltunski	mJobs.add(new Job(DETACH,0,0,true,mEffects[i]));
300	6b0b4f60	leszek	ret++;
301	6bb59aad	Leszek Koltunski	}
302			}
303
304	6b0b4f60	leszek	if( ret>0 )
305			{
306	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
307	6b0b4f60	leszek	mNumEffectsToBe-=ret;
308			}
309
310			return ret;
311	6bb59aad	Leszek Koltunski	}
312
313	2ef5dd9e	leszek	///////////////////////////////////////////////////////////////////////////////////////////////////
314
315	809dcae3	Leszek Koltunski	public synchronized int removeById(long id)
316	2ef5dd9e	leszek	{
317			for(int i=0; i<mNumEffects; i++)
318			{
319			if( mEffects[i].getID() == id )
320			{
321	96e3b88a	Leszek Koltunski	mJobs.add(new Job(DETACH,0,0,true,mEffects[i]));
322	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
323	26a4e5f6	leszek	mNumEffectsToBe--;
324			return 1;
325	2ef5dd9e	leszek	}
326			}
327
328	26a4e5f6	leszek	return 0;
329	2ef5dd9e	leszek	}
330
331	6bb59aad	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
332
333	809dcae3	Leszek Koltunski	public synchronized int removeEffect(Effect effect)
334	6a06a912	Leszek Koltunski	{
335			for(int i=0; i<mNumEffects; i++)
336			{
337	15aa7d94	Leszek Koltunski	if( mEffects[i]==effect )
338	6a06a912	Leszek Koltunski	{
339	96e3b88a	Leszek Koltunski	mJobs.add(new Job(DETACH,0,0,true,mEffects[i]));
340	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
341	26a4e5f6	leszek	mNumEffectsToBe--;
342			return 1;
343	6a06a912	Leszek Koltunski	}
344			}
345
346	26a4e5f6	leszek	return 0;
347	6a06a912	Leszek Koltunski	}
348
349			///////////////////////////////////////////////////////////////////////////////////////////////////
350	0df17fad	Leszek Koltunski	// we do want to notify Listeners if they called 'abortAll' themselves but don't want to notify
351			// them if it is the library itself which is releasing resources.
352
353	ceed2df6	Leszek Koltunski	public synchronized int removeAll(boolean notify)
354	6a06a912	Leszek Koltunski	{
355	96e3b88a	Leszek Koltunski	mJobs.add(new Job(DETALL,0,0,notify,null));
356	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
357	26a4e5f6	leszek	mNumEffectsToBe = 0;
358			return mNumEffects;
359			}
360	d07f2950	Leszek Koltunski
361	26a4e5f6	leszek	///////////////////////////////////////////////////////////////////////////////////////////////////
362
363	809dcae3	Leszek Koltunski	public boolean add(Effect effect)
364	26a4e5f6	leszek	{
365	06dbccad	Leszek Koltunski	if( mMax[mIndex]>mNumEffectsToBe \|\| !mCreated )
366	6a06a912	Leszek Koltunski	{
367	96e3b88a	Leszek Koltunski	mJobs.add(new Job(ATTACH,-1,0,false,effect));
368	34e43b0a	Leszek Koltunski	InternalMaster.newSlave(this);
369			mNumEffectsToBe++;
370			return true;
371			}
372
373			return false;
374			}
375
376			///////////////////////////////////////////////////////////////////////////////////////////////////
377
378			public boolean add(Effect effect, int position)
379			{
380			if( mMax[mIndex]>mNumEffectsToBe \|\| !mCreated )
381			{
382	96e3b88a	Leszek Koltunski	mJobs.add(new Job(ATTACH,position,0,false,effect));
383	7602a827	Leszek Koltunski	InternalMaster.newSlave(this);
384	26a4e5f6	leszek	mNumEffectsToBe++;
385			return true;
386	d07f2950	Leszek Koltunski	}
387
388	26a4e5f6	leszek	return false;
389	6a06a912	Leszek Koltunski	}
390
391	106ae28d	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
392
393			public int getNumEffects()
394			{
395			return mNumEffects;
396			}
397
398	1fad573e	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
399
400			public int getNumEffectsToBe()
401			{
402			return mNumEffectsToBe;
403			}
404
405	9dacabea	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
406
407			public Effect getEffect(int position)
408			{
409			if( position>=0 && position< mNumEffects )
410			{
411			return mEffects[position];
412			}
413			else
414			{
415			android.util.Log.e("queue", "getEffect: out of range "+position);
416			return null;
417			}
418			}
419
420	6a06a912	Leszek Koltunski	///////////////////////////////////////////////////////////////////////////////////////////////////
421	809dcae3	Leszek Koltunski
422	26a4e5f6	leszek	public void doWork()
423	6a06a912	Leszek Koltunski	{
424	11845a9e	Leszek Koltunski	boolean changed = false;
425	26a4e5f6	leszek	int num = mJobs.size();
426			Job job;
427	15aa7d94	Leszek Koltunski
428	26a4e5f6	leszek	for(int i=0; i<num; i++)
429	6a06a912	Leszek Koltunski	{
430	26a4e5f6	leszek	job = mJobs.remove(0);
431	15aa7d94	Leszek Koltunski
432	26a4e5f6	leszek	switch(job.type)
433			{
434	1418a5eb	Leszek Koltunski	case CREATE: int max = mMax[mIndex];
435			if( max>0 )
436			{
437	96e3b88a	Leszek Koltunski	mEffects = new Effect[max];
438			mFloatUniforms = new float[max*job.num1];
439			mIntUniforms = new int[max*job.num2];
440	1418a5eb	Leszek Koltunski	}
441	06dbccad	Leszek Koltunski	mCreated = true;
442
443	1418a5eb	Leszek Koltunski	break;
444			case ATTACH: if( mMax[mIndex]>mNumEffects ) // it is possible that we have first
445			{ // added effects and then lowered mMax
446	96e3b88a	Leszek Koltunski	int position = job.num1;
447	34e43b0a	Leszek Koltunski
448			if( position==-1 )
449			{
450	96e3b88a	Leszek Koltunski	mEffects[mNumEffects] = job.effect;
451			mIntUniforms[mNumEffects] = job.effect.getName().ordinal();
452	106ae28d	Leszek Koltunski
453			mNumEffects++;
454			changed = true;
455	34e43b0a	Leszek Koltunski	}
456			else if( position>=0 && position<=mNumEffects )
457			{
458			for(int j=mNumEffects; j>position; j--)
459			{
460	96e3b88a	Leszek Koltunski	mEffects[j] = mEffects[j-1];
461			mIntUniforms[j] = mIntUniforms[j-1];
462	34e43b0a	Leszek Koltunski	}
463
464	96e3b88a	Leszek Koltunski	mEffects[position] = job.effect;
465			mIntUniforms[position] = job.effect.getName().ordinal();
466	34e43b0a	Leszek Koltunski
467	106ae28d	Leszek Koltunski	mNumEffects++;
468			changed = true;
469			}
470	1418a5eb	Leszek Koltunski	}
471			else
472			{
473			android.util.Log.e("queue", "failed to add effect "+job.effect.getName());
474			}
475	26a4e5f6	leszek	break;
476	1418a5eb	Leszek Koltunski	case DETACH: for(int j=0; j<mNumEffects; j++)
477	6b0b4f60	leszek	{
478			if (mEffects[j] == job.effect)
479			{
480			remove(j);
481	11845a9e	Leszek Koltunski	changed = true;
482	6b0b4f60	leszek	break;
483			}
484			}
485	26a4e5f6	leszek	break;
486			case DETALL: for(int j=0; j<mNumEffects; j++ )
487			{
488	11845a9e	Leszek Koltunski	changed = true;
489	26a4e5f6	leszek	mEffects[j] = null;
490			}
491
492			mNumEffects= 0;
493			break;
494			}
495	6a06a912	Leszek Koltunski	}
496	d425545a	Leszek Koltunski
497	d5b709df	Leszek Koltunski	if( changed && mIndex==EffectType.POSTPROCESS.ordinal() ) regenerateID();
498	6a06a912	Leszek Koltunski	}
499			}

Project

General

Profile

Distorted Android

library / src / main / java / org / distorted / library / effectqueue / EffectQueue.java @ 96e3b88a