Merge zope3-zodb3-devel-branch to the Zope head (Zope 2 head).

Added support for persistent weak references and
PersistentWeakKeyDictionary.

Add _p_invalidate() method to persistence API.  _p_deactivate() is
advisory from the cache.  _p_invalidate() is called when database
invalidates object.

Port support for getattr/setattr hacks from ZODB4.  The doctest tests
describe the new technique pretty well.

Remove unused arguments from some cPickleCache calls.

src/persistent/README.txt

+===================
+Persistence support
+==================
+
+(This document is under construction. More basic documentation will
+ eventually appear here.)
+
+
+Overriding __getattr__, __getattribute__, __setattr__, and __delattr__
+-----------------------------------------------------------------------  
+
+Subclasses can override the attribute-management methods.  For the
+__getattr__ method, the behavior is like that for regular Python
+classes and for earlier versions of ZODB 3.
+
+For __getattribute__, __setattr__, and __delattr__, it is necessary to
+cal certain methods defined by persistent.Persistent.  Detailed
+examples and documentation is provided in the test module,
+persistent.tests.test_overriding_attrs.
+
+
+
+
+  

src/persistent/__init__.py

@@ -13,5 +13,19 @@
 ##############################################################################
 """Provide access to Persistent and PersistentMapping."""
 
-from cPersistence import Persistent
+from cPersistence import Persistent, GHOST, UPTODATE, CHANGED, STICKY
 from cPickleCache import PickleCache
+
+from cPersistence import simple_new
+import copy_reg
+copy_reg.constructor(simple_new)
+
+# Make an interface declaration for Persistent,
+# if zope.interface is available.
+try:
+    from zope.interface import classImplements
+except ImportError:
+    pass
+else:
+    from persistent.interfaces import IPersistent
+    classImplements(Persistent, IPersistent)

src/persistent/cPersistence.h

@@ -81,6 +81,8 @@ typedef struct {
     percachedelfunc percachedel;
 } cPersistenceCAPIstruct;
 
+#define cPersistenceType cPersistenceCAPI->pertype
+
 #ifndef DONT_USE_CPERSISTENCECAPI
 static cPersistenceCAPIstruct *cPersistenceCAPI;
 #endif
@@ -95,10 +97,26 @@ static cPersistenceCAPIstruct *cPersistenceCAPI;
 
 #define PER_GHOSTIFY(O) (cPersistenceCAPI->ghostify((cPersistentObject*)(O)))
 
+/* If the object is sticky, make it non-sticky, so that it can be ghostified.
+   The value is not meaningful
+ */
 #define PER_ALLOW_DEACTIVATION(O) ((O)->state==cPersistent_STICKY_STATE && ((O)->state=cPersistent_UPTODATE_STATE))
 
 #define PER_PREVENT_DEACTIVATION(O)  ((O)->state==cPersistent_UPTODATE_STATE && ((O)->state=cPersistent_STICKY_STATE))
 
+/* 
+   Make a persistent object usable from C by:
+
+   - Making sure it is not a ghost
+
+   - Making it sticky.
+
+   IMPORTANT: If you call this and don't call PER_ALLOW_DEACTIVATION, 
+              your object will not be ghostified.
+
+   PER_USE returns a 1 on success and 0 failure, where failure means
+   error.
+ */
 #define PER_USE(O) \
 (((O)->state != cPersistent_GHOST_STATE \
   || (cPersistenceCAPI->setstate((PyObject*)(O)) >= 0)) \

src/persistent/cPickleCache.c

@@ -90,7 +90,7 @@ process must skip such objects, rather than deactivating them.
 static char cPickleCache_doc_string[] =
 "Defines the PickleCache used by ZODB Connection objects.\n"
 "\n"
-"$Id: cPickleCache.c,v 1.87 2003/11/28 16:44:55 jim Exp $\n";
+"$Id: cPickleCache.c,v 1.88 2004/02/19 02:59:30 jeremy Exp $\n";
 
 #define DONT_USE_CPERSISTENCECAPI
 #include "cPersistence.h"
@@ -107,11 +107,11 @@ static cPersistenceCAPIstruct *capi;
    ccobject_head in cPersistence.c */
 typedef struct {
     CACHE_HEAD
-    int klass_count;                         /* count of persistent classes */
-    PyObject *data;                          /* oid -> object dict */
-    PyObject *jar;                           /* Connection object */
-    PyObject *setklassstate;                 /* ??? */
-    int cache_size;                          /* target number of items in cache */
+    int klass_count;                     /* count of persistent classes */
+    PyObject *data;                      /* oid -> object dict */
+    PyObject *jar;                       /* Connection object */
+    PyObject *setklassstate;             /* ??? */
+    int cache_size;                      /* target number of items in cache */
 
     /* Most of the time the ring contains only:
        * many nodes corresponding to persistent objects
@@ -138,7 +138,7 @@ static int cc_ass_sub(ccobject *self, PyObject *key, PyObject *v);
 
 /* ---------------------------------------------------------------- */
 
-#define OBJECT_FROM_RING(SELF, HERE, CTX) \
+#define OBJECT_FROM_RING(SELF, HERE) \
     ((cPersistentObject *)(((char *)here) - offsetof(cPersistentObject, ring)))
 
 static int
@@ -167,7 +167,7 @@ scan_gc_items(ccobject *self,int target)
 	   this because the ring lock is held.  We can safely assume
 	   the current ring node is a persistent object now we know it
 	   is not the home */
-        object = OBJECT_FROM_RING(self, here, "scan_gc_items");
+        object = OBJECT_FROM_RING(self, here);
         if (!object)
 	    return -1;
 
@@ -223,7 +223,7 @@ lockgc(ccobject *self, int target_size)
     }
 
     self->ring_lock = 1;
-    if (scan_gc_items(self, target_size)) {
+    if (scan_gc_items(self, target_size) < 0) {
         self->ring_lock = 0;
         return NULL;
     }
@@ -236,7 +236,7 @@ lockgc(ccobject *self, int target_size)
 static PyObject *
 cc_incrgc(ccobject *self, PyObject *args)
 {
-    int n = 1;
+    int obsolete_arg = -999; 
     int starting_size = self->non_ghost_count;
     int target_size = self->cache_size;
 
@@ -250,19 +250,30 @@ cc_incrgc(ccobject *self, PyObject *args)
             target_size = target_size_2;
     }
 
-    if (!PyArg_ParseTuple(args, "|i:incrgc", &n))
+
+    if (!PyArg_ParseTuple(args, "|i:incrgc", &obsolete_arg))
 	return NULL;
 
+    if (obsolete_arg != -999
+        &&
+        (PyErr_Warn(PyExc_DeprecationWarning,
+                    "No argument expected")
+         < 0))
+        return NULL;
+
     return lockgc(self, target_size);
 }
 
 static PyObject *
 cc_full_sweep(ccobject *self, PyObject *args)
 {
-    int dt = 0;
+    int dt = -999;
+
+    /* XXX This should be deprecated */
+
     if (!PyArg_ParseTuple(args, "|i:full_sweep", &dt))
 	return NULL;
-    if (dt == 0)
+    if (dt == -999)
 	return lockgc(self, 0);
     else
 	return cc_incrgc(self, args);
@@ -271,9 +282,18 @@ cc_full_sweep(ccobject *self, PyObject *args)
 static PyObject *
 cc_minimize(ccobject *self, PyObject *args)
 {
-    int ignored;
+    int ignored = -999;
+
     if (!PyArg_ParseTuple(args, "|i:minimize", &ignored))
 	return NULL;
+
+    if (ignored != -999
+        &&
+        (PyErr_Warn(PyExc_DeprecationWarning,
+                    "No argument expected")
+         < 0))
+        return NULL;
+
     return lockgc(self, 0);
 }
 
@@ -285,6 +305,13 @@ _invalidate(ccobject *self, PyObject *key)
     if (!v)
 	return;
     if (PyType_Check(v)) {
+        /* This looks wrong, but it isn't. We use strong references to types 
+           because they don't have the ring members.
+
+           XXX the result is that we *never* remove classes unless
+           they are modified.
+
+         */
 	if (v->ob_refcnt <= 1) {
 	    self->klass_count--;
 	    if (PyDict_DelItem(self->data, key) < 0)
@@ -372,7 +399,7 @@ cc_klass_items(ccobject *self)
     PyObject *l,*k,*v;
     int p = 0;
 
-    l = PyList_New(PyDict_Size(self->data));
+    l = PyList_New(0);
     if (l == NULL)
 	return NULL;
 
@@ -395,6 +422,45 @@ cc_klass_items(ccobject *self)
     return l;
 }
 
+static PyObject *
+cc_debug_info(ccobject *self)
+{
+    PyObject *l,*k,*v;
+    int p = 0;
+
+    l = PyList_New(0);
+    if (l == NULL)
+	return NULL;
+
+    while (PyDict_Next(self->data, &p, &k, &v)) 
+      {
+        if (v->ob_refcnt <= 0)
+          v = Py_BuildValue("Oi", k, v->ob_refcnt);
+
+        else if (! PyType_Check(v) &&
+                 (v->ob_type->tp_basicsize >= sizeof(cPersistentObject))
+                 )
+          v = Py_BuildValue("Oisi", 
+                            k, v->ob_refcnt, v->ob_type->tp_name,
+                            ((cPersistentObject*)v)->state);
+        else
+          v = Py_BuildValue("Ois", k, v->ob_refcnt, v->ob_type->tp_name);
+
+        if (v == NULL)
+          goto err;
+
+        if (PyList_Append(l, v) < 0)
+          goto err;
+      }
+
+    return l;
+
+ err:
+    Py_DECREF(l);
+    return NULL;
+
+}
+
 static PyObject *
 cc_lru_items(ccobject *self)
 {
@@ -417,7 +483,7 @@ cc_lru_items(ccobject *self)
     here = self->ring_home.r_next;
     while (here != &self->ring_home) {
         PyObject *v;
-        cPersistentObject *object = OBJECT_FROM_RING(self, here, "cc_items");
+        cPersistentObject *object = OBJECT_FROM_RING(self, here);
 
         if (object == NULL) {
             Py_DECREF(l);
@@ -520,15 +586,14 @@ static struct PyMethodDef cc_methods[] = {
     {"klass_items", (PyCFunction)cc_klass_items, METH_NOARGS,
      "List (oid, object) pairs of cached persistent classes."},
     {"full_sweep", (PyCFunction)cc_full_sweep, METH_VARARGS,
-     "full_sweep([age]) -- Perform a full sweep of the cache\n\n"
-     "Supported for backwards compatibility.  If the age argument is 0,\n"
-     "behaves like minimize().  Otherwise, behaves like incrgc()."},
+     "full_sweep() -- Perform a full sweep of the cache."},
     {"minimize",	(PyCFunction)cc_minimize, METH_VARARGS,
      "minimize([ignored]) -- Remove as many objects as possible\n\n"
      "Ghostify all objects that are not modified.  Takes an optional\n"
      "argument, but ignores it."},
     {"incrgc", (PyCFunction)cc_incrgc, METH_VARARGS,
-     "incrgc([n]) -- Perform incremental garbage collection\n\n"
+     "incrgc() -- Perform incremental garbage collection\n\n"
+     "This method had been depricated!"
      "Some other implementations support an optional parameter 'n' which\n"
      "indicates a repetition count; this value is ignored."},
     {"invalidate", (PyCFunction)cc_invalidate, METH_O,
@@ -537,6 +602,8 @@ static struct PyMethodDef cc_methods[] = {
      "get(key [, default]) -- get an item, or a default"},
     {"ringlen", (PyCFunction)cc_ringlen, METH_NOARGS,
      "ringlen() -- Returns number of non-ghost items in cache."},
+    {"debug_info", (PyCFunction)cc_debug_info, METH_NOARGS,
+     "debug_info() -- Returns debugging data about objects in the cache."},
     {NULL, NULL}		/* sentinel */
 };
 
@@ -618,7 +685,7 @@ cc_clear(ccobject *self)
 
     while (self->ring_home.r_next != &self->ring_home) {
 	CPersistentRing *here = self->ring_home.r_next;
-	cPersistentObject *o = OBJECT_FROM_RING(self, here, "cc_clear");
+	cPersistentObject *o = OBJECT_FROM_RING(self, here);
 
 	if (o->cache) {
 	    Py_INCREF(o); /* account for uncounted reference */
@@ -685,7 +752,7 @@ cc_traverse(ccobject *self, visitproc visit, void *arg)
 	return 0;
 
     while (here != &self->ring_home) {
-	cPersistentObject *o = OBJECT_FROM_RING(self, here, "foo");
+	cPersistentObject *o = OBJECT_FROM_RING(self, here);
 	VISIT(o);
 	here = here->r_next;
     }
@@ -722,6 +789,7 @@ cc_add_item(ccobject *self, PyObject *key, PyObject *v)
     PyObject *oid, *object_again, *jar;
     cPersistentObject *p;
 
+    /* Sanity check the value given to make sure it is allowed in the cache */
     if (PyType_Check(v)) {
         /* Its a persistent class, such as a ZClass. Thats ok. */
     }
@@ -743,12 +811,13 @@ cc_add_item(ccobject *self, PyObject *key, PyObject *v)
     oid = PyObject_GetAttr(v, py__p_oid);
     if (oid == NULL)
 	return -1;
-    if (!PyString_Check(oid)) {
+    if (! PyString_Check(oid)) {
         PyErr_Format(PyExc_TypeError,
                      "Cached object oid must be a string, not a %s",
 		     oid->ob_type->tp_name);
 	return -1;
     }
+
     /*  we know they are both strings.
      *  now check if they are the same string.
      */
@@ -836,8 +905,10 @@ cc_del_item(ccobject *self, PyObject *key)
 
     /* unlink this item from the ring */
     v = PyDict_GetItem(self->data, key);
-    if (v == NULL)
+    if (v == NULL) {
+	PyErr_SetObject(PyExc_KeyError, key);
 	return -1;
+    }
 
     if (PyType_Check(v)) {
 	self->klass_count--;

src/persistent/dict.py

+##############################################################################
+#
+# Copyright (c) 2001, 2002 Zope Corporation and Contributors.
+# All Rights Reserved.
+#
+# This software is subject to the provisions of the Zope Public License,
+# Version 2.0 (ZPL).  A copy of the ZPL should accompany this distribution.
+# THIS SOFTWARE IS PROVIDED "AS IS" AND ANY AND ALL EXPRESS OR IMPLIED
+# WARRANTIES ARE DISCLAIMED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+# WARRANTIES OF TITLE, MERCHANTABILITY, AGAINST INFRINGEMENT, AND FITNESS
+# FOR A PARTICULAR PURPOSE.
+#
+##############################################################################
+"""Python implementation of persistent container type
+
+$Id: dict.py,v 1.2 2004/02/19 02:59:30 jeremy Exp $
+"""
+
+import persistent
+from UserDict import IterableUserDict
+
+__metaclass__ = type
+
+class PersistentDict(persistent.Persistent, IterableUserDict):
+    """A persistent wrapper for mapping objects.
+
+    This class allows wrapping of mapping objects so that object
+    changes are registered.  As a side effect, mapping objects may be
+    subclassed.
+    """
+
+    # IterableUserDict provides all of the mapping behavior.  The
+    # PersistentDict class is responsible marking the persistent
+    # state as changed when a method actually changes the state.  At
+    # the mapping API evolves, we may need to add more methods here.
+
+    __super_delitem = IterableUserDict.__delitem__
+    __super_setitem = IterableUserDict.__setitem__
+    __super_clear = IterableUserDict.clear
+    __super_update = IterableUserDict.update
+    __super_setdefault = IterableUserDict.setdefault
+    __super_popitem = IterableUserDict.popitem
+
+    __super_p_init = persistent.Persistent.__init__
+    __super_init = IterableUserDict.__init__
+
+    def __init__(self, dict=None):
+        self.__super_init(dict)
+        self.__super_p_init()
+
+    def __delitem__(self, key):
+        self.__super_delitem(key)
+        self._p_changed = True
+
+    def __setitem__(self, key, v):
+        self.__super_setitem(key, v)
+        self._p_changed = True
+
+    def clear(self):
+        self.__super_clear()
+        self._p_changed = True
+
+    def update(self, b):
+        self.__super_update(b)
+        self._p_changed = True
+
+    def setdefault(self, key, failobj=None):
+        # We could inline all of UserDict's implementation into the
+        # method here, but I'd rather not depend at all on the
+        # implementation in UserDict (simple as it is).
+        if not self.has_key(key):
+            self._p_changed = True
+        return self.__super_setdefault(key, failobj)
+
+    def popitem(self):
+        self._p_changed = True
+        return self.__super_popitem()

src/persistent/list.py

@@ -14,9 +14,9 @@
 
 """Python implementation of persistent list.
 
-$Id: list.py,v 1.5 2003/11/28 16:44:55 jim Exp $"""
+$Id: list.py,v 1.6 2004/02/19 02:59:30 jeremy Exp $"""
 
-__version__='$Revision: 1.5 $'[11:-2]
+__version__='$Revision: 1.6 $'[11:-2]
 
 import persistent
 from UserList import UserList
@@ -53,12 +53,14 @@ class PersistentList(UserList, persistent.Persistent):
         self._p_changed = 1
 
     def __iadd__(self, other):
-        self.__super_iadd(other)
+        L = self.__super_iadd(other)
         self._p_changed = 1
+        return L
 
     def __imul__(self, n):
-        self.__super_imul(n)
+        L = self.__super_imul(n)
         self._p_changed = 1
+        return L
 
     def append(self, item):
         self.__super_append(item)

src/persistent/pickle/pickle.c

@@ -87,7 +87,7 @@ pickle_copy_dict(PyObject *state)
 {
   PyObject *copy, *key, *value;
   char *ckey;
-  int pos = 0, nr;
+  int pos = 0;
 
   copy = PyDict_New();
   if (copy == NULL)
@@ -96,11 +96,8 @@ pickle_copy_dict(PyObject *state)
   if (state == NULL)
     return copy;
 
-  while ((nr = PyDict_Next(state, &pos, &key, &value))) 
+  while (PyDict_Next(state, &pos, &key, &value))
     {
-      if (nr < 0)
-        goto err;
-
       if (key && PyString_Check(key))
         {
           ckey = PyString_AS_STRING(key);
@@ -111,9 +108,7 @@ pickle_copy_dict(PyObject *state)
             continue;
         }
 
-      if (key != NULL && value != NULL &&
-          (PyObject_SetItem(copy, key, value) < 0)
-          )
+      if (PyObject_SetItem(copy, key, value) < 0)
         goto err;
     }
   
@@ -184,6 +179,7 @@ pickle___getstate__(PyObject *self)
                 continue;
             }
 
+	  /* XXX will this go through our getattr hook? */
           value = PyObject_GetAttr(self, name);
           if (value == NULL)
             PyErr_Clear();
@@ -191,7 +187,7 @@ pickle___getstate__(PyObject *self)
             {
               int err = PyDict_SetItem(slots, name, value);
               Py_DECREF(value);
-              if (err)
+              if (err < 0)
                 goto end;
               n++;
             }
@@ -222,9 +218,7 @@ pickle_setattrs_from_dict(PyObject *self, PyObject *dict)
   
   while (PyDict_Next(dict, &pos, &key, &value)) 
     {
-      if (key != NULL && value != NULL &&
-          (PyObject_SetAttr(self, key, value) < 0)
-          )
+      if (PyObject_SetAttr(self, key, value) < 0)
         return -1;
     }
   return 0;

src/persistent/tests/testPersistent.py

@@ -15,7 +15,7 @@ import pickle
 import time
 import unittest
 
-from persistent import Persistent
+from persistent import Persistent, GHOST, UPTODATE, CHANGED, STICKY
 from persistent.cPickleCache import PickleCache
 from persistent.TimeStamp import TimeStamp
 from ZODB.utils import p64
@@ -111,7 +111,7 @@ class PersistenceTest(unittest.TestCase):
             obj._p_jar = 12
         self.assertRaises(ValueError, setoid)
 
-    def testChanged(self):
+    def testChangedAndState(self):
         obj = P()
         self.jar.add(obj)
 
@@ -122,24 +122,29 @@ class PersistenceTest(unittest.TestCase):
 
         obj.x = 1
         self.assertEqual(obj._p_changed, 1)
+        self.assertEqual(obj._p_state, CHANGED)
         self.assert_(obj in self.jar.registered)
 
         obj._p_changed = 0
         self.assertEqual(obj._p_changed, 0)
+        self.assertEqual(obj._p_state, UPTODATE)
         self.jar.registered.clear()
 
         obj._p_changed = 1
         self.assertEqual(obj._p_changed, 1)
+        self.assertEqual(obj._p_state, CHANGED)
         self.assert_(obj in self.jar.registered)
 
         # setting obj._p_changed to None ghostifies if the
         # object is in the up-to-date state, but not otherwise.
         obj._p_changed = None
         self.assertEqual(obj._p_changed, 1)
+        self.assertEqual(obj._p_state, CHANGED)
         obj._p_changed = 0
         # Now it's a ghost.
         obj._p_changed = None
         self.assertEqual(obj._p_changed, None)
+        self.assertEqual(obj._p_state, GHOST)
 
         obj = P()
         self.jar.add(obj)
@@ -148,6 +153,34 @@ class PersistenceTest(unittest.TestCase):
         # you delete the _p_changed attribute.
         del obj._p_changed
         self.assertEqual(obj._p_changed, None)
+        self.assertEqual(obj._p_state, GHOST)
+
+    def testStateReadonly(self):
+        # make sure we can't write to _p_state; we don't want yet
+        # another way to change state!
+        obj = P()
+        def setstate(value):
+            obj._p_state = value
+        self.assertRaises(TypeError, setstate, GHOST)
+        self.assertRaises(TypeError, setstate, UPTODATE)
+        self.assertRaises(TypeError, setstate, CHANGED)
+        self.assertRaises(TypeError, setstate, STICKY)
+
+    def testInvalidate(self):
+        obj = P()
+        self.jar.add(obj)
+
+        self.assertEqual(obj._p_changed, 0)
+        self.assertEqual(obj._p_state, UPTODATE)
+        obj._p_invalidate()
+        self.assertEqual(obj._p_changed, None)
+        self.assertEqual(obj._p_state, GHOST)
+
+        obj._p_activate()
+        obj.x = 1
+        obj._p_invalidate()
+        self.assertEqual(obj._p_changed, None)
+        self.assertEqual(obj._p_state, GHOST)
 
     def testSerial(self):
         noserial = "\000" * 8
@@ -196,6 +229,7 @@ class PersistenceTest(unittest.TestCase):
         # The getattr hook modified the object, so it should now be
         # in the changed state.
         self.assertEqual(obj._p_changed, 1)
+        self.assertEqual(obj._p_state, CHANGED)
         self.assertEqual(obj.curly, 2)
         self.assertEqual(obj.moe, 3)
 
@@ -213,6 +247,7 @@ class PersistenceTest(unittest.TestCase):
         # The getattr hook modified the object, so it should now be
         # in the changed state.
         self.assertEqual(obj._p_changed, 1)
+        self.assertEqual(obj._p_state, CHANGED)
         self.assertEqual(obj.curly, 2)
         self.assertEqual(obj.moe, 3)
 

src/persistent/tests/test_PickleCache.py

+##############################################################################
+#
+# Copyright (c) 2003 Zope Corporation and Contributors.
+# All Rights Reserved.
+#
+# This software is subject to the provisions of the Zope Public License,
+# Version 2.0 (ZPL).  A copy of the ZPL should accompany this distribution.
+# THIS SOFTWARE IS PROVIDED "AS IS" AND ANY AND ALL EXPRESS OR IMPLIED
+# WARRANTIES ARE DISCLAIMED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+# WARRANTIES OF TITLE, MERCHANTABILITY, AGAINST INFRINGEMENT, AND FITNESS
+# FOR A PARTICULAR PURPOSE.
+#
+##############################################################################
+"""Unit tests for PickleCache
+
+$Id: test_PickleCache.py,v 1.2 2004/02/19 02:59:32 jeremy Exp $
+"""
+
+class DummyConnection:
+
+    def setklassstate(self, obj):
+        """Method used by PickleCache."""
+
+
+def test_delitem():
+    """
+    >>> from persistent import PickleCache
+    >>> conn = DummyConnection()
+    >>> cache = PickleCache(conn)
+    >>> del cache['']
+    Traceback (most recent call last):
+    ...
+    KeyError: ''
+    >>> from persistent import Persistent
+    >>> p = Persistent()
+    >>> p._p_oid = 'foo'
+    >>> p._p_jar = conn
+    >>> cache['foo'] = p
+    >>> del cache['foo']
+
+    """
+
+from doctest import DocTestSuite
+import unittest
+
+def test_suite():
+    return unittest.TestSuite((
+        DocTestSuite(),
+        ))
+
+if __name__ == '__main__':
+    unittest.main()

src/persistent/tests/test_list.py

+##############################################################################
+#
+# Copyright (c) 2001, 2002 Zope Corporation and Contributors.
+# All Rights Reserved.
+#
+# This software is subject to the provisions of the Zope Public License,
+# Version 2.0 (ZPL).  A copy of the ZPL should accompany this distribution.
+# THIS SOFTWARE IS PROVIDED "AS IS" AND ANY AND ALL EXPRESS OR IMPLIED
+# WARRANTIES ARE DISCLAIMED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+# WARRANTIES OF TITLE, MERCHANTABILITY, AGAINST INFRINGEMENT, AND FITNESS
+# FOR A PARTICULAR PURPOSE.
+#
+##############################################################################
+"""Test the list interface to PersistentList
+"""
+
+import unittest
+from persistent.list import PersistentList
+
+l0 = []
+l1 = [0]
+l2 = [0, 1]
+
+class TestPList(unittest.TestCase):
+
+    def testTheWorld(self):
+        # Test constructors
+        u = PersistentList()
+        u0 = PersistentList(l0)
+        u1 = PersistentList(l1)
+        u2 = PersistentList(l2)
+
+        uu = PersistentList(u)
+        uu0 = PersistentList(u0)
+        uu1 = PersistentList(u1)
+        uu2 = PersistentList(u2)
+
+        v = PersistentList(tuple(u))
+        class OtherList:
+            def __init__(self, initlist):
+                self.__data = initlist
+            def __len__(self):
+                return len(self.__data)
+            def __getitem__(self, i):
+                return self.__data[i]
+        v0 = PersistentList(OtherList(u0))
+        vv = PersistentList("this is also a sequence")
+
+        # Test __repr__
+        eq = self.assertEqual
+
+        eq(str(u0), str(l0), "str(u0) == str(l0)")
+        eq(repr(u1), repr(l1), "repr(u1) == repr(l1)")
+        eq(`u2`, `l2`, "`u2` == `l2`")
+
+        # Test __cmp__ and __len__
+
+        def mycmp(a, b):
+            r = cmp(a, b)
+            if r < 0: return -1
+            if r > 0: return 1
+            return r
+
+        all = [l0, l1, l2, u, u0, u1, u2, uu, uu0, uu1, uu2]
+        for a in all:
+            for b in all:
+                eq(mycmp(a, b), mycmp(len(a), len(b)),
+                      "mycmp(a, b) == mycmp(len(a), len(b))")
+
+        # Test __getitem__
+
+        for i in range(len(u2)):
+            eq(u2[i], i, "u2[i] == i")
+
+        # Test __setitem__
+
+        uu2[0] = 0
+        uu2[1] = 100
+        try:
+            uu2[2] = 200
+        except IndexError:
+            pass
+        else:
+            raise TestFailed("uu2[2] shouldn't be assignable")
+
+        # Test __delitem__
+
+        del uu2[1]
+        del uu2[0]
+        try:
+            del uu2[0]
+        except IndexError:
+            pass
+        else:
+            raise TestFailed("uu2[0] shouldn't be deletable")
+
+        # Test __getslice__
+
+        for i in range(-3, 4):
+            eq(u2[:i], l2[:i], "u2[:i] == l2[:i]")
+            eq(u2[i:], l2[i:], "u2[i:] == l2[i:]")
+            for j in range(-3, 4):
+                eq(u2[i:j], l2[i:j], "u2[i:j] == l2[i:j]")
+
+        # Test __setslice__
+
+        for i in range(-3, 4):
+            u2[:i] = l2[:i]
+            eq(u2, l2, "u2 == l2")
+            u2[i:] = l2[i:]
+            eq(u2, l2, "u2 == l2")
+            for j in range(-3, 4):
+                u2[i:j] = l2[i:j]
+                eq(u2, l2, "u2 == l2")
+
+        uu2 = u2[:]
+        uu2[:0] = [-2, -1]
+        eq(uu2, [-2, -1, 0, 1], "uu2 == [-2, -1, 0, 1]")
+        uu2[0:] = []
+        eq(uu2, [], "uu2 == []")
+
+        # Test __contains__
+        for i in u2:
+            self.failUnless(i in u2, "i in u2")
+        for i in min(u2)-1, max(u2)+1:
+            self.failUnless(i not in u2, "i not in u2")
+
+        # Test __delslice__
+
+        uu2 = u2[:]
+        del uu2[1:2]
+        del uu2[0:1]
+        eq(uu2, [], "uu2 == []")
+
+        uu2 = u2[:]
+        del uu2[1:]
+        del uu2[:1]
+        eq(uu2, [], "uu2 == []")
+
+        # Test __add__, __radd__, __mul__ and __rmul__
+
+        #self.failUnless(u1 + [] == [] + u1 == u1, "u1 + [] == [] + u1 == u1")
+        self.failUnless(u1 + [1] == u2, "u1 + [1] == u2")
+        #self.failUnless([-1] + u1 == [-1, 0], "[-1] + u1 == [-1, 0]")
+        self.failUnless(u2 == u2*1 == 1*u2, "u2 == u2*1 == 1*u2")
+        self.failUnless(u2+u2 == u2*2 == 2*u2, "u2+u2 == u2*2 == 2*u2")
+        self.failUnless(u2+u2+u2 == u2*3 == 3*u2, "u2+u2+u2 == u2*3 == 3*u2")
+
+        # Test append
+
+        u = u1[:]
+        u.append(1)
+        eq(u, u2, "u == u2")
+
+        # Test insert
+
+        u = u2[:]
+        u.insert(0, -1)
+        eq(u, [-1, 0, 1], "u == [-1, 0, 1]")
+
+        # Test pop
+
+        u = PersistentList([0, -1, 1])
+        u.pop()
+        eq(u, [0, -1], "u == [0, -1]")
+        u.pop(0)
+        eq(u, [-1], "u == [-1]")
+
+        # Test remove
+
+        u = u2[:]
+        u.remove(1)
+        eq(u, u1, "u == u1")
+
+        # Test count
+        u = u2*3
+        eq(u.count(0), 3, "u.count(0) == 3")
+        eq(u.count(1), 3, "u.count(1) == 3")
+        eq(u.count(2), 0, "u.count(2) == 0")
+
+
+        # Test index
+
+        eq(u2.index(0), 0, "u2.index(0) == 0")
+        eq(u2.index(1), 1, "u2.index(1) == 1")
+        try:
+            u2.index(2)
+        except ValueError:
+            pass
+        else:
+            raise TestFailed("expected ValueError")
+
+        # Test reverse
+
+        u = u2[:]
+        u.reverse()
+        eq(u, [1, 0], "u == [1, 0]")
+        u.reverse()
+        eq(u, u2, "u == u2")
+
+        # Test sort
+
+        u = PersistentList([1, 0])
+        u.sort()
+        eq(u, u2, "u == u2")
+
+        # Test extend
+
+        u = u1[:]
+        u.extend(u2)
+        eq(u, u1 + u2, "u == u1 + u2")
+
+        # Test iadd
+        u = u1[:]
+        u += u2
+        eq(u, u1 + u2, "u == u1 + u2")
+
+        # Test imul
+        u = u1[:]
+        u *= 3
+        eq(u, u1 + u1 + u1, "u == u1 + u1 + u1")
+
+
+def test_suite():
+    return unittest.makeSuite(TestPList)
+
+if __name__ == "__main__":
+    loader = unittest.TestLoader()
+    unittest.main(testLoader=loader)

src/persistent/tests/test_pickle.py

@@ -13,7 +13,7 @@
 ##############################################################################
 """Basic pickling tests
 
-$Id: test_pickle.py,v 1.3 2003/12/29 22:40:50 tim_one Exp $
+$Id: test_pickle.py,v 1.4 2004/02/19 02:59:32 jeremy Exp $
 """
 
 from persistent import Persistent
@@ -73,7 +73,8 @@ def test_basic_pickling():
     1
     >>> pickle.loads(pickle.dumps(x, 1)) == x
     1
-    >>> pickle.loads(pickle.dumps(x, 2)) == x
+    
+    XXX disable until Python 2.3.4 >>> pickle.loads(pickle.dumps(x, 2)) == x
     1
 
     >>> x.__setstate__({'z': 1})
@@ -123,7 +124,8 @@ def test_pickling_w_overrides():
     1
     >>> pickle.loads(pickle.dumps(x, 1)) == x
     1
-    >>> pickle.loads(pickle.dumps(x, 2)) == x
+
+    XXX disable until Python 2.3.4 >>> pickle.loads(pickle.dumps(x, 2)) == x
     1
 
     """
@@ -164,7 +166,8 @@ def test_pickling_w_slots_only():
     1
     >>> pickle.loads(pickle.dumps(x, 1)) == x
     1
-    >>> pickle.loads(pickle.dumps(x, 2)) == x
+    
+    XXX disable until Python 2.3.4 >>> pickle.loads(pickle.dumps(x, 2)) == x
     1
 
     >>> x.s4 = 'spam'
@@ -180,7 +183,8 @@ def test_pickling_w_slots_only():
     1
     >>> pickle.loads(pickle.dumps(x, 1)) == x
     1
-    >>> pickle.loads(pickle.dumps(x, 2)) == x
+
+    XXX disable until Python 2.3.4 >>> pickle.loads(pickle.dumps(x, 2)) == x
     1
 
     """
@@ -217,7 +221,8 @@ def test_pickling_w_slots():
     1
     >>> pickle.loads(pickle.dumps(x, 1)) == x
     1
-    >>> pickle.loads(pickle.dumps(x, 2)) == x
+
+    XXX disable until Python 2.3.4     >>> pickle.loads(pickle.dumps(x, 2)) == x
     1
 
     >>> x.s4 = 'spam'
@@ -234,7 +239,8 @@ def test_pickling_w_slots():
     1
     >>> pickle.loads(pickle.dumps(x, 1)) == x
     1
-    >>> pickle.loads(pickle.dumps(x, 2)) == x
+
+    XXX disable until Python 2.3.4     >>> pickle.loads(pickle.dumps(x, 2)) == x
     1
 
     """
@@ -258,7 +264,8 @@ def test_pickling_w_slots_w_empty_dict():
     1
     >>> pickle.loads(pickle.dumps(x, 1)) == x
     1
-    >>> pickle.loads(pickle.dumps(x, 2)) == x
+
+    XXX disable until Python 2.3.4     >>> pickle.loads(pickle.dumps(x, 2)) == x
     1
 
     >>> x.s4 = 'spam'
@@ -275,7 +282,8 @@ def test_pickling_w_slots_w_empty_dict():
     1
     >>> pickle.loads(pickle.dumps(x, 1)) == x
     1
-    >>> pickle.loads(pickle.dumps(x, 2)) == x
+
+    XXX disable until Python 2.3.4     >>> pickle.loads(pickle.dumps(x, 2)) == x
     1
 
     """

src/persistent/tests/test_wref.py

+##############################################################################
+#
+# Copyright (c) 2003 Zope Corporation and Contributors.
+# All Rights Reserved.
+#
+# This software is subject to the provisions of the Zope Public License,
+# Version 2.0 (ZPL).  A copy of the ZPL should accompany this distribution.
+# THIS SOFTWARE IS PROVIDED "AS IS" AND ANY AND ALL EXPRESS OR IMPLIED
+# WARRANTIES ARE DISCLAIMED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+# WARRANTIES OF TITLE, MERCHANTABILITY, AGAINST INFRINGEMENT, AND FITNESS
+# FOR A PARTICULAR PURPOSE.
+#
+##############################################################################
+"""XXX short summary goes here.
+
+$Id: test_wref.py,v 1.2 2004/02/19 02:59:32 jeremy Exp $
+"""
+import unittest
+from doctest import DocTestSuite
+
+def test_suite():
+    return DocTestSuite('persistent.wref')
+
+if __name__ == '__main__':
+    unittest.main()

src/persistent/wref.py

+##############################################################################
+#
+# Copyright (c) 2003 Zope Corporation and Contributors.
+# All Rights Reserved.
+#
+# This software is subject to the provisions of the Zope Public License,
+# Version 2.0 (ZPL).  A copy of the ZPL should accompany this distribution.
+# THIS SOFTWARE IS PROVIDED "AS IS" AND ANY AND ALL EXPRESS OR IMPLIED
+# WARRANTIES ARE DISCLAIMED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+# WARRANTIES OF TITLE, MERCHANTABILITY, AGAINST INFRINGEMENT, AND FITNESS
+# FOR A PARTICULAR PURPOSE.
+#
+##############################################################################
+"""ZODB-based persistent weakrefs
+
+$Id: wref.py,v 1.2 2004/02/19 02:59:30 jeremy Exp $
+"""
+
+from persistent import Persistent
+
+WeakRefMarker = object()
+
+class WeakRef(object):
+    """Persistent weak references
+
+    Persistent weak references are used much like Python weak
+    references.  The major difference is that you can't specify an
+    object to be called when the object is removed from the database.
+
+    Here's an example. We'll start by creating a persistent object and
+    a refernce to it:
+
+    >>> import persistent.list
+    >>> import ZODB.tests.util
+    >>> ob = persistent.list.PersistentList()
+    >>> ref = WeakRef(ob)
+    >>> ref() is ob
+    True
+
+    The hash of the ref if the same as the hash of the referenced object:
+
+    >>> hash(ref) == hash(ob)
+    True
+
+    Two refs to the same object are equal:
+
+    >>> WeakRef(ob) == ref
+    True
+    
+    >>> ob2 = persistent.list.PersistentList([1])
+    >>> WeakRef(ob2) == ref
+    False
+
+    Lets save the reference and the referenced object in a database:
+
+    >>> db = ZODB.tests.util.DB()
+    
+    >>> conn1 = db.open()
+    >>> conn1.root()['ob'] = ob
+    >>> conn1.root()['ref'] = ref
+    >>> ZODB.tests.util.commit()
+
+    If we open a new connection, we can use the reference:
+
+    >>> conn2 = db.open()
+    >>> conn2.root()['ref']() is conn2.root()['ob']
+    True
+    >>> hash(conn2.root()['ref']) == hash(conn2.root()['ob'])
+    True
+
+    But if we delete the referenced object and pack:
+
+    >>> del conn2.root()['ob']
+    >>> ZODB.tests.util.commit()
+    >>> ZODB.tests.util.pack(db)
+
+    And then look in a new connection:
+
+    >>> conn3 = db.open()
+    >>> conn3.root()['ob']
+    Traceback (most recent call last):
+    ...
+    KeyError: 'ob'
+
+    Trying to dereference the reference returns None:
+    
+    >>> conn3.root()['ref']()
+    
+    Trying to get a hash, raises a type error:
+
+    >>> hash(conn3.root()['ref'])
+    Traceback (most recent call last):
+    ...
+    TypeError: Weakly-referenced object has gone away
+
+    Always explicitly close databases: :)
+    
+    >>> db.close()
+
+    """
+
+    # We set _p_oid to a marker so that the serialization system can
+    # provide special handling of weakrefs.
+    _p_oid = WeakRefMarker
+
+    def __init__(self, ob):
+        self._v_ob = ob
+        self.oid = ob._p_oid
+        self.dm = ob._p_jar
+
+    def __call__(self):
+        try:
+            return self._v_ob
+        except AttributeError:
+            try:
+                self._v_ob = self.dm[self.oid]
+            except KeyError:
+                return None
+            return self._v_ob
+
+    def __hash__(self):
+        self = self()
+        if self is None:
+            raise TypeError('Weakly-referenced object has gone away')
+        return hash(self)
+
+    def __eq__(self, other):
+        self = self()
+        if self is None:
+            raise TypeError('Weakly-referenced object has gone away')
+        other = other()
+        if other is None:
+            raise TypeError('Weakly-referenced object has gone away')
+
+        return self == other
+    
+            
+class PersistentWeakKeyDictionary(Persistent):
+    """Persistent weak key dictionary
+
+    This is akin to WeakKeyDictionaries. Note, however, that removal
+    of items is extremely lazy. See below.
+
+    We'll start by creating a PersistentWeakKeyDictionary and adding
+    some persistent objects to it.
+
+    >>> d = PersistentWeakKeyDictionary()
+    >>> import ZODB.tests.util
+    >>> p1 = ZODB.tests.util.P('p1')
+    >>> p2 = ZODB.tests.util.P('p2')
+    >>> p3 = ZODB.tests.util.P('p3')
+    >>> d[p1] = 1
+    >>> d[p2] = 2
+    >>> d[p3] = 3
+
+    We'll create an extra persistent object that's not in the dict:
+
+    >>> p4 = ZODB.tests.util.P('p4')
+
+    Now we'll excercise iteration and item access:
+
+    >>> l = [(str(k), d[k], d.get(k)) for k in d]
+    >>> l.sort()
+    >>> l
+    [('P(p1)', 1, 1), ('P(p2)', 2, 2), ('P(p3)', 3, 3)]
+
+    And the containment operator:
+
+    >>> [p in d for p in [p1, p2, p3, p4]]
+    [True, True, True, False]
+
+    We can add the dict and the referenced objects to a database:
+    
+    >>> db = ZODB.tests.util.DB()
+    
+    >>> conn1 = db.open()
+    >>> conn1.root()['p1'] = p1
+    >>> conn1.root()['d'] = d
+    >>> conn1.root()['p2'] = p2
+    >>> conn1.root()['p3'] = p3
+    >>> ZODB.tests.util.commit()
+
+    And things still work, as before:
+
+    >>> l = [(str(k), d[k], d.get(k)) for k in d]
+    >>> l.sort()
+    >>> l
+    [('P(p1)', 1, 1), ('P(p2)', 2, 2), ('P(p3)', 3, 3)]
+    >>> [p in d for p in [p1, p2, p3, p4]]
+    [True, True, True, False]
+
+    Likewise, we can read the objects from another connection and
+    things still work.
+
+    >>> conn2 = db.open()
+    >>> d = conn2.root()['d']
+    >>> p1 = conn2.root()['p1']
+    >>> p2 = conn2.root()['p2']
+    >>> p3 = conn2.root()['p3']
+    >>> l = [(str(k), d[k], d.get(k)) for k in d]
+    >>> l.sort()
+    >>> l
+    [('P(p1)', 1, 1), ('P(p2)', 2, 2), ('P(p3)', 3, 3)]
+    >>> [p in d for p in [p1, p2, p3, p4]]
+    [True, True, True, False]
+
+    Now, we'll delete one of the objects from the database, but *not*
+    from the dictionary:
+
+    >>> del conn2.root()['p2']
+    >>> ZODB.tests.util.commit()
+
+    And pack the database, so that the no-longer referenced p2 is
+    actually removed from the database.
+
+    >>> ZODB.tests.util.pack(db)
+
+    Now if we access the dictionary in a new connection, it no longer
+    has p2:
+    
+    >>> conn3 = db.open()
+    >>> d = conn3.root()['d']
+    >>> l = [(str(k), d[k], d.get(k)) for k in d]
+    >>> l.sort()
+    >>> l
+    [('P(p1)', 1, 1), ('P(p3)', 3, 3)]
+
+    It's worth nothing that that the versions of the dictionary in
+    conn1 and conn2 still have p2, because p2 is still in the caches
+    for those connections. 
+
+    Always explicitly close databases: :)
+    
+    >>> db.close()
+
+    """
+    # XXX it is expensive trying to load dead objects from the database.
+    #     It would be helpful if the data manager/connection cached these.
+
+    
+    def __init__(self, adict=None, **kwargs):
+        self.data = {}
+        if adict is not None:
+            keys = getattr(adict, "keys", None)
+            if keys is None:
+                adict = dict(adict)
+            self.update(adict)
+        if kwargs:
+            self.update(kwargs)
+
+    def __getstate__(self):
+        state = Persistent.__getstate__(self)
+        state['data'] = state['data'].items()
+        return state
+
+    def __setstate__(self, state):
+        state['data'] = dict([
+            (k, v) for (k, v) in state['data']
+            if k() is not None
+            ])
+        Persistent.__setstate__(self, state)
+        
+    def __setitem__(self, key, value):
+        self.data[WeakRef(key)] = value
+        
+    def __getitem__(self, key):
+        return self.data[WeakRef(key)]
+        
+    def __delitem__(self, key):
+        del self.data[WeakRef(key)]
+
+    def get(self, key, default=None):
+        """D.get(k[, d]) -> D[k] if k in D, else d.
+
+        >>> import ZODB.tests.util
+        >>> key = ZODB.tests.util.P("key")
+        >>> missing = ZODB.tests.util.P("missing")
+        >>> d = PersistentWeakKeyDictionary([(key, 1)])
+        >>> d.get(key)
+        1
+        >>> d.get(missing)
+        >>> d.get(missing, 12)
+        12
+        """
+        return self.data.get(WeakRef(key), default)
+
+    def __contains__(self, key):
+        return WeakRef(key) in self.data
+    
+    def __iter__(self):
+        for k in self.data:
+            yield k()
+
+    def update(self, adict):
+        if isinstance(adict, PersistentWeakKeyDictionary):
+            self.data.update(adict.update)
+        else:
+            for k, v in adict.items():
+                self.data[WeakRef(k)] = v
+        
+    # XXX Someone else can fill out the rest of the methods, with tests. :)
+