Telnet服务器

开发平台：
C#

TerminalDataReceiver.cs：源码内容
							/*
* Copyright (c) 2005 Poderosa Project, All Rights Reserved.
* $Id: TerminalDataReceiver.cs,v 1.2 2005/04/20 08:45:47 okajima Exp $
*/
using System;
using System.Diagnostics;
using System.Threading;
using System.Text;
using System.Windows.Forms;
using Poderosa.Connection;
using Poderosa.Config;
using Poderosa.Forms;
using Poderosa.Communication;
using Poderosa.Text;
using Poderosa.Log;
namespace Poderosa.Terminal
{
	/// <summary>
	/// TerminalDataReceiver 偺奣梫偺愢柧偱偡丅
	/// </summary>
	public class TerminalDataReceiver : IDataReceiver {
		private ConnectionTag _tag;
		//庴怣僗儗僢僪偱偙傟傜偺抣傪愝掕偟丄師偺OnPaint摍儊僀儞僗儗僢僪偱偺幚峴偱Commit偡傞
		private bool _transientScrollBarDirty; //偙傟偑棫偭偰偄傞偲梫愝掕
		private bool _transientScrollBarEnabled;
		private int  _transientScrollBarValue;
		private int  _transientScrollBarLargeChange;
		private int  _transientScrollBarMaximum;
		public TerminalDataReceiver(ConnectionTag ct) {
			_tag = ct;
		}
		public void Listen() {
			_tag.Connection.RepeatAsyncRead(this);
		}
		public void DataArrived(byte[] data, int offset, int count) {
			try {
				TerminalConnection con = _tag.Connection;
				con.AddReceivedDataStats(count);
				con.BinaryLogger.Append(data, offset, count);
				if(_tag.ModalTerminalTask!=null && _tag.ModalTerminalTask.CanReceive)
					_tag.ModalTerminalTask.Input(data, offset, count);
				else {
					TerminalDocument document = _tag.Document;
					lock(document) {
						_tag.InvalidateParam.Reset();
						_tag.Terminal.Input(data, offset, count);
						//塃抂偵僉儍儗僢僩偑棃偨偲偒偼曋媂揑偵師峴偺摢偵傕偭偰偄偔
						if(document.CaretColumn==_tag.Connection.TerminalWidth) {
							document.CurrentLineNumber++; //偙傟偵傛偭偰師峴偺懚嵼傪曐徹
							document.CaretColumn = 0;
						}
						CheckDiscardDocument();
						AdjustTransientScrollBar();
						int n = document.CurrentLineNumber-_tag.Connection.TerminalHeight+1-document.FirstLineNumber;
						if(n < 0) n = 0;
						//Debug.WriteLine(String.Format("E={0} C={1} T={2} H={3} LC={4} MAX={5} n={6}", _transientScrollBarEnabled, _tag.Document.CurrentLineNumber, _tag.Document.TopLineNumber, _tag.Connection.TerminalHeight, _transientScrollBarLargeChange, _transientScrollBarMaximum, n));
						if(IsAutoScrollMode(n)) {
							_transientScrollBarValue = n;
							document.TopLineNumber = n + document.FirstLineNumber;
						}
						else
							_transientScrollBarValue = document.TopLineNumber - document.FirstLineNumber;
						_tag.NotifyUpdate();
					}
					//Invalidate傪lock偺奜偵弌偡丅偙偺傎偆偑埨慡偲巚傢傟偨
					if(_tag.Pane!=null) _tag.InvalidateParam.InvokeFor(_tag.Pane);
					ITerminalTextLogger tl = con.TextLogger;
					if(tl!=null) {
						tl.PacketDelimiter();
						tl.Flush();
					}
				}
				ITerminalBinaryLogger bl = con.BinaryLogger;
				if(bl!=null)
					bl.Flush();
			}
			catch(Exception ex) {
				GEnv.InterThreadUIService.ReportCriticalError(ex);
			}
		}
		private bool IsAutoScrollMode(int value_candidate) {
			return _tag.Terminal.TerminalMode==TerminalMode.Normal && 
				_tag.Document.CurrentLineNumber>=_tag.Document.TopLineNumber+_tag.Connection.TerminalHeight-1 &&
				(!_transientScrollBarEnabled || value_candidate+_transientScrollBarLargeChange>_transientScrollBarMaximum);
		}
		private void CheckDiscardDocument() {
			if(_tag==null || _tag.Terminal.TerminalMode==TerminalMode.Application) return;
			TerminalDocument document = _tag.Document;
			int del = document.DiscardOldLines(GEnv.Options.TerminalBufferSize+_tag.Connection.TerminalHeight);
			if(del > 0) {
				_tag.NotifyUpdate();
				TextSelection sel = GEnv.TextSelection;
				if(sel.Owner==_tag.Pane)
					sel.ClearIfOverlapped(document.FirstLineNumber);
				int newvalue = _transientScrollBarValue - del;
				if(newvalue<0) newvalue=0;
				_transientScrollBarValue = newvalue;
				document.InvalidateAll(); //杮摉偼偙偙傑偱偟側偔偰傕椙偝偦偆偩偑擮偺偨傔
			}
		}
		internal void AdjustTransientScrollBar() {
			TerminalDocument document = _tag.Document;
			int paneheight = _tag.Connection.TerminalHeight;
			int docheight = Math.Max(document.LastLineNumber, document.TopLineNumber+paneheight-1)-document.FirstLineNumber+1;
			_transientScrollBarDirty = true;
			if((_tag.Terminal.TerminalMode==TerminalMode.Application && !GEnv.Options.AllowsScrollInAppMode)
				|| paneheight >= docheight) {
				_transientScrollBarEnabled = false;
				_transientScrollBarValue = 0;
			}
			else {
				_transientScrollBarEnabled = true;
				_transientScrollBarMaximum = docheight-1;
				_transientScrollBarLargeChange = paneheight;
			}
			//Debug.WriteLine(String.Format("E={0} V={1}", _transientScrollBarEnabled, _transientScrollBarValue));
		}
		public void SetTransientScrollBarValue(int value) {
			_transientScrollBarValue = value;
			_transientScrollBarDirty = true;
		}
		public void CommitScrollBar(VScrollBar sb, bool dirty_only) {
			if(dirty_only && !_transientScrollBarDirty) return;
			sb.Enabled = _transientScrollBarEnabled;
			sb.Maximum = _transientScrollBarMaximum;
			sb.LargeChange = _transientScrollBarLargeChange;
			//!!杮棃偙偺if暥偼晄梫側偼偢偩偑丄斖埻僄儔乕偵側傞働乕僗偑尒庴偗傜傟偨丅偦偺尨場傪扵偭偰儕儕乕僗捈慜偵偄傠偄傠偄偠傞偺偼婋尟側偺偱偙偙偼摝偘傞丅屻偱偪傖傫偲夝柧偡傞丅
			if(_transientScrollBarValue < _transientScrollBarMaximum)
				sb.Value = _transientScrollBarValue;
			_transientScrollBarDirty = false;
		}
		public void ErrorOccurred(string msg) {
			if(GEnv.Frame.IgnoreErrors) return;
			Debug.WriteLine("Closed="+_tag.Connection.IsClosed);
			if(!_tag.Connection.IsClosed) { //暵偠傞巜椷傪弌偟偨屻偺僄儔乕偼昞帵偟側偄
				GEnv.InterThreadUIService.Warning(String.Format(GEnv.Strings.GetString("Message.TerminalDataReceiver.GenericError"),_tag.Connection.Param.ShortDescription, msg));
				try {
					_tag.Connection.Close();
				}
				catch(Exception) { //僄儔乕捠抦屻偺Close偵幐攕偡傞偺偼柍帇丅
				}
				GEnv.Frame.RefreshConnection(_tag);
				_tag.NotifyDisconnect();
			}
		}
		public void DisconnectedFromServer() {
			if(GEnv.Frame.IgnoreErrors) return;
			_tag.NotifyDisconnect();
			TerminalConnection c = _tag.Connection;
			GEnv.InterThreadUIService.DisconnectedFromServer(c);
		}
		public void IndicateBell() {
			GEnv.InterThreadUIService.IndicateBell(_tag.Document);
			if(GEnv.Options.BeepOnBellChar) Win32.MessageBeep(-1);
		}
	}
	//偙傟傪幚憰偟偨僆僽僕僃僋僩傪ConnectionTag偵僙僢僩偟偰偄傞娫偼丄僨乕僞傪墶庢傝偱偒傞丅
	public interface IModalTerminalTask {
		void Input(byte[] data, int offset, int count);
		bool CanReceive { get; }
		string Caption { get; }
	}
}

						