Changeset e5dbbe5 in mainline

Timestamp:

2007-04-08T23:45:41Z (17 years ago)

Author:

Martin Decky <martin@…>

Branches:

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

Children:

72bcb25

Parents:

7cb567cd

Message:

add mcall0 command (calling a function on each CPU)

Location:

kernel/generic/src

Files:

• console/cmd.c (modified) (6 diffs)
• main/kinit.c (modified) (1 diff)

kernel/generic/src/console/cmd.c

@@ -193 +193 @@
 
 /* Data and methods for 'call0' command. */
-static char call0_buf[MAX_CMDLINE+1];
-static char carg1_buf[MAX_CMDLINE+1];
-static char carg2_buf[MAX_CMDLINE+1];
-static char carg3_buf[MAX_CMDLINE+1];
+static char call0_buf[MAX_CMDLINE + 1];
+static char carg1_buf[MAX_CMDLINE + 1];
+static char carg2_buf[MAX_CMDLINE + 1];
+static char carg3_buf[MAX_CMDLINE + 1];
 
 static int cmd_call0(cmd_arg_t *argv);
@@ -210 +210 @@
         .argc = 1,
         .argv = &call0_argv
+};
+
+/* Data and methods for 'mcall0' command. */
+static int cmd_mcall0(cmd_arg_t *argv);
+static cmd_arg_t mcall0_argv = {
+        .type = ARG_TYPE_STRING,
+        .buffer = call0_buf,
+        .len = sizeof(call0_buf)
+};
+static cmd_info_t mcall0_info = {
+        .name = "mcall0",
+        .description = "mcall0 <function> -> call function() on each CPU.",
+        .func = cmd_mcall0,
+        .argc = 1,
+        .argv = &mcall0_argv
 };
 
@@ -407 +422 @@
 static cmd_info_t *basic_commands[] = {
         &call0_info,
+        &mcall0_info,
         &call1_info,
         &call2_info,
@@ -541 +557 @@
                 unative_t f;
                 unative_t gp;
-        }fptr;
+        } fptr;
 #endif
 
@@ -552 +568 @@
         } else {
                 symbol = get_symtab_entry(symaddr);
-                printf("Calling f(): %.*p: %s\n", sizeof(uintptr_t) * 2, symaddr, symbol);
+                printf("Calling %s() (%.*p)\n", symbol, sizeof(uintptr_t) * 2, symaddr);
 #ifdef ia64
                 fptr.f = symaddr;
@@ -561 +577 @@
 #endif
                 printf("Result: %#zx\n", f());
+        }
+        
+        return 1;
+}
+
+/** Call function with zero parameters on each CPU */
+int cmd_mcall0(cmd_arg_t *argv)
+{
+        /*
+         * For each CPU, create a thread which will
+         * call the function.
+         */
+        
+        count_t i;
+        for (i = 0; i < config.cpu_count; i++) {
+                thread_t *t;
+                if ((t = thread_create((void (*)(void *)) cmd_call0, (void *) argv, TASK, THREAD_FLAG_WIRED, "call0", false))) {
+                        spinlock_lock(&t->lock);
+                        t->cpu = &cpus[i];
+                        spinlock_unlock(&t->lock);
+                        printf("cpu%u: ", i);
+                        thread_ready(t);
+                        thread_join(t);
+                } else
+                        printf("Unable to create thread for cpu%u\n", i);
         }
         

kernel/generic/src/main/kinit.c

@@ -119 +119 @@
 #ifdef CONFIG_SMP
         if (config.cpu_count > 1) {
-                unsigned int i;
+                count_t i;
                 
                 /*