| 1234567891011121314151617181920212223242526272829303132333435363738394041424344 | using System.Threading.Tasks;using System.Linq;using System;using Renci.SshNet.Messages;using System.Threading;namespace Renci.SshNet{    /// <summary>    /// Provides functionality to connect and interact with SSH server.    /// </summary>    public partial class Session    {        partial void HandleMessageCore(Message message)        {            this.HandleMessage((dynamic)message);        }        partial void ExecuteThread(Action action)        {            ThreadPool.QueueUserWorkItem(o => action());        }        partial void InternalRegisterMessage(string messageName)        {            lock (this._messagesMetadata)            {                Parallel.ForEach(                    from m in this._messagesMetadata where m.Name == messageName select m,                    item => { item.Enabled = true; item.Activated = true; });            }        }        partial void InternalUnRegisterMessage(string messageName)        {            lock (this._messagesMetadata)            {                Parallel.ForEach(                    from m in this._messagesMetadata where m.Name == messageName select m,                    item => { item.Enabled = false; item.Activated = false; });            }        }    }}
 |