/***Chuck Hall 1999
*SFSU
*
* The relay class copies data
* from the input stream to the output stream.
*
* Relay extends thread, allowing multiple instances
* of relay to coexist.
* 
* Interfaces:
*	Setup(ProxSocket, DataInputStream, DataOutputStream)
*		Passes the streams and parent class to Relay
*		The parent needs to be a thread.
*		This is just so that we can resume() the 
*		Parent process.
*
*
*	Run()
*		This is the main method.
*		It will copy from the one stream to the other 
*		As long as both stream remain open.
*		Once one of the streams closes, it will shutdown 
*		And attempt to shutdown its peer.*
*
*        Copyright 1999, Charles Hall
*
*This program 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.
*
*This program 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 this program; if not, write to the Free *Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, *MA 02111-1307  USA
*/


import java.io.*;


public class Relay extends Thread {

   private BufferedInputStream  s1;

   private BufferedOutputStream s2; 

   private Thread Parent ;

   private int iTerminate = 0 ;

   private byte[] InBuffer1024 = new byte[1024] ;

   private byte[] OutBuffer = new byte[16384] ;

   private int iHaveRead, iToWrite, iWritten ;





   public void Setup(Thread Parent,

                     DataInputStream sNew1, 

                     DataOutputStream sNew2) {

      this.Parent = Parent ;

      this.s1 = new BufferedInputStream(sNew1);

      this.s2 = new BufferedOutputStream(sNew2);

      

   }



   public void run() {

      

      // read from input s1

      iHaveRead = -1 ;



      try {

         iHaveRead = s1.read(InBuffer1024, 0, 1024) ;

      } catch(IOException e) {

		System.out.println("Relay Failure\n");
		e.printStackTrace();
        iHaveRead = -1 ;

      }  



      while(iHaveRead != -1) {

         // call process line

         iToWrite = ProcData(iHaveRead) ;



         // write to s2

         

         try {

            s2.write(OutBuffer, 0, iToWrite) ;

            s2.flush() ;

         } catch(IOException e) {

           iHaveRead = -1 ;

           break ;

         }



         // be kind to everyone else

         yield() ;



         try {

            iHaveRead = s1.read(InBuffer1024, 0, 1024) ;

         } catch(IOException e) {

           iHaveRead = -1 ;

           break ;

         }

      }//while





	try{
	 int flag =0;
	 while(flag!=-1){
		flag=s1.read(InBuffer1024,0,1024);
	 }//while
	}catch(IOException e){e.printStackTrace();}
	 Parent.resume();
   }





   // mod. the input Buffer, and write results to the output Buffer

   // return the length of the output Buffer



   private int ProcData(int iReadd) {



      // simply copy input to output here

      System.arraycopy(InBuffer1024, 0, OutBuffer, 0, iReadd) ;

 

      return(iReadd) ;

   }

}