Project

General

Profile

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

library / src / main / java / org / distorted / library / effectqueue / EffectQueue.java @ 1e672c1d

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 1e672c1d Leszek Koltunski
  int[] mAssociation;
55 f046b159 Leszek Koltunski
  long mTime;
56 71887484 Leszek Koltunski
57 13981586 Leszek Koltunski
  private static int[] mMax = new int[EffectType.LENGTH];
58 3417ab4e leszek
  private static long mNextID;
59
  private static HashMap<ArrayList<Long>,Long> mMapID = new HashMap<>(); // maps lists of Effect IDs (longs) to a
60
                                                                         // single long - the queue ID.
61 26a4e5f6 leszek
  private long mID;
62 15aa7d94 Leszek Koltunski
  private int mIndex;
63 06dbccad Leszek Koltunski
  private boolean mCreated;
64 71887484 Leszek Koltunski
65 f046b159 Leszek Koltunski
  private static class Job
66 26a4e5f6 leszek
    {
67
    int type;
68 1418a5eb Leszek Koltunski
    int num;
69 26a4e5f6 leszek
    boolean notify;
70
    Effect effect;
71
72 1418a5eb Leszek Koltunski
    Job(int t, int m, boolean n, Effect e)
73 26a4e5f6 leszek
      {
74
      type  = t;
75 1418a5eb Leszek Koltunski
      num   = m;
76 26a4e5f6 leszek
      notify= n;
77
      effect= e;
78
      }
79
    }
80
81
  private ArrayList<Job> mJobs = new ArrayList<>();
82
83 6a06a912 Leszek Koltunski
  static
84
    {
85 7b8086eb Leszek Koltunski
    onDestroy();
86 6a06a912 Leszek Koltunski
    }
87
  
88
///////////////////////////////////////////////////////////////////////////////////////////////////
89
   
90 20dbec0e Leszek Koltunski
  EffectQueue(int numUniforms, int index)
91 6a06a912 Leszek Koltunski
    {
92 06dbccad Leszek Koltunski
    mCreated            = false;
93 f046b159 Leszek Koltunski
    mTime               = 0;
94 26a4e5f6 leszek
    mID                 = 0;
95 fe6fe99a leszek
    mNumEffects         = 0;
96 26a4e5f6 leszek
    mNumEffectsToBe     = 0;
97 fe6fe99a leszek
    mIndex              = index;
98 f046b159 Leszek Koltunski
    mNumUniforms        = numUniforms;
99 1e438fc7 Leszek Koltunski
100 f046b159 Leszek Koltunski
    mJobs.add(new Job(CREATE,numUniforms,false,null)); // create the stuff that depends on max number
101 7602a827 Leszek Koltunski
    InternalMaster.newSlave(this);                     // of uniforms later, on first render.
102 6a06a912 Leszek Koltunski
    }
103
104 f046b159 Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
105
106
  EffectQueue(EffectQueue source)
107
    {
108
    if( !source.mCreated )
109
      {
110
      mCreated            = false;
111
      mTime               = 0;
112
      mID                 = 0;
113
      mNumEffects         = 0;
114
      mNumEffectsToBe     = 0;
115
      mIndex              = source.mIndex;
116
      mNumUniforms        = source.mNumUniforms;
117
118
      int numJobs = source.mJobs.size();
119
120
      for(int i=0; i<numJobs; i++)
121
        {
122
        Job job = source.mJobs.get(i);
123
        mJobs.add(job);
124
        }
125
126
      InternalMaster.newSlave(this);
127
      }
128
    else
129
      {
130
      mCreated            = true;
131
      mTime               = source.mTime;
132
      mID                 = source.mID;
133
      mNumEffects         = source.mNumEffects;
134
      mNumEffectsToBe     = source.mNumEffectsToBe;
135
      mIndex              = source.mIndex;
136
      mNumUniforms        = source.mNumUniforms;
137
138
      int max = mMax[mIndex];
139
      if( max>0 )
140
        {
141
        mUniforms        = new float[max*source.mNumUniforms];
142
        mCurrentDuration = new long[max];
143
        mEffects         = new Effect[max];
144
        mName            = new int[max];
145 1e672c1d Leszek Koltunski
        mAssociation     = new int[max];
146 f046b159 Leszek Koltunski
        }
147
148
      for(int i=0; i<mNumEffects; i++ )
149
        {
150
        mEffects[i]         = source.mEffects[i];
151
        mCurrentDuration[i] = source.mCurrentDuration[i];
152
        mName[i]            = source.mName[i];
153 1e672c1d Leszek Koltunski
        mAssociation[i]     = source.mAssociation[i];
154 f046b159 Leszek Koltunski
        }
155
      }
156
    }
157
158 a0397f32 Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
159
160 20dbec0e Leszek Koltunski
  public static void allocateQueues(EffectQueue[] queues, EffectQueue[] from, int flags)
161 a0397f32 Leszek Koltunski
    {
162 20dbec0e Leszek Koltunski
    queues[0] = (flags & DistortedLibrary.CLONE_MATRIX     ) != 0 ? from[0] : new EffectQueueMatrix();
163
    queues[1] = (flags & DistortedLibrary.CLONE_VERTEX     ) != 0 ? from[1] : new EffectQueueVertex();
164
    queues[2] = (flags & DistortedLibrary.CLONE_FRAGMENT   ) != 0 ? from[2] : new EffectQueueFragment();
165
    queues[3] = (flags & DistortedLibrary.CLONE_POSTPROCESS) != 0 ? from[3] : new EffectQueuePostprocess();
166 a0397f32 Leszek Koltunski
    }
167
168
///////////////////////////////////////////////////////////////////////////////////////////////////
169
170 644c21f2 Leszek Koltunski
  public static void compute(EffectQueue[] queues, long currTime)
171 a0397f32 Leszek Koltunski
    {
172
    ((EffectQueueMatrix     )queues[0]).compute(currTime);
173 644c21f2 Leszek Koltunski
    ((EffectQueueVertex     )queues[1]).compute(currTime);
174
    ((EffectQueueFragment   )queues[2]).compute(currTime);
175 a0397f32 Leszek Koltunski
    ((EffectQueuePostprocess)queues[3]).compute(currTime);
176
    }
177
178
///////////////////////////////////////////////////////////////////////////////////////////////////
179
180 23b733db Leszek Koltunski
  public static void send(EffectQueue[] queues, float distance, float mipmap,
181
                          float[] projection, float inflate, MeshBase mesh, int variant )
182 a0397f32 Leszek Koltunski
    {
183 23b733db Leszek Koltunski
    ((EffectQueueMatrix  )queues[0]).send(distance, mipmap, projection, mesh, variant);
184 a0397f32 Leszek Koltunski
    ((EffectQueueVertex  )queues[1]).send(inflate, variant);
185
    ((EffectQueueFragment)queues[2]).send(variant);
186
    }
187
188
///////////////////////////////////////////////////////////////////////////////////////////////////
189
190 809dcae3 Leszek Koltunski
  public static float[] getMVP(EffectQueue[] queues)
191 a0397f32 Leszek Koltunski
    {
192 d5b709df Leszek Koltunski
    return ((EffectQueueMatrix)queues[0]).getMVP();
193 a0397f32 Leszek Koltunski
    }
194
195
///////////////////////////////////////////////////////////////////////////////////////////////////
196 f046b159 Leszek Koltunski
// variant: 0 --> MAIN  1 --> OIT  2 --> prePOST  3 --> FULL
197 a0397f32 Leszek Koltunski
198 809dcae3 Leszek Koltunski
  public static void getUniforms(int programH, int variant)
199 a0397f32 Leszek Koltunski
    {
200 809dcae3 Leszek Koltunski
    EffectQueueFragment.uniforms(programH,variant);
201
    EffectQueueVertex  .uniforms(programH,variant);
202
    EffectQueueMatrix  .uniforms(programH,variant);
203 a0397f32 Leszek Koltunski
    }
204
205 26a4e5f6 leszek
///////////////////////////////////////////////////////////////////////////////////////////////////
206 9455da17 Leszek Koltunski
// Every effect queue has an ID, which should be the same iff two queues hold the same effects.
207
// (this is a speedup: then both queues can be applied once, which seriously speeds up stuff -
208
// especially important in case of postprocessing)
209 26a4e5f6 leszek
210 d5b709df Leszek Koltunski
  private void regenerateID()
211 26a4e5f6 leszek
    {
212 3417ab4e leszek
    if( mNumEffects>0 )
213
      {
214
      ArrayList<Long> list = new ArrayList<>();
215
      for (int i = 0; i < mNumEffects; i++) list.add(mEffects[i].getID());
216
      Long id = mMapID.get(list);
217
218
      if( id!=null )
219
        {
220
        mID = id;
221
        }
222
      else
223
        {
224
        mMapID.put(list,mNextID);
225
        mID = mNextID++;
226
        }
227
      }
228
    else
229
      {
230
      mID = 0;
231
      }
232 c43abe6c Leszek Koltunski
    }
233
234 6a06a912 Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
235
236 809dcae3 Leszek Koltunski
  public long getID()
237 26a4e5f6 leszek
    {
238
    return mID;
239
    }
240
241
///////////////////////////////////////////////////////////////////////////////////////////////////
242 71887484 Leszek Koltunski
243 809dcae3 Leszek Koltunski
  public static boolean setMax(int index, int m)
244 71887484 Leszek Koltunski
    {
245 7602a827 Leszek Koltunski
    if( !DistortedLibrary.isInitialized() || m<=mMax[index] )
246 71887484 Leszek Koltunski
      {
247 26a4e5f6 leszek
      mMax[index] = m<0 ? 0:m;
248 71887484 Leszek Koltunski
      return true;
249
      }
250
251
    return false;
252
    }
253
254
///////////////////////////////////////////////////////////////////////////////////////////////////
255
256 809dcae3 Leszek Koltunski
  public static int getMax(int index)
257 71887484 Leszek Koltunski
    {
258
    return mMax[index];
259
    }
260
261 6a06a912 Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
262
263 809dcae3 Leszek Koltunski
  public static void onDestroy()
264 6a06a912 Leszek Koltunski
    {
265 3417ab4e leszek
    mNextID = 1;
266
    mMapID.clear();
267 da9b3f07 Leszek Koltunski
    EffectType.reset(mMax);
268 6a06a912 Leszek Koltunski
    }
269
270
///////////////////////////////////////////////////////////////////////////////////////////////////
271 26a4e5f6 leszek
// this assumes 0<=effect<mNumEffects
272 6a06a912 Leszek Koltunski
273 26a4e5f6 leszek
  protected void remove(int effect)
274 6bb59aad Leszek Koltunski
    {
275 26a4e5f6 leszek
    mNumEffects--;
276
277
    for(int j=effect; j<mNumEffects; j++ )
278
      {
279
      mEffects[j]         = mEffects[j+1];
280
      mCurrentDuration[j] = mCurrentDuration[j+1];
281
      mName[j]            = mName[j+1];
282 1e672c1d Leszek Koltunski
      mAssociation[j]     = mAssociation[j+1];
283 26a4e5f6 leszek
      }
284
285
    mEffects[mNumEffects] = null;
286
    }
287 6bb59aad Leszek Koltunski
288 26a4e5f6 leszek
///////////////////////////////////////////////////////////////////////////////////////////////////
289
290 809dcae3 Leszek Koltunski
  public synchronized int removeByName(EffectName name)
291 26a4e5f6 leszek
    {
292 6b0b4f60 leszek
    int ret = 0;
293
294 6bb59aad Leszek Koltunski
    for(int i=0; i<mNumEffects; i++)
295
      {
296
      if( mEffects[i].getName() == name )
297
        {
298 1418a5eb Leszek Koltunski
        mJobs.add(new Job(DETACH,0,true,mEffects[i]));
299 6b0b4f60 leszek
        ret++;
300 6bb59aad Leszek Koltunski
        }
301
      }
302
303 6b0b4f60 leszek
    if( ret>0 )
304
      {
305 7602a827 Leszek Koltunski
      InternalMaster.newSlave(this);
306 6b0b4f60 leszek
      mNumEffectsToBe-=ret;
307
      }
308
309
    return ret;
310 6bb59aad Leszek Koltunski
    }
311
312 2ef5dd9e leszek
///////////////////////////////////////////////////////////////////////////////////////////////////
313
314 809dcae3 Leszek Koltunski
  public synchronized int removeById(long id)
315 2ef5dd9e leszek
    {
316
    for(int i=0; i<mNumEffects; i++)
317
      {
318
      if( mEffects[i].getID() == id )
319
        {
320 1418a5eb Leszek Koltunski
        mJobs.add(new Job(DETACH,0,true,mEffects[i]));
321 7602a827 Leszek Koltunski
        InternalMaster.newSlave(this);
322 26a4e5f6 leszek
        mNumEffectsToBe--;
323
        return 1;
324 2ef5dd9e leszek
        }
325
      }
326
327 26a4e5f6 leszek
    return 0;
328 2ef5dd9e leszek
    }
329
330 6bb59aad Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
331
332 809dcae3 Leszek Koltunski
  public synchronized int removeEffect(Effect effect)
333 6a06a912 Leszek Koltunski
    {
334
    for(int i=0; i<mNumEffects; i++)
335
      {
336 15aa7d94 Leszek Koltunski
      if( mEffects[i]==effect )
337 6a06a912 Leszek Koltunski
        {
338 1418a5eb Leszek Koltunski
        mJobs.add(new Job(DETACH,0,true,mEffects[i]));
339 7602a827 Leszek Koltunski
        InternalMaster.newSlave(this);
340 26a4e5f6 leszek
        mNumEffectsToBe--;
341
        return 1;
342 6a06a912 Leszek Koltunski
        }
343
      }
344
   
345 26a4e5f6 leszek
    return 0;
346 6a06a912 Leszek Koltunski
    }
347
348
///////////////////////////////////////////////////////////////////////////////////////////////////
349 0df17fad Leszek Koltunski
// we do want to notify Listeners if they called 'abortAll' themselves but don't want to notify
350
// them if it is the library itself which is releasing resources.
351
352 ceed2df6 Leszek Koltunski
  public synchronized int removeAll(boolean notify)
353 6a06a912 Leszek Koltunski
    {
354 1418a5eb Leszek Koltunski
    mJobs.add(new Job(DETALL,0,notify,null));
355 7602a827 Leszek Koltunski
    InternalMaster.newSlave(this);
356 26a4e5f6 leszek
    mNumEffectsToBe = 0;
357
    return mNumEffects;
358
    }
359 d07f2950 Leszek Koltunski
360 26a4e5f6 leszek
///////////////////////////////////////////////////////////////////////////////////////////////////
361
  
362 809dcae3 Leszek Koltunski
  public boolean add(Effect effect)
363 26a4e5f6 leszek
    {
364 06dbccad Leszek Koltunski
    if( mMax[mIndex]>mNumEffectsToBe || !mCreated )
365 6a06a912 Leszek Koltunski
      {
366 34e43b0a Leszek Koltunski
      mJobs.add(new Job(ATTACH,-1,false,effect));
367
      InternalMaster.newSlave(this);
368
      mNumEffectsToBe++;
369
      return true;
370
      }
371
372
    return false;
373
    }
374
375
///////////////////////////////////////////////////////////////////////////////////////////////////
376
377
  public boolean add(Effect effect, int position)
378
    {
379
    if( mMax[mIndex]>mNumEffectsToBe || !mCreated )
380
      {
381
      mJobs.add(new Job(ATTACH,position,false,effect));
382 7602a827 Leszek Koltunski
      InternalMaster.newSlave(this);
383 26a4e5f6 leszek
      mNumEffectsToBe++;
384
      return true;
385 d07f2950 Leszek Koltunski
      }
386
387 26a4e5f6 leszek
    return false;
388 6a06a912 Leszek Koltunski
    }
389
390 106ae28d Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
391
392
  public int getNumEffects()
393
    {
394
    return mNumEffects;
395
    }
396
397 9dacabea Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
398
399
  public Effect getEffect(int position)
400
    {
401
    if( position>=0 && position< mNumEffects )
402
      {
403
      return mEffects[position];
404
      }
405
    else
406
      {
407
      android.util.Log.e("queue", "getEffect: out of range "+position);
408
      return null;
409
      }
410
    }
411
412 6a06a912 Leszek Koltunski
///////////////////////////////////////////////////////////////////////////////////////////////////
413 809dcae3 Leszek Koltunski
414 26a4e5f6 leszek
  public void doWork()
415 6a06a912 Leszek Koltunski
    {
416 11845a9e Leszek Koltunski
    boolean changed = false;
417 26a4e5f6 leszek
    int num = mJobs.size();
418
    Job job;
419 15aa7d94 Leszek Koltunski
420 26a4e5f6 leszek
    for(int i=0; i<num; i++)
421 6a06a912 Leszek Koltunski
      {
422 26a4e5f6 leszek
      job = mJobs.remove(0);
423 15aa7d94 Leszek Koltunski
424 26a4e5f6 leszek
      switch(job.type)
425
        {
426 1418a5eb Leszek Koltunski
        case CREATE: int max = mMax[mIndex];
427
                     if( max>0 )
428
                       {
429
                       mUniforms        = new float[max*job.num];
430
                       mCurrentDuration = new long[max];
431
                       mEffects         = new Effect[max];
432
                       mName            = new int[max];
433 1e672c1d Leszek Koltunski
                       mAssociation     = new int[max];
434 1418a5eb Leszek Koltunski
                       }
435 06dbccad Leszek Koltunski
                     mCreated = true;
436
437 1418a5eb Leszek Koltunski
                     break;
438
        case ATTACH: if( mMax[mIndex]>mNumEffects ) // it is possible that we have first
439
                       {                            // added effects and then lowered mMax
440 34e43b0a Leszek Koltunski
                       int position = job.num;
441
442
                       if( position==-1 )
443
                         {
444
                         mCurrentDuration[mNumEffects] = 0;
445 1e672c1d Leszek Koltunski
                         mEffects[mNumEffects]    = job.effect;
446
                         mName[mNumEffects]       = job.effect.getName().ordinal();
447
                         mAssociation[mNumEffects]= job.effect.getAssociation();
448 106ae28d Leszek Koltunski
449
                         mNumEffects++;
450
                         changed = true;
451 34e43b0a Leszek Koltunski
                         }
452
                       else if( position>=0 && position<=mNumEffects )
453
                         {
454
                         for(int j=mNumEffects; j>position; j--)
455
                           {
456
                           mCurrentDuration[j] = mCurrentDuration[j-1];
457
                           mEffects[j]         = mEffects[j-1];
458
                           mName[j]            = mName[j-1];
459 1e672c1d Leszek Koltunski
                           mAssociation[j]     = mAssociation[j-1];
460 34e43b0a Leszek Koltunski
                           }
461
462
                         mCurrentDuration[position] = 0;
463 1e672c1d Leszek Koltunski
                         mEffects[position]    = job.effect;
464
                         mName[position]       = job.effect.getName().ordinal();
465
                         mAssociation[position]= job.effect.getAssociation();
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
  }