CPU state tracking
[akaros.git] / kern / src / process.c
index cdeede6..ee04506 100644 (file)
@@ -82,8 +82,8 @@ static void put_free_pid(pid_t pid)
        spin_unlock(&pid_bmask_lock);
 }
 
-/* 'resume' is the time of the most recent onlining.  'total' is the amount of
- * time consumed up to and including the current offlining.
+/* 'resume' is the time int ticks of the most recent onlining.  'total' is the
+ * amount of time in ticks consumed up to and including the current offlining.
  *
  * We could move these to the map and unmap of vcores, though not every place
  * uses that (SCPs, in particular).  However, maps/unmaps happen remotely;
@@ -93,19 +93,19 @@ static void put_free_pid(pid_t pid)
 void vcore_account_online(struct proc *p, uint32_t vcoreid)
 {
        struct vcore *vc = &p->procinfo->vcoremap[vcoreid];
-       vc->resume = nsec();
+       vc->resume_ticks = read_tsc();
 }
 
 void vcore_account_offline(struct proc *p, uint32_t vcoreid)
 {
        struct vcore *vc = &p->procinfo->vcoremap[vcoreid];
-       vc->total += nsec() - vc->resume;
+       vc->total_ticks += read_tsc() - vc->resume_ticks;
 }
 
 uint64_t vcore_account_gettotal(struct proc *p, uint32_t vcoreid)
 {
        struct vcore *vc = &p->procinfo->vcoremap[vcoreid];
-       return vc->total;
+       return vc->total_ticks;
 }
 
 /* While this could be done with just an assignment, this gives us the
@@ -256,6 +256,14 @@ void proc_init(void)
        atomic_init(&num_envs, 0);
 }
 
+void proc_set_progname(struct proc *p, char *name)
+{
+       /* might have an issue if a dentry name isn't null terminated, and we'd get
+        * extra junk up to progname_sz. */
+       strncpy(p->progname, name, PROC_PROGNAME_SZ);
+       p->progname[PROC_PROGNAME_SZ - 1] = '\0';
+}
+
 /* Be sure you init'd the vcore lists before calling this. */
 static void proc_init_procinfo(struct proc* p)
 {
@@ -275,10 +283,8 @@ static void proc_init_procinfo(struct proc* p)
        p->procinfo->num_vcores = 0;
        p->procinfo->is_mcp = FALSE;
        p->procinfo->coremap_seqctr = SEQCTR_INITIALIZER;
-       /* For now, we'll go up to the max num_cpus (at runtime).  In the future,
-        * there may be cases where we can have more vcores than num_cpus, but for
-        * now we'll leave it like this. */
-       for (int i = 0; i < num_cpus; i++) {
+       /* It's a bug in the kernel if we let them ask for more than max */
+       for (int i = 0; i < p->procinfo->max_vcores; i++) {
                TAILQ_INSERT_TAIL(&p->inactive_vcs, &p->procinfo->vcoremap[i], list);
        }
 }
@@ -296,7 +302,7 @@ static void proc_init_procdata(struct proc *p)
  * Errors include:
  *  - ENOFREEPID if it can't get a PID
  *  - ENOMEM on memory exhaustion */
-error_t proc_alloc(struct proc **pp, struct proc *parent)
+error_t proc_alloc(struct proc **pp, struct proc *parent, int flags)
 {
        error_t r;
        struct proc *p;
@@ -378,13 +384,24 @@ error_t proc_alloc(struct proc **pp, struct proc *parent)
        p->open_files.max_fdset = NR_FILE_DESC_DEFAULT;
        p->open_files.fd = p->open_files.fd_array;
        p->open_files.open_fds = (struct fd_set*)&p->open_files.open_fds_init;
+       if (parent) {
+               if (flags & PROC_DUP_FGRP)
+                       clone_files(&parent->open_files, &p->open_files);
+       } else {
+               /* no parent, we're created from the kernel */
+               assert(insert_file(&p->open_files, dev_stdin,  0, TRUE) == 0);
+               assert(insert_file(&p->open_files, dev_stdout, 1, TRUE) == 1);
+               assert(insert_file(&p->open_files, dev_stderr, 2, TRUE) == 2);
+       }
        /* Init the ucq hash lock */
        p->ucq_hashlock = (struct hashlock*)&p->ucq_hl_noref;
        hashlock_init_irqsave(p->ucq_hashlock, HASHLOCK_DEFAULT_SZ);
 
        atomic_inc(&num_envs);
        frontend_proc_init(p);
-       plan9setup(p, parent);
+       /* this does all the 9ns setup, much of which is done throughout this func
+        * for the VFS, including duping the fgrp */
+       plan9setup(p, parent, flags);
        devalarm_init(p);
        TAILQ_INIT(&p->abortable_sleepers);
        spinlock_init_irqsave(&p->abort_list_lock);
@@ -414,14 +431,11 @@ struct proc *proc_create(struct file *prog, char **argv, char **envp)
 {
        struct proc *p;
        error_t r;
-       if ((r = proc_alloc(&p, current)) < 0)
+       if ((r = proc_alloc(&p, current, 0 /* flags */)) < 0)
                panic("proc_create: %e", r);    /* one of 3 quaint usages of %e */
+       proc_set_progname(p, file_name(prog));
        procinfo_pack_args(p->procinfo, argv, envp);
        assert(load_elf(p, prog) == 0);
-       /* Connect to stdin, stdout, stderr */
-       assert(insert_file(&p->open_files, dev_stdin,  0) == 0);
-       assert(insert_file(&p->open_files, dev_stdout, 0) == 1);
-       assert(insert_file(&p->open_files, dev_stderr, 0) == 2);
        __proc_ready(p);
        return p;
 }
@@ -446,6 +460,7 @@ static void __proc_free(struct kref *kref)
        assert(kref_refcnt(&p->p_kref) == 0);
        assert(TAILQ_EMPTY(&p->alarmset.list));
 
+       p->progname[0] = 0;
        cclose(p->dot);
        cclose(p->slash);
        p->dot = p->slash = 0; /* catch bugs */
@@ -734,6 +749,7 @@ void __proc_startcore(struct proc *p, struct user_context *ctx)
        __set_proc_current(p);
        /* Clear the current_ctx, since it is no longer used */
        current_ctx = 0;        /* TODO: might not need this... */
+       __set_cpu_state(pcpui, CPU_STATE_USER);
        proc_pop_ctx(ctx);
 }
 
@@ -2202,10 +2218,18 @@ void print_allpids(void)
        {
                struct proc *p = (struct proc*)item;
                assert(p);
-               printk("%8d %-10s %6d\n", p->pid, procstate2str(p->state), p->ppid);
+               /* this actually adds an extra space, since no progname is ever
+                * PROGNAME_SZ bytes, due to the \0 counted in PROGNAME. */
+               printk("%8d %-*s %-10s %6d\n", p->pid, PROC_PROGNAME_SZ, p->progname,
+                      procstate2str(p->state), p->ppid);
        }
-       printk("     PID STATE      Parent    \n");
-       printk("------------------------------\n");
+       char dashes[PROC_PROGNAME_SZ];
+       memset(dashes, '-', PROC_PROGNAME_SZ);
+       dashes[PROC_PROGNAME_SZ - 1] = '\0';
+       /* -5, for 'Name ' */
+       printk("     PID Name %-*s State      Parent    \n",
+              PROC_PROGNAME_SZ - 5, "");
+       printk("------------------------------%s\n", dashes);
        spin_lock(&pid_hash_lock);
        hash_for_each(pid_hash, print_proc_state);
        spin_unlock(&pid_hash_lock);
@@ -2224,6 +2248,7 @@ void print_proc_info(pid_t pid)
        spinlock_debug(&p->proc_lock);
        //spin_lock(&p->proc_lock); // No locking!!
        printk("struct proc: %p\n", p);
+       printk("Program name: %s\n", p->progname);
        printk("PID: %d\n", p->pid);
        printk("PPID: %d\n", p->ppid);
        printk("State: %s (%p)\n", procstate2str(p->state), p->state);
@@ -2244,7 +2269,7 @@ void print_proc_info(pid_t pid)
                printk("\tVcore %d\n", vcore2vcoreid(p, vc_i));
        printk("Nsec Online, up to the last offlining:\n------------------------");
        for (int i = 0; i < p->procinfo->max_vcores; i++) {
-               uint64_t vc_time = vcore_account_gettotal(p, i);
+               uint64_t vc_time = tsc2nsec(vcore_account_gettotal(p, i));
                if (i % 4 == 0)
                        printk("\n");
                printk("  VC %3d: %14llu", i, vc_time);
@@ -2260,7 +2285,8 @@ void print_proc_info(pid_t pid)
        struct files_struct *files = &p->open_files;
        spin_lock(&files->lock);
        for (int i = 0; i < files->max_files; i++)
-               if (files->fd[i].fd_file) {
+               if (GET_BITMASK_BIT(files->open_fds->fds_bits, i) &&
+                   (files->fd[i].fd_file)) {
                        printk("\tFD: %02d, File: %p, File name: %s\n", i,
                               files->fd[i].fd_file, file_name(files->fd[i].fd_file));
                }