Blame frx/frx_fileinput.ml
|
Packit |
bd2e5d |
(***********************************************************************)
|
|
Packit |
bd2e5d |
(* *)
|
|
Packit |
bd2e5d |
(* MLTk, Tcl/Tk interface of OCaml *)
|
|
Packit |
bd2e5d |
(* *)
|
|
Packit |
bd2e5d |
(* Francois Rouaix, Francois Pessaux, Jun Furuse and Pierre Weis *)
|
|
Packit |
bd2e5d |
(* projet Cristal, INRIA Rocquencourt *)
|
|
Packit |
bd2e5d |
(* Jacques Garrigue, Kyoto University RIMS *)
|
|
Packit |
bd2e5d |
(* *)
|
|
Packit |
bd2e5d |
(* Copyright 2002 Institut National de Recherche en Informatique et *)
|
|
Packit |
bd2e5d |
(* en Automatique and Kyoto University. All rights reserved. *)
|
|
Packit |
bd2e5d |
(* This file is distributed under the terms of the GNU Library *)
|
|
Packit |
bd2e5d |
(* General Public License, with the special exception on linking *)
|
|
Packit |
bd2e5d |
(* described in file LICENSE found in the OCaml source tree. *)
|
|
Packit |
bd2e5d |
(* *)
|
|
Packit |
bd2e5d |
(***********************************************************************)
|
|
Packit |
bd2e5d |
open Camltk
|
|
Packit |
bd2e5d |
|
|
Packit |
bd2e5d |
let version = "$Id$"
|
|
Packit |
bd2e5d |
|
|
Packit |
bd2e5d |
(*
|
|
Packit |
bd2e5d |
* Simple spooling for fileinput callbacks
|
|
Packit |
bd2e5d |
*)
|
|
Packit |
bd2e5d |
|
|
Packit |
bd2e5d |
let waiting_list = Queue. new()
|
|
Packit |
bd2e5d |
and waiting = ref 0
|
|
Packit |
bd2e5d |
and max_open = ref 10
|
|
Packit |
bd2e5d |
and cur_open = ref 0
|
|
Packit |
bd2e5d |
|
|
Packit |
bd2e5d |
let add fd f =
|
|
Packit |
bd2e5d |
if !cur_open < !max_open then begin
|
|
Packit |
bd2e5d |
incr cur_open;
|
|
Packit |
bd2e5d |
add_fileinput fd f
|
|
Packit |
bd2e5d |
end
|
|
Packit |
bd2e5d |
else begin
|
|
Packit |
bd2e5d |
incr waiting;
|
|
Packit |
bd2e5d |
Queue.add (fd,f) waiting_list
|
|
Packit |
bd2e5d |
end
|
|
Packit |
bd2e5d |
|
|
Packit |
bd2e5d |
let remove fd =
|