Project

General

Profile

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

library / src / main / java / org / distorted / library / main / EffectQueue.java @ 11845a9e

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