basis/io/servers/servers-tests.factor

   1 USING: accessors calendar concurrency.promises fry io
   2 io.encodings.ascii io.servers
   3 io.servers.private io.sockets kernel namespaces
   4 sequences threads tools.test ;
   5 IN: io.servers
   6
   7 [ t ] [ ascii <threaded-server> listen-on empty? ] unit-test
   8
   9 [ f ] [
  10     ascii <threaded-server>
  11         25 internet-server >>insecure
  12     listen-on
  13     empty?
  14 ] unit-test
  15
  16 [ t ] [
  17     T{ inet4 f "1.2.3.4" 1234 } T{ inet4 f "1.2.3.5" 1235 }
  18     [ log-connection ] 2keep
  19     [ remote-address get = ] [ local-address get = ] bi*
  20     and
  21 ] unit-test
  22
  23 [ ] [ ascii <threaded-server> init-server drop ] unit-test
  24
  25 [ 10 ] [
  26     ascii <threaded-server>
  27         10 >>max-connections
  28     init-server semaphore>> count>>
  29 ] unit-test
  30
  31 [ "Hello world." ] [
  32     ascii <threaded-server>
  33         5 >>max-connections
  34         0 >>insecure
  35         [ "Hello world." write stop-this-server ] >>handler
  36     [
  37         insecure-addr ascii <client> drop stream-contents
  38     ] with-threaded-server
  39 ] unit-test
  40
  41 [ ] [
  42     ascii <threaded-server>
  43         5 >>max-connections
  44         0 >>insecure
  45     start-server [ '[ _ wait-for-server ] in-thread ] [ stop-server ] bi
  46 ] unit-test