kc3-lang/kc3/test/socket/facts.kc3

Branch - branch -marshallmasterpdfv0.1- tag -v0.1.9v0.1.8v0.1.7v0.1.6v0.1.5v0.1.4v0.1.3v0.1.2v0.1.15v0.1.14v0.1.13v0.1.12v0.1.11v0.1.10v0.1.1v0.1.0v0HTTPd-v0.2.0HTTPd-v0.1.1HTTPd-v0.1.0v0.1.16

• Show log

  Commit

• Hash : ca63728c
  Author : Thomas de Grivel
  Date : 2026-01-05T16:54:26
  

  give more time to socket tests
  

Download

• test/socket/facts.kc3

• require Facts
  require File
  require Socket
  require Socket.Buf
  require Socket.Facts
  
  (r = fork()) ; void
  if (r < 0) do
    exit(1)
  end
  if r == 0 do
    server_facts = Facts.database()
    if File.exists?("server_test.facts") do
      File.unlink("server_test.facts")
    end
    Facts.open(server_facts, "server_test.facts")
    puts("server: listening on 15002")
    server = Socket.listen("localhost", "15002")
    if server.fd < 0 do
      puts("server: listen failed")
      exit_subprocess(1)
    end
    puts("server: waiting for connection")
    if ! Socket.Facts.accept(server_facts, server) do
      puts("server: accept failed")
      exit_subprocess(1)
    end
    Socket.close(server)
    puts("server: accepted connection, waiting for facts")
    sleep(2)
    puts("server: adding server fact")
    Facts.add_tags(server_facts, :server, :says, :hello)
    sleep(4)
    Facts.with_tags(server_facts, ?, ?, ?, fn (fact) {
      puts("server: received #{inspect(fact)}")
    })
    puts("server: OK")
    Socket.Facts.close(server_facts)
    Facts.delete(server_facts)
    File.unlink("server_test.facts")
    exit_subprocess(0)
  else
    sleep(1)
    client_facts = Facts.database()
    if File.exists?("client_test.facts") do
      File.unlink("client_test.facts")
    end
    Facts.open(client_facts, "client_test.facts")
    puts("client: connecting to 15002")
    if ! Socket.Facts.open(client_facts, "localhost", "15002") do
      puts("client: open failed")
      exit(1)
    end
    sleep(1)
    puts("client: adding fact")
    Facts.add_tags(client_facts, :a, :b, :c)
    sleep(4)
    puts("client: checking for server facts")
    Facts.with_tags(client_facts, ?, ?, ?, fn (fact) {
      puts("client: has #{inspect(fact)}")
    })
    Socket.Facts.close(client_facts)
    Facts.delete(client_facts)
    File.unlink("client_test.facts")
    puts("client: OK")
    wait()
  end
  0
  

Download