#lang racket/base

(require (prefix-in log: (planet synx/log:1))
          (prefix-in finalize: (planet synx/util:2/finalize)))

(define max-files (make-semaphore 1008))

(define (safe-open-input-file i name)
   (semaphore-wait max-files)
   (log:info "open ~s" i)
   (finalize:register
    (open-input-file name)
    (λ (v)
      (log:info "close ~s" i)
      (close-input-port v)
      (semaphore-post max-files))))

(define (execute-hack)
   (thread (λ () (let loop () (sleep 1) (collect-garbage) (loop)))))

(define (sploof-one-file i)
   (define f (safe-open-input-file i "/dev/zero"))
   (log:info "~s ~s" i (read-bytes 4 f))
   (log:info "Done with ~s" i))

(define (main)
   (execute-hack)
   (for-each
    sync/enable-break
    (map
     thread-dead-evt
     (for/list ((i (in-range 8192))) (thread (λ () (sploof-one-file i)))))))

(provide main)