Project

General

Profile

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

library / src / main / java / org / distorted / library / effectqueue / EffectQueue.java @ 0bd9f644

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