DatabaseContext.m 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. // _____ _
  2. // |_ _| |_ _ _ ___ ___ _ __ __ _
  3. // | | | ' \| '_/ -_) -_) ' \/ _` |_
  4. // |_| |_||_|_| \___\___|_|_|_\__,_(_)
  5. //
  6. // Threema iOS Client
  7. // Copyright (c) 2019-2020 Threema GmbH
  8. //
  9. // This program is free software: you can redistribute it and/or modify
  10. // it under the terms of the GNU Affero General Public License, version 3,
  11. // as published by the Free Software Foundation.
  12. //
  13. // This program is distributed in the hope that it will be useful,
  14. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  15. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  16. // GNU Affero General Public License for more details.
  17. //
  18. // You should have received a copy of the GNU Affero General Public License
  19. // along with this program. If not, see <https://www.gnu.org/licenses/>.
  20. #import <Foundation/Foundation.h>
  21. #import "DatabaseContext.h"
  22. @implementation DatabaseContext {
  23. NSManagedObjectContext *privateContext;
  24. }
  25. static NSManagedObjectContext *mainContext;
  26. static dispatch_queue_t dispatchQueue;
  27. + (void)initialize {
  28. if (dispatchQueue == nil) {
  29. dispatchQueue = dispatch_queue_create("ch.threema.DatabaseContext.main", NULL);
  30. }
  31. }
  32. - (instancetype)initWithPersistentCoordinator:(NSPersistentStoreCoordinator *)persistentCoordinator forBackgroundProcess:(BOOL)forBackgroundProcess
  33. {
  34. self = [super init];
  35. if (self) {
  36. dispatch_sync(dispatchQueue, ^{
  37. if (mainContext == nil) {
  38. mainContext = [[NSManagedObjectContext alloc] initWithConcurrencyType:NSMainQueueConcurrencyType];
  39. [mainContext setPersistentStoreCoordinator:persistentCoordinator];
  40. [mainContext setMergePolicy:NSOverwriteMergePolicy];
  41. }
  42. });
  43. if (forBackgroundProcess) {
  44. privateContext = [[NSManagedObjectContext alloc] initWithConcurrencyType:NSMainQueueConcurrencyType];
  45. [privateContext setParentContext:mainContext];
  46. }
  47. }
  48. return self;
  49. }
  50. - (NSManagedObjectContext *)main
  51. {
  52. return mainContext;
  53. }
  54. - (NSManagedObjectContext *)current
  55. {
  56. return privateContext != nil ? privateContext : mainContext;
  57. }
  58. @end