Skip to content

Commit

Permalink
coisane: Extended use of background threads for advanced property page
Browse files Browse the repository at this point in the history 
The actions check and reset are now performend in the background.
  • Loading branch information
@mback2k
mback2k committed Jun 19, 2014
1 parent 3abc27e commit 4ed6d9d
Show file tree
Hide file tree
Showing 2 changed files with 142 additions and 54 deletions.
193 changes: 139 additions & 54 deletions coisane/coisane_prop.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -229,66 +229,30 @@ INT_PTR CALLBACK DialogProcPropertyPageAdvanced(_In_ HWND hwndDlg, _In_ UINT uMs

INT_PTR CALLBACK DialogProcPropertyPageAdvancedBtnClicked(_In_ HWND hwndDlg, _In_ UINT hwndDlgItem, _Inout_ PCOISANE_Data pData)
{
PWINSANE_Session oSession;
PWINSANE_Device oDevice;
PWINSANE_Params oParams;
LPTSTR lpName;
BOOL res;
if (pData->hThread)
return FALSE;

lpName = NULL;
switch (hwndDlgItem) {
case IDC_PROPERTIES_BUTTON_CHECK:
pData->hThread = CreateThread(NULL, 0, &ThreadProcCheckDevice, pData, CREATE_SUSPENDED, NULL);
break;

res = GetDlgItemAText(pData->hHeap, hwndDlg, IDC_PROPERTIES_COMBO_SCANNER, &lpName, NULL);
if (res != ERROR_SUCCESS) {
return FALSE;
case IDC_PROPERTIES_BUTTON_RESET:
pData->hThread = CreateThread(NULL, 0, &ThreadProcResetDevice, pData, CREATE_SUSPENDED, NULL);
break;

default:
pData->hThread = NULL;
break;
}

oSession = WINSANE_Session::Remote(pData->lpHost, pData->usPort);
if (oSession) {
g_pPropertyPageData = pData;
if (oSession->Init(NULL, &PropertyPageAuthCallback) == SANE_STATUS_GOOD) {
if (oSession->FetchDevices() == SANE_STATUS_GOOD) {
oDevice = oSession->GetDevice(lpName);
if (oDevice) {
if (oDevice->Open() == SANE_STATUS_GOOD) {
switch (hwndDlgItem) {
case IDC_PROPERTIES_BUTTON_CHECK:
if (oDevice->GetParams(&oParams) == SANE_STATUS_GOOD) {
delete oParams;
MessageBoxR(pData->hHeap, pData->hInstance, hwndDlg, IDS_PROPERTIES_SCANNER_CHECK_SUCCESSFUL, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONINFORMATION | MB_OK);
} else {
MessageBoxR(pData->hHeap, pData->hInstance, hwndDlg, IDS_PROPERTIES_SCANNER_CHECK_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONEXCLAMATION | MB_OK);
}
break;
if (!pData->hThread)
return FALSE;

case IDC_PROPERTIES_BUTTON_RESET:
if (oDevice->Cancel() == SANE_STATUS_GOOD) {
MessageBoxR(pData->hHeap, pData->hInstance, hwndDlg, IDS_PROPERTIES_SCANNER_RESET_SUCCESSFUL, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONINFORMATION | MB_OK);
} else {
MessageBoxR(pData->hHeap, pData->hInstance, hwndDlg, IDS_PROPERTIES_SCANNER_RESET_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONEXCLAMATION | MB_OK);
}
break;
}
oDevice->Close();
} else {
MessageBoxR(pData->hHeap, pData->hInstance, hwndDlg, IDS_DEVICE_OPEN_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONERROR | MB_OK);
}
} else {
MessageBoxR(pData->hHeap, pData->hInstance, hwndDlg, IDS_DEVICE_FIND_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONERROR | MB_OK);
}
} else {
MessageBoxR(pData->hHeap, pData->hInstance, hwndDlg, IDS_DEVICE_FIND_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONERROR | MB_OK);
}
oSession->Exit();
} else {
MessageBoxR(pData->hHeap, pData->hInstance, hwndDlg, IDS_SESSION_INIT_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONERROR | MB_OK);
}
g_pPropertyPageData = NULL;
delete oSession;
} else {
MessageBoxR(pData->hHeap, pData->hInstance, hwndDlg, IDS_SESSION_CONNECT_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONERROR | MB_OK);
}
ShowPropertyPageAdvancedProgress(hwndDlg);

HeapSafeFree(pData->hHeap, 0, lpName);
SetThreadPriority(pData->hThread, THREAD_PRIORITY_BELOW_NORMAL);
ResumeThread(pData->hThread);

return FALSE;
}
Expand Down Expand Up @@ -682,6 +646,127 @@ DWORD WINAPI ThreadProcSavePropertyPageAdvanced(_In_ LPVOID lpParameter)
}


static VOID WINAPI PerformDeviceAction(_In_ HANDLE hThread, _In_ UINT hwndDlgItem, _Inout_ PCOISANE_Data pData)
{
PWINSANE_Session oSession;
PWINSANE_Device oDevice;
PWINSANE_Params oParams;
LPTSTR lpText, lpName;
HRESULT hr;
BOOL res;

lpName = NULL;

res = GetDlgItemAText(pData->hHeap, pData->hwndDlg, IDC_PROPERTIES_COMBO_SCANNER, &lpName, NULL);
if (res != ERROR_SUCCESS)
return;

hr = StringCbAPrintf(pData->hHeap, &lpText, NULL, TEXT("%s:%d\n%s"), pData->lpHost, pData->usPort, pData->lpName);
if (SUCCEEDED(hr)) {
SetDlgItemText(pData->hwndDlg, IDC_PROPERTIES_PROGRESS_TEXT, lpText);
HeapSafeFree(pData->hHeap, 0, lpText);
}

SetDlgItemTextR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDC_PROPERTIES_PROGRESS_TEXT_MAIN, IDS_SESSION_STEP_CONNECT);
oSession = WINSANE_Session::Remote(pData->lpHost, pData->usPort);
if (oSession) {
g_pPropertyPageData = pData;
SetDlgItemTextR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDC_PROPERTIES_PROGRESS_TEXT_MAIN, IDS_SESSION_STEP_INIT);
if (oSession->Init(NULL, &PropertyPageAuthCallback) == SANE_STATUS_GOOD) {
SetDlgItemTextR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDC_PROPERTIES_PROGRESS_TEXT_MAIN, IDS_DEVICE_STEP_FIND);
if (oSession->FetchDevices() == SANE_STATUS_GOOD) {
oDevice = oSession->GetDevice(lpName);
if (oDevice) {
SetDlgItemTextR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDC_PROPERTIES_PROGRESS_TEXT_MAIN, IDS_DEVICE_STEP_OPEN);
if (oDevice->Open() == SANE_STATUS_GOOD) {
switch (hwndDlgItem) {
case IDC_PROPERTIES_BUTTON_CHECK:
if (oDevice->GetParams(&oParams) == SANE_STATUS_GOOD) {
delete oParams;
MessageBoxR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDS_PROPERTIES_SCANNER_CHECK_SUCCESSFUL, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONINFORMATION | MB_OK);
} else if (pData->hThread == hThread) {
MessageBoxR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDS_PROPERTIES_SCANNER_CHECK_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONEXCLAMATION | MB_OK);
}
break;

case IDC_PROPERTIES_BUTTON_RESET:
if (oDevice->Cancel() == SANE_STATUS_GOOD) {
MessageBoxR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDS_PROPERTIES_SCANNER_RESET_SUCCESSFUL, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONINFORMATION | MB_OK);
} else if (pData->hThread == hThread) {
MessageBoxR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDS_PROPERTIES_SCANNER_RESET_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONEXCLAMATION | MB_OK);
}
break;
}
oDevice->Close();
} else if (pData->hThread == hThread) {
MessageBoxR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDS_DEVICE_OPEN_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONERROR | MB_OK);
}
} else if (pData->hThread == hThread) {
MessageBoxR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDS_DEVICE_FIND_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONERROR | MB_OK);
}
} else if (pData->hThread == hThread) {
MessageBoxR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDS_DEVICE_FIND_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONERROR | MB_OK);
}
oSession->Exit();
} else if (pData->hThread == hThread) {
MessageBoxR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDS_SESSION_INIT_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONERROR | MB_OK);
}
g_pPropertyPageData = NULL;
delete oSession;
} else if (pData->hThread == hThread) {
MessageBoxR(pData->hHeap, pData->hInstance, pData->hwndDlg, IDS_SESSION_CONNECT_FAILED, IDS_PROPERTIES_SCANNER_DEVICE, MB_ICONERROR | MB_OK);
}

HeapSafeFree(pData->hHeap, 0, lpName);
}

DWORD WINAPI ThreadProcCheckDevice(_In_ LPVOID lpParameter)
{
PCOISANE_Data pData;
HANDLE hThread;

pData = (PCOISANE_Data) lpParameter;
if (!pData)
return 0;

hThread = pData->hThread;

PerformDeviceAction(hThread, IDC_PROPERTIES_BUTTON_CHECK, pData);

if (pData->hThread != hThread)
return 0;

HidePropertyPageAdvancedProgress(pData->hwndDlg);

pData->hThread = NULL;

return 0;
}

DWORD WINAPI ThreadProcResetDevice(_In_ LPVOID lpParameter)
{
PCOISANE_Data pData;
HANDLE hThread;

pData = (PCOISANE_Data) lpParameter;
if (!pData)
return 0;

hThread = pData->hThread;

PerformDeviceAction(hThread, IDC_PROPERTIES_BUTTON_RESET, pData);

if (pData->hThread != hThread)
return 0;

HidePropertyPageAdvancedProgress(pData->hwndDlg);

pData->hThread = NULL;

return 0;
}


static VOID WINAPI SwitchPropertyPageAdvancedProgress(_In_ HWND hwndDlg, _In_ BOOL bVisible)
{
int progress[] = {IDC_PROPERTIES_PROGRESS_ANIMATE, IDC_PROPERTIES_PROGRESS_TEXT_MAIN, IDC_PROPERTIES_PROGRESS_TEXT};
Expand Down
3 changes: 3 additions & 0 deletions coisane/coisane_prop.h
View file
Original file line number Diff line number Diff line change
Expand Up @@ -51,6 +51,9 @@ DWORD WINAPI ThreadProcShowPropertyPageAdvanced(_In_ LPVOID lpParameter);
BOOL WINAPI SavePropertyPageAdvanced(_In_ HWND hwndDlg, _Inout_ PCOISANE_Data pData);
DWORD WINAPI ThreadProcSavePropertyPageAdvanced(_In_ LPVOID lpParameter);

DWORD WINAPI ThreadProcCheckDevice(_In_ LPVOID lpParameter);
DWORD WINAPI ThreadProcResetDevice(_In_ LPVOID lpParameter);

VOID WINAPI ShowPropertyPageAdvancedProgress(_In_ HWND hwndDlg);
VOID WINAPI HidePropertyPageAdvancedProgress(_In_ HWND hwndDlg);

Expand Down

0 comments on commit 4ed6d9d

Please sign in to comment.