src/apps/haikudepot/server/BulkLoadContext.cpp

   1 /*
   2  * Copyright 2017, Andrew Lindesay <apl@lindesay.co.nz>.
   3  * All rights reserved. Distributed under the terms of the MIT License.
   4  */
   5 #include "BulkLoadContext.h"
   6
   7
   8 BulkLoadContext::BulkLoadContext()
   9         :
  10         fState(BULK_LOAD_INITIAL),
  11         fIconProcess(NULL),
  12         fRepositoryProcess(NULL),
  13         fPkgProcesses(new List<AbstractServerProcess*, true>()),
  14         fProcessOptions(0)
  15 {
  16 }
  17
  18
  19 BulkLoadContext::~BulkLoadContext()
  20 {
  21         StopAllProcesses();
  22
  23         if (fIconProcess != NULL)
  24                 delete fIconProcess;
  25
  26         if (fRepositoryProcess != NULL)
  27                 delete fRepositoryProcess;
  28
  29         int32 count = fPkgProcesses->CountItems();
  30         int32 i;
  31
  32         for (i = 0; i < count; i++)
  33                 delete fPkgProcesses->ItemAt(i);
  34
  35         delete fPkgProcesses;
  36 }
  37
  38
  39 bulk_load_state
  40 BulkLoadContext::State()
  41 {
  42         return fState;
  43 }
  44
  45
  46 void
  47 BulkLoadContext::SetState(bulk_load_state value)
  48 {
  49         fState = value;
  50 }
  51
  52
  53 void
  54 BulkLoadContext::StopAllProcesses()
  55 {
  56         if (fIconProcess != NULL)
  57                 fIconProcess->Stop();
  58
  59         if (fRepositoryProcess != NULL)
  60                 fRepositoryProcess->Stop();
  61
  62         int32 count = fPkgProcesses->CountItems();
  63         int32 i;
  64
  65         for (i = 0; i < count; i++)
  66                 fPkgProcesses->ItemAt(i)->Stop();
  67 }
  68
  69
  70 AbstractServerProcess*
  71 BulkLoadContext::IconProcess()
  72 {
  73         return fIconProcess;
  74 }
  75
  76
  77 void
  78 BulkLoadContext::SetIconProcess(AbstractServerProcess* value)
  79 {
  80         fIconProcess = value;
  81 }
  82
  83
  84 AbstractServerProcess*
  85 BulkLoadContext::RepositoryProcess()
  86 {
  87         return fRepositoryProcess;
  88 }
  89
  90
  91 void
  92 BulkLoadContext::SetRepositoryProcess(
  93         AbstractServerProcess* value)
  94 {
  95         fRepositoryProcess = value;
  96 }
  97
  98
  99 int32
 100 BulkLoadContext::CountPkgProcesses()
 101 {
 102         return fPkgProcesses->CountItems();
 103 }
 104
 105
 106 AbstractServerProcess*
 107 BulkLoadContext::PkgProcessAt(int32 index)
 108 {
 109         return fPkgProcesses->ItemAt(index);
 110 }
 111
 112
 113 void
 114 BulkLoadContext::AddPkgProcess(AbstractServerProcess *value)
 115 {
 116         fPkgProcesses->Add(value);
 117 }
 118
 119
 120 void
 121 BulkLoadContext::AddProcessOption(uint32 flag)
 122 {
 123         fProcessOptions = fProcessOptions | flag;
 124 }
 125
 126
 127 uint32
 128 BulkLoadContext::ProcessOptions()
 129 {
 130         return fProcessOptions;
 131 }