Docserver: Make ObjectStore set calls return Futures

chrome/common/extensions/docs/server2/appengine_wrappers.py

 # Copyright (c) 2012 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 def IsDeadlineExceededError(error):
   '''A general way of determining whether |error| is a DeadlineExceededError,
   since there are 3 different types thrown by AppEngine and we might as well
   handle them all the same way. For more info see:
   https://developers.google.com/appengine/articles/deadlineexceedederrors
   '''
@@ skipping 148 matching lines @@
   logservice = Logservice()
 
   class InMemoryMemcache(object):
     """An in-memory memcache implementation.
     """
     def __init__(self):
       self._namespaces = {}
 
     class Client(object):
       def set_multi_async(self, mapping, namespace='', time=0):
-        for k, v in mapping.iteritems():
-          memcache.set(k, v, namespace=namespace, time=time)
+        return _RPC(result=dict(
+          (k, memcache.set(k, v, namespace=namespace, time=time))
+           for k, v in mapping.iteritems()))
 
       def get_multi_async(self, keys, namespace='', time=0):
         return _RPC(result=dict(
           (k, memcache.get(k, namespace=namespace, time=time)) for k in keys))
 
     def set(self, key, value, namespace='', time=0):
       self._GetNamespace(namespace)[key] = value
 
     def get(self, key, namespace='', time=0):
       return self._GetNamespace(namespace).get(key)
@@ skipping 122 matching lines @@
       def add(self, task):
         global _task_runner
         if _task_runner:
           _task_runner(task.GetUrl(), task.GetCommit())
         return _RPC()
 
       def purge(self):
         return _RPC()
 
   taskqueue = SynchronousTaskQueue()