Skip to content

Commit

Permalink
A 3rdparty
Browse files Browse the repository at this point in the history
A    3rdparty/asl
A    3rdparty/asl/asl-semaphore-counting.adb
A    3rdparty/asl/asl-semaphore-counting.ads
M    agpl-chronos.adb
M    agpl-chronos.ads
  • Loading branch information
mosteo committed Mar 9, 2007
1 parent fceb296 commit b7130bd
Show file tree
Hide file tree
Showing 4 changed files with 142 additions and 3 deletions.
74 changes: 74 additions & 0 deletions 3rdparty/asl/asl-semaphore-counting.adb
@@ -0,0 +1,74 @@
-- The Ada Structured Library - A set of container classes and general
-- tools for use with Ada95.
-- Copyright (C) 1998-1999 Corey Minyard (minyard@acm.org)
--
-- This library is free software; you can redistribute it and/or modify it
-- under the terms of the GNU General Public License as published by the
-- Free Software Foundation; either version 2 of the License, or (at your
-- option) any later version.
--
-- This library is distributed in the hope that it will be useful, but
-- WITHOUT ANY WARRANTY; without even the implied warranty of
-- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-- General Public License for more details.
--
-- You should have received a copy of the GNU General Public License along
-- with this library; if not, write to the Free Software Foundation, Inc.,
-- 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
--
-- As a special exception, if other files instantiate generics from this
-- unit, or you link this unit with other files to produce an executable,
-- this unit does not by itself cause the resulting executable to be
-- covered by the GNU General Public License. This exception does not
-- however invalidate any other reasons why the executable file might be
-- covered by the GNU Public License.
--

package body Asl.Semaphore.Counting is

------------------------------------------------------------------------
procedure Take (O : in out Object) is
begin
O.The_Mutex.Wait;
end Take;

------------------------------------------------------------------------
procedure Give (O : in out Object) is
begin
O.The_Mutex.Release;
end Give;

------------------------------------------------------------------------
procedure Try_To_Take (O : in out Object;
Success : out Boolean;
Timeout : in Duration := 0.0) is
begin
select
O.The_Mutex.Wait;
Success := True;
or
delay Timeout;
Success := False;
end select;
end Try_To_Take;


------------------------------------------------------------------------
------------------------------------------------------------------------
protected body Mutex is

---------------------------------------------------------------------
entry Wait when (Count > 0) is
begin
Count := Count - 1;
end Wait;

---------------------------------------------------------------------
procedure Release is
begin
Count := Count + 1;
end Release;

end Mutex;

end Asl.Semaphore.Counting;
65 changes: 65 additions & 0 deletions 3rdparty/asl/asl-semaphore-counting.ads
@@ -0,0 +1,65 @@
-- The Ada Structured Library - A set of container classes and general
-- tools for use with Ada95.
-- Copyright (C) 1998-1999 Corey Minyard (minyard@acm.org)
--
-- This library is free software; you can redistribute it and/or modify it
-- under the terms of the GNU General Public License as published by the
-- Free Software Foundation; either version 2 of the License, or (at your
-- option) any later version.
--
-- This library is distributed in the hope that it will be useful, but
-- WITHOUT ANY WARRANTY; without even the implied warranty of
-- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-- General Public License for more details.
--
-- You should have received a copy of the GNU General Public License along
-- with this library; if not, write to the Free Software Foundation, Inc.,
-- 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA
--
-- As a special exception, if other files instantiate generics from this
-- unit, or you link this unit with other files to produce an executable,
-- this unit does not by itself cause the resulting executable to be
-- covered by the GNU General Public License. This exception does not
-- however invalidate any other reasons why the executable file might be
-- covered by the GNU Public License.
--

-- A standard counting semaphore. The initial count is specified when the
-- semaphore is declared. The Take operation will block is the count is
-- zero, otherwise Take will decremenet the count. Give will always
-- increment the count.

package Asl.Semaphore.Counting is

type Object (Initial_Count : Natural) is
new Asl.Semaphore.Object with private;
type Object_Ptr is access all Object;

-- Claim the semaphore. Will block until the semaphore is available.
procedure Take (O : in out Object);

-- Release the semaphore.
procedure Give (O : in out Object);

-- Try to take the semaphore, but return an error if not successful.
-- Returns True if the semaphore was claimed and False if not. This
-- will wait up to Timeout time for the semaphore to become available.
procedure Try_To_Take (O : in out Object;
Success : out Boolean;
Timeout : in Duration := 0.0);

private

protected type Mutex (Initial_Count : Natural) is
entry Wait;
procedure Release;
private
Count : Natural := Initial_Count;
end Mutex;

type Object (Initial_Count : Natural) is
new Asl.Semaphore.Object with record
The_Mutex : Mutex(Initial_Count);
end record;

end Asl.Semaphore.Counting;
4 changes: 2 additions & 2 deletions agpl-chronos.adb
Expand Up @@ -41,9 +41,9 @@ package body Agpl.Chronos is
------------------------------------------------------------------------
-- Reset --
------------------------------------------------------------------------
procedure Reset (This : in out Object) is
procedure Reset (This : in out Object; Elapsed : Duration := 0.0) is
begin
This.Start := Ada.Calendar.Clock;
This.Start := Ada.Calendar.Clock - Elapsed;
end Reset;

------------------------------------------------------------------------
Expand Down
2 changes: 1 addition & 1 deletion agpl-chronos.ads
Expand Up @@ -45,7 +45,7 @@ package Agpl.Chronos is
------------------------------------------------------------------------
-- Reset --
------------------------------------------------------------------------
procedure Reset (This : in out Object);
procedure Reset (This : in out Object; Elapsed : Duration := 0.0);
pragma Inline (Reset);

------------------------------------------------------------------------
Expand Down

0 comments on commit b7130bd

Please sign in to comment.