File: cleanup_lin.ml

package info (click to toggle)
ocaml-multicoretests 0.9-1
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 1,532 kB
  • sloc: ml: 8,904; awk: 66; ansic: 23; makefile: 11; sh: 1
file content (84 lines) | stat: -rw-r--r-- 2,040 bytes parent folder | download | duplicates (2)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
open QCheck

(** This is a variant of refs to test for exactly one cleanup per init
    (no double cleanup, no missing cleanup) *)

let cleanup_counter = Atomic.make 0

module RConf =
struct
  exception Already_cleaned
  type status = Inited | Cleaned

  type cmd = Get | Set of int | Add of int

  let pp_cmd par fmt x =
    let open Util.Pp in
    match x with
    | Get -> cst0 "Get" fmt
    | Set x -> cst1 pp_int "Set" par fmt x
    | Add x -> cst1 pp_int "Add" par fmt x

  let show_cmd = Util.Pp.to_show pp_cmd

  type t = (status ref) * (int ref)

  let gen_cmd =
    let int_gen = Gen.nat in
      (Gen.oneof
         [Gen.return Get;
	  Gen.map (fun i -> Set i) int_gen;
	  Gen.map (fun i -> Add i) int_gen;
         ])

  let shrink_cmd = Shrink.nil

  let init () =
    Atomic.incr cleanup_counter ;
    (ref Inited, ref 0)

  let cleanup (status,_) =
    Atomic.decr cleanup_counter ;
    if !status = Cleaned
    then raise Already_cleaned
    else status := Cleaned

  type res = RGet of int | RSet | RAdd

  let pp_res par fmt x =
    let open Util.Pp in
    match x with
    | RGet x -> cst1 pp_int "RGet" par fmt x
    | RSet -> cst0 "RSet" fmt
    | RAdd -> cst0 "RAdd" fmt

  let show_res = Util.Pp.to_show pp_res

  let equal_res x y =
    let open Util.Equal in
    match (x, y) with
    | RGet x, RGet y -> equal_int x y
    | RSet, RSet -> true
    | RAdd, RAdd -> true
    | _, _ -> false

  let run c (_,r) = match c with
    | Get   -> RGet (!r)
    | Set i -> (r:=i; RSet)
    | Add i -> (let old = !r in r := i + old; RAdd) (* buggy: not atomic *)
end

module RT = Lin_domain.Make_internal(RConf) [@alert "-internal"]
;;
Test.check_exn
  (let seq_len,par_len = 20,15 in
   Test.make ~count:1000 ~name:("exactly one-cleanup test")
     (RT.arb_cmds_triple seq_len par_len)
     (fun input ->
        try
          ignore (RT.lin_prop input);
          Atomic.get cleanup_counter = 0
        with
        | RConf.Already_cleaned -> failwith "Already cleaned"
        | _ -> Atomic.get cleanup_counter = 0
     ))