Changeset 69b68d1f in mainline for kernel/arch/sparc64/src/drivers/niagara.c

Timestamp:

2009-11-08T20:05:48Z (14 years ago)

Author:

Pavel Rimsky <pavel@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

70a1c59

Parents:

74cbac7d

Message:

Kernel input driver implemented, now the kconsole is usable.

File:

• kernel/arch/sparc64/src/drivers/niagara.c (modified) (12 diffs)

kernel/arch/sparc64/src/drivers/niagara.c

@@ -41 +41 @@
 #include <ddi/device.h>
 #include <arch/asm.h>
+#include <arch.h>
 #include <mm/slab.h>
 #include <arch/drivers/kbd.h>
@@ -46 +47 @@
 #include <sysinfo/sysinfo.h>
 #include <ipc/irq.h>
+#include <print.h>
+#include <proc/thread.h>
+#include <console/console.h>
+#include <genarch/srln/srln.h>
+
+#define POLL_INTERVAL  10000
 
 /**
@@ -55 +62 @@
  */
 #define FICTIONAL_INR           1
+
+
+static niagara_instance_t *instance = NULL;
 
 /* functions referenced from definitions of I/O operations structures */
@@ -78 +88 @@
  * the mapped buffer. The shared buffer definition follows.
  */
+/*
 #define OUTPUT_BUFFER_SIZE      ((PAGE_SIZE) - 2 * 8)
 static volatile struct {
@@ -87 +98 @@
         __attribute__ ((aligned(PAGE_SIZE)))
         output_buffer;
+*/
 
 #if 0
@@ -197 +209 @@
 }
 
+#endif
+
 /**
  * Function regularly called by the keyboard polling thread. Asks the
@@ -202 +216 @@
  * and sends it to the upper layers of HelenOS.
  */
-void niagara_poll(void)
-{
+static void niagara_poll(niagara_instance_t *instance)
+{
+        /*
         while (output_buffer.read_ptr != output_buffer.write_ptr) {
                 do_putchar(output_buffer.data[output_buffer.read_ptr]);
@@ -209 +224 @@
                         ((output_buffer.read_ptr) + 1) % OUTPUT_BUFFER_SIZE;
         }
+        */
 
         uint64_t c;
 
         if (__hypercall_fast_ret1(0, 0, 0, 0, 0, CONS_GETCHAR, &c) == EOK) {
+                indev_push_character(instance->srlnin, c);
+                #if 0
                 ipl_t ipl = interrupts_disable();
                 spinlock_lock(&niagara_irq.lock);
@@ -235 +253 @@
                                 chardev_push_character(&niagara_io, '\n');
                 }
-        }
-
-}
-
-#endif
+                #endif
+        }
+
+}
+
+/**
+ * Polling thread function.
+ */
+static void kniagarapoll(void *instance) {
+        while (true) {
+                //MH
+                //if (!silent)
+                        niagara_poll(instance);
+                
+                thread_usleep(POLL_INTERVAL);
+        }
+}
 
 /**
@@ -245 +275 @@
  * input/output is used.
  */
-void niagara_init(void)
-{
+static void niagara_init(void)
+{
+        if (instance)
+                return;
+        
+        instance = malloc(sizeof(niagara_instance_t), FRAME_ATOMIC);
+        
+        if (instance) {
+                instance->thread = thread_create(kniagarapoll, instance, TASK, 0,
+                        "kniagarapoll", true);
+                
+                if (!instance->thread) {
+                        free(instance);
+                        instance = NULL;
+                        return;
+                }
+        }
+
+        instance->srlnin = NULL;
+
         #if 0
         kbd_type = KBD_SUN4V;
@@ -269 +317 @@
          * niagara fb driver can communicate with kernel using a shared buffer.
          */
-        output_buffer.read_ptr = 0;
-        output_buffer.write_ptr = 0;
+        //output_buffer.read_ptr = 0;
+        //output_buffer.write_ptr = 0;
 
         #if 0
@@ -296 +344 @@
 }
 
+/**
+ * A public function which initializes input from the Niagara console.
+ */
+niagara_instance_t *niagarain_init(void)
+{
+        niagara_init();
+
+        // TODO - move to console init
+        if (instance) {
+                srln_instance_t *srln_instance = srln_init();
+                if (srln_instance) {
+                        indev_t *sink = stdin_wire();
+                        indev_t *srln = srln_wire(srln_instance, sink);
+
+                        // wire std. input to niagara
+                        instance->srlnin = srln;
+                        thread_ready(instance->thread);
+                }
+        }
+        return instance;
+}
+
 /** @}
  */