开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
mevans
资源名称：mysql-3.23.35.tar.gz　[点击查看]
上传用户：tsgydb
上传日期：2007-04-14
资源大小：10674k
文件大小：19k
源码类别：

MySQL数据库

开发平台：

Visual C++

mevans：源码内容
  1. =A0
  2. Attached are several patches for pthreads-1_60_beta6.  The patches fall
  3. into 3 catagories:
  5.   1. Crashes and hangs.
  6.   2. Missing functionality (namely flock())
  7.   3. Use of POSIX reentrant safe routines.
  9. Most of the patches contain a comment as to why the change was made.
  10. The one major exception is to fd_kern.c at line 257 (unpatched).  The
  11. change to that line is to fix a "hang" that prevents threads for
  12. scheduling for an hour if there is no external I/O event.
  14. I also include patches that modify several functions to use POSIX
  15. reentrant safe routines.  I know that MIT pthreads implements routine
  16. like gethostbyname in a thread safe manner, but we're pretty, um, anal
  17. about trying to keep our code as portable as possible.  By excluding
  18. using routines that are not reentrant safe according to the PTHREAD
  19. safe, it's easy for us to stub out the unsafe routines and catch
  20. non-compliant code.  I almost left these patches out, but I'm hoping
  21. they'll be adopted.  :-)
  23. WARNING:  None of the MIT pthreads routines that convert floats/doubles
  24. between their native forms and strings are thread safe!  (i.e printf,
  25. sprintf, fprintf, atod, strtod, etc)  I have replacements, but I need to
  26. check with the author of the replacements and my employer.
  28. Mark Evans
  30. ------------69CDAAF52A3566916F8ED01A0
  31. Content-Disposition: inline; filename="pthreads-1_60_beta6.patch"
  32. Content-Type: text/plain; charset=us-ascii; name="pthreads-1_60_beta6.patch"
  33. Content-Transfer-Encoding: 7bit
  35. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/config/config.h.in pthreads-1_60_beta6+/config/config.h.in
  36. *** pthreads-1_60_beta6/config/config.h.in Thu Mar 21 21:30:04 1996
  37. --- pthreads-1_60_beta6+/config/config.h.in Sat Mar 15 14:08:55 1997
  38. ***************
  39. *** 137,142 ****
  40. --- 137,145 ----
  41.   /* Define if you have the syscall_ftruncate function.  */
  42.   #undef HAVE_SYSCALL_FTRUNCATE
  43.   
  44. + /* Define if you have the syscall_flock function.  */
  45. + #undef HAVE_SYSCALL_FLOCK
  46. + 
  47.   /* Define if you have the syscall_getdents function.  */
  48.   #undef HAVE_SYSCALL_GETDENTS
  49.   
  50. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/config/configure.in pthreads-1_60_beta6+/config/configure.in
  51. *** pthreads-1_60_beta6/config/configure.in Wed Nov 13 14:03:08 1996
  52. --- pthreads-1_60_beta6+/config/configure.in Sat Mar 15 14:08:55 1997
  53. ***************
  54. *** 241,247 ****
  55.   
  56.   PTHREADS_CHECK_SYSCALLS(open write read creat close fcntl lseek dup2 dup pipe
  57.    fchmod fchown execve fstat lstat link unlink chdir chown chmod stat
  58. !  rename select getdtablesize ioctl ftruncate
  59.    dnl - signals
  60.    sigsuspend sigaction sigpause sigprocmask ksigaction
  61.    dnl - directory reading
  62. --- 241,247 ----
  63.   
  64.   PTHREADS_CHECK_SYSCALLS(open write read creat close fcntl lseek dup2 dup pipe
  65.    fchmod fchown execve fstat lstat link unlink chdir chown chmod stat
  66. !  rename select getdtablesize ioctl ftruncate flock
  67.    dnl - signals
  68.    sigsuspend sigaction sigpause sigprocmask ksigaction
  69.    dnl - directory reading
  70. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/gen/directory.c pthreads-1_60_beta6+/gen/directory.c
  71. *** pthreads-1_60_beta6/gen/directory.c Sat May 20 10:55:34 1995
  72. --- pthreads-1_60_beta6+/gen/directory.c Sat Mar 15 14:08:55 1997
  73. ***************
  74. *** 251,262 ****
  75. --- 251,266 ----
  76.   /*
  77.    * Seek to an entry in a directory.
  78.    * _seekdir is in telldir.c so that it can share opaque data structures.
  79. +  *
  80. +  * Use the POSIX reentrant safe readdir_r to simplify varifying POSIX
  81. +  * thread-safe compliance.
  82.    */
  83.   void seekdir(DIR * dirp, long loc)
  84.   {
  85.    register struct ddloc ** prevlp;
  86.    register struct ddloc * lp;
  87.    struct dirent * dp;
  88. +  struct dirent   de;
  89.   
  90.    pthread_mutex_lock (dirp->dd_lock);
  91.    prevlp = (struct ddloc **)&(dirp->dd_ddloc);
  92. ***************
  93. *** 277,283 ****
  94.    dirp->dd_seek = lp->loc_seek;
  95.    dirp->dd_loc = 0;
  96.    while (dirp->dd_loc < lp->loc_loc) {
  97. !  if (!(dp = readdir(dirp))) {
  98.    *prevlp = lp->loc_next;
  99.    break;
  100.    }
  101. --- 281,287 ----
  102.    dirp->dd_seek = lp->loc_seek;
  103.    dirp->dd_loc = 0;
  104.    while (dirp->dd_loc < lp->loc_loc) {
  105. !  if (readdir_r(dirp, &de, &dp)) {
  106.    *prevlp = lp->loc_next;
  107.    break;
  108.    }
  109. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/gen/getcwd.c pthreads-1_60_beta6+/gen/getcwd.c
  110. *** pthreads-1_60_beta6/gen/getcwd.c Sat Sep  2 17:39:30 1995
  111. --- pthreads-1_60_beta6+/gen/getcwd.c Sat Mar 15 14:08:55 1997
  112. ***************
  113. *** 50,67 ****
  114.    (dp->d_name[0] == '.' && (dp->d_name[1] == '' || 
  115.        dp->d_name[1] == '.' && dp->d_name[2] == ''))
  116.   
  117.   char *
  118.   getcwd(pt, size)
  119.    char *pt;
  120.    size_t size;
  121.   {
  122. -  register struct dirent *dp;
  123.    register DIR *dir;
  124.    register dev_t dev;
  125.    register ino_t ino;
  126.    register int first;
  127.    register char *bpt, *bup;
  128.    struct stat s;
  129.    dev_t root_dev;
  130.    ino_t root_ino;
  131.    size_t ptsize, upsize;
  132. --- 50,71 ----
  133.    (dp->d_name[0] == '.' && (dp->d_name[1] == '' || 
  134.        dp->d_name[1] == '.' && dp->d_name[2] == ''))
  135.   
  136. + /* Only use reentrant safe routines to simplify varifying POSIX thread-safe
  137. +  * compliance. (mevans).
  138. +  */
  139.   char *
  140.   getcwd(pt, size)
  141.    char *pt;
  142.    size_t size;
  143.   {
  144.    register DIR *dir;
  145.    register dev_t dev;
  146.    register ino_t ino;
  147.    register int first;
  148.    register char *bpt, *bup;
  149.    struct stat s;
  150. +  struct dirent *dp;
  151. +  struct dirent  de;
  152.    dev_t root_dev;
  153.    ino_t root_ino;
  154.    size_t ptsize, upsize;
  155. ***************
  156. *** 166,179 ****
  157.    save_errno = 0;
  158.    if (s.st_dev == dev) {
  159.    for (;;) {
  160. !  if (!(dp = readdir(dir)))
  161.    goto notfound;
  162.    if (dp->d_fileno == ino)
  163.    break;
  164.    }
  165.    } else
  166.    for (;;) {
  167. !  if (!(dp = readdir(dir)))
  168.    goto notfound;
  169.    if (ISDOT(dp))
  170.    continue;
  171. --- 170,183 ----
  172.    save_errno = 0;
  173.    if (s.st_dev == dev) {
  174.    for (;;) {
  175. !  if (readdir_r(dir, &de, &dp))
  176.    goto notfound;
  177.    if (dp->d_fileno == ino)
  178.    break;
  179.    }
  180.    } else
  181.    for (;;) {
  182. !  if (readdir_r(dir, &de, &dp))
  183.    goto notfound;
  184.    if (ISDOT(dp))
  185.    continue;
  186. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/include/syslog.h pthreads-1_60_beta6+/include/syslog.h
  187. *** pthreads-1_60_beta6/include/syslog.h Mon Sep 26 21:26:29 1994
  188. --- pthreads-1_60_beta6+/include/syslog.h Sat Mar 15 14:08:56 1997
  189. ***************
  190. *** 9,14 ****
  191. --- 9,16 ----
  192.   #ifndef SYSLOG_H
  193.   #define SYSLOG_H
  194.   
  195. + /* Added __[BEGIN/END]_DECLS so this file would work with C++. (mevans) */
  196. + #include <sys/cdefs.h>
  197.   #include <stdarg.h>
  198.   
  199.   /* Discipline: openlog(), closelog(), and setlogmask() are not thread-safe
  200. ***************
  201. *** 84,95 ****
  202. --- 86,101 ----
  203.   #define LOG_NDELAY 0x08 /* don't delay open */
  204.   #define LOG_NOWAIT 0x10 /* if forking to log on console, don't wait() */
  205.   
  206. + __BEGIN_DECLS
  207. + 
  208.   /* Syslogging functions. */
  209.   void syslog(int pri, char *fmt, ...);
  210.   void vsyslog(int pri, char *fmt, va_list args);
  211.   void openlog(char *ident, int logstat, int logfac);
  212.   void closelog(void);
  213.   int setlogmask(int pmask);
  214. + 
  215. + __END_DECLS
  216.   
  217.   #endif
  218.   
  219. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/machdep/engine-i386-linux-1.0.c pthreads-1_60_beta6+/machdep/engine-i386-linux-1.0.c
  220. *** pthreads-1_60_beta6/machdep/engine-i386-linux-1.0.c Mon Oct 21 20:39:13 1996
  221. --- pthreads-1_60_beta6+/machdep/engine-i386-linux-1.0.c Sat Mar 15 14:08:56 1997
  222. ***************
  223. *** 142,147 ****
  224. --- 142,149 ----
  225.        * machdep_pthread_start().
  226.        */
  227.       machdep_pthread->machdep_state->__pc = (char *)machdep_pthread_start;
  228. +     machdep_pthread->machdep_state->__bp = (char *)0;/* So the backtrace
  229. +                                                       * is sensible (mevans) */
  230.   
  231.       /* Stack starts high and builds down. */
  232.       machdep_pthread->machdep_state->__sp =
  233. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/machdep/syscall-i386-linux-1.0.S pthreads-1_60_beta6+/machdep/syscall-i386-linux-1.0.S
  234. *** pthreads-1_60_beta6/machdep/syscall-i386-linux-1.0.S Mon Oct 21 22:17:32 1996
  235. --- pthreads-1_60_beta6+/machdep/syscall-i386-linux-1.0.S Sat Mar 15 14:08:56 1997
  236. ***************
  237. *** 148,156 ****
  238.   /* =========================================================================
  239.    * exit  1 select  82
  240.    * fork  2 socketcall 102
  241. !  * read  3 readv 145
  242. !  * write  4 writev 146
  243. !  * open  5
  244.    * creat  8
  245.    * link  9
  246.    * unlink 10
  247. --- 148,156 ----
  248.   /* =========================================================================
  249.    * exit  1 select  82
  250.    * fork  2 socketcall 102
  251. !  * read  3 flock 143
  252. !  * write  4 readv 145
  253. !  * open  5 writev 146
  254.    * creat  8
  255.    * link  9
  256.    * unlink 10
  257. ***************
  258. *** 390,394 ****
  259. --- 390,401 ----
  260.    */
  261.   #ifdef HAVE_SYSCALL_WRITEV 
  262.   SYSCALL3(writev)
  263. + #endif
  264. + 
  265. + /* ==========================================================================
  266. +  * machdep_sys_flock()
  267. +  */
  268. + #ifdef HAVE_SYSCALL_FLOCK
  269. + SYSCALL2(flock)
  270.   #endif
  271.   
  272. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/net/gethostbyname.c pthreads-1_60_beta6+/net/gethostbyname.c
  273. *** pthreads-1_60_beta6/net/gethostbyname.c Mon Apr 22 22:41:21 1996
  274. --- pthreads-1_60_beta6+/net/gethostbyname.c Sat Mar 15 14:08:58 1997
  275. ***************
  276. *** 146,161 ****
  277.   {
  278.    char **alias;
  279.    FILE *fp = NULL;
  280.   
  281.    pthread_mutex_lock(&host_iterate_lock);
  282.    sethostent(0);
  283. !  while ((result = gethostent_r(result, buf, bufsize, errval)) != NULL) {
  284.    /* Check the entry's name and aliases against the given name. */
  285.    if (strcasecmp(result->h_name, name) == 0)
  286.    break;
  287.    for (alias = result->h_aliases; *alias; alias++) {
  288. !  if (strcasecmp(*alias, name) == 0)
  289.    break;
  290.    }
  291.    }
  292.    pthread_mutex_unlock(&host_iterate_lock);
  293. --- 146,166 ----
  294.   {
  295.    char **alias;
  296.    FILE *fp = NULL;
  297. +  int fFound = FALSE;
  298.   
  299.    pthread_mutex_lock(&host_iterate_lock);
  300.    sethostent(0);
  301. !  while (!fFound && (result = gethostent_r(result, buf, bufsize, errval))
  302. !  != NULL) {
  303.    /* Check the entry's name and aliases against the given name. */
  304.    if (strcasecmp(result->h_name, name) == 0)
  305.    break;
  306.    for (alias = result->h_aliases; *alias; alias++) {
  307. !  if (strcasecmp(*alias, name) == 0) {
  308. !  /* fFound will exit while loop. (mevans). */
  309. !  fFound = TRUE;
  310.    break;
  311. +  }
  312.    }
  313.    }
  314.    pthread_mutex_unlock(&host_iterate_lock);
  315. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/net/res_debug.c pthreads-1_60_beta6+/net/res_debug.c
  316. *** pthreads-1_60_beta6/net/res_debug.c Thu Feb 23 22:42:35 1995
  317. --- pthreads-1_60_beta6+/net/res_debug.c Sat Mar 15 14:08:58 1997
  318. ***************
  319. *** 375,380 ****
  320. --- 375,383 ----
  321.   
  322.   /*
  323.    * Print resource record fields in human readable form.
  324. +  *
  325. +  * Removed calls to non-reentrant routines to simplify varifying
  326. +  * POSIX thread-safe implementations. (mevans).
  327.    */
  328.   char *
  329.   p_rr(cp, msg, file)
  330. ***************
  331. *** 386,391 ****
  332. --- 389,395 ----
  333.    char *cp1, *cp2;
  334.    u_long tmpttl, t;
  335.    int lcnt;
  336. +  char buf[32];
  337.   
  338.    if ((cp = p_fqname(cp, msg, file)) == NULL)
  339.    return (NULL); /* compression error */
  340. ***************
  341. *** 413,426 ****
  342.    case C_HS:
  343.    bcopy(cp, (char *)&inaddr, sizeof(inaddr));
  344.    if (dlen == 4) {
  345. !  fprintf(file,"t%s", inet_ntoa(inaddr));
  346.    cp += dlen;
  347.    } else if (dlen == 7) {
  348.    char *address;
  349.    u_char protocol;
  350.    u_short port;
  351.   
  352. !  address = inet_ntoa(inaddr);
  353.    cp += sizeof(inaddr);
  354.    protocol = *(u_char*)cp;
  355.    cp += sizeof(u_char);
  356. --- 417,432 ----
  357.    case C_HS:
  358.    bcopy(cp, (char *)&inaddr, sizeof(inaddr));
  359.    if (dlen == 4) {
  360. !  fprintf(file,"t%s",
  361. !  inet_ntoa_r(inaddr, buf, sizeof(buf)));
  362.    cp += dlen;
  363.    } else if (dlen == 7) {
  364.    char *address;
  365.    u_char protocol;
  366.    u_short port;
  367.   
  368. !  address = inet_ntoa_r(inaddr,
  369. !  buf, sizeof(buf));
  370.    cp += sizeof(inaddr);
  371.    protocol = *(u_char*)cp;
  372.    cp += sizeof(u_char);
  373. ***************
  374. *** 524,530 ****
  375.    bcopy(cp, (char *)&inaddr, sizeof(inaddr));
  376.    cp += sizeof(u_long);
  377.    fprintf(file, "t%s %s ( ",
  378. !  inet_ntoa(inaddr),
  379.    deproto((int) *cp));
  380.    cp += sizeof(u_char);
  381.    n = 0;
  382. --- 530,536 ----
  383.    bcopy(cp, (char *)&inaddr, sizeof(inaddr));
  384.    cp += sizeof(u_long);
  385.    fprintf(file, "t%s %s ( ",
  386. !  inet_ntoa_r(inaddr, buf, sizeof(buf)),
  387.    deproto((int) *cp));
  388.    cp += sizeof(u_char);
  389.    n = 0;
  390. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/pthreads/fd_kern.c pthreads-1_60_beta6+/pthreads/fd_kern.c
  391. *** pthreads-1_60_beta6/pthreads/fd_kern.c Tue Oct  1 12:26:48 1996
  392. --- pthreads-1_60_beta6+/pthreads/fd_kern.c Sat Mar 15 14:09:00 1997
  393. ***************
  394. *** 215,221 ****
  395.    * Called when there is no active thread to run.
  396.    */
  397.   extern struct timeval __fd_kern_wait_timeout;
  398. ! 
  399.   void fd_kern_wait()
  400.   {
  401.    fd_set fd_set_read, fd_set_write, fd_set_except;
  402. --- 215,221 ----
  403.    * Called when there is no active thread to run.
  404.    */
  405.   extern struct timeval __fd_kern_wait_timeout;
  406. ! extern volatile sig_atomic_t sig_to_process;
  407.   void fd_kern_wait()
  408.   {
  409.    fd_set fd_set_read, fd_set_write, fd_set_except;
  410. ***************
  411. *** 254,260 ****
  412.   
  413.    machdep_unset_thread_timer(NULL); 
  414.    __fd_kern_wait_timeout.tv_usec = 0;
  415. !  __fd_kern_wait_timeout.tv_sec = 3600;
  416.   
  417.    machdep_sys_sigprocmask(SIG_UNBLOCK, &sig_to_block, &oset);
  418.   
  419. --- 254,260 ----
  420.   
  421.    machdep_unset_thread_timer(NULL); 
  422.    __fd_kern_wait_timeout.tv_usec = 0;
  423. !  __fd_kern_wait_timeout.tv_sec = (sig_to_process) ? 0 : 3600;
  424.   
  425.    machdep_sys_sigprocmask(SIG_UNBLOCK, &sig_to_block, &oset);
  426.   
  427. ***************
  428. *** 726,731 ****
  429. --- 726,753 ----
  430.    return(ret);
  431.   }
  432.   
  433. + #if defined (HAVE_SYSCALL_FLOCK)
  434. + /* ==========================================================================
  435. +  * flock()
  436. +  *
  437. +  *  Added (mevans)
  438. +  */
  439. + int flock(int fd, int operation)
  440. + {
  441. +  int ret;
  442. + 
  443. +  if ((ret = fd_lock(fd, FD_RDWR, NULL)) == OK) {
  444. +  if ((ret = machdep_sys_flock(fd_table[fd]->fd.i,
  445. +  operation)) < OK) {
  446. +  SET_ERRNO(-ret);
  447. +  ret = NOTOK;
  448. +  }
  449. +  fd_unlock(fd, FD_RDWR);
  450. +  }
  451. +  return(ret);
  452. + }
  453. + #endif
  454. + 
  455.   /* ==========================================================================
  456.    * pipe()
  457.    */
  458. ***************
  459. *** 1126,1132 ****
  460.    /* Get the error, this function should not fail */
  461.    machdep_sys_getsockopt(fd_table[fd]->fd.i, SOL_SOCKET,
  462.      SO_ERROR, &ret, &tmpnamelen); 
  463. !  SET_ERRNO(-ret);
  464.    ret = NOTOK;
  465.    }
  466.               } else {
  467. --- 1148,1155 ----
  468.    /* Get the error, this function should not fail */
  469.    machdep_sys_getsockopt(fd_table[fd]->fd.i, SOL_SOCKET,
  470.      SO_ERROR, &ret, &tmpnamelen);
  471. !  /* ret is already positive (mevans) */
  472. !  SET_ERRNO(ret);
  473.    ret = NOTOK;
  474.    }
  475.               } else {
  476. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/pthreads/malloc.c pthreads-1_60_beta6+/pthreads/malloc.c
  477. *** pthreads-1_60_beta6/pthreads/malloc.c Thu Mar  9 21:06:43 1995
  478. --- pthreads-1_60_beta6+/pthreads/malloc.c Sat Mar 15 14:09:00 1997
  479. ***************
  480. *** 196,204 ****
  481.    else
  482.    n = n - x;
  483.      if (n) {
  484. !     if (sbrk(n) == (char *)-1)
  485.    return (NULL);
  486.    }
  487.    bucket = 0;
  488.    amt = 8;
  489.    while (pagesz > amt) {
  490. --- 196,207 ----
  491.    else
  492.    n = n - x;
  493.      if (n) {
  494. !  if (sbrk(n) == (char *)-1) {
  495. !  /* Unlock before returning (mevans) */
  496. !  pthread_mutex_unlock(mutex);
  497.    return (NULL);
  498.    }
  499. +  }
  500.    bucket = 0;
  501.    amt = 8;
  502.    while (pagesz > amt) {
  503. ***************
  504. *** 363,366 ****
  505. --- 366,382 ----
  506.    free(cp);
  507.   
  508.      return (res);
  509. + }
  510. + /* ==========================================================================
  511. +  * calloc()
  512. +  *
  513. +  * Added to ensure pthread's allocation is used (mevans).
  514. +  */
  515. + void *calloc(size_t nmemb, size_t size)
  516. + {
  517. +  void *p;
  518. +  size *= nmemb;
  519. +  p = malloc(size);
  520. +  if (p) memset(p, 0, size);
  521. +  return (p);
  522.   }
  523. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/pthreads/select.c pthreads-1_60_beta6+/pthreads/select.c
  524. *** pthreads-1_60_beta6/pthreads/select.c Sat Jul  6 21:58:55 1996
  525. --- pthreads-1_60_beta6+/pthreads/select.c Sat Mar 15 14:09:00 1997
  526. ***************
  527. *** 165,176 ****
  528.    pthread_resched_resume(PS_SELECT_WAIT);
  529.   
  530.    /* We're awake */
  531. -  CLEAR_PF_DONE_EVENT(pthread_run);
  532.    if (sleep_cancel(pthread_run) == NOTOK) {
  533.    ret = OK;
  534.    } else {
  535.    ret = data.nfds;
  536.    }
  537.    } else {
  538.    pthread_resched_resume(PS_SELECT_WAIT);
  539.    CLEAR_PF_DONE_EVENT(pthread_run);
  540. --- 165,180 ----
  541.    pthread_resched_resume(PS_SELECT_WAIT);
  542.   
  543.    /* We're awake */
  544.    if (sleep_cancel(pthread_run) == NOTOK) {
  545.    ret = OK;
  546.    } else {
  547.    ret = data.nfds;
  548.    }
  549. +  /* Moving this after the sleep_cancel() seemed
  550. +   * to fix intermittent crashes during heavy
  551. +   * socket use. (mevans)
  552. +   */
  553. +  CLEAR_PF_DONE_EVENT(pthread_run);
  554.    } else {
  555.    pthread_resched_resume(PS_SELECT_WAIT);
  556.    CLEAR_PF_DONE_EVENT(pthread_run);
  557. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/pthreads/signal.c pthreads-1_60_beta6+/pthreads/signal.c
  558. *** pthreads-1_60_beta6/pthreads/signal.c Tue Mar 12 21:33:17 1996
  559. --- pthreads-1_60_beta6+/pthreads/signal.c Sat Mar 15 14:09:00 1997
  560. ***************
  561. *** 65,71 ****
  562.    */
  563.   
  564.   static sig_atomic_t signum_to_process[SIGMAX + 1] = { 0, };
  565. ! static sig_atomic_t sig_to_process = 0;
  566.   
  567.   /* static volatile sigset_t sig_to_process; */
  568.   static volatile int sig_count = 0;
  569. --- 65,71 ----
  570.    */
  571.   
  572.   static sig_atomic_t signum_to_process[SIGMAX + 1] = { 0, };
  573. ! volatile sig_atomic_t sig_to_process = 0;
  574.   
  575.   /* static volatile sigset_t sig_to_process; */
  576.   static volatile int sig_count = 0;
  577. ***************
  578. *** 303,309 ****
  579.    break;
  580.    case NOTOK:
  581.    /* Do the registered action, no threads were sleeping */
  582. !  sigdefault(sig);
  583.    break;
  584.    } 
  585.    break;
  586. --- 303,317 ----
  587.    break;
  588.    case NOTOK:
  589.    /* Do the registered action, no threads were sleeping */
  590. !  /* There is a timing window that gets
  591. !   * here when no threads are on the
  592. !   * sleep queue.  This is a quick fix.
  593. !   * The real problem is possibly related
  594. !   * to heavy use of condition variables
  595. !   * with time outs.
  596. !   * (mevans)
  597. !   *sigdefault(sig);
  598. !   */
  599.    break;
  600.    } 
  601.    break;
  602. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/stdio/setvbuf.c pthreads-1_60_beta6+/stdio/setvbuf.c
  603. *** pthreads-1_60_beta6/stdio/setvbuf.c Sat Sep  3 20:58:36 1994
  604. --- pthreads-1_60_beta6+/stdio/setvbuf.c Sat Mar 15 14:09:00 1997
  605. ***************
  606. *** 142,148 ****
  607.    flags |= __SLBF;
  608.    if (flags & __SRW)
  609.    flags &= ~(__SRD | __SWR);
  610. !  fp->_w = 0;
  611.    fp->_flags = flags;
  612.    fp->_bf._base = fp->_p = (unsigned char *)buf;
  613.    fp->_bf._size = size;
  614. --- 142,148 ----
  615.    flags |= __SLBF;
  616.    if (flags & __SRW)
  617.    flags &= ~(__SRD | __SWR);
  618. !  fp->_w = size; /* Was 0 (mevans) */
  619.    fp->_flags = flags;
  620.    fp->_bf._base = fp->_p = (unsigned char *)buf;
  621.    fp->_bf._size = size;
  622. diff -c -b -r -d -I .*$Id:.* pthreads-1_60_beta6/stdlib/system.c pthreads-1_60_beta6+/stdlib/system.c
  623. *** pthreads-1_60_beta6/stdlib/system.c Wed Apr 24 21:18:56 1996
  624. --- pthreads-1_60_beta6+/stdlib/system.c Sat Mar 15 14:09:01 1997
  625. ***************
  626. *** 62,68 ****
  627.    argp[2] = (char *) command;
  628.    sigemptyset(&tmp_mask);
  629.    sigaddset(&tmp_mask, SIGCHLD);
  630. !  pthread_sigmask(SIG_BLOCK, tmp_mask, &old_mask);
  631.    switch(pid = fork()) {
  632.    case -1: /* error */
  633.    (void)pthread_sigmask(SIG_SETMASK, &old_mask, NULL);
  634. --- 62,69 ----
  635.    argp[2] = (char *) command;
  636.    sigemptyset(&tmp_mask);
  637.    sigaddset(&tmp_mask, SIGCHLD);
  638. !  /* Pass the address of tmp_mask to avoid a sigfault. (mevans). */
  639. !  pthread_sigmask(SIG_BLOCK, &tmp_mask, &old_mask);
  640.    switch(pid = fork()) {
  641.    case -1: /* error */
  642.    (void)pthread_sigmask(SIG_SETMASK, &old_mask, NULL);