next up previous
Next: A.18 vc-go.setl Up: A. WEBeye Source Code Previous: A.16 vc-getname.setl

  
A.17 vc-giver.setl

Service provided:
giver

Called by parent program:
vc-toplev.setl     (Section A.42 [vc-toplev.setl])

Textually #includes:
vc-exit.setl     (Section A.15 [vc-exit.setl])
vc-getname.setl     (Section A.16 [vc-getname.setl])
vc-msg.setl     (Section A.30 [vc-msg.setl])
vc-obtain.setl     (Section A.31 [vc-obtain.setl])
vc-provide.setl     (Section A.32 [vc-provide.setl])

Source code: *

const yhwh = `vc-giver.setl';
 
-- This makes up and gives out a stream of URLs for a stream of
-- JPEGs.  It should go away when when the more civilized Java API
-- (1.2) is widely available.
 
const sigterm_fd = open (`SIGTERM', `signal');  -- catch TERM signals
const giver_fd = fileno provide_service (`giver');
 
var clients := {};
 
loop
 
  [ready] := select ([{sigterm_fdgiver_fd} + domain clients]);
 
  if sigterm_fd in ready then
    msg (yhwh + ` (' + str pid + `) caught SIGTERM');
    quit_gracefully;
  end if;
 
  for client = clients(pump_fd) | pump_fd in ready loop
    done_client (pump_fd);
  end loop;
 
  if giver_fd in ready then
    fd := accept (giver_fd);
    if fd /= om then
      name := getname fd;
      msg (name+` accepted');
      pump_fd := pump();
      if pump_fd = -1 then
        -- child
        [serv_nameserv_port] := find_service (`snap');
        serv_name(`localhost') := hostaddr;  -- for public consumption
        pfx := `http://'+serv_name+`:'+str serv_port+`/?seq=';
        i := 0;
        while (line := getline fd/= om and
              split (line) = [`JPEG'] loop
          i +:= 1;
          name := str i;
          printa (fdpfx+name);
        end loop;
        stop;
      end if;
      close (fd);  -- child hangs onto this
      client := {};
      client.name := name;
      clients(pump_fd) := client;
    end if;
  end if;
 
end loop;
 
proc done_client (pump_fd);
  msg (clients(pump_fd).name + ` done');
  close (pump_fd);
  clients(pump_fd) := om;
end proc done_client;
 
proc quit_gracefully;
  exit_gracefully ([[`pump for client ' + client.namepump_fd] :
                                          client = clients(pump_fd)]);
end proc;
 
#include ``vc-provide.setl''
#include ``vc-obtain.setl''
#include ``vc-getname.setl''
#include ``vc-exit.setl''
#include ``vc-msg.setl''


next up previous
Next: A.18 vc-go.setl Up: A. WEBeye Source Code Previous: A.16 vc-getname.setl
David Bacon
1999-12-10