summary refs log tree commit diff stats
path: root/test/testdir/largefile.txt
diff options
context:
space:
mode:
authorhut <hut@lavabit.com>2010-04-28 14:49:26 +0200
committerhut <hut@lavabit.com>2010-04-28 14:49:26 +0200
commitccb56d06a555efee9490f60029e50d9c060ec176 (patch)
treedb176f92d57600bcd942f0dca669c1be0a8888dc /test/testdir/largefile.txt
parent03ef4f4c9a23026f6ce7b0a30117b6a9cacba4de (diff)
downloadranger-ccb56d06a555efee9490f60029e50d9c060ec176.tar.gz
widgets.console: added macro %d
Diffstat (limited to 'test/testdir/largefile.txt')
0 files changed, 0 insertions, 0 deletions
im/blame/tests/async/tacceptcloserace.nim?h=devel&id=182d3c16e3b7aac9ed3575dec55e6d9a3d5042c4'>^
fb8168d33 ^


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36




             




                                                               
                               

                               


















                                                                     
                                    


                                       
discard """
  exitcode: 0
  output: ""
"""

import asyncdispatch, net, os, nativesockets

# bug: https://github.com/nim-lang/Nim/issues/5279

proc setupServerSocket(hostname: string, port: Port): AsyncFD =
  let fd = createNativeSocket()
  if fd == osInvalidSocket:
    raiseOSError(osLastError())
  setSockOptInt(fd, SOL_SOCKET, SO_REUSEADDR, 1)
  var aiList = getAddrInfo(hostname, port)
  if bindAddr(fd, aiList.ai_addr, aiList.ai_addrlen.Socklen) < 0'i32:
    freeAddrInfo(aiList)
    raiseOSError(osLastError())
  freeAddrInfo(aiList)
  if listen(fd) != 0:
    raiseOSError(osLastError())
  setBlocking(fd, false)
  result = fd.AsyncFD
  register(result)

const port = Port(5614)
for i in 0..100:
  let serverFd = setupServerSocket("localhost", port)
  serverFd.accept().callback = proc(fut: Future[AsyncFD]) =
    if not fut.failed:
      fut.read().closeSocket()

  var fd = createAsyncNativeSocket()
  waitFor fd.connect("localhost", port)
  serverFd.closeSocket()
  fd.closeSocket()