package org.rzo.yajsw.os.posix.solaris;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
import java.nio.channels.FileChannel;

import org.rzo.yajsw.os.Process;
import org.rzo.yajsw.os.posix.PosixProcess;
import org.rzo.yajsw.os.posix.bsd.macosx.MacOsXProcess;

import com.sun.jna.Memory;

public class SolarisProcess extends PosixProcess
{

	/*
	 * #define PRARGSZ 80 /* number of chars of arguments typedef struct psinfo
	 * { 0int pr_flag; /* process flags (DEPRECATED; do not use) 4int pr_nlwp;
	 * /* number of active lwps in the process 8pid_t pr_pid; /* unique process
	 * id 12pid_t pr_ppid; /* process id of parent 16pid_t pr_pgid; /* pid of
	 * process group leader 20pid_t pr_sid; /* session id 24uid_t pr_uid; /*
	 * real user id 28uid_t pr_euid; /* effective user id 32gid_t pr_gid; /*
	 * real group id 36gid_t pr_egid; /* effective group id 40uintptr_t pr_addr;
	 * /* address of process 44size_t pr_size; /* size of process image in
	 * Kbytes 48size_t pr_rssize; /* resident set size in Kbytes 52size_t
	 * pr_pad1; 56dev_t pr_ttydev; /* controlling tty device (or PRNODEV) /* The
	 * following percent numbers are 16-bit binary /* fractions [0 .. 1] with
	 * the binary point to the /* right of the high-order bit (1.0 == 0x8000)
	 * 60ushort_t pr_pctcpu; /* % of recent cpu time used by all lwps 62ushort_t
	 * pr_pctmem; /* % of system memory used by process 62timestruc_t pr_start;
	 * /* process start time, from the epoch 94timestruc_t pr_time; /* usr+sys
	 * cpu time for this process 126timestruc_t pr_ctime; /* usr+sys cpu time
	 * for reaped children 158char pr_fname[PRFNSZ]; /* name of execed file char
	 * pr_psargs[PRARGSZ]; /* initial characters of arg list int pr_wstat; /* if
	 * zombie, the wait() status int pr_argc; /* initial argument count
	 * uintptr_t pr_argv; /* address of initial argument vector uintptr_t
	 * pr_envp; /* address of initial environment vector char pr_dmodel; /* data
	 * model of the process char pr_pad2[3]; taskid_t pr_taskid; /* task id
	 * projid_t pr_projid; /* project id int pr_nzomb; /* number of zombie lwps
	 * in the process poolid_t pr_poolid; /* pool id zoneid_t pr_zoneid; /* zone
	 * id id_t pr_contract; /* process contract int pr_filler[1]; /* reserved
	 * for future use lwpsinfo_t pr_lwp; /* information for representative lwp }
	 * psinfo_t;
	 */

	static int	PRARGSZ	= 80;	/* number of chars of arguments */

	public static class psinfo
	{
		ByteBuffer	_b;

		psinfo(ByteBuffer b)
		{
			_b = b;
		}

		int getPid()
		{
			return _b.getInt(8);
		}

		int getNlwp()
		{
			return _b.getInt(4);
		}

		int getPctcpu()
		{
			return (int) (((double) _b.getShort(60)) * 100) / 0x8000;
		}

		int getPr_size()
		{
			return _b.getInt(44);
		}

	}

	public int getStdOutNo()
	{
		return 1;
	}

	public int getStdErrNo()
	{
		return 2;
	}

	public int getStdInNo()
	{
		return 3;
	}
	

	public static Process getProcess(int pid)
	{
		SolarisProcess result = null;
		File f = new File("/proc/" + pid);
		if (f.exists())
		{
			result = new SolarisProcess();
			result._pid = pid;
			result._user = result.getUserInternal();
			result._cmd = result.getCommandInternal();
			result._workingDir = result.getWorkingDirInternal();
		}
		return result;
	}

	private String getCommandInternal()
	{
		String result = _utils.osCommand(String.format("pargs -l %1$s", _pid), 5000);
		if (result == null)
			result = "?";
		// System.out.println("cmd line: "+result);
		return result;
	}

	public String getUserInternal()
	{
		if (_pid < 0)
			return null;
		String cmd = String.format("ps -p %1$s -o user", _pid);
		String res = _utils.osCommand(cmd, 5000);
		if (res == null)
			return null;
		String[] resx = res.split(System.getProperty("line.separator"));
		return resx[1];
	}

	private psinfo getPsinfo()
	{
		FileChannel in;
		try
		{
			in = new FileInputStream(String.format("/proc/%1$s/psinfo", _pid)).getChannel();
		}
		catch (FileNotFoundException e)
		{
			System.out.println("error in getCurrentThreads() " + e.getMessage());
			return null;
		}
		int size;
		try
		{
			size = (int) in.size();
		}
		catch (IOException e)
		{
			System.out.println("error in getCurrentThreads() " + e.getMessage());
			return null;
		}
		ByteBuffer b = ByteBuffer.allocateDirect(size);
		b.order(ByteOrder.LITTLE_ENDIAN);
		try
		{
			in.read(b);
		}
		catch (IOException e)
		{
			System.out.println("error in getCurrent*() " + e.getMessage());
			return null;
		}
		psinfo s = new psinfo(b);
		try
		{
			in.close();
		}
		catch (IOException e)
		{
			e.printStackTrace();
		}
		return s;
	}

	public int getCurrentCpu()
	{
		int result = -1;
		if (!isRunning())
			return result;
		psinfo s = getPsinfo();
		if (s == null)
			return -1;
		return s.getPctcpu();
	}

	public int getCurrentThreads()
	{
		int result = -1;
		if (!isRunning())
			return result;
		psinfo s = getPsinfo();
		if (s == null)
			return -1;
		return s.getNlwp();
	}

	public int getCurrentVirtualMemory()
	{
		int result = -1;
		if (!isRunning())
			return result;
		psinfo s = getPsinfo();
		if (s == null)
			return -1;
		return s.getPr_size() * 1024;
	}

	protected String getWorkingDirInternal()
	{
    String result = "";
    String cwd;
    boolean success = false;
		String procCwd = "/proc/" + getPid() + "/cwd";
    try
    {

  	 short BUFSIZE = 4096;
		 Memory dir = new Memory(BUFSIZE);
		 dir.clear();

		 if( CLibrary.INSTANCE.getcwd(dir, BUFSIZE) != null )
     {
       cwd = dir.getString(0);
       dir.clear();

       if( CLibrary.INSTANCE.chdir(procCwd) == 0 )
       {
          if( CLibrary.INSTANCE.getcwd(dir, BUFSIZE) != null ){
            result = new File(dir.getString(0)).getCanonicalPath();
            success = true;
          }
          // Restore starting directory ( if different )
          CLibrary.INSTANCE.chdir(cwd);
       }

     }

     if( !success )
       System.out.println("error reading process working dir -> please edit wrapper.working.dir in configuration file");

    } catch (IOException e){  }

    return result;

//-KBG:		short BUFSIZE = 512;
//-KBG:		Memory result = new Memory(BUFSIZE);
//-KBG:		result.clear();
//-KBG:		short size = CLibrary.INSTANCE.readlink(f, result, (short) (BUFSIZE - 1));
//-KBG:		if (size <= 0)
//-KBG:		{
//-KBG:			System.out.println("error reading process working dir -> please edit wrapper.working.dir in configuration file");
//-KBG:			return f;
//-KBG:		}
//-KBG:		result.setByte((long) size, (byte) 0);
//-KBG:		return result.getString(0);

		/*
		 * String result = null; File f = new File("/proc/" + getPid() +
		 * "/cwd"); try { result = f.getCanonicalPath(); } catch (IOException e)
		 * { e.printStackTrace(); } return result;
		 */

	}

}