snippetshare

buffer

import java.net.*;
import java.io.*;

int WW=1920, HH=1080;
int d=5;
int mlt=20, mtp=20;
int cols=((WW-mlt*2)/d) - 2;
int rows=(HH-mtp*2)/d;

int ca[][] = new int[rows][cols];
int ca_1[][] = new int[rows][cols];
int nca[][] = new int[rows][cols];

Thread lrt, rrt;
Thread lst, rst;
celrcvr lr, rr;
celsndr ls, rs;

String lhost="127.0.0.1"; //"192.168.1.2";
String rhost="127.0.0.1"; //"192.168.1.2";
int lport=9181;
int rport=9191;

volatile int lhs[]=new int[rows];
volatile int rhs[]=new int[rows];

void setup()
{
  noStroke();
  background(0);
  fullScreen();
  frameRate(15);

cainit();
  for (int i=0; i<rows; i++) lhs[i]=0;

// n/w first start receivers
  lr=new celrcvr(lport, lhs);
  rr=new celrcvr(rport, rhs);
  lrt=new Thread(lr);
  rrt=new Thread(rr);
  lrt.start();
  rrt.start();

// hang on for couple seconds
  try {
    Thread.sleep(3000);
  }
  catch(InterruptedException ie) {
    ie.printStackTrace();
  }

//  start emitters
  ls=new celsndr(lhost, rport, celwal.LEFT);
  rs=new celsndr(rhost, lport, celwal.RIGHT);
}

void draw()
{
  background(0);

carndr();
  caevolve();

fill(0, 255, 255);
  noStroke();
  text("[lr] "+lr.msg, 10, HH-4);
  text("[rr] "+rr.msg, 140, HH-4);
  text("[ls] "+ls.msg, 280, HH-4);
  text("[rs] "+rs.msg, 420, HH-4);
}

void keyPressed()
{
  if (key==' ') lr.halt=true;
}

void cainit()
{
  for (int j=0; j<rows; j++)
  {
    for (int i=0; i<cols; i++)
    {
      ca[j][i]=0;
      ca_1[j][i]=0;
      nca[j][i]=0;
    }
  }

ca[rows/2][cols/2]=255;
}

void carndr()
{
  noStroke();
  for (int j=0; j<rows; j++)
  {
    int _lc=lhs[j];
    fill(0, _lc, _lc);
    rect(mlt, mtp+j*d, d-1, d-1);

for (int i=0; i<cols; i++)
    {
      int c=ca[j][i];
      fill(c);
      rect(mlt+d+i*d, mtp+j*d, d-1, d-1);
    }

int _rc=rhs[j];
    fill(0, _rc, _rc);
    rect(mlt+d+cols*d, mtp+j*d, d-1, d-1);
  }
}

void caevolve()
{
  for (int j=0; j<rows; j++)
  {
    for (int i=0; i<cols; i++)
    {
      int _l=i==0?lhs[j]:ca[j][i-1];
      int _lu=i==0 ? (j==0?lhs[rows-1]:lhs[j-1]) : (j==0?ca[rows-1][i-1]:ca[j-1][i-1]);
      int _ld=i==0 ? (j==rows-1?lhs[0]:lhs[j+1]) : (j==rows-1?ca[0][i-1]:ca[j+1][i-1]);
      int _r=i==cols-1?rhs[j]:ca[j][i+1];
      int _ru=i==cols-1 ? (j==0?rhs[rows-1]:rhs[j-1]) : (j==0?ca[rows-1][i+1]:ca[j-1][i+1]);
      int _rd=i==cols-1 ? (j==rows-1?rhs[0]:rhs[j+1]) : (j==rows-1?ca[0][i+1]:ca[j+1][i+1]);

int ju=j==0?rows-1:j-1;
      int juu=ju==0?rows-1:ju-1;
      int _u=ca[ju][i];
      int _uu=ca[juu][i];
      int jd=(j+1)%rows;
      int jdd=(jd+1)%rows;
      int _d=ca[jd][i];
      int _dd=ca[jdd][i];

int _c=ca[j][i];
      int _p=ca_1[j][i];

int _v=_lu + _ru - _c + _d;
      if (_v<0) _v=0;
      else _v=_v%256;

nca[j][i]=_v;
    }
  }

// transition
  for (int j=0; j<rows; j++)
  {
    for (int i=0; i<cols; i++)
    {
      ca_1[j][i]=ca[j][i];
      ca[j][i]=nca[j][i];
    }
  }

// broadcast celwals
  ls.bcastcelwal();
  rs.bcastcelwal();
}

enum celwal
{
  LEFT, RIGHT
}

class celrcvr implements Runnable
{
  ServerSocket ss;
  volatile String msg;
  volatile boolean halt;
  volatile int[] xa;
  int xai;

celrcvr(int port, int arr[])
  {
    halt=false;
    xa=arr;
    xai=0;

try
    {
      ss=new ServerSocket(port);
      msg="SS:"+port;
    }
    catch(IOException ioe)
    {
      msg=ioe.getMessage();
      ioe.printStackTrace();
    }
  }

public void run()
  {
    try
    {
      msg="ss.accept()";
      Socket s=ss.accept();
      DataInputStream dis = new DataInputStream(s.getInputStream());
      msg="readByte()";

while (!halt)
      {
        byte _i=dis.readByte();
        xa[xai]=_i;
        xai=(xai+1)%rows;
      }

msg="halt!";
    }
    catch(EOFException eofe)
    {
      msg="EOFException!";
      eofe.printStackTrace();
    }
    catch(IOException ioe)
    {
      msg="IOException!";
      ioe.printStackTrace();
    }
  }
}

class celsndr
{
  Socket s;
  String rhost;
  int rport;
  volatile String msg;
  volatile boolean halt;
  celwal cw;
  DataOutputStream dos;

celsndr(String host, int port, celwal _cw)
  {
    halt=false;
    rhost=host;
    rport=port;
    cw=_cw;

try
    {
      s=new Socket(rhost, rport);
      msg=rhost+":"+rport;
      dos = new DataOutputStream(s.getOutputStream());
      msg="DOS ready";
    }
    catch(IOException ioe)
    {
      msg="IOException!";
      ioe.printStackTrace();
    }
  }

public void bcastcelwal()
  {
    try
    {
      if (cw==celwal.LEFT)
      {
        for (int i=0; i<rows; i++) dos.writeByte((byte)ca[i][0]);
      } else if (cw==celwal.RIGHT)
      {
        for (int i=0; i<rows; i++) dos.writeByte((byte)ca[i][cols-1]);
      }
    }
    catch(EOFException eofe)
    {
      msg="EOFException!";
      eofe.printStackTrace();
    }
    catch(IOException ioe)
    {
      msg=ioe.getMessage();
      ioe.printStackTrace();
    }
  }
}