Initial commit of OpenSPARC T2 architecture model.

[OpenSPARC-T2-SAM] / sam-t2 / sam / system / blaze / term_redirect.cc

// ========== Copyright Header Begin ==========================================
// 
// OpenSPARC T2 Processor File: term_redirect.cc
// Copyright (c) 2006 Sun Microsystems, Inc.  All Rights Reserved.
// DO NOT ALTER OR REMOVE COPYRIGHT NOTICES.
// 
// The above named program is free software; you can redistribute it and/or
// modify it under the terms of the GNU General Public
// License version 2 as published by the Free Software Foundation.
// 
// The above named 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 work; if not, write to the Free Software
// Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA.
// 
// ========== Copyright Header End ============================================
/*
 * Copyright (C) 2001 Sun Microsystems, Inc.
 * All rights reserved.
 */
#pragma ident "@(#)1.6	07/11/19	term_redirect.cc"

//
//  This file contains an implementation of console I/O
//  redirection
//

#include <sys/types.h>
#include <sys/stat.h>
#include <sys/time.h>
#include <assert.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <strings.h>
#include <stropts.h>
#include <unistd.h>
#include <sys/wait.h>
#include <signal.h>
#include <thread.h>

#include "types.h"
#include "blaze_globals.h"
#include "term.h"
#include "ui.h"
#include "fileutil.h"

#define MAXCURSTR  256
#define MAXCTXT    128

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

typedef struct term_redirect_t
{
  char    * script_name;
  char      current_string [MAXCURSTR];
  char      str            [MAXCTXT];
  char      *pstr;
  char      pattern        [MAXCTXT];
  char      *ptail;
  char      unix_command   [MAXCURSTR];
  uint32_t  idx; 
  FILE     *fp;
  cond_t    trd_cond;
  mutex_t   trd_lock;

  mutex_t   uc_lock;
  volatile  bool_t  unix_command_sent; 
            bool_t  unix_command_nready; 

} TermRedirect;

static TermRedirect *ptrd = NULL;

#ifdef __cplusplus
extern "C" {
#endif
  void * console_input_start (void *);
#ifdef __cplusplus
}
#endif

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

char *term_redirect_get_file ()
{
    if (ptrd) {
        return ptrd->script_name;
    }
    else {
        return NULL;
    }
}

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

void * console_input_start (void *arg)
{
    int idx = 0;

    ui->verbose("console input interceptor started ... \n");

    for (;;) {
        mutex_lock (&ptrd->trd_lock);
        cond_wait(&ptrd->trd_cond, &ptrd->trd_lock);
        ptrd->unix_command [idx = strlen(ptrd->unix_command)] = 0xD;
        ptrd->unix_command [idx + 1]                          = 0x0;
	sleep (1);
	term_fake_input ((uint8_t *)ptrd->unix_command, idx + 1, 0);
        mutex_unlock (&ptrd->trd_lock);

	mutex_lock (&ptrd->uc_lock);
        ptrd->unix_command_sent = TRUE;
	mutex_unlock (&ptrd->uc_lock);

    }
    return NULL;
}

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

void   init_term_redirect (char *fname)
{
    FILE     *fp = fopen (fname , "r");
    thread_t  tid;

    if (fp == NULL) {
      ui->error("file not found <%s> \n", fname);
      return;
    }
    ptrd = (TermRedirect*) calloc (1, sizeof(TermRedirect)); 
    ptrd->fp = fp;
    ptrd->script_name = (char*)strdup(fname);

    while (ptrd->pstr = fgets(ptrd->str, MAXCTXT - 2, ptrd->fp)) {
        if ((ptrd->ptail = get_substr_until (ptrd->str, ptrd->pattern, ':')) != NULL) {
            mutex_init(&ptrd->trd_lock, USYNC_THREAD, (void*)NULL);
            mutex_init(&ptrd->uc_lock, USYNC_THREAD, (void*)NULL);
            cond_init(&ptrd->trd_cond, USYNC_THREAD, (void *)NULL);
            thr_create(NULL, NULL, console_input_start,  (void*)ptrd, THR_BOUND, &tid);
            return;
        }
    }

    free ((char*)ptrd);
    ptrd = NULL;
    return;
}

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

void term_redirect_add (uint8_t c) 
{
    char *ps;

    if (ptrd) {

        if ((ptrd->pstr == NULL)) {
		free ((char*)ptrd);
		ptrd = NULL;
		ui->verbose("Console script is processed; return to terminal \n");
		return;
        }

        if ((c == 0xD) || (c == 0xA) || (c == 0) || (ptrd->idx >= MAXCURSTR - 2)) {
	    ptrd->idx = 0;
	    ptrd->current_string[0] = '\0';
        }
        else {
            ptrd->current_string[ptrd->idx++] = c;
            ptrd->current_string[ptrd->idx]   = '\0';

	    if ( strstr ((const char *)ptrd->current_string, (const char *)ptrd->pattern)) {

                if (!ptrd->unix_command_nready) {
		    if (get_quoted_substr (ptrd->ptail, ptrd->unix_command)) {
			mutex_lock (&ptrd->trd_lock);
			cond_signal(&ptrd->trd_cond);
			mutex_unlock (&ptrd->trd_lock); 
		    }
		    ptrd->unix_command_nready = TRUE;		
                }

	        if (!ptrd->unix_command_sent) { 
		    return;
	        }
		
                ptrd->unix_command_nready = FALSE;
                ptrd->unix_command_sent   = FALSE;

		while (ptrd->pstr = fgets (ptrd->str, MAXCTXT - 2, ptrd->fp)) {
		    if ((ptrd->ptail = get_substr_until (ptrd->str, ptrd->pattern, ':')) != NULL) {
			return;
		    }
                }
	    }
            else {
	        if (ptrd->unix_command_nready) {
		    ptrd->unix_command_nready = FALSE;
		    ptrd->unix_command_sent   = FALSE;
		    while (ptrd->pstr = fgets (ptrd->str, MAXCTXT - 2, ptrd->fp)) {
		        if ((ptrd->ptail = get_substr_until (ptrd->str, ptrd->pattern, ':')) != NULL) {
			    return;
		        }
		    }
                }
            }
        }
    }
}

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