Palacios Public Git Repository

To checkout Palacios execute

  git clone http://v3vee.org/palacios/palacios.web/palacios.git
This will give you the master branch. You probably want the devel branch or one of the release branches. To switch to the devel branch, simply execute
  cd palacios
  git checkout --track -b devel origin/devel
The other branches are similar.


Merge branch 'devel' of ssh://palacios@newskysaw/home/palacios/palacios into devel
Jack Lange [Fri, 29 Oct 2010 21:41:03 +0000 (16:41 -0500)]
Conflicts:

palacios/src/devices/apic.c

1  2 
palacios/src/devices/apic.c
test/geekos_test_vm/src/common/fmtout.c
test/geekos_test_vm/src/geekos/bget.c
test/geekos_test_vm/src/geekos/main.c
test/geekos_test_vm/src/geekos/malloc.c
test/geekos_test_vm/src/geekos/mem.c
test/geekos_test_vm/src/geekos/screen.c

  #define PrintDebug(fmt, args...)
  #endif
  
+ #ifdef CONFIG_DEBUG_APIC
+ static char *shorthand_str[] = { 
+     "(no shorthand)",
+     "(self)",
+     "(all)",
+     "(all-but-me)",
+ };
+ static char *deliverymode_str[] = { 
+     "(fixed)",
+     "(lowest priority)",
+     "(SMI)",
+     "(reserved)",
+     "(NMI)",
+     "(INIT)",
+     "(Start Up)",
+     "(ExtInt)",
+ };
+ #endif
  
  typedef enum { APIC_TMR_INT, APIC_THERM_INT, APIC_PERF_INT, 
               APIC_LINT0_INT, APIC_LINT1_INT, APIC_ERR_INT } apic_irq_type_t;
@@@ -128,15 -147,15 +147,15 @@@ struct apic_msr 
            uint8_t bootstrap_cpu : 1;
            uint8_t rsvd2         : 2;
            uint8_t apic_enable   : 1;
 -          uint64_t base_addr   : 40;
 -          uint32_t rsvd3         : 12;
 +          uint64_t base_addr    : 40;
 +          uint32_t rsvd3        : 12;
        } __attribute__((packed));
      } __attribute__((packed));
  } __attribute__((packed));
  
  
  
 -typedef enum {INIT, SIPI, STARTED} ipi_state_t; 
 +typedef enum {INIT_ST, SIPI, STARTED} ipi_state_t; 
  
  struct apic_dev_state;
  
@@@ -240,7 -259,7 +259,7 @@@ static void init_apic_state(struct apic
  
      apic->lapic_id.val = id;
      
 -    apic->ipi_state = INIT;
 +    apic->ipi_state = INIT_ST;
  
      // The P6 has 6 LVT entries, so we set the value to (6-1)...
      apic->apic_ver.val = 0x80050010;
@@@ -304,9 -323,7 +323,9 @@@ static int write_apic_msr(struct guest_
  
      apic->base_addr = src.value;
  
 -    if (v3_hook_full_mem(core->vm_info, core->cpu_id, apic->base_addr, apic->base_addr + PAGE_SIZE_4KB, apic_read, apic_write, apic_dev) == -1) {
 +    if (v3_hook_full_mem(core->vm_info, core->cpu_id, apic->base_addr, 
 +                       apic->base_addr + PAGE_SIZE_4KB, 
 +                       apic_read, apic_write, apic_dev) == -1) {
        PrintError("apic %u: core %u: Could not hook new APIC Base address\n",
                   apic->lapic_id.val, core->cpu_id);
        v3_unlock(apic->lock);
@@@ -329,7 -346,7 +348,7 @@@ static int activate_apic_irq(struct api
  
  
      if (irq_num <= 15) {
- //    PrintError("apic %u: core ?: Attempting to raise an invalid interrupt: %d\n", apic->lapic_id.val,irq_num);
+       PrintError("apic %u: core ?: Attempting to raise an invalid interrupt: %d\n", apic->lapic_id.val,irq_num);
        return -1;
      }
  
@@@ -502,7 -519,7 +521,7 @@@ static inline int should_deliver_cluste
        return 1;
      } else {
        PrintDebug("apic %u core %u: rejecting clustered IRQ (mda 0x%x != log_dst 0x%x)\n",
-                  dst_apic->lapic_id.val, dst_core->cpu_id, mda, dst_
+                  dst_apic->lapic_id.val, dst_core->cpu_id, mda, 
                   dst_apic->log_dst.dst_log_id);
        return 0;
      }
@@@ -530,22 -547,14 +549,22 @@@ static inline int should_deliver_flat_i
  static int should_deliver_ipi(struct guest_info * dst_core, 
                              struct apic_state * dst_apic, uint8_t mda) {
  
 -    if (mda == 0xff) {
 -      // always deliver broadcast
 -      return 1;
 -    }
  
      if (dst_apic->dst_fmt.model == 0xf) {
 +
 +      if (mda == 0xff) {
 +          // always deliver broadcast
 +          return 1;
 +      }
 +
        return should_deliver_cluster_ipi(dst_core, dst_apic, mda);
      } else if (dst_apic->dst_fmt.model == 0x0) {
 +
 +      if (mda == 0xff) {
 +          // always deliver broadcast
 +          return 1;
 +      }
 +
        return should_deliver_flat_ipi(dst_core, dst_apic, mda);
      } else {
        PrintError("apic %u core %u: invalid destination format register value 0x%x for logical mode delivery.\n", 
  }
  
  
 -static int deliver_ipi(struct guest_info * core, 
 -                     struct apic_state * src_apic, 
 +static int deliver_ipi(struct apic_state * src_apic, 
                       struct apic_state * dst_apic, 
                       uint32_t vector, uint8_t del_mode) {
  
            // TODO: any APIC reset on dest core (shouldn't be needed, but not sure...)
  
            // Sanity check
 -          if (dst_apic->ipi_state != INIT) { 
 +          if (dst_apic->ipi_state != INIT_ST) { 
                PrintError(" Warning: core %u is not in INIT state (mode = %d), ignored\n",
                           dst_core->cpu_id, dst_core->cpu_mode);
                // Only a warning, since INIT INIT SIPI is common
            dst_core->segments.cs.base = vector << 12;
  
            PrintDebug(" SIPI delivery (0x%x -> 0x%x:0x0) to core %u\n",
-                      vec, dst_core->segments.cs.selector, dst_core->cpu_id);
+                      vector, dst_core->segments.cs.selector, dst_core->cpu_id);
            // Maybe need to adjust the APIC?
            
            // We transition the target core to SIPI state
  }
  
  
 -static int route_ipi(struct guest_info * core, struct apic_dev_state * apic_dev,
 -                   struct apic_state * src_apic,  uint32_t icr_val) {
 -    struct int_cmd_reg * icr = (struct int_cmd_reg *)&icr_val;
 +static int route_ipi(struct apic_dev_state * apic_dev,
 +                   struct apic_state * src_apic, 
 +                   struct int_cmd_reg * icr) {
      struct apic_state * dest_apic = NULL;
  
-     PrintDebug("icc_bus: icc_bus=%p, src_apic=%u, icr_data=%llx, extirq=%u\n", 
-              icc_bus, src_apic, icr_data, extirq);
+     PrintDebug("route_ipi: src_apic=%p, icr_data=%x", 
+              src_apic, icr_val);
  
  
 -    // initial sanity checks
 -    if (src_apic == NULL) { 
 -      PrintError("route_ipi: Apparently sending from unregistered apic id=%d\n", 
 -                 src_apic->core->cpu_id);
 -      return -1;
 -    }
 -
 -
      if ((icr->dst_mode == 0) && (icr->dst >= apic_dev->num_apics)) { 
-       PrintError("icc_bus: Attempted send to unregistered apic id=%u\n", 
+       PrintError("route_ipi: Attempted send to unregistered apic id=%u\n", 
                   icr->dst);
        return -1;
      }
      dest_apic =  &(apic_dev->apics[icr->dst]);
  
  
-     PrintDebug("icc_bus: IPI %s %u from %s %u to %s %s %u (icr=0x%llx, extirq=%u)\n",
+     PrintDebug("route_ipi: IPI %s %u from apic %p to %s %s %u (icr=0x%llx)\n",
               deliverymode_str[icr->del_mode], 
               icr->vec, 
               src_apic,               
               (icr->dst_mode == 0) ? "(physical)" : "(logical)", 
               shorthand_str[icr->dst_shorthand], 
               icr->dst,
-              icr->val,
-              extirq);
+              icr->val);
  
  
      switch (icr->dst_shorthand) {
            if (icr->dst_mode == 0) { 
                // physical delivery
  
 -              if (deliver_ipi(core, src_apic, dest_apic, 
 +              if (deliver_ipi(src_apic, dest_apic, 
                                icr->vec, icr->del_mode) == -1) {
                    PrintError("Error: Could not deliver IPI\n");
                    return -1;
                         PrintError("Error checking delivery mode\n");
                         return -1;
                     } else if (del_flag == 1) {
 -                      if (deliver_ipi(core, src_apic, dest_apic, 
 +                      if (deliver_ipi(src_apic, dest_apic, 
                                        icr->vec, icr->del_mode) == -1) {
                            PrintError("Error: Could not deliver IPI\n");
                            return -1;
            
        case 1:  // self
  
 +          if (src_apic == NULL) {
 +              PrintError("Sending IPI to self from generic IPI sender\n");
 +              break;
 +          }
 +
            if (icr->dst_mode == 0) { 
 -              if (deliver_ipi(core, src_apic, src_apic, icr->vec, icr->del_mode) == -1) {
 +              if (deliver_ipi(src_apic, src_apic, icr->vec, icr->del_mode) == -1) {
                    PrintError("Could not deliver IPI\n");
                    return -1;
                }
                dest_apic = &(apic_dev->apics[i]);
  
                if ((dest_apic != src_apic) || (icr->dst_shorthand == 2)) { 
 -                  if (deliver_ipi(core, src_apic, dest_apic, icr->vec, icr->del_mode) == -1) {
 +                  if (deliver_ipi(src_apic, dest_apic, icr->vec, icr->del_mode) == -1) {
                        PrintError("Error: Could not deliver IPI\n");
                        return -1;
                    }
@@@ -1208,7 -1220,7 +1226,7 @@@ static int apic_write(struct guest_inf
                       apic->lapic_id.val, core->cpu_id,
                       apic->int_cmd.val, apic->int_cmd.dst);
  
 -          if (route_ipi(core, apic_dev, apic, apic->int_cmd.val) == -1) { 
 +          if (route_ipi(apic_dev, apic, &(apic->int_cmd)) == -1) { 
                PrintError("IPI Routing failure\n");
                return -1;
            }
@@@ -1272,33 -1284,13 +1290,35 @@@ static int apic_get_intr_number(struct 
  }
  
  
 +int v3_apic_send_ipi(struct v3_vm_info * vm, struct vm_device * dev, 
 +                   struct v3_gen_ipi * ipi) {
 +    struct apic_dev_state * apic_dev = (struct apic_dev_state *)(dev->private_data);
 +    struct int_cmd_reg tmp_icr;
 +
 +    // zero out all the fields
 +    tmp_icr.val = 0;
 +
 +
 +    tmp_icr.vec = ipi->vector;
 +    tmp_icr.del_mode = ipi->mode;
 +    tmp_icr.dst_mode = ipi->logical;
 +    tmp_icr.trig_mode = ipi->trigger_mode;
 +    tmp_icr.dst_shorthand = ipi->dst_shorthand;
 +    tmp_icr.dst = ipi->dst;
 +    
 +
 +    route_ipi(apic_dev, NULL, &tmp_icr);
 +    return -1;
 +}
 +
 +
  int v3_apic_raise_intr(struct v3_vm_info * vm, struct vm_device * dev, 
                       uint32_t irq, uint32_t dst) {
      struct apic_dev_state * apic_dev = (struct apic_dev_state *)(dev->private_data);
      struct apic_state * apic = &(apic_dev->apics[dst]); 
  
+     PrintDebug("apic %u core ?: raising interrupt IRQ %u (dst = %u).\n", apic->lapic_id.val, irq, dst); 
      activate_apic_irq(apic, irq);
  
      if (V3_Get_CPU() != dst) {
@@@ -1326,8 -1318,8 +1346,8 @@@ static int apic_begin_irq(struct guest_
        *req_location &= ~flag;
      } else {
        // do nothing... 
-       PrintDebug("apic %u: core %u: begin irq for %d ignored since I don't own it\n",
-                  apic->lapic_id.val, info->cpu_id, irq);
+       //PrintDebug("apic %u: core %u: begin irq for %d ignored since I don't own it\n",
+       //         apic->lapic_id.val, core->cpu_id, irq);
      }
  
      return 0;
@@@ -1407,13 -1399,13 +1427,13 @@@ static void apic_update_time(struct gue
  
        // raise irq
        PrintDebug("apic %u: core %u: Raising APIC Timer interrupt (periodic=%d) (icnt=%d) (div=%d)\n",
-                  apic->lapic_id.val, info->cpu_id,
+                  apic->lapic_id.val, core->cpu_id,
                   apic->tmr_vec_tbl.tmr_mode, apic->tmr_init_cnt, shift_num);
  
        if (apic_intr_pending(core, priv_data)) {
            PrintDebug("apic %u: core %u: Overriding pending IRQ %d\n", 
-                      apic->lapic_id.val, info->cpu_id, 
-                      apic_get_intr_number(info, priv_data));
+                      apic->lapic_id.val, core->cpu_id, 
+                      apic_get_intr_number(core, priv_data));
        }
  
        if (activate_internal_irq(apic, APIC_TMR_INT) == -1) {
@@@ -78,7 -78,7 +78,8 @@@ enum ranks 
  #define PTRDIFF_T_RANK        rank_long
  
  /* DHH */
--#define EMIT(x) do { (q)->Emit((q), (x)); } while (0)
++#include <geekos/vm_cons.h>
++#define EMIT(x) do { if (q == NULL) {(q)->Emit((q), (x));} } while (0)
  
  /*
   * DHH - As a hack, we buffer this many digits when generating
@@@ -525,10 -525,10 +525,9 @@@ struct bfhead 
  };
  #define BFH(p)        ((struct bfhead *) (p))
  
--static struct bfhead freelist = {     /* List of free buffers */
--    {0, 0},
--    {&freelist, &freelist}
--};
++static struct bfhead freelist;     /* List of free buffers */
++
++
  
  
  #ifdef BufStats
@@@ -1017,6 -1017,6 +1016,14 @@@ void bpool(buf, len
  
      assert(len - sizeof(struct bhead) <= -((bufsize) ESent + 1));
  
++    /* Initialize Free list since compile time static initializations appear to be broken */
++    freelist.bh.prevfree = 0;
++    freelist.bh.bsize = 0;
++    freelist.ql.flink = &freelist;
++    freelist.ql.blink = &freelist;
++
++
++
      /* Clear  the  backpointer at  the start of the block to indicate that
         there  is  no  free  block  prior  to  this   one.    That   blocks
         recombination when the first block in memory is released. */
@@@ -241,18 -241,18 +241,15 @@@ void Main(struct Boot_Info* bootInfo
  {
    struct Kernel_Thread * key_thread;
    struct Kernel_Thread * spkr_thread;
    ulong_t doIBuzz = 0;
  
    Init_BSS();
++  Init_VMCons();
    Init_Screen();
    InitSerial();
--
--  Init_VMCons();
++  Print("Initializing Memory\n");
    Init_Mem(bootInfo);
++  Print("Memory Done\n");
    Init_CRC32();
    Init_TSS();
    Init_Interrupts();
  
  
  
--
--
--
--
    PrintBoth("\n\nHello, Welcome to this horrid output-only serial interface\n");
    PrintBoth("Eventually, this will let us control the VMM\n\n");
   
@@@ -19,7 -19,7 +19,7 @@@
   */
  void Init_Heap(ulong_t start, ulong_t size)
  {
--    /*Print("Creating kernel heap: start=%lx, size=%ld\n", start, size);*/
++    Print("Creating kernel heap: start=%lx, size=%ld\n", start, size);
      bpool((void*) start, size);
  }
  
@@@ -109,7 -109,7 +109,11 @@@ void Init_Mem(struct Boot_Info* bootInf
      ulong_t pageListAddr;
      ulong_t kernEnd;
  
++
++    memset(&s_freeList, 0, sizeof(struct Page_List));
++    
      KASSERT(bootInfo->memSizeKB > 0);
++    Print("Booting with %d KB memory\n", bootInfo->memSizeKB);
  
      /*
       * Before we do anything, switch from setup.asm's temporary GDT
  
      /* Initialize the kernel heap */
      //    Init_Heap(HIGHMEM_START, KERNEL_HEAP_SIZE);
++
++    Print("Initing heap\n");
      Init_Heap(kernEnd, KERNEL_HEAP_SIZE);
  
      Print("%uKB memory detected, %u pages in freelist, %d bytes in kernel heap\n",
--      bootInfo->memSizeKB, g_freePageCount, KERNEL_HEAP_SIZE);
++        bootInfo->memSizeKB, g_freePageCount, KERNEL_HEAP_SIZE);
  }
  
  /*
@@@ -14,6 -14,6 +14,7 @@@
  #include <geekos/int.h>
  #include <geekos/fmtout.h>
  #include <geekos/screen.h>
++#include <geekos/vm_cons.h>
  
  /*
   * Information sources for VT100 and ANSI escape sequences:
@@@ -387,20 -387,20 +388,6 @@@ static void Update_Cursor(void
   * Public functions
   * ---------------------------------------------------------------------- */
  
--/*
-- * Initialize the screen module.
-- */
--void Init_Screen(void)
--{
--    bool iflag = Begin_Int_Atomic();
--
--    s_cons.row = s_cons.col = 0;
--    s_cons.currentAttr = DEFAULT_ATTRIBUTE;
--    Clear_Screen();
--
--    End_Int_Atomic(iflag);
--    Print("Screen Inited\n");
--}
  
  /*
   * Clear the screen using the current attribute.
@@@ -512,7 -512,7 +499,7 @@@ void Put_Buf(const char* buf, ulong_t l
  /* Support for Print(). */
  static void Print_Emit(struct Output_Sink *o, int ch) { Put_Char_Imp(ch); }
  static void Print_Finish(struct Output_Sink *o) { Update_Cursor(); }
--static struct Output_Sink s_outputSink = { &Print_Emit, &Print_Finish };
++static struct Output_Sink s_outputSink;
  
  /*
   * Print to console using printf()-style formatting.
@@@ -542,3 -542,3 +529,22 @@@ void PrintList(const char * fmt, va_lis
      PrintInternal(fmt, ap);
      End_Int_Atomic(iflag);
  }
++
++
++/*
++ * Initialize the screen module.
++ */
++void Init_Screen(void)
++{
++    bool iflag = Begin_Int_Atomic();
++    
++    s_outputSink.Emit = &Print_Emit;
++    s_outputSink.Finish = &Print_Finish;
++
++    s_cons.row = s_cons.col = 0;
++    s_cons.currentAttr = DEFAULT_ATTRIBUTE;
++    Clear_Screen();
++
++    End_Int_Atomic(iflag);
++    Print("Screen Inited\n");
++}