]> granicus.if.org Git - postgresql/commitdiff
Fix refcounting bug in PLy_modify_tuple().
authorTom Lane <tgl@sss.pgh.pa.us>
Wed, 26 Mar 2014 20:41:47 +0000 (16:41 -0400)
committerTom Lane <tgl@sss.pgh.pa.us>
Wed, 26 Mar 2014 20:41:47 +0000 (16:41 -0400)
We must increment the refcount on "plntup" as soon as we have the
reference, not sometime later.  Otherwise, if an error is thrown in
between, the Py_XDECREF(plntup) call in the PG_CATCH block removes a
refcount we didn't add, allowing the object to be freed even though
it's still part of the plpython function's parsetree.

This appears to be the cause of crashes seen on buildfarm member
prairiedog.  It's a bit surprising that we've not seen it fail repeatably
before, considering that the regression tests have been exercising the
faulty code path since 2009.

The real-world impact is probably minimal, since it's unlikely anyone would
be provoking the "TD["new"] is not a dictionary" error in production, and
that's the only case that is actually wrong.  Still, it's a bug affecting
the regression tests, so patch all supported branches.

In passing, remove dead variable "plstr", and demote "platt" to a local
variable inside the PG_TRY block, since we don't need to clean it up
in the PG_CATCH path.

src/pl/plpython/plpython.c

index d126d875e58765316762f7f23bd07c005b0c42aa..791d45fe588ebb75922eefa1480ec0ea22fc8a1f 100644 (file)
@@ -476,7 +476,6 @@ PLy_modify_tuple(PLyProcedure *proc, PyObject *pltd, TriggerData *tdata,
 {
        PyObject   *volatile plntup;
        PyObject   *volatile plkeys;
-       PyObject   *volatile platt;
        PyObject   *volatile plval;
        PyObject   *volatile plstr;
        HeapTuple       rtup;
@@ -489,7 +488,7 @@ PLy_modify_tuple(PLyProcedure *proc, PyObject *pltd, TriggerData *tdata,
        char       *volatile modnulls;
        TupleDesc       tupdesc;
 
-       plntup = plkeys = platt = plval = plstr = NULL;
+       plntup = plkeys = plval = plstr = NULL;
        modattrs = NULL;
        modvalues = NULL;
        modnulls = NULL;
@@ -499,10 +498,10 @@ PLy_modify_tuple(PLyProcedure *proc, PyObject *pltd, TriggerData *tdata,
                if ((plntup = PyDict_GetItemString(pltd, "new")) == NULL)
                        ereport(ERROR,
                                        (errmsg("TD[\"new\"] deleted, cannot modify row")));
+               Py_INCREF(plntup);
                if (!PyDict_Check(plntup))
                        ereport(ERROR,
                                        (errmsg("TD[\"new\"] is not a dictionary")));
-               Py_INCREF(plntup);
 
                plkeys = PyDict_Keys(plntup);
                natts = PyList_Size(plkeys);
@@ -515,6 +514,7 @@ PLy_modify_tuple(PLyProcedure *proc, PyObject *pltd, TriggerData *tdata,
 
                for (i = 0; i < natts; i++)
                {
+                       PyObject   *platt;
                        char       *src;
 
                        platt = PyList_GetItem(plkeys, i);