Telnet服务器

开发平台：
C#

Paste.cs：源码内容
							/*
* Copyright (c) 2005 Poderosa Project, All Rights Reserved.
* $Id: Paste.cs,v 1.2 2005/04/20 08:45:47 okajima Exp $
*/
using System;
using System.Collections;
using System.IO;
using System.Diagnostics;
using System.Threading;
using Poderosa.Connection;
using Poderosa.ConnectionParam;
namespace Poderosa.Terminal
{
	public class PasteProcessor : IModalTerminalTask {
		private ArrayList _data;
		private ConnectionTag _tag;
		private int _length;
		private bool _async;
		private bool _abortFlag;
		public delegate void EventHandler(int param);
		public void Input(byte[] data, int offset, int length) {
		}
		public bool CanReceive {
			get {
				return false;
			}
		}
		public string Caption {
			get {
				return GEnv.Strings.GetString("Caption.ConnectionCommandTarget.DuringPaste");
			}
		}
		public int LineCount {
			get {
				return _data.Count;
			}
		}
		public event EventHandler LineProcessed;
		public PasteProcessor(ConnectionTag tag, string text) {
			_tag = tag;
			StringReader r = new StringReader(text);
			Fill(r);
			r.Close();
		}
		public PasteProcessor(ConnectionTag tag, TextReader reader) {
			_tag = tag;
			Fill(reader);
		}
		private void Fill(TextReader reader) {
			_data = new ArrayList();
			string l = reader.ReadLine();
			while(l!=null) {
				_data.Add(l);
				_length += l.Length;
				l = reader.ReadLine();
			}
		}
		public CommandResult Perform() {
			int lim = _tag.Connection.Param is SFUTerminalParam? 250 : 1000;
			if(_length < lim) { //1000帤埲壓側傜捈峴曋偱傗偭偮偗傞
				_async = false;
				return Paste();
			}
			else {
				_async = true;
				_tag.ModalTerminalTask = this;
				new Thread(new ThreadStart(Run)).Start();
				return CommandResult.Success;
			}
		}
		private void Run() {
			try {
				Paste();
			}
			catch(Exception ex) {
				Debug.WriteLine(ex.StackTrace);
				GEnv.InterThreadUIService.Warning(GEnv.Strings.GetString("Message.ConnectionCommandTarget.SendError") + ex.Message);
			}
		}
		public void SetAbortFlag() {
			_abortFlag = true;
		}
		private CommandResult Paste() {
			//夵峴偼憲傝愭儁僀儞偺夵峴愝掕偵崌傢偣偰憲傜傟傞丅偨偩偟丄嵟廔梫慺偼夵峴暥帤偱廔傢偭偰偄傞偐斲偐偱嫇摦偑曄傢傞
			if(_async) 
				RefreshConnection();
			for(int i=0; i<_data.Count-1; i++) {
				SendLine((string)_data[i], true);
				if(_abortFlag) return CommandResult.Cancelled;
				if(this.LineProcessed!=null) LineProcessed(i);
			}
			string lastline = (string)_data[_data.Count-1];
			char last = lastline.Length==0? '' : lastline[lastline.Length-1];
			if(last=='n' || last=='r')
				SendLine(lastline, true);
			else
				SendLine(lastline, false);
			if(_async) {
				_tag.ModalTerminalTask = null;
				RefreshConnection();
			}
			if(this.LineProcessed!=null) LineProcessed(-1);
			return CommandResult.Success;
		}
		private void SendLine(string line, bool appendnl) {
			if(_tag.Connection.IsClosed || GEnv.Frame.MacroIsRunning) return;
	
			//GEnv.Frame.StatusBar.IndicateSendData();
			if(appendnl)
				line += new string(TerminalUtil.NewLineChars(_tag.Connection.Param.TransmitNL));
			char[] chars = line.ToCharArray();
			if(_tag.Connection.Param.LocalEcho) {
				lock(_tag.Document) {
					_tag.Terminal.Input(chars, 0, chars.Length);
				}
			}
			if(_tag.Connection.Param is SFUTerminalParam) { //SFU偼傑偲傔偰憲怣偡傞偲庢傝偙傏偟偑偱偰偟傑偆丅暢傔丅
				int x = 0;
				while(x < chars.Length) {
					_tag.Connection.WriteChar(chars[x++]);
					if((x % 100)==0) Thread.Sleep(100);
				}
				Thread.Sleep(100);
			}
			else
				_tag.Connection.WriteChars(chars);
		}
		private void RefreshConnection() {
			//InterThread偼傕偲傕偲昤夋僗儗僢僪偐傜屇傇偨傔偺傕偺偱丄Document傪儘僢僋偟偰偄傞偺偑慜採丅側偺偱偁偊偰儘僢僋偟偰偐傜屇傃偵偄偔偙偲偱挷惍傪偲傞
			lock(_tag.Document) {
				GEnv.InterThreadUIService.RefreshConnection(_tag);
			}
		}
	}
}

						