#include "inc.h"
#include <assert.h>
#include <minix/dmap.h>
#include <minix/endpoint.h>

#include <minix/vfsif.h>
#include "fs.h"
#include "buf.h"
#include "inode.h"
#include "drivers.h"


/* Declare some local functions. */
FORWARD _PROTOTYPE(void init_server, (void)				);
FORWARD _PROTOTYPE(void get_work, (message *m_in)			);

FORWARD _PROTOTYPE(void cch_check, (void)				);

/*===========================================================================*
 *				main                                         *
 *===========================================================================*/
PUBLIC int main(int argc, char *argv[])
{
/* This is the main routine of this service. The main loop consists of 
 * three major activities: getting new work, processing the work, and
 * sending the reply. The loop never terminates, unless a panic occurs.
 */
  int error, ind;
  message m;

  /* Initialize the server, then go to work. */
  init_server();	

  fs_m_in.m_type = FS_READY;

  if (send(FS_PROC_NR, &fs_m_in) != OK) {
      printf("MFS(%d): Error sending login to VFS\n", SELF_E);
      return -1;
  }

  while(!unmountdone || !exitsignaled) {
      endpoint_t src;
      /* Wait for request message. */
      get_work(&fs_m_in);
      src = fs_m_in.m_source;
      error = OK;

      caller_uid = -1;	/* To trap errors */
      caller_gid = -1;

      /* Exit request? */
      if(src == PM_PROC_NR) {
	exitsignaled = 1;
	fs_sync();
	continue;
      }

      /* This must be a regular VFS request. */
      assert(src == VFS_PROC_NR && !unmountdone);

      req_nr = fs_m_in.m_type;

      if (req_nr < VFS_BASE)
      {
      	fs_m_in.m_type += VFS_BASE;
      	req_nr = fs_m_in.m_type;
      }
      ind= req_nr-VFS_BASE;

      if (ind < 0 || ind >= NREQS) {
	  printf("mfs: bad request %d\n", req_nr); 
	  printf("ind = %d\n", ind);
          error = EINVAL; 
      }
      else {
          error = (*fs_call_vec[ind])();
	  /*cch_check();*/
      }

      fs_m_out.m_type = error; 
      reply(src, &fs_m_out);

      if (error == OK && rdahed_inode != NIL_INODE) {
          read_ahead(); /* do block read ahead */
      }
  }
}

/*===========================================================================*
 *				init_server                                  *
 *===========================================================================*/
PRIVATE void init_server(void)
{
   int i;

   /* Init inode table */
   for (i = 0; i < NR_INODES; ++i) {
	   inode[i].i_count = 0;
	   cch[i] = 0;
   }
	
   init_inode_cache();

   /* Init driver mapping */
   for (i = 0; i < NR_DEVICES; ++i) 
       driver_endpoints[i].driver_e = NONE;
	
   SELF_E = getprocnr();
   buf_pool();
   fs_block_size = _MIN_BLOCK_SIZE;
}

/*===========================================================================*
 *				get_work				     *
 *===========================================================================*/
PRIVATE void get_work(m_in)
message *m_in;				/* pointer to message */
{
    int srcok = 0;
    endpoint_t src;
    do {
    	int s;				/* receive status */
	if (OK != (s = receive(ANY, m_in))) 	/* wait for message */
		panic("MFS","receive failed", s);
	src = fs_m_in.m_source;

	if (src != FS_PROC_NR) {
		if(src == PM_PROC_NR) {
			if(fs_m_in.m_type == PROC_EVENT)
				srcok = 1; /* Normal exit request. */
		    	else
				printf("MFS: unexpected message from PM\n");
		} else
			printf("MFS: unexpected source %d\n", src);
	} else if(src == FS_PROC_NR) {
		if(unmountdone) {
			printf("MFS: unmounted: unexpected message from FS\n");
		} else {
			/* Normal FS request. */
			srcok = 1;
		}
	} else
		printf("MFS: unexpected source %d\n", src);
   } while(!srcok);

   assert((src == FS_PROC_NR && !unmountdone) || 
	(src == PM_PROC_NR && fs_m_in.m_type == PROC_EVENT));
}


/*===========================================================================*
 *				reply					     *
 *===========================================================================*/
PUBLIC void reply(who, m_out)
int who;	
message *m_out;                       	/* report result */
{
    if (OK != send(who, m_out))    /* send the message */
        printf("MFS(%d) was unable to send reply\n", SELF_E);
}

PRIVATE void cch_check(void) 
{
  int i;

  for (i = 0; i < NR_INODES; ++i) {
	  if (inode[i].i_count != cch[i] &&
		req_nr != REQ_GETNODE &&
		req_nr != REQ_PUTNODE &&
		req_nr != REQ_CLONE_OPCL && req_nr != REQ_READSUPER_S &&
		req_nr != REQ_MOUNTPOINT_S && req_nr != REQ_UNMOUNT &&
		req_nr != REQ_PIPE && req_nr != REQ_SYNC && 
		req_nr != REQ_LOOKUP_S)
printf("MFS(%d) inode(%d) cc: %d req_nr: %d\n",
	SELF_E, inode[i].i_num, inode[i].i_count - cch[i], req_nr);
	  
	  cch[i] = inode[i].i_count;
  }
}