]> granicus.if.org Git - python/commitdiff
Backout changeset 46393019b650
authorVictor Stinner <victor.stinner@gmail.com>
Fri, 13 Dec 2013 03:14:41 +0000 (04:14 +0100)
committerVictor Stinner <victor.stinner@gmail.com>
Fri, 13 Dec 2013 03:14:41 +0000 (04:14 +0100)
test_capi is failing and the fix is not trivial, I prefer to revert

Doc/whatsnew/3.4.rst
Misc/NEWS
Modules/_testcapimodule.c
Modules/_tracemalloc.c
Python/thread.c
Python/thread_nt.h
Python/thread_pthread.h

index 8fe906be218bb2500b79ad920a4ba024f8a35830..5d360c4d51592672dbfb3bf52d98ae8f5496f0e4 100644 (file)
@@ -1068,8 +1068,3 @@ that may require changes to your code.
   working directory will also now have an absolute path, including when using
   ``-m`` with the interpreter (this does not influence when the path to a file
   is specified on the command-line).
-
-* (C API) :c:func:`PyThread_set_key_value` now always set the value. In Python
-  3.3, the function did nothing if the key already exists (if the current
-  value is a non-NULL pointer).
-
index 800002a89d951e7a4f54e3496da9762a69033c12..8be054f7657287e1ecd34c1ea315baa747d792a5 100644 (file)
--- a/Misc/NEWS
+++ b/Misc/NEWS
@@ -10,10 +10,6 @@ Release date: 2014-01-05
 Core and Builtins
 -----------------
 
-- Issue #19787: PyThread_set_key_value() now always set the value. In Python
-  3.3, the function did nothing if the key already exists (if the current value
-  is a non-NULL pointer).
-
 - Issue #14432: Remove the thread state field from the frame structure. Fix a
   crash when a generator is created in a C thread that is destroyed while the
   generator is still used. The issue was that a generator contains a frame, and
index 6f2a75cdad6e98801916492ecb7863861461b485..a0cffde5bfaad8d2c1a3eade67592aaa8d689cf4 100644 (file)
@@ -2511,10 +2511,6 @@ run_in_subinterp(PyObject *self, PyObject *args)
     r = PyRun_SimpleString(code);
     Py_EndInterpreter(substate);
 
-    /* restore previous thread safe. It was replaced by Py_NewInterpreter()
-       which creates a new thread state. */
-    _PyThreadState_Init(mainstate);
-
     PyThreadState_Swap(mainstate);
 
     return PyLong_FromLong(r);
index 95b05d61c55d27c55224ecb16ea5d7f70c00e82d..b39e950c2733525a047ba31a396e0f156aa1af48 100644 (file)
@@ -168,11 +168,14 @@ set_reentrant(int reentrant)
     assert(reentrant == 0 || reentrant == 1);
     if (reentrant) {
         assert(PyThread_get_key_value(tracemalloc_reentrant_key) == NULL);
-        PyThread_set_key_value(tracemalloc_reentrant_key, REENTRANT);
+        PyThread_set_key_value(tracemalloc_reentrant_key,
+                               REENTRANT);
     }
     else {
-        assert(PyThread_get_key_value(tracemalloc_reentrant_key) == REENTRANT);
-        PyThread_set_key_value(tracemalloc_reentrant_key, NULL);
+        /* FIXME: PyThread_set_key_value() cannot be used to set the flag
+           to zero, because it does nothing if the variable has already
+           a value set. */
+        PyThread_delete_key_value(tracemalloc_reentrant_key);
     }
 }
 
index 5396ca30e3eabe0c3f1381264f9fbe1d37baec3f..8540942e28a128034bab10d509e45802553d8791 100644 (file)
@@ -205,7 +205,7 @@ static int nkeys = 0;  /* PyThread_create_key() hands out nkeys+1 next */
  * segfaults.  Now we lock the whole routine.
  */
 static struct key *
-find_key(int key, int update, void *value)
+find_key(int key, void *value)
 {
     struct key *p, *prev_p;
     long id = PyThread_get_thread_ident();
@@ -215,11 +215,8 @@ find_key(int key, int update, void *value)
     PyThread_acquire_lock(keymutex, 1);
     prev_p = NULL;
     for (p = keyhead; p != NULL; p = p->next) {
-        if (p->id == id && p->key == key) {
-            if (update)
-                p->value = value;
+        if (p->id == id && p->key == key)
             goto Done;
-        }
         /* Sanity check.  These states should never happen but if
          * they do we must abort.  Otherwise we'll end up spinning in
          * in a tight loop with the lock held.  A similar check is done
@@ -230,7 +227,7 @@ find_key(int key, int update, void *value)
         if (p->next == keyhead)
             Py_FatalError("tls find_key: circular list(!)");
     }
-    if (!update && value == NULL) {
+    if (value == NULL) {
         assert(p == NULL);
         goto Done;
     }
@@ -282,12 +279,19 @@ PyThread_delete_key(int key)
     PyThread_release_lock(keymutex);
 }
 
+/* Confusing:  If the current thread has an association for key,
+ * value is ignored, and 0 is returned.  Else an attempt is made to create
+ * an association of key to value for the current thread.  0 is returned
+ * if that succeeds, but -1 is returned if there's not enough memory
+ * to create the association.  value must not be NULL.
+ */
 int
 PyThread_set_key_value(int key, void *value)
 {
     struct key *p;
 
-    p = find_key(key, 1, value);
+    assert(value != NULL);
+    p = find_key(key, value);
     if (p == NULL)
         return -1;
     else
@@ -300,7 +304,7 @@ PyThread_set_key_value(int key, void *value)
 void *
 PyThread_get_key_value(int key)
 {
-    struct key *p = find_key(key, 0, NULL);
+    struct key *p = find_key(key, NULL);
 
     if (p == NULL)
         return NULL;
index ee2079fc613501c907364f5f97e3a6ed609e3095..ab5a08168f7dc6413cf1928764bcd7d758762ce1 100644 (file)
@@ -389,11 +389,20 @@ PyThread_delete_key(int key)
     TlsFree(key);
 }
 
+/* We must be careful to emulate the strange semantics implemented in thread.c,
+ * where the value is only set if it hasn't been set before.
+ */
 int
 PyThread_set_key_value(int key, void *value)
 {
     BOOL ok;
+    void *oldvalue;
 
+    assert(value != NULL);
+    oldvalue = TlsGetValue(key);
+    if (oldvalue != NULL)
+        /* ignore value if already set */
+        return 0;
     ok = TlsSetValue(key, value);
     if (!ok)
         return -1;
index d9f7c76f2aba0e1d3190b0c5495fc3e4c63bcf29..20f85358968b45b5972a90f0e8b347cad495714c 100644 (file)
@@ -627,6 +627,9 @@ int
 PyThread_set_key_value(int key, void *value)
 {
     int fail;
+    void *oldValue = pthread_getspecific(key);
+    if (oldValue != NULL)
+        return 0;
     fail = pthread_setspecific(key, value);
     return fail ? -1 : 0;
 }