////////////////////////////////////////////////////////////////////////
//
// Copyright (C) 1993-2022 The Octave Project Developers
//
// See the file COPYRIGHT.md in the top-level directory of this
// distribution or <https://octave.org/copyright/>.
//
// This file is part of Octave.
//
// Octave 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 3 of the License, or
// (at your option) any later version.
//
// Octave 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 Octave; see the file COPYING.  If not, see
// <https://www.gnu.org/licenses/>.
//
////////////////////////////////////////////////////////////////////////

#if defined (HAVE_CONFIG_H)
#  include "config.h"
#endif

#include <csignal>
#include <cstdlib>

#include <iostream>
#include <new>

#if defined (OCTAVE_USE_WINDOWS_API)
#  define WIN32_LEAN_AND_MEAN
#  include <windows.h>
#endif

#include "child-list.h"
#include "cmd-edit.h"
#include "oct-syscalls.h"
#include "quit.h"
#include "signal-wrappers.h"

#include "defun.h"
#include "error.h"
#include "input.h"
#include "interpreter-private.h"
#include "interpreter.h"
#include "load-save.h"
#include "octave.h"
#include "oct-map.h"
#include "pager.h"
#include "sighandlers.h"
#include "sysdep.h"
#include "utils.h"
#include "variables.h"

OCTAVE_BEGIN_NAMESPACE(octave)

// Nonzero means we have already printed a message for this series of
// SIGPIPES.  We assume that the writer will eventually give up.
int pipe_handler_error_count = 0;

// TRUE means we can be interrupted.
bool can_interrupt = false;

// TRUE means we should try to enter the debugger on SIGINT.
bool Vdebug_on_interrupt = false;

// Allow users to avoid writing octave-workspace for SIGHUP (sent by
// closing gnome-terminal, for example).  Note that this variable has
// no effect if Vcrash_dumps_octave_core is FALSE.
static bool Vsighup_dumps_octave_core = true;

// Similar to Vsighup_dumps_octave_core, but for SIGQUIT signal.
static bool Vsigquit_dumps_octave_core = true;

// Similar to Vsighup_dumps_octave_core, but for SIGTERM signal.
static bool Vsigterm_dumps_octave_core = true;

// List of signals we have caught since last call to signal_handler.
static bool *signals_caught = nullptr;

static void
my_friendly_exit (int sig, bool save_vars = true)
{
  std::cerr << "fatal: caught signal "
            << octave_strsignal_wrapper (sig)
            << " -- stopping myself..." << std::endl;

  if (save_vars)
    {
      load_save_system& load_save_sys = __get_load_save_system__ ();

      load_save_sys.dump_octave_core ();
    }

  sysdep_cleanup ();

  throw exit_exception (1);
}

// Called from octave_quit () to actually do something about the signals
// we have caught.

void
respond_to_pending_signals (void)
{
  // The list of signals is relatively short, so we will just go
  // linearly through the list.

  // Interrupt signals are currently handled separately.

  static int sigint;
  static const bool have_sigint
    = octave_get_sig_number ("SIGINT", &sigint);

  static int sigbreak;
  static const bool have_sigbreak
    = octave_get_sig_number ("SIGBREAK", &sigbreak);

  // Termination signals.

  static int sighup;
  static const bool have_sighup
    = octave_get_sig_number ("SIGHUP", &sighup);

  static int sigquit;
  static const bool have_sigquit
    = octave_get_sig_number ("SIGQUIT", &sigquit);

  static int sigterm;
  static const bool have_sigterm
    = octave_get_sig_number ("SIGTERM", &sigterm);

  // Alarm signals.

  static int sigalrm;
  static const bool have_sigalrm
    = octave_get_sig_number ("SIGALRM", &sigalrm);

  static int sigvtalrm;
  static const bool have_sigvtalrm
    = octave_get_sig_number ("SIGVTALRM", &sigvtalrm);

  // I/O signals.

  static int sigio;
  static const bool have_sigio
    = octave_get_sig_number ("SIGIO", &sigio);

  static int siglost;
  static const bool have_siglost
    = octave_get_sig_number ("SIGLOST", &siglost);

  static int sigpipe;
  static const bool have_sigpipe
    = octave_get_sig_number ("SIGPIPE", &sigpipe);

  // Job control signals.

  static int sigchld;
  static const bool have_sigchld
    = octave_get_sig_number ("SIGCHLD", &sigchld);

  static int sigcld;
  static const bool have_sigcld
    = octave_get_sig_number ("SIGCLD", &sigcld);

  // Resource limit signals.

  static int sigxcpu;
  static const bool have_sigxcpu
    = octave_get_sig_number ("SIGXCPU", &sigxcpu);

  static int sigxfsz;
  static const bool have_sigxfsz
    = octave_get_sig_number ("SIGXFSZ", &sigxfsz);

  // User signals.

  static int sigusr1;
  static const bool have_sigusr1
    = octave_get_sig_number ("SIGUSR1", &sigusr1);

  static int sigusr2;
  static const bool have_sigusr2
    = octave_get_sig_number ("SIGUSR2", &sigusr2);

  child_list& kids = __get_child_list__ ();

  for (int sig = 0; sig < octave_num_signals (); sig++)
    {
      if (signals_caught[sig])
        {
          signals_caught[sig] = false;

          if ((have_sigchld && sig == sigchld)
              || (have_sigcld && sig == sigcld))
            {
              // FIXME: should we block or ignore?
              volatile interrupt_handler saved_interrupt_handler
                = ignore_interrupts ();

              void *context = octave_block_child ();

              kids.wait ();

              set_interrupt_handler (saved_interrupt_handler);

              octave_unblock_child (context);

              kids.reap ();
            }
          else if (have_sigpipe && sig == sigpipe)
            {
              std::cerr << "warning: broken pipe" << std::endl;

              // Don't loop forever on account of this.
              // FIXME: is this really needed?  Does it do anything
              // useful now?

              if (pipe_handler_error_count++ > 100
                  && octave_interrupt_state >= 0)
                octave_interrupt_state++;
            }
          else if (have_sighup && sig == sighup)
            my_friendly_exit (sighup, Vsighup_dumps_octave_core);
          else if (have_sigquit && sig == sigquit)
            my_friendly_exit (sigquit, Vsigquit_dumps_octave_core);
          else if (have_sigterm && sig == sigterm)
            my_friendly_exit (sigterm, Vsigterm_dumps_octave_core);
          else if ((have_sigalrm && sig == sigalrm)
                   || (have_sigvtalrm && sig == sigvtalrm)
                   || (have_sigio && sig == sigio)
                   || (have_siglost && sig == siglost)
                   || (have_sigxcpu && sig == sigxcpu)
                   || (have_sigxfsz && sig == sigxfsz)
                   || (have_sigusr1 && sig == sigusr1)
                   || (have_sigusr2 && sig == sigusr2))
            std::cerr << "warning: ignoring signal: "
                      << octave_strsignal_wrapper (sig)
                      << std::endl;
          else if ((have_sigint && sig == sigint)
                   || (have_sigbreak && sig == sigbreak))
            ; // Handled separately; do nothing.
          else
            std::cerr << "warning: ignoring unexpected signal: "
                      << octave_strsignal_wrapper (sig)
                      << std::endl;
        }
    }
}

sig_handler *
set_signal_handler (int sig, sig_handler *handler, bool restart_syscalls)
{
  return octave_set_signal_handler_internal (sig, handler, restart_syscalls);
}

sig_handler *
set_signal_handler (const char *signame, sig_handler *handler,
                    bool restart_syscalls)
{
  return octave_set_signal_handler_by_name (signame, handler,
         restart_syscalls);
}

static void
generic_sig_handler (int sig)
{
  // FIXME: this function may execute in a separate signal handler or
  // signal watcher thread so it should probably be more careful about
  // how it accesses global objects.

  octave_signal_caught = 1;

  signals_caught[sig] = true;

  static int sigint;
  static const bool have_sigint
    = octave_get_sig_number ("SIGINT", &sigint);

  static int sigbreak;
  static const bool have_sigbreak
    = octave_get_sig_number ("SIGBREAK", &sigbreak);

  if ((have_sigint && sig == sigint)
      || (have_sigbreak && sig == sigbreak))
    {
      if (! octave_initialized)
        exit (1);

      if (can_interrupt)
        {
          octave_signal_caught = 1;
          octave_interrupt_state++;
        }
    }
}

static void
deadly_sig_handler (int sig)
{
  std::cerr << "fatal: caught signal "
            << octave_strsignal_wrapper (sig)
            << " -- stopping myself..." << std::endl;

  octave_set_default_signal_handler (sig);

  octave_raise_wrapper (sig);
}

static void
fpe_sig_handler (int)
{
  // FIXME: is there something better we can do?

  std::cerr << "warning: floating point exception" << std::endl;
}

interrupt_handler
catch_interrupts (void)
{
  interrupt_handler retval;

  retval.int_handler = set_signal_handler ("SIGINT", generic_sig_handler);
  retval.brk_handler = set_signal_handler ("SIGBREAK", generic_sig_handler);

  return retval;
}

interrupt_handler
ignore_interrupts (void)
{
  interrupt_handler retval;

  retval.int_handler = set_signal_handler ("SIGINT", SIG_IGN);
  retval.brk_handler = set_signal_handler ("SIGBREAK", SIG_IGN);

  return retval;
}

interrupt_handler
set_interrupt_handler (const volatile interrupt_handler& h,
                       bool restart_syscalls)
{
  interrupt_handler retval;

  retval.int_handler = set_signal_handler ("SIGINT", h.int_handler,
                       restart_syscalls);

  retval.brk_handler = set_signal_handler ("SIGBREAK", h.brk_handler,
                       restart_syscalls);

  return retval;
}

// Install all the handlers for the signals we might care about.

void
install_signal_handlers (void)
{
  if (! signals_caught)
    signals_caught = new bool [octave_num_signals ()];

  for (int i = 0; i < octave_num_signals (); i++)
    signals_caught[i] = false;

  // Interrupt signals.

  catch_interrupts ();

  // Program Error signals.  These are most likely unrecoverable for
  // us.

  set_signal_handler ("SIGABRT", deadly_sig_handler);
  set_signal_handler ("SIGBUS", deadly_sig_handler);
  set_signal_handler ("SIGEMT", deadly_sig_handler);
  set_signal_handler ("SIGILL", deadly_sig_handler);
  // SIGIOT is normally another name for SIGABRT.
  set_signal_handler ("SIGIOT", deadly_sig_handler);
  set_signal_handler ("SIGSEGV", deadly_sig_handler);
  set_signal_handler ("SIGSYS", deadly_sig_handler);
  set_signal_handler ("SIGTRAP", deadly_sig_handler);

  // Handle SIGFPE separately.

  set_signal_handler ("SIGFPE", fpe_sig_handler);

  // Handle other signals for which the default action is to terminate
  // the program.

  // Termination signals.

  set_signal_handler ("SIGHUP", generic_sig_handler);
  set_signal_handler ("SIGQUIT", generic_sig_handler);
  set_signal_handler ("SIGTERM", generic_sig_handler);

  // Alarm signals.

  set_signal_handler ("SIGALRM", generic_sig_handler);
  set_signal_handler ("SIGVTALRM", generic_sig_handler);

  // I/O signals.

  set_signal_handler ("SIGLOST", generic_sig_handler);
  set_signal_handler ("SIGPIPE", generic_sig_handler);

  // Job control signals.  We only recognize signals about child
  // processes.

  set_signal_handler ("SIGCHLD", generic_sig_handler);
  set_signal_handler ("SIGCLD", generic_sig_handler);

  // Resource limit signals.

  // FIXME: does it really make sense to try to handle the CPU limit
  // signal?

  set_signal_handler ("SIGXCPU", generic_sig_handler);
  set_signal_handler ("SIGXFSZ", generic_sig_handler);

  // User signals.

  set_signal_handler ("SIGUSR1", generic_sig_handler);
  set_signal_handler ("SIGUSR2", generic_sig_handler);

  // This does nothing on Windows systems.
  octave_create_interrupt_watcher_thread (generic_sig_handler);
}

static void
set_sig_struct_field (octave_scalar_map& m, const char *signame)
{
  int signum;

  // The names in the struct do not include the leading "SIG" prefix.

  if (octave_get_sig_number (signame, &signum))
    m.assign (&signame[3], signum);
}

static octave_scalar_map
make_sig_struct (void)
{
  octave_scalar_map m;

  set_sig_struct_field (m, "SIGABRT");
  set_sig_struct_field (m, "SIGALRM");
  set_sig_struct_field (m, "SIGBUS");
  set_sig_struct_field (m, "SIGCHLD");
  set_sig_struct_field (m, "SIGCLD");
  set_sig_struct_field (m, "SIGCONT");
  set_sig_struct_field (m, "SIGEMT");
  set_sig_struct_field (m, "SIGFPE");
  set_sig_struct_field (m, "SIGHUP");
  set_sig_struct_field (m, "SIGILL");
  set_sig_struct_field (m, "SIGINFO");
  set_sig_struct_field (m, "SIGINT");
  set_sig_struct_field (m, "SIGIO");
  set_sig_struct_field (m, "SIGIOT");
  set_sig_struct_field (m, "SIGKILL");
  set_sig_struct_field (m, "SIGLOST");
  set_sig_struct_field (m, "SIGPIPE");
  set_sig_struct_field (m, "SIGPOLL");
  set_sig_struct_field (m, "SIGPROF");
  set_sig_struct_field (m, "SIGPWR");
  set_sig_struct_field (m, "SIGQUIT");
  set_sig_struct_field (m, "SIGSEGV");
  set_sig_struct_field (m, "SIGSTKFLT");
  set_sig_struct_field (m, "SIGSTOP");
  set_sig_struct_field (m, "SIGSYS");
  set_sig_struct_field (m, "SIGTERM");
  set_sig_struct_field (m, "SIGTRAP");
  set_sig_struct_field (m, "SIGTSTP");
  set_sig_struct_field (m, "SIGTTIN");
  set_sig_struct_field (m, "SIGTTOU");
  set_sig_struct_field (m, "SIGUNUSED");
  set_sig_struct_field (m, "SIGURG");
  set_sig_struct_field (m, "SIGUSR1");
  set_sig_struct_field (m, "SIGUSR2");
  set_sig_struct_field (m, "SIGVTALRM");
  set_sig_struct_field (m, "SIGWINCH");
  set_sig_struct_field (m, "SIGXCPU");
  set_sig_struct_field (m, "SIGXFSZ");

  return m;
}

DEFUN (SIG, args, ,
       doc: /* -*- texinfo -*-
@deftypefn {} {@var{S} =} SIG ()
Return a structure containing Unix signal names and their defined values.
@end deftypefn */)
{
  if (args.length () != 0)
    print_usage ();

  static octave_scalar_map m = make_sig_struct ();

  return ovl (m);
}

/*
%!assert (isstruct (SIG ()))
%!assert (! isempty (SIG ()))

%!error SIG (1)
*/

DEFUN (debug_on_interrupt, args, nargout,
       doc: /* -*- texinfo -*-
@deftypefn  {} {@var{val} =} debug_on_interrupt ()
@deftypefnx {} {@var{old_val} =} debug_on_interrupt (@var{new_val})
@deftypefnx {} {@var{old_val} =} debug_on_interrupt (@var{new_val}, "local")
Query or set the internal variable that controls whether Octave will try
to enter debugging mode when it receives an interrupt signal (typically
generated with @kbd{C-c}).

If a second interrupt signal is received before reaching the debugging mode,
a normal interrupt will occur.

When called from inside a function with the @qcode{"local"} option, the
variable is changed locally for the function and any subroutines it calls.
The original variable value is restored when exiting the function.
@seealso{debug_on_error, debug_on_warning}
@end deftypefn */)
{
  return set_internal_variable (Vdebug_on_interrupt, args, nargout,
                                "debug_on_interrupt");
}

/*
%!test
%! orig_val = debug_on_interrupt ();
%! old_val = debug_on_interrupt (! orig_val);
%! assert (orig_val, old_val);
%! assert (debug_on_interrupt (), ! orig_val);
%! debug_on_interrupt (orig_val);
%! assert (debug_on_interrupt (), orig_val);

%!error debug_on_interrupt (1, 2)
*/

DEFUN (sighup_dumps_octave_core, args, nargout,
       doc: /* -*- texinfo -*-
@deftypefn  {} {@var{val} =} sighup_dumps_octave_core ()
@deftypefnx {} {@var{old_val} =} sighup_dumps_octave_core (@var{new_val})
@deftypefnx {} {@var{old_val} =} sighup_dumps_octave_core (@var{new_val}, "local")
Query or set the internal variable that controls whether Octave tries
to save all current variables to the file @file{octave-workspace} if it
receives a hangup signal.

When called from inside a function with the @qcode{"local"} option, the
variable is changed locally for the function and any subroutines it calls.
The original variable value is restored when exiting the function.
@end deftypefn */)
{
  return set_internal_variable (Vsighup_dumps_octave_core,
                                args, nargout,
                                "sighup_dumps_octave_core");
}

/*
%!test
%! orig_val = sighup_dumps_octave_core ();
%! old_val = sighup_dumps_octave_core (! orig_val);
%! assert (orig_val, old_val);
%! assert (sighup_dumps_octave_core (), ! orig_val);
%! sighup_dumps_octave_core (orig_val);
%! assert (sighup_dumps_octave_core (), orig_val);

%!error sighup_dumps_octave_core (1, 2)
*/

DEFUN (sigquit_dumps_octave_core, args, nargout,
       doc: /* -*- texinfo -*-
@deftypefn  {} {@var{val} =} sigquit_dumps_octave_core ()
@deftypefnx {} {@var{old_val} =} sigquit_dumps_octave_core (@var{new_val})
@deftypefnx {} {@var{old_val} =} sigquit_dumps_octave_core (@var{new_val}, "local")
Query or set the internal variable that controls whether Octave tries
to save all current variables to the file @file{octave-workspace} if it
receives a quit signal.

When called from inside a function with the @qcode{"local"} option, the
variable is changed locally for the function and any subroutines it calls.
The original variable value is restored when exiting the function.
@end deftypefn */)
{
  return set_internal_variable (Vsigquit_dumps_octave_core,
                                args, nargout,
                                "sigquit_dumps_octave_core");
}

/*
%!test
%! orig_val = sigquit_dumps_octave_core ();
%! old_val = sigquit_dumps_octave_core (! orig_val);
%! assert (orig_val, old_val);
%! assert (sigquit_dumps_octave_core (), ! orig_val);
%! sigquit_dumps_octave_core (orig_val);
%! assert (sigquit_dumps_octave_core (), orig_val);

%!error sigquit_dumps_octave_core (1, 2)
*/

DEFUN (sigterm_dumps_octave_core, args, nargout,
       doc: /* -*- texinfo -*-
@deftypefn  {} {@var{val} =} sigterm_dumps_octave_core ()
@deftypefnx {} {@var{old_val} =} sigterm_dumps_octave_core (@var{new_val})
@deftypefnx {} {@var{old_val} =} sigterm_dumps_octave_core (@var{new_val}, "local")
Query or set the internal variable that controls whether Octave tries
to save all current variables to the file @file{octave-workspace} if it
receives a terminate signal.

When called from inside a function with the @qcode{"local"} option, the
variable is changed locally for the function and any subroutines it calls.
The original variable value is restored when exiting the function.
@end deftypefn */)
{
  return set_internal_variable (Vsigterm_dumps_octave_core,
                                args, nargout,
                                "sigterm_dumps_octave_core");
}

/*
%!test
%! orig_val = sigterm_dumps_octave_core ();
%! old_val = sigterm_dumps_octave_core (! orig_val);
%! assert (orig_val, old_val);
%! assert (sigterm_dumps_octave_core (), ! orig_val);
%! sigterm_dumps_octave_core (orig_val);
%! assert (sigterm_dumps_octave_core (), orig_val);

%!error sigterm_dumps_octave_core (1, 2)
*/

OCTAVE_END_NAMESPACE(octave)