2 * Background Copy Job Interface for BITS
4 * Copyright 2007 Google (Roy Shea)
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or (at your option) any later version.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
27 #include "wine/debug.h"
29 WINE_DEFAULT_DEBUG_CHANNEL(qmgr);
31 static void BackgroundCopyJobDestructor(BackgroundCopyJobImpl *This)
33 DeleteCriticalSection(&This->cs);
34 HeapFree(GetProcessHeap(), 0, This->displayName);
35 HeapFree(GetProcessHeap(), 0, This);
38 static ULONG WINAPI BITS_IBackgroundCopyJob_AddRef(IBackgroundCopyJob2 *iface)
40 BackgroundCopyJobImpl *This = (BackgroundCopyJobImpl *) iface;
41 return InterlockedIncrement(&This->ref);
44 static HRESULT WINAPI BITS_IBackgroundCopyJob_QueryInterface(
45 IBackgroundCopyJob2 *iface, REFIID riid, LPVOID *ppvObject)
47 BackgroundCopyJobImpl *This = (BackgroundCopyJobImpl *) iface;
48 TRACE("IID: %s\n", debugstr_guid(riid));
50 if (IsEqualGUID(riid, &IID_IUnknown)
51 || IsEqualGUID(riid, &IID_IBackgroundCopyJob)
52 || IsEqualGUID(riid, &IID_IBackgroundCopyJob2))
54 *ppvObject = &This->lpVtbl;
55 BITS_IBackgroundCopyJob_AddRef(iface);
63 static ULONG WINAPI BITS_IBackgroundCopyJob_Release(IBackgroundCopyJob2 *iface)
65 BackgroundCopyJobImpl *This = (BackgroundCopyJobImpl *) iface;
66 ULONG ref = InterlockedDecrement(&This->ref);
69 BackgroundCopyJobDestructor(This);
74 /*** IBackgroundCopyJob methods ***/
76 static HRESULT WINAPI BITS_IBackgroundCopyJob_AddFileSet(
77 IBackgroundCopyJob2 *iface,
79 BG_FILE_INFO *pFileSet)
82 for (i = 0; i < cFileCount; ++i)
84 HRESULT hr = IBackgroundCopyJob_AddFile(iface, pFileSet[i].RemoteName,
85 pFileSet[i].LocalName);
92 static HRESULT WINAPI BITS_IBackgroundCopyJob_AddFile(
93 IBackgroundCopyJob2 *iface,
97 BackgroundCopyJobImpl *This = (BackgroundCopyJobImpl *) iface;
98 IBackgroundCopyFile *pFile;
99 BackgroundCopyFileImpl *file;
102 /* We should return E_INVALIDARG in these cases. */
103 FIXME("Check for valid filenames and supported protocols\n");
105 res = BackgroundCopyFileConstructor(This, RemoteUrl, LocalName, (LPVOID *) &pFile);
109 /* Add a reference to the file to file list */
110 IBackgroundCopyFile_AddRef(pFile);
111 file = (BackgroundCopyFileImpl *) pFile;
112 EnterCriticalSection(&This->cs);
113 list_add_head(&This->files, &file->entryFromJob);
114 This->jobProgress.BytesTotal = BG_SIZE_UNKNOWN;
115 ++This->jobProgress.FilesTotal;
116 LeaveCriticalSection(&This->cs);
121 static HRESULT WINAPI BITS_IBackgroundCopyJob_EnumFiles(
122 IBackgroundCopyJob2 *iface,
123 IEnumBackgroundCopyFiles **ppEnum)
126 return EnumBackgroundCopyFilesConstructor((LPVOID *) ppEnum, iface);
129 static HRESULT WINAPI BITS_IBackgroundCopyJob_Suspend(
130 IBackgroundCopyJob2 *iface)
132 FIXME("Not implemented\n");
136 static HRESULT WINAPI BITS_IBackgroundCopyJob_Resume(
137 IBackgroundCopyJob2 *iface)
139 BackgroundCopyJobImpl *This = (BackgroundCopyJobImpl *) iface;
142 EnterCriticalSection(&globalMgr.cs);
143 if (This->state == BG_JOB_STATE_CANCELLED
144 || This->state == BG_JOB_STATE_ACKNOWLEDGED)
146 rv = BG_E_INVALID_STATE;
148 else if (This->jobProgress.FilesTransferred == This->jobProgress.FilesTotal)
152 else if (This->state != BG_JOB_STATE_CONNECTING
153 && This->state != BG_JOB_STATE_TRANSFERRING)
155 This->state = BG_JOB_STATE_QUEUED;
156 SetEvent(globalMgr.jobEvent);
158 LeaveCriticalSection(&globalMgr.cs);
163 static HRESULT WINAPI BITS_IBackgroundCopyJob_Cancel(
164 IBackgroundCopyJob2 *iface)
166 FIXME("Not implemented\n");
170 static HRESULT WINAPI BITS_IBackgroundCopyJob_Complete(
171 IBackgroundCopyJob2 *iface)
173 BackgroundCopyJobImpl *This = (BackgroundCopyJobImpl *) iface;
176 EnterCriticalSection(&This->cs);
178 if (This->state == BG_JOB_STATE_CANCELLED
179 || This->state == BG_JOB_STATE_ACKNOWLEDGED)
181 rv = BG_E_INVALID_STATE;
185 BackgroundCopyFileImpl *file;
186 LIST_FOR_EACH_ENTRY(file, &This->files, BackgroundCopyFileImpl, entryFromJob)
188 if (file->fileProgress.Completed)
190 if (!MoveFileExW(file->tempFileName, file->info.LocalName,
191 (MOVEFILE_COPY_ALLOWED
192 | MOVEFILE_REPLACE_EXISTING
193 | MOVEFILE_WRITE_THROUGH)))
195 ERR("Couldn't rename file %s -> %s\n",
196 debugstr_w(file->tempFileName),
197 debugstr_w(file->info.LocalName));
198 rv = BG_S_PARTIAL_COMPLETE;
202 rv = BG_S_PARTIAL_COMPLETE;
206 This->state = BG_JOB_STATE_ACKNOWLEDGED;
207 LeaveCriticalSection(&This->cs);
212 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetId(
213 IBackgroundCopyJob2 *iface,
216 BackgroundCopyJobImpl *This = (BackgroundCopyJobImpl *) iface;
221 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetType(
222 IBackgroundCopyJob2 *iface,
225 BackgroundCopyJobImpl *This = (BackgroundCopyJobImpl *) iface;
234 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetProgress(
235 IBackgroundCopyJob2 *iface,
236 BG_JOB_PROGRESS *pVal)
238 BackgroundCopyJobImpl *This = (BackgroundCopyJobImpl *) iface;
243 EnterCriticalSection(&This->cs);
244 pVal->BytesTotal = This->jobProgress.BytesTotal;
245 pVal->BytesTransferred = This->jobProgress.BytesTransferred;
246 pVal->FilesTotal = This->jobProgress.FilesTotal;
247 pVal->FilesTransferred = This->jobProgress.FilesTransferred;
248 LeaveCriticalSection(&This->cs);
253 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetTimes(
254 IBackgroundCopyJob2 *iface,
257 FIXME("Not implemented\n");
261 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetState(
262 IBackgroundCopyJob2 *iface,
265 BackgroundCopyJobImpl *This = (BackgroundCopyJobImpl *) iface;
270 /* Don't think we need a critical section for this */
275 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetError(
276 IBackgroundCopyJob2 *iface,
277 IBackgroundCopyError **ppError)
279 FIXME("Not implemented\n");
283 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetOwner(
284 IBackgroundCopyJob2 *iface,
287 FIXME("Not implemented\n");
291 static HRESULT WINAPI BITS_IBackgroundCopyJob_SetDisplayName(
292 IBackgroundCopyJob2 *iface,
295 FIXME("Not implemented\n");
299 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetDisplayName(
300 IBackgroundCopyJob2 *iface,
303 BackgroundCopyJobImpl *This = (BackgroundCopyJobImpl *) iface;
309 n = (lstrlenW(This->displayName) + 1) * sizeof **pVal;
310 *pVal = CoTaskMemAlloc(n);
312 return E_OUTOFMEMORY;
313 memcpy(*pVal, This->displayName, n);
317 static HRESULT WINAPI BITS_IBackgroundCopyJob_SetDescription(
318 IBackgroundCopyJob2 *iface,
321 FIXME("Not implemented\n");
325 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetDescription(
326 IBackgroundCopyJob2 *iface,
329 FIXME("Not implemented\n");
333 static HRESULT WINAPI BITS_IBackgroundCopyJob_SetPriority(
334 IBackgroundCopyJob2 *iface,
337 FIXME("Not implemented\n");
341 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetPriority(
342 IBackgroundCopyJob2 *iface,
343 BG_JOB_PRIORITY *pVal)
345 FIXME("Not implemented\n");
349 static HRESULT WINAPI BITS_IBackgroundCopyJob_SetNotifyFlags(
350 IBackgroundCopyJob2 *iface,
353 FIXME("Not implemented\n");
357 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetNotifyFlags(
358 IBackgroundCopyJob2 *iface,
361 FIXME("Not implemented\n");
365 static HRESULT WINAPI BITS_IBackgroundCopyJob_SetNotifyInterface(
366 IBackgroundCopyJob2 *iface,
369 FIXME("Not implemented\n");
373 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetNotifyInterface(
374 IBackgroundCopyJob2 *iface,
377 FIXME("Not implemented\n");
381 static HRESULT WINAPI BITS_IBackgroundCopyJob_SetMinimumRetryDelay(
382 IBackgroundCopyJob2 *iface,
385 FIXME("Not implemented\n");
389 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetMinimumRetryDelay(
390 IBackgroundCopyJob2 *iface,
393 FIXME("Not implemented\n");
397 static HRESULT WINAPI BITS_IBackgroundCopyJob_SetNoProgressTimeout(
398 IBackgroundCopyJob2 *iface,
401 FIXME("Not implemented\n");
405 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetNoProgressTimeout(
406 IBackgroundCopyJob2 *iface,
409 FIXME("Not implemented\n");
413 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetErrorCount(
414 IBackgroundCopyJob2 *iface,
417 FIXME("Not implemented\n");
421 static HRESULT WINAPI BITS_IBackgroundCopyJob_SetProxySettings(
422 IBackgroundCopyJob2 *iface,
423 BG_JOB_PROXY_USAGE ProxyUsage,
424 const WCHAR *ProxyList,
425 const WCHAR *ProxyBypassList)
427 FIXME("Not implemented\n");
431 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetProxySettings(
432 IBackgroundCopyJob2 *iface,
433 BG_JOB_PROXY_USAGE *pProxyUsage,
435 LPWSTR *pProxyBypassList)
437 FIXME("Not implemented\n");
441 static HRESULT WINAPI BITS_IBackgroundCopyJob_TakeOwnership(
442 IBackgroundCopyJob2 *iface)
444 FIXME("Not implemented\n");
448 static HRESULT WINAPI BITS_IBackgroundCopyJob_SetNotifyCmdLine(
449 IBackgroundCopyJob2 *iface,
453 FIXME("Not implemented\n");
457 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetNotifyCmdLine(
458 IBackgroundCopyJob2 *iface,
462 FIXME("Not implemented\n");
466 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetReplyProgress(
467 IBackgroundCopyJob2 *iface,
468 BG_JOB_REPLY_PROGRESS *progress)
470 FIXME("Not implemented\n");
474 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetReplyData(
475 IBackgroundCopyJob2 *iface,
479 FIXME("Not implemented\n");
483 static HRESULT WINAPI BITS_IBackgroundCopyJob_SetReplyFileName(
484 IBackgroundCopyJob2 *iface,
487 FIXME("Not implemented\n");
491 static HRESULT WINAPI BITS_IBackgroundCopyJob_GetReplyFileName(
492 IBackgroundCopyJob2 *iface,
495 FIXME("Not implemented\n");
499 static HRESULT WINAPI BITS_IBackgroundCopyJob_SetCredentials(
500 IBackgroundCopyJob2 *iface,
501 BG_AUTH_CREDENTIALS *cred)
503 FIXME("Not implemented\n");
507 static HRESULT WINAPI BITS_IBackgroundCopyJob_RemoveCredentials(
508 IBackgroundCopyJob2 *iface,
509 BG_AUTH_TARGET target,
510 BG_AUTH_SCHEME scheme)
512 FIXME("Not implemented\n");
516 static const IBackgroundCopyJob2Vtbl BITS_IBackgroundCopyJob_Vtbl =
518 BITS_IBackgroundCopyJob_QueryInterface,
519 BITS_IBackgroundCopyJob_AddRef,
520 BITS_IBackgroundCopyJob_Release,
521 BITS_IBackgroundCopyJob_AddFileSet,
522 BITS_IBackgroundCopyJob_AddFile,
523 BITS_IBackgroundCopyJob_EnumFiles,
524 BITS_IBackgroundCopyJob_Suspend,
525 BITS_IBackgroundCopyJob_Resume,
526 BITS_IBackgroundCopyJob_Cancel,
527 BITS_IBackgroundCopyJob_Complete,
528 BITS_IBackgroundCopyJob_GetId,
529 BITS_IBackgroundCopyJob_GetType,
530 BITS_IBackgroundCopyJob_GetProgress,
531 BITS_IBackgroundCopyJob_GetTimes,
532 BITS_IBackgroundCopyJob_GetState,
533 BITS_IBackgroundCopyJob_GetError,
534 BITS_IBackgroundCopyJob_GetOwner,
535 BITS_IBackgroundCopyJob_SetDisplayName,
536 BITS_IBackgroundCopyJob_GetDisplayName,
537 BITS_IBackgroundCopyJob_SetDescription,
538 BITS_IBackgroundCopyJob_GetDescription,
539 BITS_IBackgroundCopyJob_SetPriority,
540 BITS_IBackgroundCopyJob_GetPriority,
541 BITS_IBackgroundCopyJob_SetNotifyFlags,
542 BITS_IBackgroundCopyJob_GetNotifyFlags,
543 BITS_IBackgroundCopyJob_SetNotifyInterface,
544 BITS_IBackgroundCopyJob_GetNotifyInterface,
545 BITS_IBackgroundCopyJob_SetMinimumRetryDelay,
546 BITS_IBackgroundCopyJob_GetMinimumRetryDelay,
547 BITS_IBackgroundCopyJob_SetNoProgressTimeout,
548 BITS_IBackgroundCopyJob_GetNoProgressTimeout,
549 BITS_IBackgroundCopyJob_GetErrorCount,
550 BITS_IBackgroundCopyJob_SetProxySettings,
551 BITS_IBackgroundCopyJob_GetProxySettings,
552 BITS_IBackgroundCopyJob_TakeOwnership,
553 BITS_IBackgroundCopyJob_SetNotifyCmdLine,
554 BITS_IBackgroundCopyJob_GetNotifyCmdLine,
555 BITS_IBackgroundCopyJob_GetReplyProgress,
556 BITS_IBackgroundCopyJob_GetReplyData,
557 BITS_IBackgroundCopyJob_SetReplyFileName,
558 BITS_IBackgroundCopyJob_GetReplyFileName,
559 BITS_IBackgroundCopyJob_SetCredentials,
560 BITS_IBackgroundCopyJob_RemoveCredentials
563 HRESULT BackgroundCopyJobConstructor(LPCWSTR displayName, BG_JOB_TYPE type,
564 GUID *pJobId, LPVOID *ppObj)
567 BackgroundCopyJobImpl *This;
570 TRACE("(%s,%d,%p)\n", debugstr_w(displayName), type, ppObj);
572 This = HeapAlloc(GetProcessHeap(), 0, sizeof *This);
574 return E_OUTOFMEMORY;
576 This->lpVtbl = &BITS_IBackgroundCopyJob_Vtbl;
577 InitializeCriticalSection(&This->cs);
581 n = (lstrlenW(displayName) + 1) * sizeof *displayName;
582 This->displayName = HeapAlloc(GetProcessHeap(), 0, n);
583 if (!This->displayName)
585 DeleteCriticalSection(&This->cs);
586 HeapFree(GetProcessHeap(), 0, This);
587 return E_OUTOFMEMORY;
589 memcpy(This->displayName, displayName, n);
591 hr = CoCreateGuid(&This->jobId);
594 DeleteCriticalSection(&This->cs);
595 HeapFree(GetProcessHeap(), 0, This->displayName);
596 HeapFree(GetProcessHeap(), 0, This);
599 *pJobId = This->jobId;
601 list_init(&This->files);
602 This->jobProgress.BytesTotal = 0;
603 This->jobProgress.BytesTransferred = 0;
604 This->jobProgress.FilesTotal = 0;
605 This->jobProgress.FilesTransferred = 0;
607 This->state = BG_JOB_STATE_SUSPENDED;
609 *ppObj = &This->lpVtbl;
613 void processJob(BackgroundCopyJobImpl *job)
617 BackgroundCopyFileImpl *file;
620 EnterCriticalSection(&job->cs);
621 LIST_FOR_EACH_ENTRY(file, &job->files, BackgroundCopyFileImpl, entryFromJob)
622 if (!file->fileProgress.Completed)
627 LeaveCriticalSection(&job->cs);
630 transitionJobState(job, BG_JOB_STATE_QUEUED, BG_JOB_STATE_TRANSFERRED);
634 if (!processFile(file, job))