Home | History | Annotate | Download | only in multiprocessing

Lines Matching refs:ident

229                 ident, methodname, args, kwds = request
231 obj, exposed, gettypeid = id_to_obj[ident]
235 self.id_to_local_proxy_obj[ident]
267 self, conn, ident, obj, *args, **kwds
294 def fallback_getvalue(self, conn, ident, obj):
297 def fallback_str(self, conn, ident, obj):
300 def fallback_repr(self, conn, ident, obj):
320 for ident in keys:
321 if ident != '0':
323 (ident, self.id_to_refcount[ident],
324 str(self.id_to_obj[ident][0])[:75]))
331 # Doesn't use (len(self.id_to_obj) - 1) as we shouldn't count ident='0'
367 ident = '%x' % id(obj) # convert to string because xmlrpclib
369 util.debug('%r callable returned object with id %r', typeid, ident)
371 self.id_to_obj[ident] = (obj, set(exposed), method_to_typeid)
372 if ident not in self.id_to_refcount:
373 self.id_to_refcount[ident] = 0
375 self.incref(c, ident)
376 return ident, tuple(exposed)
392 def incref(self, c, ident):
395 self.id_to_refcount[ident] += 1
401 if ident in self.id_to_local_proxy_obj:
402 self.id_to_refcount[ident] = 1
403 self.id_to_obj[ident] = \
404 self.id_to_local_proxy_obj[ident]
405 obj, exposed, gettypeid = self.id_to_obj[ident]
406 util.debug('Server re-enabled tracking & INCREF %r', ident)
410 def decref(self, c, ident):
411 if ident not in self.id_to_refcount and \
412 ident in self.id_to_local_proxy_obj:
413 util.debug('Server DECREF skipping %r', ident)
417 assert self.id_to_refcount[ident] >= 1
418 self.id_to_refcount[ident] -= 1
419 if self.id_to_refcount[ident] == 0:
420 del self.id_to_refcount[ident]
422 if ident not in self.id_to_refcount:
425 # Otherwise, deleting self.id_to_obj[ident] would trigger the
428 self.id_to_obj[ident] = (None, (), None) # thread-safe
429 util.debug('disposing of obj with id %r', ident)
431 del self.id_to_obj[ident]
511 ident = ':'.join(str(i) for i in self._process._identity)
512 ident