Ignore:
Timestamp:
Jun 24, 2010, 1:15:16 PM (11 years ago)
Author:
Paul Lelgemann
Message:

o Refactoring in CrypP2P
o AES: NullReference in AES-Plugin fixed
o Small fixes in KeySearcher, StorageKeyGenerator uses IV and truncates input data

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/CrypP2P/Internal/P2PBase.cs

    r1696 r1698  
    5151        #region Variables
    5252
    53         private readonly AutoResetEvent _systemJoined;
    54         private readonly AutoResetEvent _systemLeft;
    55         private IBootstrapper _bootstrapper;
    56         private IP2PLinkManager _linkmanager;
    57         private P2POverlay _overlay;
     53        private readonly AutoResetEvent systemJoined;
     54        private readonly AutoResetEvent systemLeft;
     55        private IBootstrapper bootstrapper;
     56        private IP2PLinkManager linkmanager;
     57        private P2POverlay overlay;
    5858        internal IDHT Dht;
    5959        internal IVersionedDHT VersionedDht;
     
    8989            IsInitialized = false;
    9090
    91             _systemJoined = new AutoResetEvent(false);
    92             _systemLeft = new AutoResetEvent(false);
     91            systemJoined = new AutoResetEvent(false);
     92            systemLeft = new AutoResetEvent(false);
    9393        }
    9494
     
    108108
    109109                    // NAT-Traversal stuff needs a different Snal-Version
    110                     _linkmanager = new Snal(scheduler);
     110                    linkmanager = new Snal(scheduler);
    111111
    112112                    var settings = new PeersAtPlay.P2PLink.SnalNG.Settings();
     
    136136                    }
    137137
    138                     _linkmanager.Settings = settings;
    139                     _linkmanager.ApplicationType = ApplicationType.CrypTool;
     138                    linkmanager.Settings = settings;
     139                    linkmanager.ApplicationType = ApplicationType.CrypTool;
    140140
    141141                    break;
     
    148148                case P2PBootstrapperType.LocalMachineBootstrapper:
    149149                    // LocalMachineBootstrapper = only local connection (runs only on one machine)
    150                     _bootstrapper = new LocalMachineBootstrapper();
     150                    bootstrapper = new LocalMachineBootstrapper();
    151151                    break;
    152152                case P2PBootstrapperType.IrcBootstrapper:
     
    155155                    PeersAtPlay.P2POverlay.Bootstrapper.IrcBootstrapperV2.Settings.UsePeerCache = false;
    156156
    157                     _bootstrapper = new IrcBootstrapper(scheduler);
     157                    bootstrapper = new IrcBootstrapper(scheduler);
    158158                    break;
    159159                default:
     
    164164            {
    165165                case P2PArchitecture.FullMesh:
    166                     _overlay = new FullMeshOverlay(scheduler);
     166                    overlay = new FullMeshOverlay(scheduler);
    167167                    Dht = new FullMeshDHT(scheduler);
    168168                    break;
    169169                case P2PArchitecture.Chord:
    170                     _overlay = new ChordNGCore(scheduler);
    171                     Dht = (IDHT) _overlay;
     170                    overlay = new ChordNGCore(scheduler);
     171                    Dht = (IDHT) overlay;
    172172                    break;
    173173                default:
     
    175175            }
    176176
    177             _overlay.MessageReceived += OverlayMessageReceived;
     177            overlay.MessageReceived += OverlayMessageReceived;
    178178            Dht.SystemJoined += OnDhtSystemJoined;
    179179            Dht.SystemLeft += OnDhtSystemLeft;
     
    183183            P2PManager.GuiLogMessage("Initializing DHT with world name " + P2PSettings.Default.WorldName,
    184184                                                NotificationLevel.Info);
    185             Dht.Initialize(P2PSettings.Default.PeerName, string.Empty, P2PSettings.Default.WorldName, _overlay,
    186                             _bootstrapper,
    187                             _linkmanager, null);
     185            Dht.Initialize(P2PSettings.Default.PeerName, string.Empty, P2PSettings.Default.WorldName, overlay,
     186                            bootstrapper,
     187                            linkmanager, null);
    188188
    189189            IsInitialized = true;
     
    215215
    216216            // Wait for event SystemJoined. When it's invoked, the peer completely joined the P2P system
    217             _systemJoined.WaitOne();
     217            systemJoined.WaitOne();
    218218            P2PManager.GuiLogMessage("System join process ended.", NotificationLevel.Debug);
    219219
     
    242242
    243243            // wait till systemLeft Event is invoked
    244             _systemLeft.WaitOne();
     244            systemLeft.WaitOne();
    245245
    246246            return true;
     
    258258        public PeerId GetPeerId(out string sPeerName)
    259259        {
    260             sPeerName = _linkmanager.UserName;
    261             return new PeerId(_overlay.LocalAddress);
     260            sPeerName = linkmanager.UserName;
     261            return new PeerId(overlay.LocalAddress);
    262262        }
    263263
     
    270270        {
    271271            LogToMonitor("GetPeerID: Converting byte[] to PeerId-Object");
    272             return new PeerId(_overlay.GetAddress(byteId));
     272            return new PeerId(overlay.GetAddress(byteId));
    273273        }
    274274
     
    277277        {
    278278            // get stack size of the pap use-data and add own use data (for optimizing Stack size)
    279             var realStackSize = _overlay.GetHeaderSize() + data.Length;
     279            var realStackSize = overlay.GetHeaderSize() + data.Length;
    280280
    281281            var stackData = new ByteStack(realStackSize);
    282282            stackData.Push(data);
    283283
    284             var destinationAddr = _overlay.GetAddress(destinationPeer);
     284            var destinationAddr = overlay.GetAddress(destinationPeer);
    285285            var overlayMsg = new OverlayMessage(MessageReceiverType.P2PBase,
    286                                                 _overlay.LocalAddress, destinationAddr, stackData);
    287 
    288             _overlay.Send(overlayMsg);
     286                                                overlay.LocalAddress, destinationAddr, stackData);
     287
     288            overlay.Send(overlayMsg);
    289289        }
    290290
     
    319319                OnSystemJoined();
    320320
    321             _systemJoined.Set();
     321            systemJoined.Set();
    322322            IsConnected = true;
    323323        }
     
    333333            // Allow new connection to start and check for waiting / blocked tasks
    334334            // TODO reset running ConnectionWorkers?
    335             _systemLeft.Set();
    336             _systemJoined.Set();
     335            systemLeft.Set();
     336            systemJoined.Set();
    337337
    338338            LogToMonitor("CrypP2P left the system.");
Note: See TracChangeset for help on using the changeset viewer.