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 =