summary refs log tree commit diff stats
path: root/nimdoc
diff options
context:
space:
mode:
authorringabout <43030857+ringabout@users.noreply.github.com>2023-02-19 14:49:19 +0800
committerGitHub <noreply@github.com>2023-02-19 14:49:19 +0800
commite896977bd16b2471e4aaaa363690622420e99acc (patch)
tree9c790befa78f8ce56f02f0d81282422b21539c3e /nimdoc
parent6b93db7070c984121e18b502d938d5e455d4ba70 (diff)
downloadNim-e896977bd16b2471e4aaaa363690622420e99acc.tar.gz
closes #1072; add a test case (#21396)
Diffstat (limited to 'nimdoc')
0 files changed, 0 insertions, 0 deletions
&id=c57fcf42df4206229de10c8ed0463fe94517bd4b'>^
5b55aa52d ^
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()