teraterm/teraterm/teraterm.cpp

/* Tera Term
 Copyright(C) 1994-1998 T. Teranishi
 All rights reserved. */

/* TERATERM.EXE, main */

#include "stdafx.h"
#include "teraterm.h"
#include "tttypes.h"
#include "commlib.h"
#include "ttwinman.h"
#include "buffer.h"
#include "vtterm.h"
#include "vtwin.h"
#include "clipboar.h"
#include "ttftypes.h"
#include "filesys.h"
#include "telnet.h"
#include "tektypes.h"
#include "tekwin.h"
#include "ttdde.h"

#include "teraapp.h"

#include "compat_w95.h"

#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif

BEGIN_MESSAGE_MAP(CTeraApp, CWinApp)
        //{{AFX_MSG_MAP(CTeraApp)
        //}}AFX_MSG_MAP
END_MESSAGE_MAP()

CTeraApp::CTeraApp()
{
}

// CTeraApp instance
CTeraApp theApp;


// CTeraApp initialization
BOOL CTeraApp::InitInstance()
{
  // インストーラで実行を検出するために mutex を作成する (2006.8.12 maya)
  // 2重起動防止のためではないので、特に返り値は見ない
  HANDLE hMutex;
  hMutex = CreateMutex(NULL, TRUE, "TeraTermProAppMutex");

  hInst = m_hInstance;
  m_pMainWnd = new CVTWindow();
  pVTWin = m_pMainWnd;
  return TRUE;
}

int CTeraApp::ExitInstance()
{
  return CWinApp::ExitInstance();
}

// Tera Term main engine
BOOL CTeraApp::OnIdle(LONG lCount)
{
        static int Busy = 2;
        int Change, nx, ny;
        BOOL Size;

        if (lCount==0) Busy = 2;

        if (cv.Ready)
        {
                /* Sender */
                CommSend(&cv);

                /* Parser */
                if ((cv.HLogBuf!=NULL) && (cv.LogBuf==NULL))
                        cv.LogBuf = (PCHAR)GlobalLock(cv.HLogBuf);

                if ((cv.HBinBuf!=NULL) && (cv.BinBuf==NULL))
                        cv.BinBuf = (PCHAR)GlobalLock(cv.HBinBuf);

                if ((TelStatus==TelIdle) && cv.TelMode)
                        TelStatus = TelIAC;

                if (TelStatus != TelIdle)
                {
                        ParseTel(&Size,&nx,&ny);
                        if (Size) {
                                LockBuffer();
                                ChangeTerminalSize(nx,ny);
                                UnlockBuffer();
                        }
                }
                else {
                        if (cv.ProtoFlag) Change = ProtoDlgParse();
                        else {
                                switch (ActiveWin) {
                                case IdVT: 
                                        Change =  ((CVTWindow*)pVTWin)->Parse(); 
                                        // TEK windowのアクティブ中に pause を使うと、CPU使用率100%となる
                                        // 現象への暫定対処。(2006.2.6 yutaka)
                                        // 待ち時間をなくし、コンテキストスイッチだけにする。(2006.3.20 yutaka)
                                        Sleep(0);
                                        break;

                                case IdTEK:
                                        if (pTEKWin != NULL) {
                                                Change = ((CTEKWindow*)pTEKWin)->Parse();
                                                // TEK windowのアクティブ中に pause を使うと、CPU使用率100%となる
                                                // 現象への暫定対処。(2006.2.6 yutaka)
                                                Sleep(1);
                                        }
                                        else
                                                Change = IdVT;
                                        break;

                                default:
                                        Change = 0;
                                }

                                switch (Change) {
                                case IdVT: VTActivate(); break;
                                case IdTEK: ((CVTWindow*)pVTWin)->OpenTEK(); break;
                                }
                        }
                }

                if (cv.LogBuf!=NULL)
                {
                        if (FileLog) LogToFile();
                        if (DDELog && AdvFlag) DDEAdv();
                        GlobalUnlock(cv.HLogBuf);
                        cv.LogBuf = NULL;
                }

                if (cv.BinBuf!=NULL)
                {
                        if (BinLog) LogToFile();
                        GlobalUnlock(cv.HBinBuf);
                        cv.BinBuf = NULL;
                }

                /* Talker */
                switch (TalkStatus) {
                case IdTalkCB: CBSend(); break; /* clip board */
                case IdTalkFile: FileSend(); break; /* file */
                }

                /* Receiver */
                if (DDELog && cv.DCount >0) {
                        // ログバッファがまだDDEクライアントへ送られていない場合は、
                        // TCPパケットの受信を行わない。
                        // 連続して受信を行うと、ログバッファがラウンドロビンにより未送信のデータを
                        // 上書きしてしまう可能性がある。(2007.6.14 yutaka)

                } else {
                        CommReceive(&cv);
                }

        }

        if (cv.Ready &&
                (cv.RRQ || (cv.OutBuffCount>0) || (cv.InBuffCount>0) ||
                (cv.LCount>0) || (cv.BCount>0) || (cv.DCount>0)) )
                Busy = 2;
        else
                Busy--;

        return (Busy>0);
}

BOOL CTeraApp::PreTranslateMessage(MSG* pMsg)
{
  if (ts.MetaKey>0)
    return FALSE; /* ignore accelerator keys */
  else
    return CWinApp::PreTranslateMessage(pMsg);
}