Re: Downloading files using BITS gives Transient Error
On Nov 6, 10:47 pm, NKH <nishant...@gmail.com> wrote:
Hi,
I have created an application that tries to get a set of files using
BITS from a remote machine..The only response I'm getting is Transient
Error when queried for Job State..The function is as given below..I
have tried MSDN but could not clearly understand the issues with that.
I tried testing the URL created with bitsadmin.exe and it works.
Please help to know what i'm doing wrong here
Thanks,
NKH
int BITSGet(WCHAR *filelist, WCHAR* src, WCHAR* destination, long
WebPort)
{
IBackgroundCopyManager* g_pbcm = NULL;
HRESULT hr;
HRESULT hrError = 0;
GUID JobId;
IBackgroundCopyJob* pJob = NULL;
IBackgroundCopyJob2* pJob2 = NULL;
BG_AUTH_CREDENTIALS ac;
BG_JOB_STATE JobState;
BG_FILE_INFO* paFiles = NULL;
int idx = 0;
WCHAR* pszDescription = NULL;
WCHAR* pszRemoteName = NULL;
BG_ERROR_CONTEXT Context;
HANDLE hTimer = NULL;
LARGE_INTEGER liDueTime;
IBackgroundCopyError* pError = NULL;
IBackgroundCopyFile* pFile = NULL;
liDueTime.QuadPart = -10000000; //Poll every 1 second
hTimer = CreateWaitableTimer(NULL, FALSE, (LPCTSTR)"MyTimer");
SetWaitableTimer(hTimer, &liDueTime, 1000, NULL, NULL, 0);
WCHAR *sserver = L"TestServer01";
// Try to lookup server from environment var Web Port
WCHAR *baseport = WebPort;
int port = 0;
_itow(port,qsbaseport,(wcslen(qsbaseport) + 1) * sizeof(WCHAR));
cout<<port<<endl;
// Try to lookup server from environment var DESTDRIVE
WCHAR *ddrive = getEnvVars("DESTDRIVE");
//number of files that need to be downloaded
int fileCount = 0;
WCHAR files[MAX_FILES][INTERNET_MAX_URL_LENGTH] = {0};
WCHAR sep[] = L",";
WCHAR *token;// = (char *)malloc(MAX_PATH);
token = wcstok(filelist,sep);
while(token != NULL)
{
wcscpy(files[fileCount],token);
token = wcstok(NULL,sep);
fileCount++;
}
WCHAR *temp = (WCHAR *) malloc(INTERNET_MAX_URL_LENGTH);
WCHAR source[MAX_FILES][INTERNET_MAX_URL_LENGTH];
WCHAR dest[MAX_FILES][MAX_PATH];
//Remote URL/Source
WCHAR webURL[INTERNET_MAX_URL_LENGTH] = {0};
wcscpy(webURL,L"http://");
wcscat(webURL,sserver);
wcsncat(webURL,L":",1);
wcscat(webURL,baseport);
//Local Path/Destination
WCHAR *tempdestination = (WCHAR *)malloc(MAX_PATH);
wcscpy(tempdestination,qsdrive);
wcscat(tempdestination,destination);
//destination[wcslen(destination)] = '\0';
for(int k = 0;k<fileCount;k++)
{
//Remote URL
wcscpy(temp,webURL);
wcscat(temp,src);
wcscat(temp,files[k]);
wcscpy(source[k],temp);
//Destination Local Path
wcscpy(temp,tempdestination);
wcscat(temp,files[k]);
wcscpy(dest[k],temp);
}
free(temp);
free(qsbaseport);
free(qsserver);
free(qsdrive);
BG_FILE_INFO fileInfo[MAX_FILES] = { 0 };
for(int i = 0; i < fileCount; ++i)
{
fileInfo[i].RemoteName = source[i];
fileInfo[i].LocalName = dest[i];
}
hr = CoInitializeEx(NULL, COINIT_APARTMENTTHREADED);
if (SUCCEEDED(hr))
{
hr = CoCreateInstance(__uuidof(BackgroundCopyManager),N=
ULL,
CLSCTX_LOCAL_SERVER,
__uuidof(IBackgroundCopyManager),
(void**) &g_pbcm);
if (SUCCEEDED(hr))
{
cout<<"Created instance of BackgroundCopyManager"=
<<endl;
hr = g_pbcm->CreateJob(L"DownloadClientFiles",
BG_JOB_TYPE_DOWNLOAD, &JobId, &pJob);
if (SUCCEEDED(hr))
{
cout<<"Created job instance"<<endl;
hr = pJob->AddFileSet(fileCount, fileIn=
fo);
if (FAILED(hr))
{
if(hr == E_ACCESSDENIED)
{
cout<<"Access denied"<<en=
dl;
}
else if(hr == E_INVALIDARG)
{
cout<<"Invalid Arguments =
for BITS"<<endl;
}
else if(hr == BG_E_TOO_MANY_F=
ILES)
{
cout<<"Too many files in =
the BITS download
queue"<<endl;
}
else
{
cout<<"Error while adding=
file set to the
job"<<endl;
}
return 2;
}
else if(hr == S_OK)
{
cout<<"Added file to the job"<<en=
dl;
}
//The default priority level for a job is
BG_JOB_PRIORITY_NORMAL.
hr = pJob->SetPriority(BG_JOB_PRIORITY_=
FOREGROUND);
if (FAILED(hr))
{
cout<<"priority failed"<<endl;
}
hr = pJob->Resume();
if(FAILED(hr))
{
if(hr == BG_E_EMPTY)
{
cout<<"No files to transf=
er for job..Problem
with BITS URL"<<endl;
}
else if(hr == BG_E_INVALID_ST=
ATE)
{
cout<<"Invalid job state =
for job"<<endl;
}
}
else if(SUCCEEDED(hr))
{
cout<<"Job resumed"<<endl;
}
do
{
WaitForSingleObject(hTimer, INFIN=
ITE);
//Use JobStates[State] to set the=
window text in a
user interface.
hr = pJob->GetState(&JobState);
if (FAILED(hr))
{
//Handle error
cout<<"Failed to get job =
state for job"<<endl;
}
errReturn(JobState);
if (BG_JOB_STATE_TRANSFERRED ==
= JobState)
{
cout<<"Job completed"<<en=
dl;
hr = pJob->Complete();
//cancel the timer and cl=
ose it before exiting
CancelWaitableTimer(hTime=
r);
CloseHandle(hTimer);
return 0;
}
if (BG_JOB_STATE_CONNECTING ==
= JobState)
{
cout<<"Connecting"<<endl;
}
if (BG_JOB_STATE_SUSPENDED ===
JobState)
{
cout<<"Suspended"<<endl;
}
if (BG_JOB_STATE_ERROR == Job=
State)
{
cout<<"job state returned=
error"<<endl;
errReturn(JobState);
hr = pJob->GetError(&pE=
rror);
if (SUCCEEDED(hr))
{
pError->GetError(=
&Context, &hrError);
//Retrieve a desc=
ription associated with
the HRESULT value.
hr = pError->Ge=
tErrorDescription(LANGIDFROMLCID(GetThreadLocale()),
&pszDescription);
if (SUCCEEDED(hr)=
)
{
if (BG_ER=
ROR_CONTEXT_REMOTE_FILE ==
Context)
{
c=
out<<"Could not access the
specified URL"<<endl;
h=
r = pError->GetFile(&pFile);
i=
f (SUCCEEDED(hr))
{
=
hr = pFile->GetRemoteName(&pszRemoteName);
=
if (SUCCEEDED(hr))
=
{
=
//Do something with the
information.
CoTaskMemFree(pszRemoteName);
=
}
=
pFile->Release();
}
}
CoTaskMem=
Free(pszDescription);
}
pError->Release()=
;
}
errReturn(JobState);
pJob->Cancel();
//cancel the timer and cl=
ose it before exiting
CancelWaitableTimer(hTime=
r);
CloseHandle(hTimer);
return 1;
}
else if(BG_JOB_STATE_TRANSIENT_ER=
ROR == JobState)
{
cout<<"Transient Error fo=
r job"<<endl;
errReturn(JobState);
hr = pJob->SetMinimumRe=
tryDelay(60);
if(FAILED(hr))
cout<<"failed del=
ay"<<endl;
else
pJob->Resume();
}
//Call pJob->GetError(&pError); t=
o retrieve an
IBackgroundCopyError interface
//pointer which you use to determ=
ine the cause of
the error.
else if (BG_JOB_STATE_TRANSFERRIN=
G == JobState)
{
cout<<"Transferring"<<end=
l;
}
//Call pJob->GetProgress(&Progres=
s); to determine
the number of bytes
//and files transferred.
} while (BG_JOB_STATE_TRANSFERRED != Jo=
bState &&
BG_JOB_STATE_ERROR != JobState)=
;
CancelWaitableTimer(hTimer);
CloseHandle(hTimer);
}
else
{
cout<<"job creation failed"<<endl;
}
}
else
{
cout<<"Failed initialisation of BackgroundCopyMan=
ager COM
Interface"<<endl;
}
}
else
{
cout<<"Error while initialising COM Instance for BITS"<<e=
ndl;
}
::CoUninitialize();
return 3;
}- Hide quoted text -
- Show quoted text -
This application works as a Windows Service with LocalSystemAccount
login..The client is Windows XP SP3..