ExternalVendorCode/tahoe-lafs
1
0
Fork 0
mirror of https://github.com/tahoe-lafs/tahoe-lafs.git synced 2025-04-13 22:03:04 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Serialize queue items using their path and type

Browse Source
This commit is contained in:
Jean-Paul Calderone 2019-03-04 10:47:05 -05:00
parent 64ef320592
commit fa3429f1cc
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/allmydata/frontends/magic_folder.py
View File

@ -773,7 +773,7 @@ ALL_FILES = MessageType(
_ITEMS = Field(
u"items",
lambda deque: list(deque),
lambda deque: list(dict(relpath=item.relpath_u, kind=item.kind) for item in deque),
u"Items in a processing queue.",
)
@ -1055,6 +1055,8 @@ class IQueuedItem(Interface):
@implementer(IQueuedItem)
class QueuedItem(object):
kind = None
def __init__(self, relpath_u, progress, size):
self.relpath_u = relpath_u
self.progress = progress
@ -1096,7 +1098,7 @@ class UploadItem(QueuedItem):
"""
Represents a single item the _deque of the Uploader
"""
pass
kind = u"upload"
_ITEM = Field(
@ -1611,6 +1613,8 @@ class DownloadItem(QueuedItem):
"""
Represents a single item in the _deque of the Downloader
"""
kind = u"download"
def __init__(self, relpath_u, progress, filenode, metadata, size):
super(DownloadItem, self).__init__(relpath_u, progress, size)
self.file_node = filenode