summaryrefslogtreecommitdiff
path: root/task/task.c
diff options
context:
space:
mode:
Diffstat (limited to 'task/task.c')
-rw-r--r--task/task.c281
1 files changed, 0 insertions, 281 deletions
diff --git a/task/task.c b/task/task.c
deleted file mode 100644
index 0e6abc7..0000000
--- a/task/task.c
+++ /dev/null
@@ -1,281 +0,0 @@
-/* Main function for the task server.
- Copyright (C) 2004 Free Software Foundation, Inc.
- Written by Marcus Brinkmann.
-
- This file is part of the GNU Hurd.
-
- The GNU Hurd is free software; you can redistribute it and/or
- modify it under the terms of the GNU Lesser General Public
- License as published by the Free Software Foundation; either
- version 2.1 of the License, or (at your option) any later version.
-
- The GNU Hurd is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- Lesser General Public License for more details.
-
- You should have received a copy of the GNU Lesser General Public
- License along with the GNU C Library; if not, write to the Free
- Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
- 02111-1307 USA. */
-
-#if HAVE_CONFIG_H
-#include <config.h>
-#endif
-
-#include <stdlib.h>
-#include <pthread.h>
-
-#include <hurd/startup.h>
-#include <hurd/wortel.h>
-
-#include "task.h"
-
-
-/* Initialized by the machine-specific startup-code. */
-extern struct hurd_startup_data *__hurd_startup_data;
-
-
-/* The program name. */
-char program_name[] = "task";
-
-
-/* The following functions are required by pthread. */
-
-void
-__attribute__ ((__noreturn__))
-exit (int __status)
-{
- panic ("exit() called");
-}
-
-
-void
-abort (void)
-{
- panic ("abort() called");
-}
-
-
-/* FIXME: Should be elsewhere. Needed by libhurd-slab. */
-int
-getpagesize()
-{
- return l4_min_page_size ();
-}
-
-
-void
-create_bootstrap_caps (hurd_cap_bucket_t bucket)
-{
- error_t err;
- hurd_cap_handle_t cap;
- hurd_cap_obj_t obj;
- task_t task;
-
- l4_accept (L4_UNTYPED_WORDS_ACCEPTOR);
-
- while (1)
- {
- hurd_task_id_t task_id;
- unsigned int nr_threads;
- l4_thread_id_t threads[L4_NUM_MRS];
-
- task_id = wortel_get_task_cap_request (&nr_threads, threads);
-
- if (nr_threads == 0)
- {
- /* This requests the master control capability. */
-
- /* FIXME: Create capability. */
- /* FIXME: Use our control cap for this task here. */
- wortel_get_task_cap_reply (0xf00);
-
- /* This is the last request made. */
- return;
- }
- else
- {
- debug ("Creating task cap for 0x%x:", task_id);
-
- err = task_alloc (task_id, nr_threads, threads, &task);
- if (err)
- panic ("task_alloc: %i", err);
-
- obj = hurd_cap_obj_from_user (task_t, task);
- hurd_cap_obj_unlock (obj);
-
- err = task_id_enter (task);
- if (err)
- panic ("task_id_enter: %i", err);
-
- err = hurd_cap_bucket_inject (bucket, obj, task_id, &cap);
- if (err)
- panic ("hurd_cap_bucket_inject: %i", err);
-
- hurd_cap_obj_lock (obj);
- hurd_cap_obj_drop (obj);
-
- debug (" 0x%x\n", cap);
-
- /* Return CAP. */
- wortel_get_task_cap_reply (cap);
- }
- }
-}
-
-
-/* Get our task ID. */
-static l4_word_t
-get_task_id ()
-{
- return l4_version (l4_my_global_id ());
-}
-
-
-/* Initialize the thread support, and return the L4 thread ID to be
- used for the server thread. */
-static l4_thread_id_t
-setup_threads (void)
-{
- l4_word_t err;
- l4_word_t first_free_thread_no;
- pthread_t thread;
- l4_thread_id_t server_thread;
- l4_thread_id_t main_thread;
- l4_thread_id_t extra_thread;
- l4_thread_id_t pager;
-
- first_free_thread_no = wortel_get_first_free_thread_no ();
-
- /* Use the first free thread as main thread. */
- main_thread = l4_global_id (first_free_thread_no, get_task_id ());
- server_thread = l4_my_global_id ();
-
- /* Create the main thread as an active thread. The scheduler is
- us. */
- err = wortel_thread_control (main_thread, l4_myself (), l4_myself (),
- main_thread,
- (void *)
- (l4_address (__hurd_startup_data->utcb_area)
- + l4_utcb_size ()));
- if (err)
- panic ("could not create main task thread: %s", l4_strerror (err));
-
- /* Switch threads. We still need the current main thread as the
- server thread. */
- pager = l4_pager ();
- switch_thread (server_thread, main_thread);
- l4_set_pager (pager);
-
- /* Create the main thread. */
- err = pthread_create (&thread, 0, 0, 0);
-
- if (err)
- panic ("could not create main thread: %i", err);
-
- /* FIXME: This is unecessary as soon as we implement this properly
- in pthread (of course, within the task server, we will use an
- override to not actually make an RPC to ourselves. */
-
- /* Now add the remaining extra threads to the pool. */
- extra_thread = l4_global_id (first_free_thread_no + 1, get_task_id ());
- err = wortel_thread_control (extra_thread, l4_myself (), l4_myself (),
- extra_thread,
- (void *)
- (l4_address (__hurd_startup_data->utcb_area)
- + 2 * l4_utcb_size ()));
- pthread_pool_add_np (extra_thread);
-
- extra_thread = l4_global_id (first_free_thread_no + 2, get_task_id ());
- err = wortel_thread_control (extra_thread, l4_myself (), l4_myself (),
- extra_thread,
- (void *)
- (l4_address (__hurd_startup_data->utcb_area)
- + 3 * l4_utcb_size ()));
- pthread_pool_add_np (extra_thread);
-
- /* FIXME: Look up the real limits on the KIP, or get them from wortel. */
- thread_set_range (l4_global_id (first_free_thread_no + 3, 1),
- l4_global_id (first_free_thread_no & 0xffff, 1));
-
- return server_thread;
-}
-
-
-void *
-task_server (void *arg)
-{
- hurd_cap_bucket_t bucket = (hurd_cap_bucket_t) arg;
- error_t err;
-
- /* No root object is provided by the task server. */
- /* FIXME: Use a worker timeout. */
- /* FIXME: Use a no-sender callback that deletes the resources from a
- dead task and turns it into a zombie or removes it from the hash
- table completely. */
- err = hurd_cap_bucket_manage_mt (bucket, NULL, 0, 0);
- if (err)
- debug ("bucket_manage_mt failed: %i\n", err);
-
- panic ("bucket_manage_mt returned!");
-}
-
-
-static void
-bootstrap_final (void)
-{
- l4_thread_id_t task_server;
- hurd_cap_handle_t task_cap;
- l4_thread_id_t deva_server;
- hurd_cap_handle_t deva_cap;
-
- wortel_bootstrap_final (&task_server, &task_cap, &deva_server, &deva_cap);
-
- /* FIXME: Do something with the task cap. */
-}
-
-
-int
-main (int argc, char *argv[])
-{
- error_t err;
- l4_thread_id_t server_thread;
- hurd_cap_bucket_t bucket;
- pthread_t manager;
-
- output_debug = 1;
-
- debug ("%s " PACKAGE_VERSION "\n", program_name);
-
- server_thread = setup_threads ();
-
- /* FIXME: Start the scheduler. */
-
- err = task_class_init ();
- if (err)
- panic ("task_class_init: %i", err);
-
- err = hurd_cap_bucket_create (&bucket);
- if (err)
- panic ("bucket_create: %i", err);
-
- create_bootstrap_caps (bucket);
-
- /* Create the server thread and start serving RPC requests. */
- err = pthread_create_from_l4_tid_np (&manager, NULL, server_thread,
- task_server, bucket);
-
- if (err)
- panic ("pthread_create_from_l4_tid_np: %i", err);
- pthread_detach (manager);
-
- bootstrap_final ();
-
- /* FIXME: Eventually, add shutdown support on wortels(?)
- request. */
- while (1)
- l4_sleep (L4_NEVER);
-
- return 0;
-}
generated by cgit v1.2.3 (git 2.39.1) at 2025-07-31 06:50:48 +0000