| 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; });
- }
- }
- }
- }
|