/[dtapublic]/projs/trunk/shared_source/c_tcl_base_7_5_w_mods/tclasync.c
ViewVC logotype

Diff of /projs/trunk/shared_source/c_tcl_base_7_5_w_mods/tclasync.c

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 67 by dashley, Mon Oct 31 00:57:34 2016 UTC revision 71 by dashley, Sat Nov 5 11:07:06 2016 UTC
# Line 1  Line 1 
1  /* $Header$ */  /* $Header$ */
2  /*  /*
3   * tclAsync.c --   * tclAsync.c --
4   *   *
5   *      This file provides low-level support needed to invoke signal   *      This file provides low-level support needed to invoke signal
6   *      handlers in a safe way.  The code here doesn't actually handle   *      handlers in a safe way.  The code here doesn't actually handle
7   *      signals, though.  This code is based on proposals made by   *      signals, though.  This code is based on proposals made by
8   *      Mark Diekhans and Don Libes.   *      Mark Diekhans and Don Libes.
9   *   *
10   * Copyright (c) 1993 The Regents of the University of California.   * Copyright (c) 1993 The Regents of the University of California.
11   * Copyright (c) 1994 Sun Microsystems, Inc.   * Copyright (c) 1994 Sun Microsystems, Inc.
12   *   *
13   * See the file "license.terms" for information on usage and redistribution   * See the file "license.terms" for information on usage and redistribution
14   * of this file, and for a DISCLAIMER OF ALL WARRANTIES.   * of this file, and for a DISCLAIMER OF ALL WARRANTIES.
15   *   *
16   * RCS: @(#) $Id: tclasync.c,v 1.1.1.1 2001/06/13 04:33:03 dtashley Exp $   * RCS: @(#) $Id: tclasync.c,v 1.1.1.1 2001/06/13 04:33:03 dtashley Exp $
17   */   */
18    
19  #include "tclInt.h"  #include "tclInt.h"
20  #include "tclPort.h"  #include "tclPort.h"
21    
22  /*  /*
23   * One of the following structures exists for each asynchronous   * One of the following structures exists for each asynchronous
24   * handler:   * handler:
25   */   */
26    
27  typedef struct AsyncHandler {  typedef struct AsyncHandler {
28      int ready;                          /* Non-zero means this handler should      int ready;                          /* Non-zero means this handler should
29                                           * be invoked in the next call to                                           * be invoked in the next call to
30                                           * Tcl_AsyncInvoke. */                                           * Tcl_AsyncInvoke. */
31      struct AsyncHandler *nextPtr;       /* Next in list of all handlers for      struct AsyncHandler *nextPtr;       /* Next in list of all handlers for
32                                           * the process. */                                           * the process. */
33      Tcl_AsyncProc *proc;                /* Procedure to call when handler      Tcl_AsyncProc *proc;                /* Procedure to call when handler
34                                           * is invoked. */                                           * is invoked. */
35      ClientData clientData;              /* Value to pass to handler when it      ClientData clientData;              /* Value to pass to handler when it
36                                           * is invoked. */                                           * is invoked. */
37  } AsyncHandler;  } AsyncHandler;
38    
39  /*  /*
40   * The variables below maintain a list of all existing handlers.   * The variables below maintain a list of all existing handlers.
41   */   */
42    
43  static AsyncHandler *firstHandler;      /* First handler defined for process,  static AsyncHandler *firstHandler;      /* First handler defined for process,
44                                           * or NULL if none. */                                           * or NULL if none. */
45  static AsyncHandler *lastHandler;       /* Last handler or NULL. */  static AsyncHandler *lastHandler;       /* Last handler or NULL. */
46    
47  TCL_DECLARE_MUTEX(asyncMutex)           /* Process-wide async handler lock */  TCL_DECLARE_MUTEX(asyncMutex)           /* Process-wide async handler lock */
48    
49  /*  /*
50   * The variable below is set to 1 whenever a handler becomes ready and   * The variable below is set to 1 whenever a handler becomes ready and
51   * it is cleared to zero whenever Tcl_AsyncInvoke is called.  It can be   * it is cleared to zero whenever Tcl_AsyncInvoke is called.  It can be
52   * checked elsewhere in the application by calling Tcl_AsyncReady to see   * checked elsewhere in the application by calling Tcl_AsyncReady to see
53   * if Tcl_AsyncInvoke should be invoked.   * if Tcl_AsyncInvoke should be invoked.
54   */   */
55    
56  static int asyncReady = 0;  static int asyncReady = 0;
57    
58  /*  /*
59   * The variable below indicates whether Tcl_AsyncInvoke is currently   * The variable below indicates whether Tcl_AsyncInvoke is currently
60   * working.  If so then we won't set asyncReady again until   * working.  If so then we won't set asyncReady again until
61   * Tcl_AsyncInvoke returns.   * Tcl_AsyncInvoke returns.
62   */   */
63    
64  static int asyncActive = 0;  static int asyncActive = 0;
65    
66  /*  /*
67   *----------------------------------------------------------------------   *----------------------------------------------------------------------
68   *   *
69   * Tcl_AsyncCreate --   * Tcl_AsyncCreate --
70   *   *
71   *      This procedure creates the data structures for an asynchronous   *      This procedure creates the data structures for an asynchronous
72   *      handler, so that no memory has to be allocated when the handler   *      handler, so that no memory has to be allocated when the handler
73   *      is activated.   *      is activated.
74   *   *
75   * Results:   * Results:
76   *      The return value is a token for the handler, which can be used   *      The return value is a token for the handler, which can be used
77   *      to activate it later on.   *      to activate it later on.
78   *   *
79   * Side effects:   * Side effects:
80   *      Information about the handler is recorded.   *      Information about the handler is recorded.
81   *   *
82   *----------------------------------------------------------------------   *----------------------------------------------------------------------
83   */   */
84    
85  Tcl_AsyncHandler  Tcl_AsyncHandler
86  Tcl_AsyncCreate(proc, clientData)  Tcl_AsyncCreate(proc, clientData)
87      Tcl_AsyncProc *proc;                /* Procedure to call when handler      Tcl_AsyncProc *proc;                /* Procedure to call when handler
88                                           * is invoked. */                                           * is invoked. */
89      ClientData clientData;              /* Argument to pass to handler. */      ClientData clientData;              /* Argument to pass to handler. */
90  {  {
91      AsyncHandler *asyncPtr;      AsyncHandler *asyncPtr;
92    
93      asyncPtr = (AsyncHandler *) ckalloc(sizeof(AsyncHandler));      asyncPtr = (AsyncHandler *) ckalloc(sizeof(AsyncHandler));
94      asyncPtr->ready = 0;      asyncPtr->ready = 0;
95      asyncPtr->nextPtr = NULL;      asyncPtr->nextPtr = NULL;
96      asyncPtr->proc = proc;      asyncPtr->proc = proc;
97      asyncPtr->clientData = clientData;      asyncPtr->clientData = clientData;
98      Tcl_MutexLock(&asyncMutex);      Tcl_MutexLock(&asyncMutex);
99      if (firstHandler == NULL) {      if (firstHandler == NULL) {
100          firstHandler = asyncPtr;          firstHandler = asyncPtr;
101      } else {      } else {
102          lastHandler->nextPtr = asyncPtr;          lastHandler->nextPtr = asyncPtr;
103      }      }
104      lastHandler = asyncPtr;      lastHandler = asyncPtr;
105      Tcl_MutexUnlock(&asyncMutex);      Tcl_MutexUnlock(&asyncMutex);
106      return (Tcl_AsyncHandler) asyncPtr;      return (Tcl_AsyncHandler) asyncPtr;
107  }  }
108    
109  /*  /*
110   *----------------------------------------------------------------------   *----------------------------------------------------------------------
111   *   *
112   * Tcl_AsyncMark --   * Tcl_AsyncMark --
113   *   *
114   *      This procedure is called to request that an asynchronous handler   *      This procedure is called to request that an asynchronous handler
115   *      be invoked as soon as possible.  It's typically called from   *      be invoked as soon as possible.  It's typically called from
116   *      an interrupt handler, where it isn't safe to do anything that   *      an interrupt handler, where it isn't safe to do anything that
117   *      depends on or modifies application state.   *      depends on or modifies application state.
118   *   *
119   * Results:   * Results:
120   *      None.   *      None.
121   *   *
122   * Side effects:   * Side effects:
123   *      The handler gets marked for invocation later.   *      The handler gets marked for invocation later.
124   *   *
125   *----------------------------------------------------------------------   *----------------------------------------------------------------------
126   */   */
127    
128  void  void
129  Tcl_AsyncMark(async)  Tcl_AsyncMark(async)
130      Tcl_AsyncHandler async;             /* Token for handler. */      Tcl_AsyncHandler async;             /* Token for handler. */
131  {  {
132      Tcl_MutexLock(&asyncMutex);      Tcl_MutexLock(&asyncMutex);
133      ((AsyncHandler *) async)->ready = 1;      ((AsyncHandler *) async)->ready = 1;
134      if (!asyncActive) {      if (!asyncActive) {
135          asyncReady = 1;          asyncReady = 1;
136          TclpAsyncMark(async);          TclpAsyncMark(async);
137      }      }
138      Tcl_MutexUnlock(&asyncMutex);      Tcl_MutexUnlock(&asyncMutex);
139  }  }
140    
141  /*  /*
142   *----------------------------------------------------------------------   *----------------------------------------------------------------------
143   *   *
144   * Tcl_AsyncInvoke --   * Tcl_AsyncInvoke --
145   *   *
146   *      This procedure is called at a "safe" time at background level   *      This procedure is called at a "safe" time at background level
147   *      to invoke any active asynchronous handlers.   *      to invoke any active asynchronous handlers.
148   *   *
149   * Results:   * Results:
150   *      The return value is a normal Tcl result, which is intended to   *      The return value is a normal Tcl result, which is intended to
151   *      replace the code argument as the current completion code for   *      replace the code argument as the current completion code for
152   *      interp.   *      interp.
153   *   *
154   * Side effects:   * Side effects:
155   *      Depends on the handlers that are active.   *      Depends on the handlers that are active.
156   *   *
157   *----------------------------------------------------------------------   *----------------------------------------------------------------------
158   */   */
159    
160  int  int
161  Tcl_AsyncInvoke(interp, code)  Tcl_AsyncInvoke(interp, code)
162      Tcl_Interp *interp;                 /* If invoked from Tcl_Eval just after      Tcl_Interp *interp;                 /* If invoked from Tcl_Eval just after
163                                           * completing a command, points to                                           * completing a command, points to
164                                           * interpreter.  Otherwise it is                                           * interpreter.  Otherwise it is
165                                           * NULL. */                                           * NULL. */
166      int code;                           /* If interp is non-NULL, this gives      int code;                           /* If interp is non-NULL, this gives
167                                           * completion code from command that                                           * completion code from command that
168                                           * just completed. */                                           * just completed. */
169  {  {
170      AsyncHandler *asyncPtr;      AsyncHandler *asyncPtr;
171      Tcl_MutexLock(&asyncMutex);      Tcl_MutexLock(&asyncMutex);
172    
173      if (asyncReady == 0) {      if (asyncReady == 0) {
174          Tcl_MutexUnlock(&asyncMutex);          Tcl_MutexUnlock(&asyncMutex);
175          return code;          return code;
176      }      }
177      asyncReady = 0;      asyncReady = 0;
178      asyncActive = 1;      asyncActive = 1;
179      if (interp == NULL) {      if (interp == NULL) {
180          code = 0;          code = 0;
181      }      }
182    
183      /*      /*
184       * Make one or more passes over the list of handlers, invoking       * Make one or more passes over the list of handlers, invoking
185       * at most one handler in each pass.  After invoking a handler,       * at most one handler in each pass.  After invoking a handler,
186       * go back to the start of the list again so that (a) if a new       * go back to the start of the list again so that (a) if a new
187       * higher-priority handler gets marked while executing a lower       * higher-priority handler gets marked while executing a lower
188       * priority handler, we execute the higher-priority handler       * priority handler, we execute the higher-priority handler
189       * next, and (b) if a handler gets deleted during the execution       * next, and (b) if a handler gets deleted during the execution
190       * of a handler, then the list structure may change so it isn't       * of a handler, then the list structure may change so it isn't
191       * safe to continue down the list anyway.       * safe to continue down the list anyway.
192       */       */
193    
194      while (1) {      while (1) {
195          for (asyncPtr = firstHandler; asyncPtr != NULL;          for (asyncPtr = firstHandler; asyncPtr != NULL;
196                  asyncPtr = asyncPtr->nextPtr) {                  asyncPtr = asyncPtr->nextPtr) {
197              if (asyncPtr->ready) {              if (asyncPtr->ready) {
198                  break;                  break;
199              }              }
200          }          }
201          if (asyncPtr == NULL) {          if (asyncPtr == NULL) {
202              break;              break;
203          }          }
204          asyncPtr->ready = 0;          asyncPtr->ready = 0;
205          Tcl_MutexUnlock(&asyncMutex);          Tcl_MutexUnlock(&asyncMutex);
206          code = (*asyncPtr->proc)(asyncPtr->clientData, interp, code);          code = (*asyncPtr->proc)(asyncPtr->clientData, interp, code);
207          Tcl_MutexLock(&asyncMutex);          Tcl_MutexLock(&asyncMutex);
208      }      }
209      asyncActive = 0;      asyncActive = 0;
210      Tcl_MutexUnlock(&asyncMutex);      Tcl_MutexUnlock(&asyncMutex);
211      return code;      return code;
212  }  }
213    
214  /*  /*
215   *----------------------------------------------------------------------   *----------------------------------------------------------------------
216   *   *
217   * Tcl_AsyncDelete --   * Tcl_AsyncDelete --
218   *   *
219   *      Frees up all the state for an asynchronous handler.  The handler   *      Frees up all the state for an asynchronous handler.  The handler
220   *      should never be used again.   *      should never be used again.
221   *   *
222   * Results:   * Results:
223   *      None.   *      None.
224   *   *
225   * Side effects:   * Side effects:
226   *      The state associated with the handler is deleted.   *      The state associated with the handler is deleted.
227   *   *
228   *----------------------------------------------------------------------   *----------------------------------------------------------------------
229   */   */
230    
231  void  void
232  Tcl_AsyncDelete(async)  Tcl_AsyncDelete(async)
233      Tcl_AsyncHandler async;             /* Token for handler to delete. */      Tcl_AsyncHandler async;             /* Token for handler to delete. */
234  {  {
235      AsyncHandler *asyncPtr = (AsyncHandler *) async;      AsyncHandler *asyncPtr = (AsyncHandler *) async;
236      AsyncHandler *prevPtr;      AsyncHandler *prevPtr;
237    
238      Tcl_MutexLock(&asyncMutex);      Tcl_MutexLock(&asyncMutex);
239      if (firstHandler == asyncPtr) {      if (firstHandler == asyncPtr) {
240          firstHandler = asyncPtr->nextPtr;          firstHandler = asyncPtr->nextPtr;
241          if (firstHandler == NULL) {          if (firstHandler == NULL) {
242              lastHandler = NULL;              lastHandler = NULL;
243          }          }
244      } else {      } else {
245          prevPtr = firstHandler;          prevPtr = firstHandler;
246          while (prevPtr->nextPtr != asyncPtr) {          while (prevPtr->nextPtr != asyncPtr) {
247              prevPtr = prevPtr->nextPtr;              prevPtr = prevPtr->nextPtr;
248          }          }
249          prevPtr->nextPtr = asyncPtr->nextPtr;          prevPtr->nextPtr = asyncPtr->nextPtr;
250          if (lastHandler == asyncPtr) {          if (lastHandler == asyncPtr) {
251              lastHandler = prevPtr;              lastHandler = prevPtr;
252          }          }
253      }      }
254      Tcl_MutexUnlock(&asyncMutex);      Tcl_MutexUnlock(&asyncMutex);
255      ckfree((char *) asyncPtr);      ckfree((char *) asyncPtr);
256  }  }
257    
258  /*  /*
259   *----------------------------------------------------------------------   *----------------------------------------------------------------------
260   *   *
261   * Tcl_AsyncReady --   * Tcl_AsyncReady --
262   *   *
263   *      This procedure can be used to tell whether Tcl_AsyncInvoke   *      This procedure can be used to tell whether Tcl_AsyncInvoke
264   *      needs to be called.  This procedure is the external interface   *      needs to be called.  This procedure is the external interface
265   *      for checking the internal asyncReady variable.   *      for checking the internal asyncReady variable.
266   *   *
267   * Results:   * Results:
268   *      The return value is 1 whenever a handler is ready and is 0   *      The return value is 1 whenever a handler is ready and is 0
269   *      when no handlers are ready.   *      when no handlers are ready.
270   *   *
271   * Side effects:   * Side effects:
272   *      None.   *      None.
273   *   *
274   *----------------------------------------------------------------------   *----------------------------------------------------------------------
275   */   */
276    
277  int  int
278  Tcl_AsyncReady()  Tcl_AsyncReady()
279  {  {
280      return asyncReady;      return asyncReady;
281  }  }
282    
283  /* End of tclasync.c */  /* End of tclasync.c */

Legend:
Removed from v.67  
changed lines
  Added in v.71

dashley@gmail.com
ViewVC Help
Powered by ViewVC 1.1.25