mpichconfigdlg.cpp

MPICH是MPI的重要研究,提供了一系列的接口函数,为并行计算的实现提供了编程环境.

	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }

    // get mpd version
    WriteString(sock, "version");
    if (!ReadStringTimeout(sock, pszStr, MPD_SHORT_TIMEOUT))
    {
	WriteString(sock, "done");
	m_config_host_msg = "unable to reach mpd";
	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }
    // where do I put the mpd version?

    // get hosts
    WriteString(sock, "lget hosts");
    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
    {
	WriteString(sock, "done");
	m_config_host_msg = "unable to reach mpd";
	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }
    m_host_hosts = pszStr;

    // get launch timeout
    WriteString(sock, "lget timeout");
    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
    {
	WriteString(sock, "done");
	m_config_host_msg = "unable to reach mpd";
	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }
    m_host_launch = atoi(pszStr);
    if (m_host_launch < 1)
	m_host_launch = 10;

    // get nocolor
    WriteString(sock, "lget nocolor");
    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
    {
	WriteString(sock, "done");
	m_config_host_msg = "unable to reach mpd";
	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }
    if (strlen(pszStr) == 0)
    {
	// if nocolor is not set, get color
	WriteString(sock, "lget color");
	if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
	{
	    WriteString(sock, "done");
	    m_config_host_msg = "unable to reach mpd";
	    UpdateData(FALSE);
	    SetCursor(hOldCursor);
	    return;
	}
	if (strlen(pszStr) == 0)
	    m_host_color_no = FALSE;
	else
	    m_host_color_no = (stricmp(pszStr, "yes") != 0);
    }
    else
    {
	m_host_color_no = (stricmp(pszStr, "yes") == 0);
    }
    m_host_color_yes = !m_host_color_no;

    // get nodots
    WriteString(sock, "lget nodots");
    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
    {
	WriteString(sock, "done");
	m_config_host_msg = "unable to reach mpd";
	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }
    m_host_dots_no = (stricmp(pszStr, "yes") == 0);
    m_host_dots_yes = !m_host_dots_no;

    // get nomapping
    WriteString(sock, "lget nomapping");
    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
    {
	WriteString(sock, "done");
	m_config_host_msg = "unable to reach mpd";
	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }
    m_host_mapping_no = (stricmp(pszStr, "yes") == 0);
    m_host_mapping_yes = !m_host_mapping_no;

    // get nopopup_debug
    WriteString(sock, "lget nopopup_debug");
    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
    {
	WriteString(sock, "done");
	m_config_host_msg = "unable to reach mpd";
	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }
    m_host_popup_debug_no = (stricmp(pszStr, "yes") == 0);
    m_host_popup_debug_yes = !m_host_popup_debug_no;

    // get dbg
    WriteString(sock, "lget dbg");
    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
    {
	WriteString(sock, "done");
	m_config_host_msg = "unable to reach mpd";
	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }
    m_host_catch_yes = (stricmp(pszStr, "yes") == 0);
    m_host_catch_no = !m_host_catch_yes;

    // get exitcodes
    WriteString(sock, "lget exitcodes");
    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
    {
	WriteString(sock, "done");
	m_config_host_msg = "unable to reach mpd";
	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }
    m_host_codes_yes = (stricmp(pszStr, "yes") == 0);
    m_host_codes_no = !m_host_codes_yes;

    // get usejobhost
    WriteString(sock, "lget usejobhost");
    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
    {
	WriteString(sock, "done");
	m_config_host_msg = "unable to reach mpd";
	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }
    if (strlen(pszStr))
    {
	m_host_jobhost_yes = (stricmp(pszStr, "yes") == 0);
	m_host_jobhost_no = !m_host_jobhost_yes;
	if (m_host_jobhost_yes)
	{
	    // get jobhost
	    WriteString(sock, "lget jobhost");
	    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
	    {
		WriteString(sock, "done");
		m_config_host_msg = "unable to reach mpd";
		UpdateData(FALSE);
		SetCursor(hOldCursor);
		return;
	    }
	    m_host_jobhost = pszStr;
	    m_host_jobhost_edit.EnableWindow();

	    // get jobhostpwd
	    WriteString(sock, "lget jobhostpwd");
	    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
	    {
		WriteString(sock, "done");
		m_config_host_msg = "unable to reach mpd";
		UpdateData(FALSE);
		SetCursor(hOldCursor);
		return;
	    }
	    if (strlen(pszStr))
	    {
		m_bhost_use_jobhost_pwd = TRUE;
		m_host_jobhost_pwd = pszStr;
		if (m_bhost_use_jobhost)
		    m_host_jobhost_pwd_edit.EnableWindow(); // only enable if option checked
	    }
	    else
	    {
		m_bhost_use_jobhost_pwd = FALSE;
		m_host_jobhost_pwd_edit.EnableWindow(FALSE);
	    }
	}
    }
    else
    {
	m_host_jobhost_yes = false;
	m_host_jobhost_no = true;
	m_host_jobhost = "";
	m_host_jobhost_edit.EnableWindow(FALSE);
	m_bhost_use_jobhost_pwd = FALSE;
	m_host_jobhost_pwd_edit.EnableWindow(FALSE);
    }

    // get logfile
    WriteString(sock, "lget RedirectToLogfile");
    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
    {
	WriteString(sock, "done");
	m_config_host_msg = "unable to reach mpd";
	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }
    if (strlen(pszStr))
    {
	m_host_logfile_yes = (stricmp(pszStr, "yes") == 0);
	m_host_logfile_no = !m_host_logfile_yes;
    }
    else
    {
	m_host_logfile_yes = false;
	m_host_logfile_no = true;
	m_host_logfile = "";
	m_host_logfile_edit.EnableWindow(FALSE);
    }

    // get logfile
    WriteString(sock, "lget LogFile");
    if (!ReadStringTimeout(sock, pszStr, MPD_DEFAULT_TIMEOUT))
    {
	WriteString(sock, "done");
	m_config_host_msg = "unable to reach mpd";
	UpdateData(FALSE);
	SetCursor(hOldCursor);
	return;
    }
    m_host_logfile = pszStr;
    if (m_host_logfile_yes)
	m_host_logfile_edit.EnableWindow();

    // get mpich version
    WriteString(sock, "mpich version");
    if (ReadStringTimeout(sock, pszStr, MPD_SHORT_TIMEOUT))
    {
	m_config_host_msg = "mpich ";
	m_config_host_msg += pszStr;
    }
    else
    {
	m_config_host_msg = "mpich - unknown version";
    }

    // close the session
    WriteString(sock, "done");
    easy_closesocket(sock);

    SetCursor(hOldCursor);
    UpdateData(FALSE);
}

void CMPICHConfigDlg::GetHostsString()
{
    int num_hosts;
    QVS_Container qvs;
    char host[100];
    int i;

    UpdateData();

    num_hosts = m_host_list.GetItemCount();

    if (num_hosts < 1)
    {
	m_hosts = "";
	UpdateData(FALSE);
	return;
    }

    for (i=0; i<num_hosts; i++)
    {
	m_host_list.GetItemText(i, 0, host, 100);
	qvs.encode_string(host);
    }

    qvs.output_encoded_string(m_hosts.GetBuffer(8192), 8192);
    m_hosts.ReleaseBuffer();

    UpdateData(FALSE);
}

LRESULT CMPICHConfigDlg::WindowProc(UINT message, WPARAM wParam, LPARAM lParam) 
{
    static int num_steps=0, cur_step=0;
    switch (message)
    {
    case USER_MSG_DISABLE:
	m_apply_btn.EnableWindow(FALSE);
	m_apply_single_btn.EnableWindow(FALSE);
	//m_modify_btn.EnableWindow(FALSE);
	break;
    case USER_MSG_ENABLE:
	m_apply_btn.EnableWindow();
	m_apply_single_btn.EnableWindow();
	//m_modify_btn.EnableWindow();
	break;
    case USER_MSG_NUM_STEPS:
	num_steps = wParam;
	cur_step = 0;
	m_progress.SetRange(0, num_steps);
	m_progress.SetStep(1);
	m_progress.SetPos(0);
	break;
    case USER_MSG_STEPIT:
	cur_step++;
	m_nofm.Format("%d of %d", cur_step, num_steps);
	UpdateData(FALSE);
	m_progress.StepIt();
	break;
    case USER_MSG_GETHOST:
	GetHostConfig();
	break;
    }
    return CDialog::WindowProc(message, wParam, lParam);
}

void CMPICHConfigDlg::OnHostCatchChk() 
{
    UpdateData();
    //m_host_catch_yes_btn.EnableWindow(m_bhost_catch);
    //m_host_catch_no_btn.EnableWindow(m_bhost_catch);
    m_host_catch_yes_btn.EnableWindow();
    m_host_catch_no_btn.EnableWindow();
    UpdateModifyButtonState();
}

void CMPICHConfigDlg::OnHostCatchYes() 
{
    UpdateData();
    m_host_catch_yes = TRUE;
    m_host_catch_no = FALSE;
    UpdateData(FALSE);
}

void CMPICHConfigDlg::OnHostCatchNo() 
{
    UpdateData();
    m_host_catch_yes = FALSE;
    m_host_catch_no = TRUE;
    UpdateData(FALSE);
}

void CMPICHConfigDlg::OnCatchChk() 
{
    UpdateData();
    m_catch_yes_btn.EnableWindow(m_bcatch);
    m_catch_no_btn.EnableWindow(m_bcatch);
    UpdateApplyButtonStates();
}

void CMPICHConfigDlg::OnCatchYes() 
{
    UpdateData();
    m_catch_yes = TRUE;
    m_catch_no = FALSE;
    UpdateData(FALSE);
}

void CMPICHConfigDlg::OnCatchNo() 
{
    UpdateData();
    m_catch_yes = FALSE;
    m_catch_no = TRUE;
    UpdateData(FALSE);
}

void CMPICHConfigDlg::OnHostCodesYes() 
{
    UpdateData();
    m_host_codes_yes = TRUE;
    m_host_codes_no = FALSE;
    UpdateData(FALSE);
}

void CMPICHConfigDlg::OnHostCodesNo() 
{
    UpdateData();
    m_host_codes_yes = FALSE;
    m_host_codes_no = TRUE;
    UpdateData(FALSE);
}

void CMPICHConfigDlg::OnHostCodesChk() 
{
    UpdateData();
    //m_host_codes_yes_btn.EnableWindow(m_bhost_codes);
    //m_host_codes_no_btn.EnableWindow(m_bhost_codes);
    m_host_codes_yes_btn.EnableWindow();
    m_host_codes_no_btn.EnableWindow();
    UpdateModifyButtonState();
}

void CMPICHConfigDlg::OnCodesChk() 
{
    UpdateData();
    m_codes_yes_btn.EnableWindow(m_bcodes);
    m_codes_no_btn.EnableWindow(m_bcodes);
    UpdateApplyButtonStates();
}

void CMPICHConfigDlg::OnCodesYes() 
{
    UpdateData();
    m_codes_yes = TRUE;
    m_codes_no = FALSE;
    UpdateData(FALSE);
}

void CMPICHConfigDlg::OnCodesNo() 
{
    UpdateData();
    m_codes_yes = FALSE;
    m_codes_no = TRUE;
    UpdateData(FALSE);
}

void CMPICHConfigDlg::OnRedirectMpdChk() 
{
    UpdateData();
    m_logfile_yes_btn.EnableWindow(m_blogfile);
    m_logfile_no_btn.EnableWindow(m_blogfile);

    m_logfile_static.EnableWindow(m_blogfile && m_logfile_yes);
    m_logfile_edit.EnableWindow(m_blogfile && m_logfile_yes);
    UpdateApplyButtonStates();
}

void CMPICHConfigDlg::OnRedirectMpdNo() 
{
    UpdateData();
    m_logfile_yes = FALSE;
    m_logfile_no = TRUE;
    m_logfile_static.EnableWindow(FALSE);
    m_logfile_edit.EnableWindow(FALSE);
    UpdateData(FALSE);
}

void CMPICHConfigDlg::OnRedirectMpdYes() 
{
    UpdateData();
    m_logfile_yes = TRUE;
    m_logfile_no = FALSE;
    m_logfile_static.EnableWindow();
    m_logfile_edit.EnableWindow();
    UpdateData(FALSE);
}

void CMPICHConfigDlg::OnHostRedirectMpdChk() 
{
    UpdateData();
    m_host_logfile_yes_btn.EnableWindow();
    m_host_logfile_no_btn.EnableWindow();
    m_host_logfile_edit.EnableWindow(m_host_logfile_yes);
    UpdateModifyButtonState();
}

void CMPICHConfigDlg::OnHostRedirectMpdNo() 
{
    UpdateData();
    m_host_logfile_yes = FALSE;
    m_host_logfile_no = TRUE;
    m_host_logfile_edit.EnableWindow(FALSE);
    UpdateData(FALSE);
}

void CMPICHConfigDlg::OnHostRedirectMpdYes() 
{
    UpdateData();
    m_host_logfile_yes = TRUE;
    m_host_logfile_no = FALSE;
    m_host_logfile_edit.EnableWindow();
    UpdateData(FALSE);
}