| 1 | 
 ---------------------------------------------------------------- | 
 
 
 
 
 
 | 2 | 
 --  ZLib for Ada thick binding.                               -- | 
 
 
 
 
 
 | 3 | 
 --                                                            -- | 
 
 
 
 
 
 | 4 | 
 --  Copyright (C) 2002-2003 Dmitriy Anisimkov                 -- | 
 
 
 
 
 
 | 5 | 
 --                                                            -- | 
 
 
 
 
 
 | 6 | 
 --  Open source license information is in the zlib.ads file.  -- | 
 
 
 
 
 
 | 7 | 
 ---------------------------------------------------------------- | 
 
 
 
 
 
 | 8 | 
 --  Continuous test for ZLib multithreading. If the test would fail | 
 
 
 
 
 
 | 9 | 
 --  we should provide thread safe allocation routines for the Z_Stream. | 
 
 
 
 
 
 | 10 | 
 -- | 
 
 
 
 
 
 | 11 | 
 --  $Id: mtest.adb,v 1.4 2004/07/23 07:49:54 vagul Exp $ | 
 
 
 
 
 
 | 12 | 
  | 
 
 
 
 
 
 | 13 | 
 with ZLib; | 
 
 
 
 
 
 | 14 | 
 with Ada.Streams; | 
 
 
 
 
 
 | 15 | 
 with Ada.Numerics.Discrete_Random; | 
 
 
 
 
 
 | 16 | 
 with Ada.Text_IO; | 
 
 
 
 
 
 | 17 | 
 with Ada.Exceptions; | 
 
 
 
 
 
 | 18 | 
 with Ada.Task_Identification; | 
 
 
 
 
 
 | 19 | 
  | 
 
 
 
 
 
 | 20 | 
 procedure MTest is | 
 
 
 
 
 
 | 21 | 
    use Ada.Streams; | 
 
 
 
 
 
 | 22 | 
    use ZLib; | 
 
 
 
 
 
 | 23 | 
  | 
 
 
 
 
 
 | 24 | 
    Stop : Boolean := False; | 
 
 
 
 
 
 | 25 | 
  | 
 
 
 
 
 
 | 26 | 
    pragma Atomic (Stop); | 
 
 
 
 
 
 | 27 | 
  | 
 
 
 
 
 
 | 28 | 
    subtype Visible_Symbols is Stream_Element range 16#20# .. 16#7E#; | 
 
 
 
 
 
 | 29 | 
  | 
 
 
 
 
 
 | 30 | 
    package Random_Elements is | 
 
 
 
 
 
 | 31 | 
       new Ada.Numerics.Discrete_Random (Visible_Symbols); | 
 
 
 
 
 
 | 32 | 
  | 
 
 
 
 
 
 | 33 | 
    task type Test_Task; | 
 
 
 
 
 
 | 34 | 
  | 
 
 
 
 
 
 | 35 | 
    task body Test_Task is | 
 
 
 
 
 
 | 36 | 
       Buffer : Stream_Element_Array (1 .. 100_000); | 
 
 
 
 
 
 | 37 | 
       Gen : Random_Elements.Generator; | 
 
 
 
 
 
 | 38 | 
  | 
 
 
 
 
 
 | 39 | 
       Buffer_First  : Stream_Element_Offset; | 
 
 
 
 
 
 | 40 | 
       Compare_First : Stream_Element_Offset; | 
 
 
 
 
 
 | 41 | 
  | 
 
 
 
 
 
 | 42 | 
       Deflate : Filter_Type; | 
 
 
 
 
 
 | 43 | 
       Inflate : Filter_Type; | 
 
 
 
 
 
 | 44 | 
  | 
 
 
 
 
 
 | 45 | 
       procedure Further (Item : in Stream_Element_Array); | 
 
 
 
 
 
 | 46 | 
  | 
 
 
 
 
 
 | 47 | 
       procedure Read_Buffer | 
 
 
 
 
 
 | 48 | 
         (Item : out Ada.Streams.Stream_Element_Array; | 
 
 
 
 
 
 | 49 | 
          Last : out Ada.Streams.Stream_Element_Offset); | 
 
 
 
 
 
 | 50 | 
  | 
 
 
 
 
 
 | 51 | 
       ------------- | 
 
 
 
 
 
 | 52 | 
       -- Further -- | 
 
 
 
 
 
 | 53 | 
       ------------- | 
 
 
 
 
 
 | 54 | 
  | 
 
 
 
 
 
 | 55 | 
       procedure Further (Item : in Stream_Element_Array) is | 
 
 
 
 
 
 | 56 | 
  | 
 
 
 
 
 
 | 57 | 
          procedure Compare (Item : in Stream_Element_Array); | 
 
 
 
 
 
 | 58 | 
  | 
 
 
 
 
 
 | 59 | 
          ------------- | 
 
 
 
 
 
 | 60 | 
          -- Compare -- | 
 
 
 
 
 
 | 61 | 
          ------------- | 
 
 
 
 
 
 | 62 | 
  | 
 
 
 
 
 
 | 63 | 
          procedure Compare (Item : in Stream_Element_Array) is | 
 
 
 
 
 
 | 64 | 
             Next_First : Stream_Element_Offset := Compare_First + Item'Length; | 
 
 
 
 
 
 | 65 | 
          begin | 
 
 
 
 
 
 | 66 | 
             if Buffer (Compare_First .. Next_First - 1) /= Item then | 
 
 
 
 
 
 | 67 | 
                raise Program_Error; | 
 
 
 
 
 
 | 68 | 
             end if; | 
 
 
 
 
 
 | 69 | 
  | 
 
 
 
 
 
 | 70 | 
             Compare_First := Next_First; | 
 
 
 
 
 
 | 71 | 
          end Compare; | 
 
 
 
 
 
 | 72 | 
  | 
 
 
 
 
 
 | 73 | 
          procedure Compare_Write is new ZLib.Write (Write => Compare); | 
 
 
 
 
 
 | 74 | 
       begin | 
 
 
 
 
 
 | 75 | 
          Compare_Write (Inflate, Item, No_Flush); | 
 
 
 
 
 
 | 76 | 
       end Further; | 
 
 
 
 
 
 | 77 | 
  | 
 
 
 
 
 
 | 78 | 
       ----------------- | 
 
 
 
 
 
 | 79 | 
       -- Read_Buffer -- | 
 
 
 
 
 
 | 80 | 
       ----------------- | 
 
 
 
 
 
 | 81 | 
  | 
 
 
 
 
 
 | 82 | 
       procedure Read_Buffer | 
 
 
 
 
 
 | 83 | 
         (Item : out Ada.Streams.Stream_Element_Array; | 
 
 
 
 
 
 | 84 | 
          Last : out Ada.Streams.Stream_Element_Offset) | 
 
 
 
 
 
 | 85 | 
       is | 
 
 
 
 
 
 | 86 | 
          Buff_Diff   : Stream_Element_Offset := Buffer'Last - Buffer_First; | 
 
 
 
 
 
 | 87 | 
          Next_First : Stream_Element_Offset; | 
 
 
 
 
 
 | 88 | 
       begin | 
 
 
 
 
 
 | 89 | 
          if Item'Length <= Buff_Diff then | 
 
 
 
 
 
 | 90 | 
             Last := Item'Last; | 
 
 
 
 
 
 | 91 | 
  | 
 
 
 
 
 
 | 92 | 
             Next_First := Buffer_First + Item'Length; | 
 
 
 
 
 
 | 93 | 
  | 
 
 
 
 
 
 | 94 | 
             Item := Buffer (Buffer_First .. Next_First - 1); | 
 
 
 
 
 
 | 95 | 
  | 
 
 
 
 
 
 | 96 | 
             Buffer_First := Next_First; | 
 
 
 
 
 
 | 97 | 
          else | 
 
 
 
 
 
 | 98 | 
             Last := Item'First + Buff_Diff; | 
 
 
 
 
 
 | 99 | 
             Item (Item'First .. Last) := Buffer (Buffer_First .. Buffer'Last); | 
 
 
 
 
 
 | 100 | 
             Buffer_First := Buffer'Last + 1; | 
 
 
 
 
 
 | 101 | 
          end if; | 
 
 
 
 
 
 | 102 | 
       end Read_Buffer; | 
 
 
 
 
 
 | 103 | 
  | 
 
 
 
 
 
 | 104 | 
       procedure Translate is new Generic_Translate | 
 
 
 
 
 
 | 105 | 
                                    (Data_In  => Read_Buffer, | 
 
 
 
 
 
 | 106 | 
                                     Data_Out => Further); | 
 
 
 
 
 
 | 107 | 
  | 
 
 
 
 
 
 | 108 | 
    begin | 
 
 
 
 
 
 | 109 | 
       Random_Elements.Reset (Gen); | 
 
 
 
 
 
 | 110 | 
  | 
 
 
 
 
 
 | 111 | 
       Buffer := (others => 20); | 
 
 
 
 
 
 | 112 | 
  | 
 
 
 
 
 
 | 113 | 
       Main : loop | 
 
 
 
 
 
 | 114 | 
          for J in Buffer'Range loop | 
 
 
 
 
 
 | 115 | 
             Buffer (J) := Random_Elements.Random (Gen); | 
 
 
 
 
 
 | 116 | 
  | 
 
 
 
 
 
 | 117 | 
             Deflate_Init (Deflate); | 
 
 
 
 
 
 | 118 | 
             Inflate_Init (Inflate); | 
 
 
 
 
 
 | 119 | 
  | 
 
 
 
 
 
 | 120 | 
             Buffer_First  := Buffer'First; | 
 
 
 
 
 
 | 121 | 
             Compare_First := Buffer'First; | 
 
 
 
 
 
 | 122 | 
  | 
 
 
 
 
 
 | 123 | 
             Translate (Deflate); | 
 
 
 
 
 
 | 124 | 
  | 
 
 
 
 
 
 | 125 | 
             if Compare_First /= Buffer'Last + 1 then | 
 
 
 
 
 
 | 126 | 
                raise Program_Error; | 
 
 
 
 
 
 | 127 | 
             end if; | 
 
 
 
 
 
 | 128 | 
  | 
 
 
 
 
 
 | 129 | 
             Ada.Text_IO.Put_Line | 
 
 
 
 
 
 | 130 | 
               (Ada.Task_Identification.Image | 
 
 
 
 
 
 | 131 | 
                  (Ada.Task_Identification.Current_Task) | 
 
 
 
 
 
 | 132 | 
                & Stream_Element_Offset'Image (J) | 
 
 
 
 
 
 | 133 | 
                & ZLib.Count'Image (Total_Out (Deflate))); | 
 
 
 
 
 
 | 134 | 
  | 
 
 
 
 
 
 | 135 | 
             Close (Deflate); | 
 
 
 
 
 
 | 136 | 
             Close (Inflate); | 
 
 
 
 
 
 | 137 | 
  | 
 
 
 
 
 
 | 138 | 
             exit Main when Stop; | 
 
 
 
 
 
 | 139 | 
          end loop; | 
 
 
 
 
 
 | 140 | 
       end loop Main; | 
 
 
 
 
 
 | 141 | 
    exception | 
 
 
 
 
 
 | 142 | 
       when E : others => | 
 
 
 
 
 
 | 143 | 
          Ada.Text_IO.Put_Line (Ada.Exceptions.Exception_Information (E)); | 
 
 
 
 
 
 | 144 | 
          Stop := True; | 
 
 
 
 
 
 | 145 | 
    end Test_Task; | 
 
 
 
 
 
 | 146 | 
  | 
 
 
 
 
 
 | 147 | 
    Test : array (1 .. 4) of Test_Task; | 
 
 
 
 
 
 | 148 | 
  | 
 
 
 
 
 
 | 149 | 
    pragma Unreferenced (Test); | 
 
 
 
 
 
 | 150 | 
  | 
 
 
 
 
 
 | 151 | 
    Dummy : Character; | 
 
 
 
 
 
 | 152 | 
  | 
 
 
 
 
 
 | 153 | 
 begin | 
 
 
 
 
 
 | 154 | 
    Ada.Text_IO.Get_Immediate (Dummy); | 
 
 
 
 
 
 | 155 | 
    Stop := True; | 
 
 
 
 
 
 | 156 | 
 end MTest; |