/*------------------------------------------------------------------------------------------*\
 *
 *   Copyright (C) 2004 AVM GmbH <fritzbox_info@avm.de>
 *
 *   This program 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 2 of the License, or
 *   (at your option) any later version.
 *
 *   This 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 program; if not, write to the Free Software
 *   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
\*------------------------------------------------------------------------------------------*/
#include <linux/module.h>
#include <linux/kernel.h>
#include <linux/init.h>
#include <linux/proc_fs.h>
#include <linux/kthread.h>
#include <linux/module.h>
#include <asm/uaccess.h>
#include <linux/slab.h>
#include <asm/fcntl.h>
#include <asm/ioctl.h>
#include <linux/semaphore.h>
#include <asm/errno.h>
#include <linux/wait.h>
#include <linux/cdev.h>
#include <linux/fs.h>
#include <linux/tffs.h>
#include <linux/zlib.h>
#include <linux/version.h>
#if defined(CONFIG_PROC_FS)
#include <linux/proc_fs.h>
#endif /*--- #if defined(CONFIG_PROC_FS) ---*/
#include <asm/mach_avm.h>

#include <linux/seq_file.h>

/*------------------------------------------------------------------------------------------*\
\*------------------------------------------------------------------------------------------*/
/*--- #define TFFS_DEBUG ---*/
#include "tffs_local.h"

/*------------------------------------------------------------------------------------------*\
\*------------------------------------------------------------------------------------------*/
//MODULE_PARM_DESC (tffs_mtd, "MTD device used for tiny flash file system with double buffering");
MODULE_DESCRIPTION("TFFS 'tiny flash file system with double buffering' driver version 2.2");
MODULE_SUPPORTED_DEVICE("MTD[0..n]");
MODULE_LICENSE("GPL");
#define TFFS3_MODULE_VERSION "3.0"
MODULE_VERSION(TFFS3_MODULE_VERSION);

/*-----------------------------------------------------------------------------------------------*\
\*-----------------------------------------------------------------------------------------------*/
static void tffs_cleanup(void);

struct file_operations tffs_fops = {
        owner: THIS_MODULE,
        open: tffs_open,
        flush: tffs_flush,
        release: tffs_release,
        read: tffs_read,
        write: tffs_write,
        unlocked_ioctl: tffs_unlocked_ioctl,
};

struct tffs_cdev tffs;
char panic_log_workspace[PANIC_LOG_WRKSPC_SIZE];

/*-----------------------------------------------------------------------------------------------*\
\*-----------------------------------------------------------------------------------------------*/
static int tffs_thread(void *data)
{
    struct tffs_cdev *my_tffs;
    int result;
    struct tffs_core_handle *handle;

    my_tffs = (struct tffs_cdev *) data;

    my_tffs->thread_state = tffs3_thread_state_init;

    handle = TFFS3_Open(0, tffs3_mode_write);
    BUG_ON(IS_ERR_OR_NULL(handle));

    result = 0;
    do{
        pr_debug("[%s] waiting for events\n", __func__);
        my_tffs->thread_state = tffs3_thread_state_idle;
        if(wait_event_interruptible(my_tffs->event_wq,
               test_and_clear_bit(TFFS_EVENT_BIT_TRIGGER, &my_tffs->pending_events)))
        {
            pr_err("[%s] interrupted while waiting for events, exiting\n", __func__);
            result = -EINTR;
            break;
        }

        my_tffs->thread_state = tffs3_thread_state_process;
        my_tffs->request_count++;

        /*--- auswerten des Events ---*/
        pr_debug("[%s] processing events 0x%08lx\n", __func__, my_tffs->pending_events);

        if(test_and_clear_bit(TFFS_EVENT_BIT_PANIC, &my_tffs->pending_events)){
            pr_emerg("[%s] panic triggered\n", __func__);
            panic("Async panic triggered.\n");
        }

        if(kthread_should_stop()
          || test_and_clear_bit(TFFS_EVENT_BIT_CLEANUP, &my_tffs->pending_events))
        {
            pr_debug("[%s] Cleanup\n", __func__);
            (void) TFFS3_Cleanup(handle);
        }


    }while(!kthread_should_stop());

    TFFS3_Close(handle);

    pr_info("[%s] event thread dead\n", __func__);

    my_tffs->thread_state = tffs3_thread_state_down;
    my_tffs->kthread      = NULL;

    return result;
}

/*-----------------------------------------------------------------------------------------------*\
\*-----------------------------------------------------------------------------------------------*/
void tffs_send_event(unsigned int event)
{
    unsigned int i = 0;

    pr_debug("[%s] Called with event 0x%08x\n", __func__, event);

    event &= ~(TFFS_EVENT_TRIGGER);
    if(event == 0){
        return;
    }

    do{
        i = ffs(event);
        set_bit(i - 1, &tffs.pending_events);
        event >>= i;
    }while(event);

    mb();
    set_bit(TFFS_EVENT_BIT_TRIGGER, &tffs.pending_events);

    // call wake.._sync so caller won't be scheduled out immediately
    // and gets a chance to release the tffs core mutex
    wake_up_interruptible_sync(&tffs.event_wq);
}

/*------------------------------------------------------------------------------------------*\
\*------------------------------------------------------------------------------------------*/
static void tffs_init_cleanup(void)
{
#if defined(CONFIG_PROC_FS)
    tffs_proc_remove(&tffs);
#endif /*--- #if defined(CONFIG_PROC_FS) ---*/

    if(tffs.cdev_ticfg){
        kobject_put(&tffs.cdev_ticfg->kobj);
        cdev_del(tffs.cdev_ticfg);
    }

    if(tffs.cdev){
        kobject_put(&tffs.cdev->kobj);
        cdev_del(tffs.cdev);
    }
    unregister_chrdev_region(tffs.device, 1);
}

/*-----------------------------------------------------------------------------------------------*\
\*-----------------------------------------------------------------------------------------------*/

#if defined(CONFIG_MACH_PUMA7) && defined(CONFIG_X86_PUMA7)
extern void avm_prom_tffs_sync(void);
#endif

int
#if defined(CONFIG_TFFS_MODULE)
    __init 
#endif
           do_tffs_init(void)
{
    int reason;

    memset(&tffs, 0x0, sizeof(tffs));

    tffs.device = MKDEV(0, 0);
    /*--- reason = register_chrdev_region(tffs.device, 1, "tffs"); ---*/
    reason = alloc_chrdev_region(&tffs.device, 0, 1, "tffs");
    if(reason < 0){
        /*--- DBG((KERN_ERR "[tffs] alloc_chrdev_region failed: reason %d!\n", reason)); ---*/
        pr_err("[%s] register_chrdev_region failed: reason %d!\n", __func__, reason);
        return reason;
    }

    tffs.cdev_ticfg = 0;
    tffs.cdev = cdev_alloc();
    if(!tffs.cdev){
        DBG((KERN_ERR "[tffs] cdev_alloc failed!\n"));
        tffs_cleanup();
        return -ENODEV;
    }

    tffs.cdev->owner = tffs_fops.owner;
    tffs.cdev->ops = &tffs_fops;
    kobject_set_name(&(tffs.cdev->kobj), "tffs0");

    if(cdev_add(tffs.cdev, tffs.device, 256)){
        DBG((KERN_ERR "[tffs] cdev_add failed!\n"));
        tffs_cleanup();
        tffs_init_cleanup();
        return -ENODEV;
    }

    if(TFFS3_Init()){
        tffs_cleanup();
        tffs_init_cleanup();
        DBG((KERN_ERR "[tffs] TFFS_Init failed!\n"));
        return -ENODEV;
    }

    init_waitqueue_head(&tffs.event_wq);

    DBG((KERN_INFO "[tffs] Character device init successfull \n"));


    tffs.thread_state = tffs3_thread_state_off;
    tffs.kthread = kthread_run(tffs_thread, (void * )&tffs, "tffsd");
    BUG_ON((tffs.kthread == NULL) || IS_ERR((void *)tffs.kthread));
    pr_info("TFFS: tiny flash file system driver. GPL (c) AVM Berlin (Version %s)\n", TFFS3_MODULE_VERSION);

#ifdef CONFIG_PROC_FS
    tffs_proc_init(&tffs);
#endif

#ifdef CONFIG_SYSCTL
    avm_urlader_env_init();
#endif /* CONFIG_SYSCTL */

#if defined(CONFIG_MACH_PUMA7) && defined(CONFIG_X86_PUMA7)
    avm_prom_tffs_sync();
#endif

    return 0;
}

#if (defined(CONFIG_MACH_PUMA7) && defined(CONFIG_X86_PUMA7)) || defined(CONFIG_ARCH_IPQ807x)
/* TODO: Problem with this is we may finish initialization after userland init
 *       already got started.
 */
static void tffs_init_work_func(struct work_struct * __always_unused work)
{
    TFFS3_Wait_For_Backend();
    do_tffs_init();
}

static DECLARE_WORK(tffs_init_work, tffs_init_work_func);

static int __init tffs_init(void)
{
    schedule_work(&tffs_init_work);
    return 0;
}
#else /* !(CONFIG_MACH_PUMA7 && CONFIG_X86_PUMA7) */
static int __init tffs_init(void) {
    return do_tffs_init();
}
#endif
late_initcall(tffs_init);

/*-----------------------------------------------------------------------------------------------*\
\*-----------------------------------------------------------------------------------------------*/
static void tffs_cleanup(void)
{
}

module_exit(tffs_cleanup);

/* vim: set sw=4 ts=4 et ai cc=80 : */