blob: 61b633a93dd42cd15ad68886a7017135b6a96ec4 (
plain) (
blame)
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
|
import nativesockets
import net
import os
when defined(posix):
import posix
type ServerSocket* = object
sock*: Socket
path*: string
var SocketDirectory* = "/tmp/cha"
const SocketPathPrefix = "cha_sock_"
proc getSocketPath*(pid: Pid): string =
SocketDirectory / SocketPathPrefix & $pid
proc initServerSocket*(buffered = true, blocking = true): ServerSocket =
createDir(SocketDirectory)
result.sock = newSocket(Domain.AF_UNIX, SockType.SOCK_STREAM, Protocol.IPPROTO_IP, buffered)
if not blocking:
result.sock.getFd().setBlocking(false)
result.path = getSocketPath(getpid())
discard unlink(cstring(result.path))
bindUnix(result.sock, result.path)
listen(result.sock)
proc close*(ssock: ServerSocket) =
close(ssock.sock)
discard unlink(cstring(ssock.path))
|