Project

General

Profile

Download (13.9 KB) Statistics
| Branch: | Revision:

library / src / main / java / org / distorted / library / effectqueue / EffectQueue.java @ 7602a827

1 d333eb6b Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
2
// Copyright 2016 Leszek Koltunski                                                               //
3
//                                                                                               //
4 7602a827 Leszek Koltunski
// This file is part of DistortedLibrary.                                                               //
5 d333eb6b Leszek Koltunski
//                                                                                               //
6 7602a827 Leszek Koltunski
// DistortedLibrary 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 7602a827 Leszek Koltunski
// DistortedLibrary 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 7602a827 Leszek Koltunski
// along with DistortedLibrary.  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 e458a4ba Leszek Koltunski
import org.distorted.library.message.EffectListener;
28
import org.distorted.library.message.EffectMessage;
29 ed06301f Leszek Koltunski
import org.distorted.library.message.EffectMessageSender;
30 a4835695 Leszek Koltunski
31 26a4e5f6 leszek
import java.util.ArrayList;
32 3417ab4e leszek
import java.util.HashMap;
33 6a06a912 Leszek Koltunski
34
///////////////////////////////////////////////////////////////////////////////////////////////////
35 809dcae3 Leszek Koltunski
/**
36
 * Not part of public API, do not document
37
 *
38
 * @y.exclude
39
 */
40 7602a827 Leszek Koltunski
public abstract class EffectQueue implements InternalMaster.Slave
41 6a06a912 Leszek Koltunski
  {
42 809dcae3 Leszek Koltunski
  static final int MAIN_VARIANTS = 3; // Number of Main program variants (ATM 3: MAIN, MAIN OIT, PREPROCESS)
43
44 1418a5eb Leszek Koltunski
  private static final int CREATE = 0;
45
  private static final int ATTACH = 1;
46
  private static final int DETACH = 2;
47
  private static final int DETALL = 3;
48 26a4e5f6 leszek
49 8bfefd68 Leszek Koltunski
  int mNumEffects;              // 'ToBe' will be more than mNumEffects if doWork() hasn't
50
  private int mNumEffectsToBe;  // added them yet (or less if it hasn't removed some yet)
51 13981586 Leszek Koltunski
  float[] mUniforms;
52
  long[] mCurrentDuration;
53
  Effect[] mEffects;
54
  int[] mName;
55
  long mTime=0;
56
  ArrayList<EffectListener> mListeners =null;
57
  int mNumListeners=0;  // ==mListeners.length(), but we only create mListeners if the first one gets added
58
  long mDistortedEffectsID;
59 71887484 Leszek Koltunski
60 13981586 Leszek Koltunski
  private static int[] mMax = new int[EffectType.LENGTH];
61 3417ab4e leszek
  private static long mNextID;
62
  private static HashMap<ArrayList<Long>,Long> mMapID = new HashMap<>(); // maps lists of Effect IDs (longs) to a
63
                                                                         // single long - the queue ID.
64 26a4e5f6 leszek
  private long mID;
65 15aa7d94 Leszek Koltunski
  private int mIndex;
66 06dbccad Leszek Koltunski
  private boolean mCreated;
67 71887484 Leszek Koltunski
68 26a4e5f6 leszek
  private class Job
69
    {
70
    int type;
71 1418a5eb Leszek Koltunski
    int num;
72 26a4e5f6 leszek
    boolean notify;
73
    Effect effect;
74
75 1418a5eb Leszek Koltunski
    Job(int t, int m, boolean n, Effect e)
76 26a4e5f6 leszek
      {
77
      type  = t;
78 1418a5eb Leszek Koltunski
      num   = m;
79 26a4e5f6 leszek
      notify= n;
80
      effect= e;
81
      }
82
    }
83
84
  private ArrayList<Job> mJobs = new ArrayList<>();
85
86 6a06a912 Leszek Koltunski
  static
87
    {
88 7b8086eb Leszek Koltunski
    onDestroy();
89 6a06a912 Leszek Koltunski
    }
90
  
91
///////////////////////////////////////////////////////////////////////////////////////////////////
92
   
93 15aa7d94 Leszek Koltunski
  EffectQueue(long id, int numUniforms, int index)
94 6a06a912 Leszek Koltunski
    {
95 06dbccad Leszek Koltunski
    mCreated            = false;
96 26a4e5f6 leszek
    mID                 = 0;
97 fe6fe99a leszek
    mNumEffects         = 0;
98 26a4e5f6 leszek
    mNumEffectsToBe     = 0;
99 fe6fe99a leszek
    mDistortedEffectsID = id;
100
    mIndex              = index;
101 1e438fc7 Leszek Koltunski
102 1418a5eb Leszek Koltunski
    mJobs.add(new Job(CREATE,numUniforms,false,null));  // create the stuff that depends on max number
103 7602a827 Leszek Koltunski
    InternalMaster.newSlave(this);                     // of uniforms later, on first render.
104 6a06a912 Leszek Koltunski
    }
105
106 a0397f32 Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
107
108 809dcae3 Leszek Koltunski
  public static void allocateQueues(EffectQueue[] queues, EffectQueue[] from, int flags, long id)
109 a0397f32 Leszek Koltunski
    {
110 7602a827 Leszek Koltunski
    queues[0] = (flags & DistortedLibrary.CLONE_MATRIX     ) != 0 ? from[0] : new EffectQueueMatrix(id);
111
    queues[1] = (flags & DistortedLibrary.CLONE_VERTEX     ) != 0 ? from[1] : new EffectQueueVertex(id);
112
    queues[2] = (flags & DistortedLibrary.CLONE_FRAGMENT   ) != 0 ? from[2] : new EffectQueueFragment(id);
113
    queues[3] = (flags & DistortedLibrary.CLONE_POSTPROCESS) != 0 ? from[3] : new EffectQueuePostprocess(id);
114 a0397f32 Leszek Koltunski
    }
115
116
///////////////////////////////////////////////////////////////////////////////////////////////////
117
118 809dcae3 Leszek Koltunski
  public static void compute(EffectQueue[] queues, long currTime, float halfW, float halfH, float halfZ )
119 a0397f32 Leszek Koltunski
    {
120
    ((EffectQueueMatrix     )queues[0]).compute(currTime);
121
    ((EffectQueueVertex     )queues[1]).compute(currTime,halfW,halfH,halfZ);
122
    ((EffectQueueFragment   )queues[2]).compute(currTime,halfW,halfH,halfZ);
123
    ((EffectQueuePostprocess)queues[3]).compute(currTime);
124
    }
125
126
///////////////////////////////////////////////////////////////////////////////////////////////////
127
128 809dcae3 Leszek Koltunski
  public static void send( EffectQueue[] queues, int width, int height, float distance, float mipmap,
129
                           float[] projection, float inflate, float halfW, float halfH, float halfZ, int variant )
130 a0397f32 Leszek Koltunski
    {
131 809dcae3 Leszek Koltunski
    ((EffectQueueMatrix  )queues[0]).send(width, height, distance, mipmap, projection, halfW, halfH, halfZ, variant);
132 a0397f32 Leszek Koltunski
    ((EffectQueueVertex  )queues[1]).send(inflate, variant);
133
    ((EffectQueueFragment)queues[2]).send(variant);
134
    }
135
136
///////////////////////////////////////////////////////////////////////////////////////////////////
137
138 809dcae3 Leszek Koltunski
  public static float[] getMVP(EffectQueue[] queues)
139 a0397f32 Leszek Koltunski
    {
140 d5b709df Leszek Koltunski
    return ((EffectQueueMatrix)queues[0]).getMVP();
141 a0397f32 Leszek Koltunski
    }
142
143
///////////////////////////////////////////////////////////////////////////////////////////////////
144
145 809dcae3 Leszek Koltunski
  public static void getUniforms(int programH, int variant)
146 a0397f32 Leszek Koltunski
    {
147 809dcae3 Leszek Koltunski
    EffectQueueFragment.uniforms(programH,variant);
148
    EffectQueueVertex  .uniforms(programH,variant);
149
    EffectQueueMatrix  .uniforms(programH,variant);
150 a0397f32 Leszek Koltunski
    }
151
152 26a4e5f6 leszek
///////////////////////////////////////////////////////////////////////////////////////////////////
153 9455da17 Leszek Koltunski
// Every effect queue has an ID, which should be the same iff two queues hold the same effects.
154
// (this is a speedup: then both queues can be applied once, which seriously speeds up stuff -
155
// especially important in case of postprocessing)
156 26a4e5f6 leszek
157 d5b709df Leszek Koltunski
  private void regenerateID()
158 26a4e5f6 leszek
    {
159 3417ab4e leszek
    if( mNumEffects>0 )
160
      {
161
      ArrayList<Long> list = new ArrayList<>();
162
      for (int i = 0; i < mNumEffects; i++) list.add(mEffects[i].getID());
163
      Long id = mMapID.get(list);
164
165
      if( id!=null )
166
        {
167
        mID = id;
168
        }
169
      else
170
        {
171
        mMapID.put(list,mNextID);
172
        mID = mNextID++;
173
        }
174
      }
175
    else
176
      {
177
      mID = 0;
178
      }
179 c43abe6c Leszek Koltunski
    }
180
181 6a06a912 Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
182
183 809dcae3 Leszek Koltunski
  public long getID()
184 26a4e5f6 leszek
    {
185
    return mID;
186
    }
187
188
///////////////////////////////////////////////////////////////////////////////////////////////////
189 71887484 Leszek Koltunski
190 809dcae3 Leszek Koltunski
  public static boolean setMax(int index, int m)
191 71887484 Leszek Koltunski
    {
192 7602a827 Leszek Koltunski
    if( !DistortedLibrary.isInitialized() || m<=mMax[index] )
193 71887484 Leszek Koltunski
      {
194 26a4e5f6 leszek
      mMax[index] = m<0 ? 0:m;
195 71887484 Leszek Koltunski
      return true;
196
      }
197
198
    return false;
199
    }
200
201
///////////////////////////////////////////////////////////////////////////////////////////////////
202
203 809dcae3 Leszek Koltunski
  public static int getMax(int index)
204 71887484 Leszek Koltunski
    {
205
    return mMax[index];
206
    }
207
208 6a06a912 Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
209
210 809dcae3 Leszek Koltunski
  public void registerForMessages(EffectListener el)
211 6a06a912 Leszek Koltunski
    {
212 26a4e5f6 leszek
    if( mListeners==null ) mListeners = new ArrayList<>();
213 452f8632 Leszek Koltunski
214
    if( !mListeners.contains(el) )
215
      {
216
      mListeners.add(el);
217
      mNumListeners++;
218
      }
219 6a06a912 Leszek Koltunski
    }
220
 
221
///////////////////////////////////////////////////////////////////////////////////////////////////
222
223 809dcae3 Leszek Koltunski
  public void deregisterForMessages(EffectListener el)
224 6a06a912 Leszek Koltunski
    {
225 452f8632 Leszek Koltunski
    if( mListeners.remove(el) )
226 6a06a912 Leszek Koltunski
      {
227
      mNumListeners--;
228
      }
229
    }
230
231
///////////////////////////////////////////////////////////////////////////////////////////////////
232
233 809dcae3 Leszek Koltunski
  public static void onDestroy()
234 6a06a912 Leszek Koltunski
    {
235 3417ab4e leszek
    mNextID = 1;
236
    mMapID.clear();
237 da9b3f07 Leszek Koltunski
    EffectType.reset(mMax);
238 6a06a912 Leszek Koltunski
    }
239
240
///////////////////////////////////////////////////////////////////////////////////////////////////
241 26a4e5f6 leszek
// this assumes 0<=effect<mNumEffects
242 6a06a912 Leszek Koltunski
243 26a4e5f6 leszek
  protected void remove(int effect)
244 6bb59aad Leszek Koltunski
    {
245 26a4e5f6 leszek
    mNumEffects--;
246
247
    long removedID = mEffects[effect].getID();
248
249
    for(int j=effect; j<mNumEffects; j++ )
250
      {
251
      mEffects[j]         = mEffects[j+1];
252
      mCurrentDuration[j] = mCurrentDuration[j+1];
253
      mName[j]            = mName[j+1];
254
      }
255
256
    mEffects[mNumEffects] = null;
257
258
    for(int i=0; i<mNumListeners; i++)
259
      EffectMessageSender.newMessage( mListeners.get(i), EffectMessage.EFFECT_REMOVED, removedID, mDistortedEffectsID);
260
    }
261 6bb59aad Leszek Koltunski
262 26a4e5f6 leszek
///////////////////////////////////////////////////////////////////////////////////////////////////
263
264 809dcae3 Leszek Koltunski
  public synchronized int removeByName(EffectName name)
265 26a4e5f6 leszek
    {
266 6b0b4f60 leszek
    int ret = 0;
267
268 6bb59aad Leszek Koltunski
    for(int i=0; i<mNumEffects; i++)
269
      {
270
      if( mEffects[i].getName() == name )
271
        {
272 1418a5eb Leszek Koltunski
        mJobs.add(new Job(DETACH,0,true,mEffects[i]));
273 6b0b4f60 leszek
        ret++;
274 6bb59aad Leszek Koltunski
        }
275
      }
276
277 6b0b4f60 leszek
    if( ret>0 )
278
      {
279 7602a827 Leszek Koltunski
      InternalMaster.newSlave(this);
280 6b0b4f60 leszek
      mNumEffectsToBe-=ret;
281
      }
282
283
    return ret;
284 6bb59aad Leszek Koltunski
    }
285
286 2ef5dd9e leszek
///////////////////////////////////////////////////////////////////////////////////////////////////
287
288 809dcae3 Leszek Koltunski
  public synchronized int removeById(long id)
289 2ef5dd9e leszek
    {
290
    for(int i=0; i<mNumEffects; i++)
291
      {
292
      if( mEffects[i].getID() == id )
293
        {
294 1418a5eb Leszek Koltunski
        mJobs.add(new Job(DETACH,0,true,mEffects[i]));
295 7602a827 Leszek Koltunski
        InternalMaster.newSlave(this);
296 26a4e5f6 leszek
        mNumEffectsToBe--;
297
        return 1;
298 2ef5dd9e leszek
        }
299
      }
300
301 26a4e5f6 leszek
    return 0;
302 2ef5dd9e leszek
    }
303
304 6bb59aad Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
305
306 809dcae3 Leszek Koltunski
  public synchronized int removeEffect(Effect effect)
307 6a06a912 Leszek Koltunski
    {
308
    for(int i=0; i<mNumEffects; i++)
309
      {
310 15aa7d94 Leszek Koltunski
      if( mEffects[i]==effect )
311 6a06a912 Leszek Koltunski
        {
312 1418a5eb Leszek Koltunski
        mJobs.add(new Job(DETACH,0,true,mEffects[i]));
313 7602a827 Leszek Koltunski
        InternalMaster.newSlave(this);
314 26a4e5f6 leszek
        mNumEffectsToBe--;
315
        return 1;
316 6a06a912 Leszek Koltunski
        }
317
      }
318
   
319 26a4e5f6 leszek
    return 0;
320 6a06a912 Leszek Koltunski
    }
321
322
///////////////////////////////////////////////////////////////////////////////////////////////////
323 0df17fad Leszek Koltunski
// we do want to notify Listeners if they called 'abortAll' themselves but don't want to notify
324
// them if it is the library itself which is releasing resources.
325
326 809dcae3 Leszek Koltunski
  public synchronized int abortAll(boolean notify)
327 6a06a912 Leszek Koltunski
    {
328 1418a5eb Leszek Koltunski
    mJobs.add(new Job(DETALL,0,notify,null));
329 7602a827 Leszek Koltunski
    InternalMaster.newSlave(this);
330 26a4e5f6 leszek
    mNumEffectsToBe = 0;
331
    return mNumEffects;
332
    }
333 d07f2950 Leszek Koltunski
334 26a4e5f6 leszek
///////////////////////////////////////////////////////////////////////////////////////////////////
335
  
336 809dcae3 Leszek Koltunski
  public boolean add(Effect effect)
337 26a4e5f6 leszek
    {
338 06dbccad Leszek Koltunski
    if( mMax[mIndex]>mNumEffectsToBe || !mCreated )
339 6a06a912 Leszek Koltunski
      {
340 1418a5eb Leszek Koltunski
      mJobs.add(new Job(ATTACH,0,false,effect));
341 7602a827 Leszek Koltunski
      InternalMaster.newSlave(this);
342 26a4e5f6 leszek
      mNumEffectsToBe++;
343
      return true;
344 d07f2950 Leszek Koltunski
      }
345
346 26a4e5f6 leszek
    return false;
347 6a06a912 Leszek Koltunski
    }
348
349
///////////////////////////////////////////////////////////////////////////////////////////////////
350 809dcae3 Leszek Koltunski
351 26a4e5f6 leszek
  public void doWork()
352 6a06a912 Leszek Koltunski
    {
353 11845a9e Leszek Koltunski
    boolean changed = false;
354 26a4e5f6 leszek
    int num = mJobs.size();
355
    Job job;
356 15aa7d94 Leszek Koltunski
357 26a4e5f6 leszek
    for(int i=0; i<num; i++)
358 6a06a912 Leszek Koltunski
      {
359 26a4e5f6 leszek
      job = mJobs.remove(0);
360 15aa7d94 Leszek Koltunski
361 26a4e5f6 leszek
      switch(job.type)
362
        {
363 1418a5eb Leszek Koltunski
        case CREATE: int max = mMax[mIndex];
364
                     if( max>0 )
365
                       {
366
                       mUniforms        = new float[max*job.num];
367
                       mCurrentDuration = new long[max];
368
                       mEffects         = new Effect[max];
369
                       mName            = new int[max];
370
                       }
371 06dbccad Leszek Koltunski
                     mCreated = true;
372
373 1418a5eb Leszek Koltunski
                     break;
374
        case ATTACH: if( mMax[mIndex]>mNumEffects ) // it is possible that we have first
375
                       {                            // added effects and then lowered mMax
376
                       mCurrentDuration[mNumEffects] = 0;
377
                       mEffects[mNumEffects] = job.effect;
378
                       mName[mNumEffects] = job.effect.getName().ordinal();
379
                       mNumEffects++;
380 11845a9e Leszek Koltunski
                       changed = true;
381 1418a5eb Leszek Koltunski
                       }
382
                     else
383
                       {
384
                       android.util.Log.e("queue", "failed to add effect "+job.effect.getName());
385
                       }
386 26a4e5f6 leszek
                     break;
387 1418a5eb Leszek Koltunski
        case DETACH: for(int j=0; j<mNumEffects; j++)
388 6b0b4f60 leszek
                       {
389
                       if (mEffects[j] == job.effect)
390
                         {
391
                         remove(j);
392 11845a9e Leszek Koltunski
                         changed = true;
393 6b0b4f60 leszek
                         break;
394
                         }
395
                       }
396 26a4e5f6 leszek
                     break;
397
        case DETALL: for(int j=0; j<mNumEffects; j++ )
398
                       {
399 11845a9e Leszek Koltunski
                       changed = true;
400
401 26a4e5f6 leszek
                       if( job.notify )
402
                         {
403
                         for(int k=0; k<mNumListeners; k++)
404
                           EffectMessageSender.newMessage( mListeners.get(k), EffectMessage.EFFECT_REMOVED, mEffects[j].getID(), mDistortedEffectsID);
405
                         }
406
407
                       mEffects[j] = null;
408
                       }
409
410
                     mNumEffects= 0;
411
                     break;
412
        }
413 6a06a912 Leszek Koltunski
      }
414 d425545a Leszek Koltunski
415 d5b709df Leszek Koltunski
    if( changed && mIndex==EffectType.POSTPROCESS.ordinal() ) regenerateID();
416 6a06a912 Leszek Koltunski
    }
417
  }