Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
jio_mebibou
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
Alexandra Rogova
jio_mebibou
Commits
4f466b0c
Commit
4f466b0c
authored
May 19, 2017
by
Romain Courteaud
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
ReplicateStorage: correctly skip attachment
parent
fa8ad6e0
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
14 additions
and
19 deletions
+14
-19
src/jio.storage/replicatestorage.js
src/jio.storage/replicatestorage.js
+14
-19
No files found.
src/jio.storage/replicatestorage.js
View file @
4f466b0c
...
...
@@ -299,7 +299,7 @@
});
}
function
checkAndPropagateAttachment
(
context
,
skip_document_dict
,
function
checkAndPropagateAttachment
(
context
,
skip_attachment_dict
,
status_hash
,
local_hash
,
blob
,
source
,
destination
,
id
,
name
,
...
...
@@ -330,7 +330,7 @@
// Deleted on both side, drop signature
return
context
.
_signature_sub_storage
.
removeAttachment
(
id
,
name
)
.
push
(
function
()
{
skip_attachment_dict
[
id
]
=
null
;
skip_attachment_dict
[
name
]
=
null
;
});
}
...
...
@@ -339,7 +339,7 @@
hash
:
local_hash
}))
.
push
(
function
()
{
skip_
document_dict
[
id
]
=
null
;
skip_
attachment_dict
[
name
]
=
null
;
});
}
...
...
@@ -396,7 +396,6 @@
}
function
checkAttachmentSignatureDifference
(
queue
,
context
,
skip_document_dict
,
skip_attachment_dict
,
source
,
destination
,
id
,
name
,
...
...
@@ -439,7 +438,7 @@
local_hash
=
generateHashFromArrayBuffer
(
array_buffer
);
if
(
local_hash
!==
status_hash
)
{
return
checkAndPropagateAttachment
(
context
,
skip_document_dict
,
return
checkAndPropagateAttachment
(
context
,
skip_attachment_dict
,
status_hash
,
local_hash
,
blob
,
source
,
destination
,
id
,
name
,
...
...
@@ -449,7 +448,7 @@
});
}
function
checkAttachmentLocalDeletion
(
queue
,
context
,
skip_document_dict
,
function
checkAttachmentLocalDeletion
(
queue
,
context
,
skip_attachment_dict
,
destination
,
id
,
name
,
source
,
conflict_force
,
conflict_revert
,
...
...
@@ -462,7 +461,7 @@
})
.
push
(
function
(
result
)
{
status_hash
=
result
.
hash
;
return
checkAndPropagateAttachment
(
context
,
skip_document_dict
,
return
checkAndPropagateAttachment
(
context
,
skip_attachment_dict
,
status_hash
,
null
,
null
,
source
,
destination
,
id
,
name
,
...
...
@@ -471,9 +470,10 @@
});
}
function
pushDocumentAttachment
(
context
,
skip_document_dict
,
function
pushDocumentAttachment
(
context
,
skip_attachment_dict
,
id
,
source
,
destination
,
options
)
{
destination
,
options
)
{
var
queue
=
new
RSVP
.
Queue
(),
local_dict
=
{},
signature_dict
=
{};
...
...
@@ -527,7 +527,6 @@
if
(
is_modification
===
true
||
is_creation
===
true
)
{
argument_list
.
push
([
undefined
,
context
,
skip_document_dict
,
skip_attachment_dict
,
source
,
destination
,
id
,
key
,
...
...
@@ -554,7 +553,6 @@
if
(
!
local_dict
.
hasOwnProperty
(
key
))
{
argument_list
.
push
([
undefined
,
context
,
skip_document_dict
,
skip_attachment_dict
,
destination
,
id
,
key
,
source
,
...
...
@@ -574,7 +572,7 @@
});
}
function
repairDocumentAttachment
(
context
,
id
,
skip_document_dict
)
{
function
repairDocumentAttachment
(
context
,
id
)
{
var
skip_attachment_dict
=
{};
return
new
RSVP
.
Queue
()
.
push
(
function
()
{
...
...
@@ -583,7 +581,6 @@
context
.
_check_local_attachment_deletion
)
{
return
pushDocumentAttachment
(
context
,
skip_document_dict
,
skip_attachment_dict
,
id
,
context
.
_local_sub_storage
,
...
...
@@ -609,7 +606,6 @@
context
.
_check_remote_attachment_deletion
)
{
return
pushDocumentAttachment
(
context
,
skip_document_dict
,
skip_attachment_dict
,
id
,
context
.
_remote_sub_storage
,
...
...
@@ -738,7 +734,7 @@
// ie, replication should prevent losing user data
// Synchronize attachments before, to ensure
// all of them will be deleted too
return
repairDocumentAttachment
(
context
,
id
,
skip_document_dict
)
return
repairDocumentAttachment
(
context
,
id
)
.
push
(
function
()
{
return
destination
.
allAttachments
(
id
);
})
...
...
@@ -1046,9 +1042,9 @@
});
}
function
repairDocument
(
queue
,
context
,
id
,
skip_document_dict
)
{
function
repairDocument
(
queue
,
context
,
id
)
{
queue
.
push
(
function
()
{
return
repairDocumentAttachment
(
context
,
id
,
skip_document_dict
);
return
repairDocumentAttachment
(
context
,
id
);
});
}
...
...
@@ -1184,8 +1180,7 @@
for
(
i
=
0
;
i
<
len
;
i
+=
1
)
{
local_argument_list
.
push
(
[
undefined
,
context
,
result
.
data
.
rows
[
i
].
id
,
skip_document_dict
]
[
undefined
,
context
,
result
.
data
.
rows
[
i
].
id
]
);
}
return
dispatchQueue
(
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment