Merge master.kernel.org:/pub/scm/linux/kernel/git/steve/gfs2-2.6-nmw
[pandora-kernel.git] / drivers / char / mmtimer.c
index 78c89a3..c091603 100644 (file)
@@ -1,11 +1,11 @@
 /*
- * Intel Multimedia Timer device implementation for SGI SN platforms.
+ * Timer device implementation for SGI SN platforms.
  *
  * This file is subject to the terms and conditions of the GNU General Public
  * License.  See the file "COPYING" in the main directory of this archive
  * for more details.
  *
- * Copyright (c) 2001-2004 Silicon Graphics, Inc.  All rights reserved.
+ * Copyright (c) 2001-2006 Silicon Graphics, Inc.  All rights reserved.
  *
  * This driver exports an API that should be supportable by any HPET or IA-PC
  * multimedia timer.  The code below is currently specific to the SGI Altix
@@ -25,7 +25,6 @@
 #include <linux/init.h>
 #include <linux/errno.h>
 #include <linux/mm.h>
-#include <linux/devfs_fs_kernel.h>
 #include <linux/mmtimer.h>
 #include <linux/miscdevice.h>
 #include <linux/posix-timers.h>
@@ -45,7 +44,7 @@ MODULE_LICENSE("GPL");
 /* name of the device, usually in /dev */
 #define MMTIMER_NAME "mmtimer"
 #define MMTIMER_DESC "SGI Altix RTC Timer"
-#define MMTIMER_VERSION "2.0"
+#define MMTIMER_VERSION "2.1"
 
 #define RTC_BITS 55 /* 55 bits for this implementation */
 
@@ -64,7 +63,7 @@ static int mmtimer_mmap(struct file *file, struct vm_area_struct *vma);
  */
 static unsigned long mmtimer_femtoperiod = 0;
 
-static struct file_operations mmtimer_fops = {
+static const struct file_operations mmtimer_fops = {
        .owner =        THIS_MODULE,
        .mmap =         mmtimer_mmap,
        .ioctl =        mmtimer_ioctl,
@@ -227,10 +226,7 @@ typedef struct mmtimer {
        struct tasklet_struct tasklet;
 } mmtimer_t;
 
-/*
- * Total number of comparators is comparators/node * MAX nodes/running kernel
- */
-static mmtimer_t timers[NUM_COMPARATORS*MAX_COMPACT_NODES];
+static mmtimer_t ** timers;
 
 /**
  * mmtimer_ioctl - ioctl interface for /dev/mmtimer
@@ -332,7 +328,6 @@ static int mmtimer_mmap(struct file *file, struct vm_area_struct *vma)
        if (PAGE_SIZE > (1 << 16))
                return -ENOSYS;
 
-       vma->vm_flags |= (VM_IO | VM_SHM | VM_LOCKED );
        vma->vm_page_prot = pgprot_noncached(vma->vm_page_prot);
 
        mmtimer_addr = __pa(RTC_COUNTER_ADDR);
@@ -427,7 +422,6 @@ static int inline reschedule_periodic_timer(mmtimer_t *x)
  * mmtimer_interrupt - timer interrupt handler
  * @irq: irq received
  * @dev_id: device the irq came from
- * @regs: register state upon receipt of the interrupt
  *
  * Called when one of the comarators matches the counter, This
  * routine will send signals to processes that have requested
@@ -438,32 +432,32 @@ static int inline reschedule_periodic_timer(mmtimer_t *x)
  * registers.
  */
 static irqreturn_t
-mmtimer_interrupt(int irq, void *dev_id, struct pt_regs *regs)
+mmtimer_interrupt(int irq, void *dev_id)
 {
        int i;
-       mmtimer_t *base = timers + cpu_to_node(smp_processor_id()) *
-                                               NUM_COMPARATORS;
        unsigned long expires = 0;
        int result = IRQ_NONE;
+       unsigned indx = cpu_to_node(smp_processor_id());
 
        /*
         * Do this once for each comparison register
         */
        for (i = 0; i < NUM_COMPARATORS; i++) {
+               mmtimer_t *base = timers[indx] + i;
                /* Make sure this doesn't get reused before tasklet_sched */
-               spin_lock(&base[i].lock);
-               if (base[i].cpu == smp_processor_id()) {
-                       if (base[i].timer)
-                               expires = base[i].timer->it.mmtimer.expires;
+               spin_lock(&base->lock);
+               if (base->cpu == smp_processor_id()) {
+                       if (base->timer)
+                               expires = base->timer->it.mmtimer.expires;
                        /* expires test won't work with shared irqs */
                        if ((mmtimer_int_pending(i) > 0) ||
                                (expires && (expires < rtc_time()))) {
                                mmtimer_clr_int_pending(i);
-                               tasklet_schedule(&base[i].tasklet);
+                               tasklet_schedule(&base->tasklet);
                                result = IRQ_HANDLED;
                        }
                }
-               spin_unlock(&base[i].lock);
+               spin_unlock(&base->lock);
                expires = 0;
        }
        return result;
@@ -523,7 +517,7 @@ static int sgi_timer_del(struct k_itimer *timr)
 {
        int i = timr->it.mmtimer.clock;
        cnodeid_t nodeid = timr->it.mmtimer.node;
-       mmtimer_t *t = timers + nodeid * NUM_COMPARATORS +i;
+       mmtimer_t *t = timers[nodeid] + i;
        unsigned long irqflags;
 
        if (i != TIMER_OFF) {
@@ -609,11 +603,11 @@ static int sgi_timer_set(struct k_itimer *timr, int flags,
        preempt_disable();
 
        nodeid =  cpu_to_node(smp_processor_id());
-       base = timers + nodeid * NUM_COMPARATORS;
 retry:
        /* Don't use an allocated timer, or a deleted one that's pending */
        for(i = 0; i< NUM_COMPARATORS; i++) {
-               if (!base[i].timer && !base[i].tasklet.state) {
+               base = timers[nodeid] + i;
+               if (!base->timer && !base->tasklet.state) {
                        break;
                }
        }
@@ -623,14 +617,14 @@ retry:
                return -EBUSY;
        }
 
-       spin_lock_irqsave(&base[i].lock, irqflags);
+       spin_lock_irqsave(&base->lock, irqflags);
 
-       if (base[i].timer || base[i].tasklet.state != 0) {
-               spin_unlock_irqrestore(&base[i].lock, irqflags);
+       if (base->timer || base->tasklet.state != 0) {
+               spin_unlock_irqrestore(&base->lock, irqflags);
                goto retry;
        }
-       base[i].timer = timr;
-       base[i].cpu = smp_processor_id();
+       base->timer = timr;
+       base->cpu = smp_processor_id();
 
        timr->it.mmtimer.clock = i;
        timr->it.mmtimer.node = nodeid;
@@ -645,11 +639,11 @@ retry:
                }
        } else {
                timr->it.mmtimer.expires -= period;
-               if (reschedule_periodic_timer(base+i))
+               if (reschedule_periodic_timer(base))
                        err = -EINVAL;
        }
 
-       spin_unlock_irqrestore(&base[i].lock, irqflags);
+       spin_unlock_irqrestore(&base->lock, irqflags);
 
        preempt_enable();
 
@@ -675,9 +669,10 @@ static struct k_clock sgi_clock = {
 static int __init mmtimer_init(void)
 {
        unsigned i;
+       cnodeid_t node, maxn = -1;
 
        if (!ia64_platform_is("sn2"))
-               return -1;
+               return 0;
 
        /*
         * Sanity check the cycles/sec variable
@@ -685,31 +680,58 @@ static int __init mmtimer_init(void)
        if (sn_rtc_cycles_per_second < 100000) {
                printk(KERN_ERR "%s: unable to determine clock frequency\n",
                       MMTIMER_NAME);
-               return -1;
+               goto out1;
        }
 
        mmtimer_femtoperiod = ((unsigned long)1E15 + sn_rtc_cycles_per_second /
                               2) / sn_rtc_cycles_per_second;
 
-       for (i=0; i< NUM_COMPARATORS*MAX_COMPACT_NODES; i++) {
-               spin_lock_init(&timers[i].lock);
-               timers[i].timer = NULL;
-               timers[i].cpu = 0;
-               timers[i].i = i % NUM_COMPARATORS;
-               tasklet_init(&timers[i].tasklet, mmtimer_tasklet, (unsigned long) (timers+i));
-       }
-
-       if (request_irq(SGI_MMTIMER_VECTOR, mmtimer_interrupt, SA_PERCPU_IRQ, MMTIMER_NAME, NULL)) {
+       if (request_irq(SGI_MMTIMER_VECTOR, mmtimer_interrupt, IRQF_PERCPU, MMTIMER_NAME, NULL)) {
                printk(KERN_WARNING "%s: unable to allocate interrupt.",
                        MMTIMER_NAME);
-               return -1;
+               goto out1;
        }
 
-       strcpy(mmtimer_miscdev.devfs_name, MMTIMER_NAME);
        if (misc_register(&mmtimer_miscdev)) {
                printk(KERN_ERR "%s: failed to register device\n",
                       MMTIMER_NAME);
-               return -1;
+               goto out2;
+       }
+
+       /* Get max numbered node, calculate slots needed */
+       for_each_online_node(node) {
+               maxn = node;
+       }
+       maxn++;
+
+       /* Allocate list of node ptrs to mmtimer_t's */
+       timers = kmalloc(sizeof(mmtimer_t *)*maxn, GFP_KERNEL);
+       if (timers == NULL) {
+               printk(KERN_ERR "%s: failed to allocate memory for device\n",
+                               MMTIMER_NAME);
+               goto out3;
+       }
+
+       memset(timers,0,(sizeof(mmtimer_t *)*maxn));
+
+       /* Allocate mmtimer_t's for each online node */
+       for_each_online_node(node) {
+               timers[node] = kmalloc_node(sizeof(mmtimer_t)*NUM_COMPARATORS, GFP_KERNEL, node);
+               if (timers[node] == NULL) {
+                       printk(KERN_ERR "%s: failed to allocate memory for device\n",
+                               MMTIMER_NAME);
+                       goto out4;
+               }
+               for (i=0; i< NUM_COMPARATORS; i++) {
+                       mmtimer_t * base = timers[node] + i;
+
+                       spin_lock_init(&base->lock);
+                       base->timer = NULL;
+                       base->cpu = 0;
+                       base->i = i;
+                       tasklet_init(&base->tasklet, mmtimer_tasklet,
+                               (unsigned long) (base));
+               }
        }
 
        sgi_clock_period = sgi_clock.res = NSEC_PER_SEC / sn_rtc_cycles_per_second;
@@ -719,6 +741,17 @@ static int __init mmtimer_init(void)
               sn_rtc_cycles_per_second/(unsigned long)1E6);
 
        return 0;
+
+out4:
+       for_each_online_node(node) {
+               kfree(timers[node]);
+       }
+out3:
+       misc_deregister(&mmtimer_miscdev);
+out2:
+       free_irq(SGI_MMTIMER_VECTOR, NULL);
+out1:
+       return -1;
 }
 
 module_init(mmtimer_init);