basis/io/servers/connection/connection-tests.factor

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