Commits

Anonymous committed b5ec2ad

Updated for testing Cf-0.7 sources.

  • Participants
  • Parent commits b2d73bb

Comments (0)

Files changed (1)

File cf/t/t_cf.ml

 
     let rparen = Cf_parser.alt [
         ?. ')';
-        Cf_parser.err (fun _ -> failwith "Expected ')'");
+        Cf_parser.err ~f:(fun _ -> failwith "Expected ')'") ();
     ]
     
     let number = Cf_parser.alt [
             let b = new Cf_tcp6_socket.endpoint (active#socket) in
             a#setsockopt Cf_ip_common.tcp_nodelay true;
             b#setsockopt Cf_ip_common.tcp_nodelay true;
+            a#setsockopt Cf_socket.so_sndlowat 1;
+            b#setsockopt Cf_socket.so_sndlowat 1;
             let laddr = a#getpeername and raddr = b#getsockname in
             let lhost, lport, lscope = laddr in
             let rhost, rport, rscope = raddr in
     
     class clock n dt =
         object
-            inherit [unit] time Cf_tai64n.last as super
+            inherit [unit Cf_poll.state_t] time Cf_tai64n.last as super
             
             val mutable count_: int = n
             
                 epoch_ <- Cf_tai64n.add (Cf_tai64n.now ()) dt;
                 super#load_ p
             
-            method private service_ p =
+            method private service p =
                 if count_ > 0 then begin
                     count_ <- pred count_;
                     epoch_ <- Cf_tai64n.add epoch_ dt;
     
     class interrupt n dt =
         object(self:'self)
-            inherit [int] signal Sys.sigint as super
+            inherit [int Cf_poll.state_t] signal Sys.sigint as super
 
             val clock_ = new clock n dt
             
                 super#unload_ p;
                 clock_#unload
             
-            method private service_ p =
+            method private service p =
                 clock_#unload;
                 `Final clock_#count