pthread_init.c
上传用户:tsgydb
上传日期:2007-04-14
资源大小:10674k
文件大小:4k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* ==== pthread_init.c ========================================================
  2.  * Copyright (c) 1993, 1994 by Chris Provenzano, proven@mit.edu
  3.  * All rights reserved.
  4.  *
  5.  * Redistribution and use in source and binary forms, with or without
  6.  * modification, are permitted provided that the following conditions
  7.  * are met:
  8.  * 1. Redistributions of source code must retain the above copyright
  9.  *    notice, this list of conditions and the following disclaimer.
  10.  * 2. Redistributions in binary form must reproduce the above copyright
  11.  *    notice, this list of conditions and the following disclaimer in the
  12.  *    documentation and/or other materials provided with the distribution.
  13.  * 3. All advertising materials mentioning features or use of this software
  14.  *    must display the following acknowledgement:
  15.  *  This product includes software developed by Chris Provenzano.
  16.  * 4. The name of Chris Provenzano may not be used to endorse or promote 
  17.  *   products derived from this software without specific prior written
  18.  *   permission.
  19.  *
  20.  * THIS SOFTWARE IS PROVIDED BY CHRIS PROVENZANO ``AS IS'' AND
  21.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  22.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  23.  * ARE DISCLAIMED.  IN NO EVENT SHALL CHRIS PROVENZANO BE LIABLE FOR ANY 
  24.  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
  25.  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR 
  26.  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
  27.  * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 
  28.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  29.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 
  30.  * SUCH DAMAGE.
  31.  *
  32.  * Description : Pthread_init routine.
  33.  *
  34.  *  1.00 94/09/20 proven
  35.  *      -Started coding this file.
  36.  */
  37. #ifndef lint
  38. static const char rcsid[] = "$Id$";
  39. #endif
  40. #include <pthread.h>
  41. #include <stdlib.h>
  42. #include <string.h>
  43. /* 
  44.  * errno is declared here to prevent the linker from pulling in errno
  45.  * from the C library (and whatever else is in that file). I also use
  46.  * errno as the default location for error numbers for the initial thread
  47.  * giving some backwards compatibility.
  48.  */
  49. #ifdef errno
  50. #undef errno
  51. #endif
  52. #if !defined(M_UNIX)
  53. int errno;
  54. #else
  55. extern int errno;
  56. #endif
  57. /* ==========================================================================
  58.  * pthread_init()
  59.  *
  60.  * We use features of the C++ linker to make sure this function is called
  61.  * before anything else is done in the program.  See init.cc.
  62.  */
  63. void pthread_init(void)
  64. {
  65. struct machdep_pthread machdep_data = MACHDEP_PTHREAD_INIT;
  66. /* Only call this once */
  67. if (pthread_initial) {
  68. return;
  69. }
  70. pthread_pagesize = getpagesize();
  71. /* Initialize the first thread */
  72. if ((pthread_initial = (pthread_t)malloc(sizeof(struct pthread))) &&
  73.   (pthread_current_prio_queue = (struct pthread_prio_queue *)
  74.   malloc(sizeof(struct pthread_prio_queue)))) {
  75. memcpy(&(pthread_initial->machdep_data), &machdep_data, 
  76.   sizeof(machdep_data));
  77. memcpy(&pthread_initial->attr, &pthread_attr_default,
  78.    sizeof(pthread_attr_t));
  79. pthread_initial->pthread_priority = PTHREAD_DEFAULT_PRIORITY;
  80. pthread_initial->state = PS_RUNNING;
  81. pthread_queue_init(&(pthread_initial->join_queue));
  82. pthread_initial->specific_data = NULL;
  83. pthread_initial->specific_data_count = 0;
  84. pthread_initial->cleanup = NULL;
  85. pthread_initial->queue = NULL;
  86. pthread_initial->next = NULL;
  87. pthread_initial->flags = 0;
  88. pthread_initial->pll = NULL;
  89. pthread_initial->sll = NULL;
  90. /* PTHREADS spec says we start with cancellability on and deferred */
  91. SET_PF_CANCEL_STATE(pthread_initial, PTHREAD_CANCEL_ENABLE);
  92. SET_PF_CANCEL_TYPE(pthread_initial, PTHREAD_CANCEL_DEFERRED);
  93. /* Ugly errno hack */
  94. pthread_initial->error_p = &errno;
  95. pthread_initial->error = 0;
  96. pthread_prio_queue_init(pthread_current_prio_queue);
  97. pthread_link_list = pthread_initial;
  98. pthread_run = pthread_initial;
  99. uthread_sigmask = &(pthread_run->sigmask);
  100. /* XXX can I assume the mask and pending siganl sets are empty. */
  101. sigemptyset(&(pthread_initial->sigpending));
  102. sigemptyset(&(pthread_initial->sigmask));
  103. pthread_initial->sigcount = 0;
  104. /* Initialize the signal handler. */
  105. sig_init();
  106. /* Initialize the fd table. */
  107. fd_init();
  108. /* Start the scheduler */
  109. machdep_set_thread_timer(&(pthread_run->machdep_data));
  110. #ifdef M_UNIX
  111. machdep_sys_init();
  112. #endif
  113. return;
  114. }
  115. PANIC();
  116. }