Ignore:
Timestamp:
Nov 22, 2010, 11:45:51 AM (11 years ago)
Author:
nolte
Message:

Added the version number at the beginning of the stream.
Still needs to be tested and verified.
Update to version 1 will be announced soon.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/CrypPlugins/KeySearcher/P2P/Storage/StorageHelper.cs

    r2094 r2121  
    4545                binaryWriter.Write(valueKey.decryption.Length);
    4646                binaryWriter.Write(valueKey.decryption);
    47             }
    48            
     47            }                       
     48           
     49            //TODO: Hash Table write;
     50
     51            return StoreWithStatistic(KeyInDht(nodeToUpdate), memoryStream.ToArray());
     52        }
     53
     54        private static void UpdateNodeInDht(Node nodeToUpdate, BinaryWriter binaryWriter)
     55        {
     56            binaryWriter.Write(nodeToUpdate.LeftChildFinished);
     57            binaryWriter.Write(nodeToUpdate.RightChildFinished);
     58        }
     59
     60        private static void UpdateLeafInDht(Leaf nodeToUpdate, BinaryWriter binaryWriter)
     61        {
    4962            //TODO: Versionnumber write
    5063            //-----------------------------------------------------
     64            //binaryWriter.Write('V');
    5165            //binaryWriter.Write(version);
    5266            //-----------------------------------------------------
    53            
    54             //TODO: Hash Table write;
    55 
    56             return StoreWithStatistic(KeyInDht(nodeToUpdate), memoryStream.ToArray());
    57         }
    58 
    59         private static void UpdateNodeInDht(Node nodeToUpdate, BinaryWriter binaryWriter)
    60         {
    61             binaryWriter.Write(nodeToUpdate.LeftChildFinished);
    62             binaryWriter.Write(nodeToUpdate.RightChildFinished);
    63         }
    64 
    65         private static void UpdateLeafInDht(Leaf nodeToUpdate, BinaryWriter binaryWriter)
    66         {
    6767            var buffer = nodeToUpdate.LastReservationDate.ToBinary();
    6868            binaryWriter.Write(buffer);
     
    112112                nodeToUpdate.Result.AddLast(newResult);
    113113            }
    114 
     114           
    115115            //-------------------------------------------------------------------------------------------
    116116            //AFTER CHANGING THE FOLLOWING PART INCREASE THE VERSION-NUMBER AT THE TOP OF THIS CLASS!
    117117            //-------------------------------------------------------------------------------------------
    118             //TODO: Versionnumber read
    119118            /*
    120             try
    121             {
    122                 //If you're already at the end of the stream ignore the version
    123                 if (binaryReader.BaseStream.Length != binaryReader.BaseStream.Position)
    124                 {
    125                     int versionInUse = binaryReader.ReadInt32();
    126                     //Check if a newer Version is in use
    127                     if (versionInUse > version)
    128                     {
    129                         throw new KeySearcherStopException();
    130                     }
    131                     //TODO: Hashtable read
    132                 }
    133             }
    134             catch(Exception)
    135             {
    136                 throw new KeySearcherStopException();
    137             }
    138 
    139             //----------------------------------------------------------------------------------
     119            if (binaryReader.BaseStream.Length != binaryReader.BaseStream.Position)
     120            {
     121                //TODO: Hashtable read
     122            }
    140123            */
     124
    141125            if (resultCount > 0)
    142126            {
     
    157141        private static void UpdateLeafFromDht(Leaf nodeToUpdate, BinaryReader binaryReader)
    158142        {
     143            //---------------------------------------------------------------------------------
     144            //TODO: Versionnumber read
     145            //CheckVersion(binaryReader);
     146            //----------------------------------------------------------------------------------
     147           
    159148            var date = DateTime.FromBinary(binaryReader.ReadInt64());
    160149            if (date > nodeToUpdate.LastReservationDate)
     
    163152            }
    164153           
    165             //----------------------------------------------------------------
    166154            try
    167155            {
     
    180168                nodeToUpdate.setClientIdentifier(-1);
    181169            }
    182             //----------------------------------------------------------------
    183170           
    184171        }
     
    188175            return string.Format("{0}_node_{1}_{2}", node.DistributedJobIdentifier, node.From, node.To);
    189176        }
     177
     178        //----------------------------------------------------------------------------
     179        public static void CheckVersion(BinaryReader binaryReader)
     180        {
     181            /*
     182            try
     183            {
     184                //Checking in theres a version in the stream
     185                if (binaryReader.PeekChar().Equals('V'))
     186                {
     187                    //Reading the char and the versionnumber
     188                    binaryReader.ReadChar();
     189                    int versionInUse = binaryReader.ReadInt32();
     190                    //Check if a newer Version is in use
     191                    if (versionInUse > version)
     192                    {
     193                        throw new KeySearcherStopException();
     194                    }
     195                }
     196            }
     197            catch(Exception)
     198            {
     199                throw new KeySearcherStopException();
     200            }
     201            */
     202        }
     203        //-----------------------------------------------------------------------------
    190204
    191205        public DateTime StartDate(String ofJobIdentifier)
     
    205219        }
    206220
    207         //------------------------------------------------------------------------
    208221        public long SubmitterID(String ofJobIdentifier)
    209222        {
     
    220233            return Cryptool.PluginBase.Miscellaneous.UniqueIdentifier.GetID();
    221234        }
    222         //---------------------------------------------------------------------------
    223235
    224236        public RequestResult RetrieveWithStatistic(string key)
Note: See TracChangeset for help on using the changeset viewer.