>3=WJ27Vh3d|G@f=.D*DZƿL 2#y;lDiEdTRH P@*5rA :άIUʆl0Sjы#d?tPӷ/-;)mrZ'VL{]v4t:j&׵/^>T~W vjU7W&zhHwˇהUtydEG8 :KqhgAihs'@"S)./<w j/d[_Z\t7_s%(݄h+)`6XaG/T8je1眍{ 'CuK' &J>B][OIiК@β矛ďW7Payj3Aأ~k75ϭ*l있仒"y{,LX=h{AvoS4)M`Ys,:/r=DSNfUq4;(q]Q67Y{wJV.&$/.slh1۴RԶ^1F#O7$ƣi~J+ U=oZpN<<K]*R}uň1=k z㝝x! p TIj+. ]T@- Ӝf- WQ3w@'bN4tSp )p TIj+. ]s/~v+>=,Ui>irʽ=$4M uH&ix 4ng992aAKݨIP)+67Fzԟ=)D1-O#zfqq/צ<)Noٌk@d)"[`s:pz)(}y' ӹg&N?^m tA'X`$-oF˿s(sb D 6צfFk#]d+d|:=f,b ?-Kt`vb$XgŃ>$34Ͻ1ªM} P<k  s'}i[wꭆ=@th0V8 Ə6! ||C"&<|FA]!Dvuy" nH'!g+~o~j:"/]Yq`B |oCFW 6dF2DK(wC1}XE}X;2Ѯ-q/šid?߮VZ AbUJf#%vA oz! ݴݾJ$W>9}$/.slhV ,pFyg$pevCÃ>EAHuKdװ31I D3xźB*&2 SGmkfpMi4 ao][ҫَWuRFc/ր:zy6l[Mny{!b j#dS/Ϸ{؃_@BoQOWI%E+AbXJC#Aq7Dlpofj*m덗qzr Du[fDtLgYůb̌TFRVޚ6iZWnӷLaXlQf\# prI:40pR-shɓSoc:5DLf'McpHNv*n? ing filename; std::string sourceName; std::string destName; bool filenameIsDest; InitializeBaton(Database* db_, Napi::Function cb_, Backup* backup_) : Baton(db_, cb_), backup(backup_), filenameIsDest(true) { backup->Ref(); } virtual ~InitializeBaton() override { backup->Unref(); if (!db->IsOpen() && db->IsLocked()) { // The database handle was closed before the backup could be opened. backup->FinishAll(); } } }; struct StepBaton : Baton { int pages; std::set retryErrorsSet; StepBaton(Backup* backup_, Napi::Function cb_, int pages_) : Baton(backup_, cb_), pages(pages_) {} virtual ~StepBaton() override = default; }; typedef void (*Work_Callback)(Baton* baton); struct Call { Call(Work_Callback cb_, Baton* baton_) : callback(cb_), baton(baton_) {}; Work_Callback callback; Baton* baton; }; Backup(const Napi::CallbackInfo& info); ~Backup() { if (!finished) { FinishAll(); } retryErrors.Reset(); } WORK_DEFINITION(Step) WORK_DEFINITION(Finish) Napi::Value IdleGetter(const Napi::CallbackInfo& info); Napi::Value CompletedGetter(const Napi::CallbackInfo& info); Napi::Value FailedGetter(const Napi::CallbackInfo& info); Napi::Value PageCountGetter(const Napi::CallbackInfo& info); Napi::Value RemainingGetter(const Napi::CallbackInfo& info); Napi::Value FatalErrorGetter(const Napi::CallbackInfo& info); Napi::Value RetryErrorGetter(const Napi::CallbackInfo& info); void FatalErrorSetter(const Napi::CallbackInfo& info, const Napi::Value& value); void RetryErrorSetter(const Napi::CallbackInfo& info, const Napi::Value& value); protected: static void Work_BeginInitialize(Database::Baton* baton); static void Work_Initialize(napi_env env, void* data); static void Work_AfterInitialize(napi_env env, napi_status status, void* data); void Schedule(Work_Callback callback, Baton* baton); void Process(); void CleanQueue(); template static void Error(T* baton); void FinishAll(); void FinishSqlite(); void GetRetryErrors(std::set& retryErrorsSet); Database* db; sqlite3_backup* _handle = NULL; sqlite3* _otherDb = NULL; sqlite3* _destDb = NULL; bool inited = false; bool locked = true; bool completed = false; bool failed = false; int remaining = -1; int pageCount = -1; bool finished = false; int status; std::string message; std::queue> queue; Napi::Reference retryErrors; }; } #endif