disastrOS.c

#include <sys/types.h>
#include <sys/time.h>
#include <assert.h>
#include <stdarg.h>
#include <stdlib.h>
#include <stdio.h>
#include <signal.h>
#include <unistd.h>
#include "disastrOS.h"
#include "disastrOS_syscalls.h"
#include "disastrOS_timer.h"
#include "disastrOS_resource.h"
#include "disastrOS_descriptor.h"
#include "disastrOS_mq.h"

FILE* log_file=NULL;
PCB* init_pcb;
PCB* running;
int last_pid;
ListHead ready_list;
ListHead waiting_list;
ListHead zombie_list;
ListHead timer_list;
/**
int reader_messi_in_pausa = 0;
int reader_fatti_ripartire = 0;
int writer_messi_in_pausa = 0;
int writer_fatti_ripartire = 0;
**/
// a resource can be a device, a file or an ipc thing
ListHead resources_list;

ListHead mq_list;

SyscallFunctionType syscall_vector[DSOS_MAX_SYSCALLS];
int syscall_numarg[DSOS_MAX_SYSCALLS];

ucontext_t interrupt_context;           
ucontext_t trap_context;
ucontext_t main_context;
ucontext_t idle_context;
int shutdown_now=0; // used for termination
char system_stack[STACK_SIZE];

sigset_t signal_set;                       // process wide signal mask 
char signal_stack[STACK_SIZE];     
volatile int disastrOS_time=0;




void timerHandler(int j, siginfo_t *si, void *old_context) {
  if(DEBUG==1) printf("Sono entrato nella funzione timerHandler, sto per fare uno swap\n");
  swapcontext(&running->cpu_state, &interrupt_context);
  if(DEBUG==1) printf("Ho fatto uno swap in TimerHandler\n");
}

void timerInterrupt(){
  if (log_file)
    fprintf(log_file, "TIME: %d\tPID: %d\tACTION: %s\n", disastrOS_time, running->pid, "TIMER_OUT");
  ++disastrOS_time;
  printf("time: %d\n", disastrOS_time);

  internal_schedule();

  if (log_file)
    fprintf(log_file, "TIME: %d\tPID: %d\tACTION: %s\n", disastrOS_time, running->pid, "TIMER_IN");

  printf("running pid: %d\n", running->pid);
  //disastrOS_printStatus();
  setcontext(&running->cpu_state);
}


//set up the signal action
void setupSignals(void) {
  struct sigaction act;
  act.sa_sigaction = timerHandler;
  sigemptyset(&act.sa_mask);
  act.sa_flags = SA_RESTART | SA_SIGINFO;

  sigemptyset(&signal_set);
  sigaddset(&signal_set, SIGALRM);

  if(sigaction(SIGALRM, &act, NULL) != 0) {
    perror("Signal handler");
  }

  // start the timer
  struct itimerval it;
  it.it_interval.tv_sec = 0;
  it.it_interval.tv_usec = INTERVAL * 1000;
  it.it_value = it.it_interval;
  if (setitimer(ITIMER_REAL, &it, NULL) ) perror("setitiimer");
}




int disastrOS_syscall(int syscall_num, ...) {
  assert(running); 
  va_list ap;
  if (syscall_num<0||syscall_num>DSOS_MAX_SYSCALLS)
    return DSOS_ESYSCALL_OUT_OF_RANGE;

  int nargs=syscall_numarg[syscall_num];
  va_start(ap,syscall_num);
  for (int i=0; i<nargs; ++i){
    running->syscall_args[i] = va_arg(ap,long int);
  }
  va_end(ap);
  running->syscall_num=syscall_num;
  swapcontext(&running->cpu_state, &trap_context);
  return running->syscall_retvalue;
}

void disastrOS_trap(){
  int syscall_num=running->syscall_num;
  if (log_file)
    fprintf(log_file, "TIME: %d\tPID: %d\tACTION: %s %d\n",
	    disastrOS_time,
	    running->pid,
	    "SYSCALL_IN",
	    syscall_num);
  
  if (syscall_num<0||syscall_num>DSOS_MAX_SYSCALLS) {
    running->syscall_retvalue = DSOS_ESYSCALL_OUT_OF_RANGE;
    goto return_to_process;
  }
  SyscallFunctionType my_syscall=syscall_vector[syscall_num];
  if (! my_syscall) {
    running->syscall_retvalue = DSOS_ESYSCALL_NOT_IMPLEMENTED;
    goto return_to_process;
  }
 
  disastrOS_debug("syscall: %d, pid: %d\n", syscall_num, running->pid);
  (*my_syscall)();
  //internal_schedule();
 return_to_process:
  if (log_file)
    fprintf(log_file, "TIME: %d\tPID: %d\tACTION: %s %d\n",
	    disastrOS_time,
	    running->pid,
	    "SYSCALL_OUT",
	    syscall_num);
  if (running)
    setcontext(&running->cpu_state);
  else {
    printf("no active processes\n");
    //disastrOS_printStatus();
  }
}

void disastrOS_start(void (*f)(void*), void* f_args, char* logfile){  
  /* INITIALIZATION OF SYSTEM STRUCTURES*/
  disastrOS_debug("initializing system structures\n");
  PCB_init();
  Timer_init();
  Resource_init();
  Descriptor_init();
  MessageQueue_init();
  Message_init();
  init_pcb=0;

  // populate the vector of syscalls and number of arguments for each syscall
  for (int i=0; i<DSOS_MAX_SYSCALLS; ++i){
    syscall_vector[i]=0;
  }
  syscall_vector[DSOS_CALL_PREEMPT]   = internal_preempt;
  syscall_numarg[DSOS_CALL_PREEMPT]   = 0;
  
  syscall_vector[DSOS_CALL_FORK]      = internal_fork;
  syscall_numarg[DSOS_CALL_FORK]      = 0;

  syscall_vector[DSOS_CALL_SPAWN]      = internal_spawn;
  syscall_numarg[DSOS_CALL_SPAWN]      = 2;

  syscall_vector[DSOS_CALL_WAIT]      = internal_wait;
  syscall_numarg[DSOS_CALL_WAIT]      = 2;

  syscall_vector[DSOS_CALL_EXIT]      = internal_exit;
  syscall_numarg[DSOS_CALL_EXIT]      = 1;

  syscall_vector[DSOS_CALL_SLEEP]     = internal_sleep;
  syscall_numarg[DSOS_CALL_SLEEP]     = 1;

  syscall_vector[DSOS_CALL_OPEN_RESOURCE]     = internal_openResource;
  syscall_numarg[DSOS_CALL_OPEN_RESOURCE]     = 3;

  syscall_vector[DSOS_CALL_CLOSE_RESOURCE]     = internal_closeResource;
  syscall_numarg[DSOS_CALL_CLOSE_RESOURCE]     = 1;

  syscall_vector[DSOS_CALL_DESTROY_RESOURCE]     = internal_destroyResource;
  syscall_numarg[DSOS_CALL_DESTROY_RESOURCE]     = 1;

  syscall_vector[DSOS_CALL_SHUTDOWN]      = internal_shutdown;
  syscall_numarg[DSOS_CALL_SHUTDOWN]      = 0;

  //Nuove system call

  syscall_vector[DSOS_CALL_OPEN_MQ]      = internal_openMessageQueue;
  syscall_numarg[DSOS_CALL_OPEN_MQ]      = 2;

  syscall_vector[DSOS_CALL_CLOSE_MQ]     = internal_closeMessageQueue;
  syscall_numarg[DSOS_CALL_CLOSE_MQ]     = 1;

  syscall_vector[DSOS_CALL_WRITE_MQ]     = internal_MessageQueue_write;
  syscall_numarg[DSOS_CALL_WRITE_MQ]     = 3;

  syscall_vector[DSOS_CALL_READ_MQ]      = internal_MessageQueue_read;
  syscall_numarg[DSOS_CALL_READ_MQ]      = 3;

  syscall_vector[DSOS_CALL_DESTROY_MQ]   = internal_destroyMessageQueue;
  syscall_numarg[DSOS_CALL_DESTROY_MQ]   = 1;



  // setup the scheduling lists
  running=0;
  List_init(&ready_list);
  List_init(&waiting_list);
  List_init(&zombie_list);
  List_init(&resources_list);
  List_init(&timer_list);
  List_init(&mq_list);


  /* INITIALIZATION OF SYSCALL AND INTERRUPT INFRASTRUCTIRE*/
  disastrOS_debug("setting entry point for system shudtown... ");
  getcontext(&main_context); //<< we will come back here on shutdown
  if (shutdown_now)
    exit(0);

  // setting system trap
  disastrOS_debug("setting entry point for system trap... ");
  getcontext(&trap_context);
  trap_context.uc_stack.ss_sp = system_stack;
  trap_context.uc_stack.ss_size = STACK_SIZE;
  sigemptyset(&trap_context.uc_sigmask);
  sigaddset(&trap_context.uc_sigmask, SIGALRM); //< this disables alarm during system trap
  trap_context.uc_stack.ss_flags = 0;
  trap_context.uc_link = &main_context;
  makecontext(&trap_context, disastrOS_trap, 0); //<< this extablishes a context for the system

  disastrOS_debug("setting entry point for timer interrupt... ");
  interrupt_context=trap_context; // the interrupt and the system live on the same stack
  interrupt_context.uc_link = &main_context;
  sigemptyset(&interrupt_context.uc_sigmask);
  makecontext(&interrupt_context, timerInterrupt, 0); //< this is a context for the interrupt


  

  /* STARTING FIRST PROCESS AND IDLING*/
  running=PCB_alloc();
  running->status=Running;
  init_pcb=running;
  
  // create a trampoline for the first process (see spawn)
  disastrOS_debug("preparing trampoline for first process ... ");
  getcontext(&running->cpu_state);
  running->cpu_state.uc_stack.ss_sp = running->stack;
  running->cpu_state.uc_stack.ss_size = STACK_SIZE;
  running->cpu_state.uc_stack.ss_flags = 0;
  running->cpu_state.uc_link = &main_context;
  
  makecontext(&running->cpu_state, (void(*)()) f, 1, f_args);


  // initialize timers and signals
  setupSignals();
  
  // we start the first process
  disastrOS_debug("starting\n");
  if (logfile){
    log_file=fopen(logfile, "w");
    fprintf(log_file, "TIME: %d\tPID: -1\tACTION: START\n", disastrOS_time);
  }
  setcontext(&running->cpu_state);
}

int disastrOS_fork(){
  return disastrOS_syscall(DSOS_CALL_FORK);
}

int disastrOS_wait(int pid, int *retval){
  return disastrOS_syscall(DSOS_CALL_WAIT, pid, retval);
}

void disastrOS_exit(int exitval) {
  disastrOS_syscall(DSOS_CALL_EXIT, exitval);
}

void disastrOS_preempt() {
  disastrOS_syscall(DSOS_CALL_PREEMPT);
}

void disastrOS_spawn(void (*f)(void*), void* args ) {
  disastrOS_syscall(DSOS_CALL_SPAWN, f, args);
}

void disastrOS_shutdown() {
  disastrOS_syscall(DSOS_CALL_SHUTDOWN);
}

void disastrOS_sleep(int sleep_time) {
  disastrOS_syscall(DSOS_CALL_SLEEP, sleep_time);
}

int disastrOS_getpid(){
  if (! running)
    return -1;
  return running->pid;
}

int disastrOS_openResource(int resource_id, int type, int mode) {
  return disastrOS_syscall(DSOS_CALL_OPEN_RESOURCE, resource_id, type, mode);
}

int disastrOS_closeResource(int fd) {
  return disastrOS_syscall(DSOS_CALL_CLOSE_RESOURCE, fd);
}

int disastrOS_destroyResource(int resource_id) {
  return disastrOS_syscall(DSOS_CALL_DESTROY_RESOURCE, resource_id);
}

// Nuove syscalls

int disastrOS_openMessageQueue(int id, int mode) {
  return disastrOS_syscall(DSOS_CALL_OPEN_MQ, id, mode);
}

int disastrOS_closeMessageQueue(int fd) {
  return disastrOS_syscall(DSOS_CALL_CLOSE_MQ, fd);
}

int disastrOS_MessageQueue_write(int id, char* write_buffer, int len) {
  return disastrOS_syscall(DSOS_CALL_WRITE_MQ, id, write_buffer, len);
}

int disastrOS_MessageQueue_read(int id, char* buf, int len) {
  return disastrOS_syscall(DSOS_CALL_READ_MQ, id, buf, len);
}

int disastrOS_MessageQueue_destroy(int id) {
  return disastrOS_syscall(DSOS_CALL_DESTROY_MQ, id);
}



void disastrOS_printStatus(){
  printf("\n****************** DisastrOS ******************\n");
  printf("Running: ");
  if (running)
    PCB_print(running);
  printf("\n");
  printf("Timers: ");
  TimerList_print(&timer_list);
  printf("\nResources: ");
  ResourceList_print(&resources_list);
  printf("\nMessage Queues: ");
  MessageQueueList_print(&mq_list);
  printf("\nReady: ");
  PCBList_print(&ready_list);
  printf("\nWaiting: ");
  PCBList_print(&waiting_list);
  printf("\nZombie: ");
  PCBList_print(&zombie_list);
  printf("\n***********************************************\n\n");
};