Project

General

Profile

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

library / src / main / java / org / distorted / library / effectqueue / EffectQueue.java @ b7074bc6

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