Init distrefs as kernel init time

Fixes sharing on distref's lazy init flag

Init distrefs as kernel init time
726b49a0 · Austin Clements · 0bfacd12 · 726b49a0 · 726b49a0
--- a/kernel/distref.cc
+++ b/kernel/distref.cc
@@ -241,23 +241,17 @@ distref_wakeup()
 void
 distref_check(distributed_refcnt *dr)
 {
-  static bool initialized;
-  static spinlock initlock("distref initlock");
+  // Add it to the maybe-free list
+  if (workers.load()->enqueue(dr))
+    distref_wakeup();
+}

-  if (!initialized) {
-    acquire(&initlock);
-    if (!initialized) {
+void
+initdistref()
+{
  struct proc *t = threadalloc(distref_thread, nullptr);
  acquire(&t->lock);
  safestrcpy(t->name, "distref_thread", sizeof(t->name));
  addrun(t);
  release(&t->lock);
-      initialized = true;
-    }
-    release(&initlock);
-  }
-
-  // Add it to the maybe-free list
-  if (workers.load()->enqueue(dr))
-    distref_wakeup();
 }
--- a/kernel/main.cc
+++ b/kernel/main.cc
@@ -40,6 +40,7 @@ void initidle(void);
 void initcpprt(void);
 void initfutex(void);
 void initcmdline(void);
+void initdistref(void);
 void idleloop(void);

 #define IO_RTC  0x70
@@ -161,6 +162,7 @@ cmain(u64 mbmagic, u64 mbaddr)
  initsched();     // scheduler run queues
  initidle();
  initgc();        // gc epochs and threads
+  initdistref();   // distref collector thread
  initdisk();      // disk
  initbio();       // buffer cache
  initinode();     // inode cache