Horizon – Diff between revs 10 and 11
?pathlinks?
Rev 10 | Rev 11 | |||
---|---|---|---|---|
Line 153... | Line 153... | |||
153 | |
153 | |
|
Line 154... | Line 154... | |||
154 | #endregion |
154 | #endregion |
|
Line 155... | Line 155... | |||
155 | |
155 | |
|
156 | #region Public Methods |
156 | #region Public Methods |
|
157 | |
157 | |
|
158 | public async Task DeleteScreenshot(string hash, CancellationToken cancellationToken) |
158 | public async Task DeleteScreenshotAsync(string hash, CancellationToken cancellationToken) |
|
159 | { |
159 | { |
|
160 | var connectionString = new SQLiteConnectionStringBuilder |
160 | var connectionString = new SQLiteConnectionStringBuilder |
|
Line 202... | Line 202... | |||
202 | { |
202 | { |
|
203 | _databaseLock.Release(); |
203 | _databaseLock.Release(); |
|
204 | } |
204 | } |
|
205 | } |
205 | } |
|
Line 206... | Line 206... | |||
206 | |
206 | |
|
207 | public async Task NormalizeTime(string hash, CancellationToken cancellationToken) |
207 | public async Task NormalizeTimeAsync(string hash, CancellationToken cancellationToken) |
|
208 | { |
208 | { |
|
209 | await _databaseLock.WaitAsync(cancellationToken); |
209 | await _databaseLock.WaitAsync(cancellationToken); |
|
210 | try |
210 | try |
|
211 | { |
211 | { |
|
Line 280... | Line 280... | |||
280 | { |
280 | { |
|
281 | _databaseLock.Release(); |
281 | _databaseLock.Release(); |
|
282 | } |
282 | } |
|
283 | } |
283 | } |
|
Line 284... | Line 284... | |||
284 | |
284 | |
|
285 | public async Task<long> CountSnapshots(CancellationToken cancellationToken) |
285 | public async Task<long> CountSnapshotsAsync(CancellationToken cancellationToken) |
|
286 | { |
286 | { |
|
287 | await _databaseLock.WaitAsync(cancellationToken); |
287 | await _databaseLock.WaitAsync(cancellationToken); |
|
288 | try |
288 | try |
|
289 | { |
289 | { |
|
Line 320... | Line 320... | |||
320 | { |
320 | { |
|
321 | _databaseLock.Release(); |
321 | _databaseLock.Release(); |
|
322 | } |
322 | } |
|
323 | } |
323 | } |
|
Line 324... | Line 324... | |||
324 | |
324 | |
|
325 | public async IAsyncEnumerable<Snapshot> LoadSnapshots([EnumeratorCancellation] CancellationToken cancellationToken) |
325 | public async IAsyncEnumerable<Snapshot> LoadSnapshotsAsync([EnumeratorCancellation] CancellationToken cancellationToken) |
|
326 | { |
326 | { |
|
327 | await _databaseLock.WaitAsync(cancellationToken); |
327 | await _databaseLock.WaitAsync(cancellationToken); |
|
328 | try |
328 | try |
|
329 | { |
329 | { |
|
Line 374... | Line 374... | |||
374 | { |
374 | { |
|
375 | _databaseLock.Release(); |
375 | _databaseLock.Release(); |
|
376 | } |
376 | } |
|
377 | } |
377 | } |
|
Line 378... | Line 378... | |||
378 | |
378 | |
|
379 | public async Task CreateSnapshot(string name, string path, Color color, CancellationToken cancellationToken) |
379 | public async Task CreateSnapshotAsync(string name, string path, Color color, CancellationToken cancellationToken) |
|
380 | { |
380 | { |
|
381 | await _databaseLock.WaitAsync(cancellationToken); |
381 | await _databaseLock.WaitAsync(cancellationToken); |
|
382 | try |
382 | try |
|
383 | { |
383 | { |
|
Line 516... | Line 516... | |||
516 | { |
516 | { |
|
517 | _databaseLock.Release(); |
517 | _databaseLock.Release(); |
|
518 | } |
518 | } |
|
519 | } |
519 | } |
|
Line 520... | Line 520... | |||
520 | |
520 | |
|
521 | public async Task CreateSnapshot(string name, string path, |
521 | public async Task CreateSnapshotAsync(string name, string path, |
|
522 | Bitmap shot, Color color, CancellationToken cancellationToken) |
522 | Bitmap shot, Color color, CancellationToken cancellationToken) |
|
523 | { |
523 | { |
|
524 | await _databaseLock.WaitAsync(cancellationToken); |
524 | await _databaseLock.WaitAsync(cancellationToken); |
|
525 | try |
525 | try |
|
Line 690... | Line 690... | |||
690 | { |
690 | { |
|
691 | _databaseLock.Release(); |
691 | _databaseLock.Release(); |
|
692 | } |
692 | } |
|
693 | } |
693 | } |
|
Line 694... | Line 694... | |||
694 | |
694 | |
|
695 | public async Task SaveFile(string path, string hash, CancellationToken cancellationToken) |
695 | public async Task SaveFileAsync(string path, string hash, CancellationToken cancellationToken) |
|
696 | { |
696 | { |
|
697 | await _databaseLock.WaitAsync(cancellationToken); |
697 | await _databaseLock.WaitAsync(cancellationToken); |
|
698 | try |
698 | try |
|
699 | { |
699 | { |
|
Line 748... | Line 748... | |||
748 | { |
748 | { |
|
749 | _databaseLock.Release(); |
749 | _databaseLock.Release(); |
|
750 | } |
750 | } |
|
751 | } |
751 | } |
|
Line 752... | Line 752... | |||
752 | |
752 | |
|
753 | public async Task RevertFile(string name, string hash, CancellationToken cancellationToken, bool atomic = true) |
753 | public async Task RevertFileAsync(string name, string hash, CancellationToken cancellationToken, bool atomic = true) |
|
754 | { |
754 | { |
|
755 | await _databaseLock.WaitAsync(cancellationToken); |
755 | await _databaseLock.WaitAsync(cancellationToken); |
|
756 | try |
756 | try |
|
757 | { |
757 | { |
|
Line 868... | Line 868... | |||
868 | { |
868 | { |
|
869 | _databaseLock.Release(); |
869 | _databaseLock.Release(); |
|
870 | } |
870 | } |
|
871 | } |
871 | } |
|
Line 872... | Line 872... | |||
872 | |
872 | |
|
873 | public async Task RemoveFileFast(IEnumerable<string> hashes, CancellationToken cancellationToken) |
873 | public async Task RemoveFileFastAsync(IEnumerable<string> hashes, CancellationToken cancellationToken) |
|
874 | { |
874 | { |
|
875 | await _databaseLock.WaitAsync(cancellationToken); |
875 | await _databaseLock.WaitAsync(cancellationToken); |
|
876 | try |
876 | try |
|
877 | { |
877 | { |
|
Line 921... | Line 921... | |||
921 | { |
921 | { |
|
922 | _databaseLock.Release(); |
922 | _databaseLock.Release(); |
|
923 | } |
923 | } |
|
924 | } |
924 | } |
|
Line 925... | Line 925... | |||
925 | |
925 | |
|
926 | public async Task RemoveFile(string hash, CancellationToken cancellationToken) |
926 | public async Task RemoveFileAsync(string hash, CancellationToken cancellationToken) |
|
927 | { |
927 | { |
|
928 | await _databaseLock.WaitAsync(cancellationToken); |
928 | await _databaseLock.WaitAsync(cancellationToken); |
|
929 | try |
929 | try |
|
930 | { |
930 | { |
|
Line 965... | Line 965... | |||
965 | { |
965 | { |
|
966 | _databaseLock.Release(); |
966 | _databaseLock.Release(); |
|
967 | } |
967 | } |
|
968 | } |
968 | } |
|
Line 969... | Line 969... | |||
969 | |
969 | |
|
970 | public async Task UpdateColor(string hash, Color color, CancellationToken cancellationToken) |
970 | public async Task UpdateColorAsync(string hash, Color color, CancellationToken cancellationToken) |
|
971 | { |
971 | { |
|
Line 972... | Line 972... | |||
972 | await _databaseLock.WaitAsync(cancellationToken); |
972 | await _databaseLock.WaitAsync(cancellationToken); |
|
973 | |
973 | |
|
Line 1011... | Line 1011... | |||
1011 | { |
1011 | { |
|
1012 | _databaseLock.Release(); |
1012 | _databaseLock.Release(); |
|
1013 | } |
1013 | } |
|
1014 | } |
1014 | } |
|
Line 1015... | Line 1015... | |||
1015 | |
1015 | |
|
1016 | public async Task RemoveColor(string hash, CancellationToken cancellationToken) |
1016 | public async Task RemoveColorAsync(string hash, CancellationToken cancellationToken) |
|
1017 | { |
1017 | { |
|
1018 | await _databaseLock.WaitAsync(cancellationToken); |
1018 | await _databaseLock.WaitAsync(cancellationToken); |
|
1019 | try |
1019 | try |
|
1020 | { |
1020 | { |
|
Line 1055... | Line 1055... | |||
1055 | { |
1055 | { |
|
1056 | _databaseLock.Release(); |
1056 | _databaseLock.Release(); |
|
1057 | } |
1057 | } |
|
1058 | } |
1058 | } |
|
Line 1059... | Line 1059... | |||
1059 | |
1059 | |
|
1060 | public async Task<SnapshotPreview> RetrievePreview(string hash, CancellationToken cancellationToken) |
1060 | public async Task<SnapshotPreview> RetrievePreviewAsync(string hash, CancellationToken cancellationToken) |
|
1061 | { |
1061 | { |
|
1062 | await _databaseLock.WaitAsync(cancellationToken); |
1062 | await _databaseLock.WaitAsync(cancellationToken); |
|
1063 | try |
1063 | try |
|
1064 | { |
1064 | { |
|
Line 1116... | Line 1116... | |||
1116 | { |
1116 | { |
|
1117 | _databaseLock.Release(); |
1117 | _databaseLock.Release(); |
|
1118 | } |
1118 | } |
|
1119 | } |
1119 | } |
|
Line 1120... | Line 1120... | |||
1120 | |
1120 | |
|
1121 | public async Task<MemoryStream> RetrieveFileStream(string hash, CancellationToken cancellationToken) |
1121 | public async Task<MemoryStream> RetrieveFileStreamAsync(string hash, CancellationToken cancellationToken) |
|
1122 | { |
1122 | { |
|
1123 | await _databaseLock.WaitAsync(cancellationToken); |
1123 | await _databaseLock.WaitAsync(cancellationToken); |
|
1124 | try |
1124 | try |
|
1125 | { |
1125 | { |
|
Line 1175... | Line 1175... | |||
1175 | { |
1175 | { |
|
1176 | _databaseLock.Release(); |
1176 | _databaseLock.Release(); |
|
1177 | } |
1177 | } |
|
1178 | } |
1178 | } |
|
Line 1179... | Line 1179... | |||
1179 | |
1179 | |
|
1180 | public async Task RelocateFile(string hash, string path, CancellationToken cancellationToken) |
1180 | public async Task RelocateFileAsync(string hash, string path, CancellationToken cancellationToken) |
|
1181 | { |
1181 | { |
|
1182 | await _databaseLock.WaitAsync(cancellationToken); |
1182 | await _databaseLock.WaitAsync(cancellationToken); |
|
1183 | try |
1183 | try |
|
1184 | { |
1184 | { |
|
Line 1221... | Line 1221... | |||
1221 | { |
1221 | { |
|
1222 | _databaseLock.Release(); |
1222 | _databaseLock.Release(); |
|
1223 | } |
1223 | } |
|
1224 | } |
1224 | } |
|
Line 1225... | Line 1225... | |||
1225 | |
1225 | |
|
1226 | public async Task UpdateNote(string hash, string note, CancellationToken cancellationToken) |
1226 | public async Task UpdateNoteAsync(string hash, string note, CancellationToken cancellationToken) |
|
1227 | { |
1227 | { |
|
1228 | await _databaseLock.WaitAsync(cancellationToken); |
1228 | await _databaseLock.WaitAsync(cancellationToken); |
|
1229 | try |
1229 | try |
|
1230 | { |
1230 | { |
|
Line 1270... | Line 1270... | |||
1270 | { |
1270 | { |
|
1271 | _databaseLock.Release(); |
1271 | _databaseLock.Release(); |
|
1272 | } |
1272 | } |
|
1273 | } |
1273 | } |
|
Line 1274... | Line 1274... | |||
1274 | |
1274 | |
|
1275 | public async Task<string> UpdateFile(string hash, byte[] data, CancellationToken cancellationToken) |
1275 | public async Task<string> UpdateFileAsync(string hash, byte[] data, CancellationToken cancellationToken) |
|
1276 | { |
1276 | { |
|
1277 | await _databaseLock.WaitAsync(cancellationToken); |
1277 | await _databaseLock.WaitAsync(cancellationToken); |
|
1278 | try |
1278 | try |
|
1279 | { |
1279 | { |
|
Line 1390... | Line 1390... | |||
1390 | { |
1390 | { |
|
1391 | _databaseLock.Release(); |
1391 | _databaseLock.Release(); |
|
1392 | } |
1392 | } |
|
1393 | } |
1393 | } |
|
Line 1394... | Line 1394... | |||
1394 | |
1394 | |
|
1395 | public async Task UpdateHash(string from, string to, CancellationToken cancellationToken) |
1395 | public async Task UpdateHashAsync(string from, string to, CancellationToken cancellationToken) |
|
1396 | { |
1396 | { |
|
1397 | await _databaseLock.WaitAsync(cancellationToken); |
1397 | await _databaseLock.WaitAsync(cancellationToken); |
|
1398 | try |
1398 | try |
|
1399 | { |
1399 | { |