Distorted Android

///////////////////////////////////////////////////////////////////////////////////////////////////

// Copyright 2016 Leszek Koltunski                                                               //

//                                                                                               //

// This file is part of Distorted.                                                               //

//                                                                                               //

// Distorted is free software: you can redistribute it and/or modify                             //

// it under the terms of the GNU General Public License as published by                          //

// the Free Software Foundation, either version 2 of the License, or                             //

// (at your option) any later version.                                                           //

//                                                                                               //

// Distorted is distributed in the hope that it will be useful,                                  //

// but WITHOUT ANY WARRANTY; without even the implied warranty of                                //

// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the                                 //

// GNU General Public License for more details.                                                  //

//                                                                                               //

// You should have received a copy of the GNU General Public License                             //

// along with Distorted.  If not, see <http://www.gnu.org/licenses/>.                            //

///////////////////////////////////////////////////////////////////////////////////////////////////

package org.distorted.examples.save;

import android.app.Activity;

import android.graphics.Bitmap;

import android.widget.Toast;

import java.io.BufferedOutputStream;

import java.io.FileOutputStream;

import java.io.IOException;

import java.lang.ref.WeakReference;

import java.nio.ByteBuffer;

import java.util.Vector;

public class SaveWorkerThread extends Thread

  {

  private static Vector<WorkLoad> mBuffers;

  private static SaveWorkerThread mThis=null;

  private static volatile boolean mPaused;

  private static WeakReference<Activity> mWeakAct;

  private static class WorkLoad

    {

    ByteBuffer buffer;

    int width;

    int height;

    String filename;

    WorkLoad(ByteBuffer buf, int w, int h, String name)

      {

      buffer   = buf;

      width    = w;

      height   = h;

      filename = name;

      }

    }

///////////////////////////////////////////////////////////////////////////////////////////////////

  public SaveWorkerThread()

    {

    }

///////////////////////////////////////////////////////////////////////////////////////////////////

  static void startSending(Activity act)

    {

    mWeakAct = new WeakReference(act);

    mPaused = false;

    if( mThis==null )

      {

      mBuffers = new Vector<>();

      mThis = new SaveWorkerThread();

      mThis.start();

      }

    else

      {

      synchronized(mThis)

        {

        mThis.notify();

        }

      }

    }

///////////////////////////////////////////////////////////////////////////////////////////////////

  static void stopSending()

    {

    mPaused = true;

    }

///////////////////////////////////////////////////////////////////////////////////////////////////

  public void run()

    {

    WorkLoad load;

    while(true)

      {

      if( mBuffers.size()>0 )

        {

        load = mBuffers.remove(0);

        process(load);

        }

      if( mPaused )

        {

        synchronized(mThis)

          {

          try  { mThis.wait(); }

          catch(InterruptedException ex) { }

          }

        }

      }

    }

///////////////////////////////////////////////////////////////////////////////////////////////////

  static void newBuffer(ByteBuffer buffer, int width, int height, String filename)

    {

    WorkLoad load = new WorkLoad(buffer,width,height,filename);

    mBuffers.add(load);

    }

///////////////////////////////////////////////////////////////////////////////////////////////////

  private void process(WorkLoad load)

    {

    ByteBuffer buf = load.buffer;

    int width  = load.width;

    int height = load.height;

    final String filename = load.filename;

    byte[] tmp1 = new byte[width*4];

    byte[] tmp2 = new byte[width*4];

    for(int i=0; i<height/2; i++)

      {

      buf.position((         i)*width*4);  // GL uses a coordinate system from mathematics; i.e.

      buf.get(tmp1);                       // (0,0) is in the lower-left corner. 2D stuff has

      buf.position((height-1-i)*width*4);  // the origin on the upper-left corner; we have to flip

      buf.get(tmp2);                       // out bitmap upside down!

      buf.position((         i)*width*4);

      buf.put(tmp2);

      buf.position((height-1-i)*width*4);

      buf.put(tmp1);

      }

    buf.rewind();

    BufferedOutputStream bos =null;

    final Activity act = mWeakAct.get();

    try

      {

      bos = new BufferedOutputStream(new FileOutputStream(filename));

      Bitmap bmp = Bitmap.createBitmap( width, height, Bitmap.Config.ARGB_8888);

      bmp.copyPixelsFromBuffer(buf);

      bmp.compress(Bitmap.CompressFormat.PNG, 90, bos);

      bmp.recycle();

      act.runOnUiThread(new Runnable()

        {

        public void run()

          {

          Toast.makeText(act,

              "Saving to \n\n"+filename+"\n\nsuccessful" ,

              Toast.LENGTH_LONG).show();

          }

        });

      }

    catch(final Exception ex)

      {

      act.runOnUiThread(new Runnable()

        {

        public void run()

          {

          Toast.makeText(act,

              "Saving to \n\n"+filename+"\n\n failed: "+"\n\n"+ex.getMessage() ,

              Toast.LENGTH_LONG).show();

          }

        });

      }

    finally

      {

      if(bos!=null)

        {

        try { bos.close(); }

        catch(IOException io) {}

        }

      }

    }

  }