diff --git a/lib/http/client.py b/lib/http/client.py index d32eb5be6802544c7aede7a01d0e4e0b3f736ff9..5ca76a16375de8eb18a400b78b9cc94dffdeed8b 100644 --- a/lib/http/client.py +++ b/lib/http/client.py @@ -95,6 +95,14 @@ class HttpClientRequest(object): self.resp_headers = None self.resp_body = None + def __repr__(self): + status = ["%s.%s" % (self.__class__.__module__, self.__class__.__name__), + "%s:%s" % (self.host, self.port), + self.method, + self.path] + + return "<%s at %#x>" % (" ".join(status), id(self)) + class _HttpClientToServerMessageWriter(http.HttpMessageWriter): pass @@ -328,6 +336,12 @@ class _HttpClientPendingRequest(object): # Thread synchronization self.done = threading.Event() + def __repr__(self): + status = ["%s.%s" % (self.__class__.__module__, self.__class__.__name__), + "req=%r" % self.request] + + return "<%s at %#x>" % (" ".join(status), id(self)) + class HttpClientWorker(workerpool.BaseWorker): """HTTP client worker class. diff --git a/lib/jqueue.py b/lib/jqueue.py index f7e05575fb1af7a03a9cd5c48677c14c0ac58c2c..f989ef8390110e11543121902e54baf236912bb3 100644 --- a/lib/jqueue.py +++ b/lib/jqueue.py @@ -190,6 +190,13 @@ class _QueuedJob(object): # Condition to wait for changes self.change = threading.Condition(self.queue._lock) + def __repr__(self): + status = ["%s.%s" % (self.__class__.__module__, self.__class__.__name__), + "id=%s" % self.id, + "ops=%s" % ",".join([op.input.Summary() for op in self.ops])] + + return "<%s at %#x>" % (" ".join(status), id(self)) + @classmethod def Restore(cls, queue, state): """Restore a _QueuedJob from serialized state: