fs_main.c

Go to the documentation of this file.

#ifndef __KERNEL__
#  define __KERNEL__
#endif


#include <linux/init.h>
#include <linux/kernel.h>
#include <linux/module.h>
#include <linux/version.h>
#include <linux/fs.h>
#include <linux/sched.h>
#include <linux/statfs.h>
#include <linux/mm.h>
#include <asm/uaccess.h>
#include <asm/errno.h>
#include <linux/buffer_head.h>
#include <linux/pagemap.h> /* unlock_page */
#include <linux/proc_fs.h>
#include <asm/atomic.h>
#include <linux/string.h>


#include "fsc_device.h"
#include "rkfs.h"
#include "parser.h"


int result;

struct_command ret_command; /* BIG ISSUE NR.1 - ask Mr.Child */

char out_buf[OUT_BUF_LENGTH];


int query(const char* command, int command_length) {
  int result;
  
  FSPDEBUG("query(%s), len=%d\n", command, (int) command_length);
  result = fsc_query(command, command_length, out_buf, OUT_BUF_LENGTH);
  
  if (result > 0) {
    out_buf[result] = '\0'; /* adding trailing zero for print out, there is always enough space */
    parse_message(out_buf, result, &ret_command);
    return RKFS_DEF_QUERY_OK;
  }

  else {
   FSPDEBUG("error on query\n");
   return RKFS_DEF_QUERY_ERROR;
  }
  
}


void rkfs_deamon_test(void) {
        
/* this test will pass under condition of newly started database - no used counters!! */
#ifdef TEST_DEAMON

   query("MYSQL1.1 TS");
   query("MYSQL1.1 RE 1");
   query("MYSQL1.1 RE 8");
   query("MYSQL1.1 CF 8 hello.txt");
   query("MYSQL1.1 CF 1 hello.txt");
   query("MYSQL1.1 CF 1 hello.txt");
   query("MYSQL1.1 MD 1 novy_adresar");
   query("MYSQL1.1 MD 8 jiny_adresar");
   query("MYSQL1.1 MD 1 novy_adresar");
   query("MYSQL1.1 RF 50");
   query("MYSQL1.1 RF 2");
   query("MYSQL1.1 CF 1 vypln");
   query("MYSQL1.1 RD 1");
   query("MYSQL1.1 RD 3");
   query("MYSQL1.1 CR 49");
   query("MYSQL1.1 CR 7");
   query("MYSQL1.1 GB 1 0");
   query("MYSQL1.1 GB 1 1000");
   query("MYSQL1.1 GB 400 0");
   query("MYSQL1.1 GB 8 0");
   query("MYSQL1.1 GB 9 0");
   query("MYSQL1.1 GB 9 1");
   query("MYSQL1.1 AB 8 cd");
   query("MYSQL1.1 CR 8");
   query("MYSQL1.1 AB 8 ab");
   query("MYSQL1.1 AB 500 cd");
   query("MYSQL1.1 LU 1 xxxxx");
   query("MYSQL1.1 LU 1 todo.txt");
   query("MYSQL1.1 LU 1 novy_adresar");
   query("MYSQL1.1 LU 800 ahoj");
   query("MYSQL1.1 FI 1");
   query("MYSQL1.1 FI 2");
   query("MYSQL1.1 DI 10001");
   query("MYSQL1.1 DI 103485");
   query("MYSQL1.1 RI 4");
   query("MYSQL1.1 RI 10001");
#endif
}


struct file_system_type rkfs = {
  name:        "rkfs",
  get_sb:     rkfs_get_sb,
  kill_sb:    rkfs_kill_sb,
  owner:      THIS_MODULE
};


int rkfs_next_data_item(char **com_data_pos, char *ret_buf) {
  int len = 0;

  while ((**com_data_pos) != '/' && (**com_data_pos) != '\0') {
    *(ret_buf++) = *((*com_data_pos)++);
    len++;
  }
  
  *ret_buf = '\0';
  (*com_data_pos)++;
  
  return len;
}


int rkfs_atoi(char* str) {
  int result = 0;
  char char_num;
  int int_num;
  
  while ((*str) != '\0') {
    char_num = *(str++);
    switch (char_num) {
      case '0': int_num = 0; break;
      case '1': int_num = 1; break;
      case '2': int_num = 2; break;
      case '3': int_num = 3; break;
      case '4': int_num = 4; break;
      case '5': int_num = 5; break;
      case '6': int_num = 6; break;
      case '7': int_num = 7; break;
      case '8': int_num = 8; break;
      case '9': int_num = 9; break;
      default:  int_num = 0; break;
    }
    result = result*10 + int_num;
  }
  return result;
}

static int __init
rkfs_init_module(void) {
    int result;
    create_proc_read_entry("fsc_dev", 0, NULL, fsc_read_procmem, NULL); 
    result = register_filesystem(&rkfs);
    
    if  (result != 0) {
      printk(KERN_ERR "RKFS: unable to register RKFS filesystem.\n");
      printk(KERN_INFO "RKFS: register_filesystem error = %d.\n", result);
      return result;    
    }
    
    fsc_init(); 
    result = register_chrdev(fsc_major, CHAR_DEVICE_NAME,  &fsc_fops);
    
    if (result < 0) {
        printk(KERN_ERR "FSC: unable to register RKFSCHAR character device. \n");
        printk(KERN_INFO "FSC: register_chrdev error = %d.\n", result);
        return result;
    }
        
    if (fsc_major == 0) {
        fsc_major = result;
        printk(KERN_INFO "FSC: char device succesfully loaded.\n");
    }   
    
    printk(KERN_INFO "RKFS: filesystem succesfully loaded.\n");
    return 0;
}


static void      rkfs_cleanup_module(void) {
        int result;  
        remove_proc_entry("fsc_dev", NULL);
        result = unregister_filesystem(&rkfs);
        
        if (result != 0) {
                printk(KERN_ERR "RKFS: cannot be unloaded. \n");
                printk(KERN_INFO "RKFS: unregister_filesystem error = %d.\n", result);
        }
         
        else {
                printk(KERN_INFO "RKFS: filesystem succesfully unloaded. \n");
        }
        
    fsc_fini(); 
        result = unregister_chrdev(fsc_major, CHAR_DEVICE_NAME);

        if (result != 0) {
                printk(KERN_ERR "FSC: cannot be unloaded. \n");
                printk(KERN_INFO "FSC: unregister_chrdev error = %d.\n", result);
        }
         
        else {
                printk(KERN_INFO "FSC: char device succesfully unloaded.\n");
        }
        
}


module_init(rkfs_init_module);


module_exit(rkfs_cleanup_module);

---