diff --git a/bootstrap.sh b/bootstrap.sh
index ade74a9aa4..7f19c24406 100755
--- a/bootstrap.sh
+++ b/bootstrap.sh
@@ -12,8 +12,11 @@ cd ".."
./bin/nim c koch
./koch boot -d:release
+./koch geninstall
-cp -f install.sh.template install.sh
-chmod +x install.sh
+set +x
+
+echo
+echo 'Install Nim using "./install.sh
" or "sudo ./install.sh ".'
exit 0
diff --git a/compiler/ccgexprs.nim b/compiler/ccgexprs.nim
index 32fc76470b..6d69dafa55 100644
--- a/compiler/ccgexprs.nim
+++ b/compiler/ccgexprs.nim
@@ -747,6 +747,17 @@ proc genTupleElem(p: BProc, e: PNode, d: var TLoc) =
addf(r, ".Field$1", [rope(i)])
putIntoDest(p, d, ty.sons[i], r, a.s)
+proc lookupFieldAgain(p: BProc, ty: PType; field: PSym; r: var Rope): PSym =
+ var ty = ty
+ assert r != nil
+ while ty != nil:
+ assert(ty.kind in {tyTuple, tyObject})
+ result = lookupInRecord(ty.n, field.name)
+ if result != nil: break
+ if not p.module.compileToCpp: add(r, ".Sup")
+ ty = getUniqueType(ty.sons[0])
+ if result == nil: internalError(field.info, "genCheckedRecordField")
+
proc genRecordField(p: BProc, e: PNode, d: var TLoc) =
var a: TLoc
var ty = genRecordFieldAux(p, e, d, a)
@@ -758,15 +769,7 @@ proc genRecordField(p: BProc, e: PNode, d: var TLoc) =
addf(r, ".Field$1", [rope(f.position)])
putIntoDest(p, d, f.typ, r, a.s)
else:
- var field: PSym = nil
- while ty != nil:
- if ty.kind notin {tyTuple, tyObject}:
- internalError(e.info, "genRecordField")
- field = lookupInRecord(ty.n, f.name)
- if field != nil: break
- if not p.module.compileToCpp: add(r, ".Sup")
- ty = getUniqueType(ty.sons[0])
- if field == nil: internalError(e.info, "genRecordField 2 ")
+ let field = lookupFieldAgain(p, ty, f, r)
if field.loc.r == nil: internalError(e.info, "genRecordField 3")
addf(r, ".$1", [field.loc.r])
putIntoDest(p, d, field.typ, r, a.s)
@@ -774,7 +777,8 @@ proc genRecordField(p: BProc, e: PNode, d: var TLoc) =
proc genInExprAux(p: BProc, e: PNode, a, b, d: var TLoc)
-proc genFieldCheck(p: BProc, e: PNode, obj: Rope, field: PSym) =
+proc genFieldCheck(p: BProc, e: PNode, obj: Rope, field: PSym;
+ origTy: PType) =
var test, u, v: TLoc
for i in countup(1, sonsLen(e) - 1):
var it = e.sons[i]
@@ -786,8 +790,12 @@ proc genFieldCheck(p: BProc, e: PNode, obj: Rope, field: PSym) =
assert(disc.kind == nkSym)
initLoc(test, locNone, it.typ, OnStack)
initLocExpr(p, it.sons[1], u)
- initLoc(v, locExpr, disc.typ, OnUnknown)
- v.r = "$1.$2" % [obj, disc.sym.loc.r]
+ var o = obj
+ let d = lookupFieldAgain(p, origTy, disc.sym, o)
+ initLoc(v, locExpr, d.typ, OnUnknown)
+ v.r = o
+ v.r.add(".")
+ v.r.add(d.loc.r)
genInExprAux(p, it, u, v, test)
let id = nodeTableTestOrSet(p.module.dataCache,
newStrNode(nkStrLit, field.name.s), gBackendId)
@@ -804,25 +812,14 @@ proc genFieldCheck(p: BProc, e: PNode, obj: Rope, field: PSym) =
proc genCheckedRecordField(p: BProc, e: PNode, d: var TLoc) =
if optFieldCheck in p.options:
- var
- a: TLoc
- f, field: PSym
- ty: PType
- r: Rope
- ty = genRecordFieldAux(p, e.sons[0], d, a)
- r = rdLoc(a)
- f = e.sons[0].sons[1].sym
- field = nil
- while ty != nil:
- assert(ty.kind in {tyTuple, tyObject})
- field = lookupInRecord(ty.n, f.name)
- if field != nil: break
- if not p.module.compileToCpp: add(r, ".Sup")
- ty = getUniqueType(ty.sons[0])
- if field == nil: internalError(e.info, "genCheckedRecordField")
+ var a: TLoc
+ let ty = genRecordFieldAux(p, e.sons[0], d, a)
+ var r = rdLoc(a)
+ let f = e.sons[0].sons[1].sym
+ let field = lookupFieldAgain(p, ty, f, r)
if field.loc.r == nil:
internalError(e.info, "genCheckedRecordField") # generate the checks:
- genFieldCheck(p, e, r, field)
+ genFieldCheck(p, e, r, field, ty)
add(r, rfmt(nil, ".$1", field.loc.r))
putIntoDest(p, d, field.typ, r, a.s)
else:
@@ -1150,20 +1147,15 @@ proc genObjConstr(p: BProc, e: PNode, d: var TLoc) =
else:
constructLoc(p, tmp)
discard getTypeDesc(p.module, t)
+ let ty = getUniqueType(t)
for i in 1 .. `_
This module implements helpers for SCGI applications.
-* `sockets `_
- This module implements a simple portable type-safe sockets layer.
-
-* `asyncio `_
- This module implements an asynchronous event loop for sockets.
-
* `browsers `_
This module implements procs for opening URLs with the user's default
browser.
@@ -220,9 +214,6 @@ Internet Protocols and Support
* `smtp `_
This module implement a simple SMTP client.
-* `ftpclient `_
- This module implements an FTP client.
-
* `cookies `_
This module contains helper procs for parsing and generating cookies.
@@ -253,7 +244,7 @@ Internet Protocols and Support
This module implements a high-level sockets API. It will replace the
``sockets`` module in the future.
-* `rawsockets `_
+* `nativesockets `_
This module implements a low-level sockets API.
* `selectors `_
@@ -265,8 +256,6 @@ Parsers
* `parseopt `_
The ``parseopt`` module implements a command line option parser.
- **Deprecated since version 0.9.3:** Use the `parseopt2
- `_ module instead.
* `parseopt2 `_
The ``parseopt2`` module implements a command line option parser. This
@@ -397,6 +386,31 @@ Modules for JS backend
Declaration of the Document Object Model for the JS backend.
+Deprecated modules
+------------------
+
+* `asyncio `_
+ This module implements an asynchronous event loop for sockets.
+ **Deprecated since version 0.11.2:**
+ Use the `asyncnet `_ together with the
+ `asyncdispatch `_ module instead.
+
+* `ftpclient `_
+ This module implements an FTP client.
+ **Deprecated since version 0.11.3:**
+ Use the `asyncftpclient `_ module instead.
+
+* `sockets `_
+ This module implements a simple portable type-safe sockets layer.
+ **Deprecated since version 0.11.2:**
+ Use the `net `_ or the `rawsockets `_ module
+ instead.
+
+* `rawsockets `_
+ **Deprecated since version 0.11.4:**
+ This module has been renamed to `nativesockets `_.
+
+
Impure libraries
================
diff --git a/doc/manual/types.txt b/doc/manual/types.txt
index c9ac6f0628..babf3286f2 100644
--- a/doc/manual/types.txt
+++ b/doc/manual/types.txt
@@ -490,6 +490,11 @@ to an open array parameter.
The openarray type cannot be nested: multidimensional openarrays are not
supported because this is seldom needed and cannot be done efficiently.
+.. code-block:: nim
+ proc testOpenArray(x: openArray[int]) = echo repr(x)
+
+ testOpenArray([1,2,3]) # array[]
+ testOpenArray(@[1,2,3]) # seq[]
Varargs
-------
diff --git a/install.sh.template b/install.sh.template
deleted file mode 100644
index 1292abdab5..0000000000
--- a/install.sh.template
+++ /dev/null
@@ -1,9 +0,0 @@
-#!/bin/sh
-set -e
-set -x
-
-if [ "$1" != "" ]; then
- exec ./koch install "$1"
-else
- exec ./koch install
-fi
diff --git a/koch.nim b/koch.nim
index 8992271bfd..3d1a22b9cc 100644
--- a/koch.nim
+++ b/koch.nim
@@ -41,6 +41,7 @@ Options:
Possible Commands:
boot [options] bootstraps with given command line options
install [bindir] installs to given directory; Unix only!
+ geninstall generate ./install.sh; Unix only!
clean cleans Nim project; removes generated files
web [options] generates the website and the full documentation
website [options] generates only the website
@@ -127,9 +128,12 @@ proc nsis(args: string) =
exec(("tools" / "niminst" / "niminst --var:version=$# --var:mingw=mingw$#" &
" nsis compiler/installer.ini") % [VersionAsString, $(sizeof(pointer)*8)])
+proc geninstall(args="") =
+ exec("$# cc -r $# --var:version=$# --var:mingw=none --main:compiler/nim.nim scripts compiler/installer.ini $#" %
+ [findNim(), compileNimInst, VersionAsString, args])
+
proc install(args: string) =
- exec("$# cc -r $# --var:version=$# --var:mingw=none --main:compiler/nim.nim scripts compiler/installer.ini" %
- [findNim(), compileNimInst, VersionAsString])
+ geninstall()
exec("sh ./install.sh $#" % args)
proc web(args: string) =
@@ -373,6 +377,7 @@ of cmdArgument:
of "zip": zip(op.cmdLineRest)
of "xz": xz(op.cmdLineRest)
of "nsis": nsis(op.cmdLineRest)
+ of "geninstall": geninstall(op.cmdLineRest)
of "install": install(op.cmdLineRest)
of "test", "tests": tests(op.cmdLineRest)
of "update":
diff --git a/lib/core/unsigned.nim b/lib/deprecated/core/unsigned.nim
similarity index 100%
rename from lib/core/unsigned.nim
rename to lib/deprecated/core/unsigned.nim
diff --git a/lib/pure/actors.nim b/lib/deprecated/pure/actors.nim
similarity index 100%
rename from lib/pure/actors.nim
rename to lib/deprecated/pure/actors.nim
diff --git a/lib/pure/actors.nim.cfg b/lib/deprecated/pure/actors.nim.cfg
similarity index 100%
rename from lib/pure/actors.nim.cfg
rename to lib/deprecated/pure/actors.nim.cfg
diff --git a/lib/pure/asyncio.nim b/lib/deprecated/pure/asyncio.nim
similarity index 100%
rename from lib/pure/asyncio.nim
rename to lib/deprecated/pure/asyncio.nim
diff --git a/lib/pure/ftpclient.nim b/lib/deprecated/pure/ftpclient.nim
similarity index 99%
rename from lib/pure/ftpclient.nim
rename to lib/deprecated/pure/ftpclient.nim
index 229fe4b511..1188c0795f 100644
--- a/lib/pure/ftpclient.nim
+++ b/lib/deprecated/pure/ftpclient.nim
@@ -11,7 +11,7 @@ include "system/inclrtl"
import sockets, strutils, parseutils, times, os, asyncio
from asyncnet import nil
-from rawsockets import nil
+from nativesockets import nil
from asyncdispatch import PFuture
## **Note**: This module is deprecated since version 0.11.3.
## You should use the async version of this module
@@ -55,7 +55,7 @@ type
user*, pass*: string
address*: string
when SockType is asyncnet.AsyncSocket:
- port*: rawsockets.Port
+ port*: nativesockets.Port
else:
port*: Port
diff --git a/lib/pure/parseopt.nim b/lib/deprecated/pure/parseopt.nim
similarity index 100%
rename from lib/pure/parseopt.nim
rename to lib/deprecated/pure/parseopt.nim
diff --git a/lib/pure/parseurl.nim b/lib/deprecated/pure/parseurl.nim
similarity index 100%
rename from lib/pure/parseurl.nim
rename to lib/deprecated/pure/parseurl.nim
diff --git a/lib/deprecated/pure/rawsockets.nim b/lib/deprecated/pure/rawsockets.nim
new file mode 100644
index 0000000000..ee77b232e5
--- /dev/null
+++ b/lib/deprecated/pure/rawsockets.nim
@@ -0,0 +1,14 @@
+import nativesockets
+export nativesockets
+
+{.warning: "rawsockets module is deprecated, use nativesockets instead".}
+
+template newRawSocket*(domain, sockType, protocol: cint): expr =
+ {.warning: "newRawSocket is deprecated, use newNativeSocket instead".}
+ newNativeSocket(domain, sockType, protocol)
+
+template newRawSocket*(domain: Domain = AF_INET,
+ sockType: SockType = SOCK_STREAM,
+ protocol: Protocol = IPPROTO_TCP): expr =
+ {.warning: "newRawSocket is deprecated, use newNativeSocket instead".}
+ newNativeSocket(domain, sockType, protocol)
diff --git a/lib/pure/sockets.nim b/lib/deprecated/pure/sockets.nim
similarity index 99%
rename from lib/pure/sockets.nim
rename to lib/deprecated/pure/sockets.nim
index 8fa69256be..5d6fa00787 100644
--- a/lib/pure/sockets.nim
+++ b/lib/deprecated/pure/sockets.nim
@@ -9,7 +9,7 @@
## **Warning:** Since version 0.10.2 this module is deprecated.
## Use the `net `_ or the
-## `rawsockets `_ module instead.
+## `nativesockets `_ module instead.
##
## This module implements portable sockets, it supports a mix of different types
## of sockets. Sockets are buffered by default meaning that data will be
diff --git a/lib/pure/asyncdispatch.nim b/lib/pure/asyncdispatch.nim
index 110bc6d741..7bba6bd898 100644
--- a/lib/pure/asyncdispatch.nim
+++ b/lib/pure/asyncdispatch.nim
@@ -11,7 +11,7 @@ include "system/inclrtl"
import os, oids, tables, strutils, macros, times
-import rawsockets, net
+import nativesockets, net
export Port, SocketFlag
@@ -475,7 +475,7 @@ when defined(windows) or defined(nimdoc):
addr bytesRet, nil, nil) == 0
proc initAll() =
- let dummySock = newRawSocket()
+ let dummySock = newNativeSocket()
if not initPointer(dummySock, connectExPtr, WSAID_CONNECTEX):
raiseOSError(osLastError())
if not initPointer(dummySock, acceptExPtr, WSAID_ACCEPTEX):
@@ -528,7 +528,7 @@ when defined(windows) or defined(nimdoc):
RemoteSockaddr, RemoteSockaddrLength)
proc connect*(socket: AsyncFD, address: string, port: Port,
- domain = rawsockets.AF_INET): Future[void] =
+ domain = nativesockets.AF_INET): Future[void] =
## Connects ``socket`` to server at ``address:port``.
##
## Returns a ``Future`` which will complete when the connection succeeds
@@ -827,7 +827,7 @@ when defined(windows) or defined(nimdoc):
verifyPresence(socket)
var retFuture = newFuture[tuple[address: string, client: AsyncFD]]("acceptAddr")
- var clientSock = newRawSocket()
+ var clientSock = newNativeSocket()
if clientSock == osInvalidSocket: raiseOSError(osLastError())
const lpOutputLen = 1024
@@ -900,17 +900,17 @@ when defined(windows) or defined(nimdoc):
return retFuture
- proc newAsyncRawSocket*(domain, sockType, protocol: cint): AsyncFD =
+ proc newAsyncNativeSocket*(domain, sockType, protocol: cint): AsyncFD =
## Creates a new socket and registers it with the dispatcher implicitly.
- result = newRawSocket(domain, sockType, protocol).AsyncFD
+ result = newNativeSocket(domain, sockType, protocol).AsyncFD
result.SocketHandle.setBlocking(false)
register(result)
- proc newAsyncRawSocket*(domain: Domain = rawsockets.AF_INET,
- sockType: SockType = SOCK_STREAM,
- protocol: Protocol = IPPROTO_TCP): AsyncFD =
+ proc newAsyncNativeSocket*(domain: Domain = nativesockets.AF_INET,
+ sockType: SockType = SOCK_STREAM,
+ protocol: Protocol = IPPROTO_TCP): AsyncFD =
## Creates a new socket and registers it with the dispatcher implicitly.
- result = newRawSocket(domain, sockType, protocol).AsyncFD
+ result = newNativeSocket(domain, sockType, protocol).AsyncFD
result.SocketHandle.setBlocking(false)
register(result)
@@ -973,18 +973,18 @@ else:
var data = PData(fd: fd, readCBs: @[], writeCBs: @[])
p.selector.register(fd.SocketHandle, {}, data.RootRef)
- proc newAsyncRawSocket*(domain: cint, sockType: cint,
- protocol: cint): AsyncFD =
- result = newRawSocket(domain, sockType, protocol).AsyncFD
+ proc newAsyncNativeSocket*(domain: cint, sockType: cint,
+ protocol: cint): AsyncFD =
+ result = newNativeSocket(domain, sockType, protocol).AsyncFD
result.SocketHandle.setBlocking(false)
when defined(macosx):
result.SocketHandle.setSockOptInt(SOL_SOCKET, SO_NOSIGPIPE, 1)
register(result)
- proc newAsyncRawSocket*(domain: Domain = AF_INET,
- sockType: SockType = SOCK_STREAM,
- protocol: Protocol = IPPROTO_TCP): AsyncFD =
- result = newRawSocket(domain, sockType, protocol).AsyncFD
+ proc newAsyncNativeSocket*(domain: Domain = AF_INET,
+ sockType: SockType = SOCK_STREAM,
+ protocol: Protocol = IPPROTO_TCP): AsyncFD =
+ result = newNativeSocket(domain, sockType, protocol).AsyncFD
result.SocketHandle.setBlocking(false)
when defined(macosx):
result.SocketHandle.setSockOptInt(SOL_SOCKET, SO_NOSIGPIPE, 1)
diff --git a/lib/pure/asyncnet.nim b/lib/pure/asyncnet.nim
index d7a8c30945..6b19a48be0 100644
--- a/lib/pure/asyncnet.nim
+++ b/lib/pure/asyncnet.nim
@@ -56,7 +56,7 @@
##
import asyncdispatch
-import rawsockets
+import nativesockets
import net
import os
@@ -112,8 +112,8 @@ proc newAsyncSocket*(domain: Domain = AF_INET, sockType: SockType = SOCK_STREAM,
##
## This procedure will also create a brand new file descriptor for
## this socket.
- result = newAsyncSocket(newAsyncRawSocket(domain, sockType, protocol), domain,
- sockType, protocol, buffered)
+ result = newAsyncSocket(newAsyncNativeSocket(domain, sockType, protocol),
+ domain, sockType, protocol, buffered)
proc newAsyncSocket*(domain, sockType, protocol: cint,
buffered = true): AsyncSocket =
@@ -121,8 +121,9 @@ proc newAsyncSocket*(domain, sockType, protocol: cint,
##
## This procedure will also create a brand new file descriptor for
## this socket.
- result = newAsyncSocket(newAsyncRawSocket(domain, sockType, protocol),
- Domain(domain), SockType(sockType), Protocol(protocol), buffered)
+ result = newAsyncSocket(newAsyncNativeSocket(domain, sockType, protocol),
+ Domain(domain), SockType(sockType),
+ Protocol(protocol), buffered)
when defined(ssl):
proc getSslError(handle: SslPtr, err: cint): cint =
diff --git a/lib/pure/collections/critbits.nim b/lib/pure/collections/critbits.nim
index 424bcdcca7..09b20fd450 100644
--- a/lib/pure/collections/critbits.nim
+++ b/lib/pure/collections/critbits.nim
@@ -123,6 +123,14 @@ proc containsOrIncl*(c: var CritBitTree[void], key: string): bool =
var n = rawInsert(c, key)
result = c.count == oldCount
+proc inc*(c: var CritBitTree[int]; key: string) =
+ ## counts the 'key'.
+ let oldCount = c.count
+ var n = rawInsert(c, key)
+ if c.count == oldCount:
+ # not a new key:
+ inc n.val
+
proc incl*(c: var CritBitTree[void], key: string) =
## includes `key` in `c`.
discard rawInsert(c, key)
diff --git a/lib/pure/httpclient.nim b/lib/pure/httpclient.nim
index 30b838b7e3..a5d4ec1a10 100644
--- a/lib/pure/httpclient.nim
+++ b/lib/pure/httpclient.nim
@@ -81,7 +81,7 @@
import net, strutils, uri, parseutils, strtabs, base64, os, mimetypes, math
import asyncnet, asyncdispatch
-import rawsockets
+import nativesockets
type
Response* = tuple[
@@ -764,10 +764,10 @@ proc newConnection(client: AsyncHttpClient, url: Uri) {.async.} =
let port =
if url.port == "":
if url.scheme.toLower() == "https":
- rawsockets.Port(443)
+ nativesockets.Port(443)
else:
- rawsockets.Port(80)
- else: rawsockets.Port(url.port.parseInt)
+ nativesockets.Port(80)
+ else: nativesockets.Port(url.port.parseInt)
if url.scheme.toLower() == "https":
when defined(ssl):
diff --git a/lib/pure/rawsockets.nim b/lib/pure/nativesockets.nim
similarity index 93%
rename from lib/pure/rawsockets.nim
rename to lib/pure/nativesockets.nim
index 1b62913f1a..c9e067a3e7 100644
--- a/lib/pure/rawsockets.nim
+++ b/lib/pure/nativesockets.nim
@@ -93,8 +93,8 @@ when useWinVersion:
IOC_IN* = int(-2147483648)
FIONBIO* = IOC_IN.int32 or ((sizeof(int32) and IOCPARM_MASK) shl 16) or
(102 shl 8) or 126
- rawAfInet = winlean.AF_INET
- rawAfInet6 = winlean.AF_INET6
+ nativeAfInet = winlean.AF_INET
+ nativeAfInet6 = winlean.AF_INET6
proc ioctlsocket*(s: SocketHandle, cmd: clong,
argptr: ptr clong): cint {.
@@ -102,8 +102,8 @@ when useWinVersion:
else:
let
osInvalidSocket* = posix.INVALID_SOCKET
- rawAfInet = posix.AF_INET
- rawAfInet6 = posix.AF_INET6
+ nativeAfInet = posix.AF_INET
+ nativeAfInet6 = posix.AF_INET6
proc `==`*(a, b: Port): bool {.borrow.}
## ``==`` for ports.
@@ -157,12 +157,14 @@ else:
result = cint(ord(p))
-proc newRawSocket*(domain: Domain = AF_INET, sockType: SockType = SOCK_STREAM,
- protocol: Protocol = IPPROTO_TCP): SocketHandle =
+proc newNativeSocket*(domain: Domain = AF_INET,
+ sockType: SockType = SOCK_STREAM,
+ protocol: Protocol = IPPROTO_TCP): SocketHandle =
## Creates a new socket; returns `InvalidSocket` if an error occurs.
socket(toInt(domain), toInt(sockType), toInt(protocol))
-proc newRawSocket*(domain: cint, sockType: cint, protocol: cint): SocketHandle =
+proc newNativeSocket*(domain: cint, sockType: cint,
+ protocol: cint): SocketHandle =
## Creates a new socket; returns `InvalidSocket` if an error occurs.
##
## Use this overload if one of the enums specified above does
@@ -201,7 +203,9 @@ proc getAddrInfo*(address: string, port: Port, domain: Domain = AF_INET,
hints.ai_family = toInt(domain)
hints.ai_socktype = toInt(sockType)
hints.ai_protocol = toInt(protocol)
- hints.ai_flags = AI_V4MAPPED
+ # https://bugs.freebsd.org/bugzilla/show_bug.cgi?id=198092
+ when not defined(freebsd):
+ hints.ai_flags = AI_V4MAPPED
var gaiResult = getaddrinfo(address, $port, addr(hints), result)
if gaiResult != 0'i32:
when useWinVersion:
@@ -229,17 +233,17 @@ proc ntohs*(x: int16): int16 =
when cpuEndian == bigEndian: result = x
else: result = (x shr 8'i16) or (x shl 8'i16)
-proc htonl*(x: int32): int32 =
+template htonl*(x: int32): expr =
## Converts 32-bit integers from host to network byte order. On machines
## where the host byte order is the same as network byte order, this is
## a no-op; otherwise, it performs a 4-byte swap operation.
- result = rawsockets.ntohl(x)
+ nativesockets.ntohl(x)
-proc htons*(x: int16): int16 =
+template htons*(x: int16): expr =
## Converts 16-bit positive integers from host to network byte order.
## On machines where the host byte order is the same as network byte
## order, this is a no-op; otherwise, it performs a 2-byte swap operation.
- result = rawsockets.ntohs(x)
+ nativesockets.ntohs(x)
proc getServByName*(name, proto: string): Servent {.tags: [ReadIOEffect].} =
## Searches the database from the beginning and finds the first entry for
@@ -280,7 +284,7 @@ proc getHostByAddr*(ip: string): Hostent {.tags: [ReadIOEffect].} =
when useWinVersion:
var s = winlean.gethostbyaddr(addr(myaddr), sizeof(myaddr).cuint,
- cint(rawsockets.AF_INET))
+ cint(AF_INET))
if s == nil: raiseOSError(osLastError())
else:
var s = posix.gethostbyaddr(addr(myaddr), sizeof(myaddr).Socklen,
@@ -330,9 +334,9 @@ proc getSockDomain*(socket: SocketHandle): Domain =
if getsockname(socket, cast[ptr SockAddr](addr(name)),
addr(namelen)) == -1'i32:
raiseOSError(osLastError())
- if name.sa_family == rawAfInet:
+ if name.sa_family == nativeAfInet:
result = AF_INET
- elif name.sa_family == rawAfInet6:
+ elif name.sa_family == nativeAfInet6:
result = AF_INET6
else:
raiseOSError(osLastError(), "unknown socket family in getSockFamily")
@@ -340,9 +344,9 @@ proc getSockDomain*(socket: SocketHandle): Domain =
proc getAddrString*(sockAddr: ptr SockAddr): string =
## return the string representation of address within sockAddr
- if sockAddr.sa_family == rawAfInet:
+ if sockAddr.sa_family == nativeAfInet:
result = $inet_ntoa(cast[ptr Sockaddr_in](sockAddr).sin_addr)
- elif sockAddr.sa_family == rawAfInet6:
+ elif sockAddr.sa_family == nativeAfInet6:
when not useWinVersion:
# TODO: Windows
result = newString(posix.INET6_ADDRSTRLEN)
@@ -368,7 +372,7 @@ proc getSockName*(socket: SocketHandle): Port =
if getsockname(socket, cast[ptr SockAddr](addr(name)),
addr(namelen)) == -1'i32:
raiseOSError(osLastError())
- result = Port(rawsockets.ntohs(name.sin_port))
+ result = Port(nativesockets.ntohs(name.sin_port))
proc getLocalAddr*(socket: SocketHandle, domain: Domain): (string, Port) =
## returns the socket's local address and port number.
@@ -385,7 +389,8 @@ proc getLocalAddr*(socket: SocketHandle, domain: Domain): (string, Port) =
if getsockname(socket, cast[ptr SockAddr](addr(name)),
addr(namelen)) == -1'i32:
raiseOSError(osLastError())
- result = ($inet_ntoa(name.sin_addr), Port(rawsockets.ntohs(name.sin_port)))
+ result = ($inet_ntoa(name.sin_addr),
+ Port(nativesockets.ntohs(name.sin_port)))
of AF_INET6:
var name: Sockaddr_in6
when useWinVersion:
@@ -401,7 +406,7 @@ proc getLocalAddr*(socket: SocketHandle, domain: Domain): (string, Port) =
if inet_ntop(name.sin6_family.cint,
addr name, buf.cstring, sizeof(buf).int32).isNil:
raiseOSError(osLastError())
- result = ($buf, Port(rawsockets.ntohs(name.sin6_port)))
+ result = ($buf, Port(nativesockets.ntohs(name.sin6_port)))
else:
raiseOSError(OSErrorCode(-1), "invalid socket family in getLocalAddr")
@@ -420,7 +425,8 @@ proc getPeerAddr*(socket: SocketHandle, domain: Domain): (string, Port) =
if getpeername(socket, cast[ptr SockAddr](addr(name)),
addr(namelen)) == -1'i32:
raiseOSError(osLastError())
- result = ($inet_ntoa(name.sin_addr), Port(rawsockets.ntohs(name.sin_port)))
+ result = ($inet_ntoa(name.sin_addr),
+ Port(nativesockets.ntohs(name.sin_port)))
of AF_INET6:
var name: Sockaddr_in6
when useWinVersion:
@@ -436,7 +442,7 @@ proc getPeerAddr*(socket: SocketHandle, domain: Domain): (string, Port) =
if inet_ntop(name.sin6_family.cint,
addr name, buf.cstring, sizeof(buf).int32).isNil:
raiseOSError(osLastError())
- result = ($buf, Port(rawsockets.ntohs(name.sin6_port)))
+ result = ($buf, Port(nativesockets.ntohs(name.sin6_port)))
else:
raiseOSError(OSErrorCode(-1), "invalid socket family in getLocalAddr")
diff --git a/lib/pure/net.nim b/lib/pure/net.nim
index 00a6c0c921..d1016011e4 100644
--- a/lib/pure/net.nim
+++ b/lib/pure/net.nim
@@ -10,7 +10,7 @@
## This module implements a high-level cross-platform sockets interface.
{.deadCodeElim: on.}
-import rawsockets, os, strutils, unsigned, parseutils, times
+import nativesockets, os, strutils, unsigned, parseutils, times
export Port, `$`, `==`
const useWinVersion = defined(Windows) or defined(nimdoc)
@@ -145,7 +145,7 @@ proc newSocket*(domain, sockType, protocol: cint, buffered = true): Socket =
## Creates a new socket.
##
## If an error occurs EOS will be raised.
- let fd = newRawSocket(domain, sockType, protocol)
+ let fd = newNativeSocket(domain, sockType, protocol)
if fd == osInvalidSocket:
raiseOSError(osLastError())
result = newSocket(fd, domain.Domain, sockType.SockType, protocol.Protocol,
@@ -156,7 +156,7 @@ proc newSocket*(domain: Domain = AF_INET, sockType: SockType = SOCK_STREAM,
## Creates a new socket.
##
## If an error occurs EOS will be raised.
- let fd = newRawSocket(domain, sockType, protocol)
+ let fd = newNativeSocket(domain, sockType, protocol)
if fd == osInvalidSocket:
raiseOSError(osLastError())
result = newSocket(fd, domain, sockType, protocol, buffered)
@@ -354,7 +354,7 @@ proc listen*(socket: Socket, backlog = SOMAXCONN) {.tags: [ReadIOEffect].} =
## queue of pending connections.
##
## Raises an EOS error upon failure.
- if rawsockets.listen(socket.fd, backlog) < 0'i32:
+ if nativesockets.listen(socket.fd, backlog) < 0'i32:
raiseOSError(osLastError())
proc bindAddr*(socket: Socket, port = Port(0), address = "") {.
diff --git a/lib/pure/rationals.nim b/lib/pure/rationals.nim
index 7d9241412a..72c64befce 100644
--- a/lib/pure/rationals.nim
+++ b/lib/pure/rationals.nim
@@ -39,6 +39,63 @@ proc toRational*[T:SomeInteger](x: T): Rational[T] =
result.num = x
result.den = 1
+proc toRationalSub(x: float, n: int): Rational[int] =
+ var
+ a = 0
+ b, c, d = 1
+ result = 0 // 1 # rational 0
+ while b <= n and d <= n:
+ let ac = (a+c)
+ let bd = (b+d)
+ # scale by 1000 so not overflow for high precision
+ let mediant = (ac/1000) / (bd/1000)
+ if x == mediant:
+ if bd <= n:
+ result.num = ac
+ result.den = bd
+ return result
+ elif d > b:
+ result.num = c
+ result.den = d
+ return result
+ else:
+ result.num = a
+ result.den = b
+ return result
+ elif x > mediant:
+ a = ac
+ b = bd
+ else:
+ c = ac
+ d = bd
+ if (b > n):
+ return initRational(c, d)
+ return initRational(a, b)
+
+proc toRational*(x: float, n: int = high(int)): Rational[int] =
+ ## Calculate the best rational numerator and denominator
+ ## that approximates to `x`, where the denominator is
+ ## smaller than `n` (default is the largest possible
+ ## int to give maximum resolution)
+ ##
+ ## The algorithm is based on the Farey sequence named
+ ## after John Farey
+ ##
+ ## .. code-block:: Nim
+ ## import math, rationals
+ ## for i in 1..10:
+ ## let t = (10 ^ (i+3)).int
+ ## let x = toRational(PI, t)
+ ## let newPI = x.num / x.den
+ ## echo x, " ", newPI, " error: ", PI - newPI, " ", t
+ if x > 1:
+ result = toRationalSub(1.0/x, n)
+ swap(result.num, result.den)
+ elif x == 1.0:
+ result = 1 // 1
+ else:
+ result = toRationalSub(x, n)
+
proc toFloat*[T](x: Rational[T]): float =
## Convert a rational number `x` to a float.
x.num / x.den
@@ -288,3 +345,8 @@ when isMainModule:
assert toRational(5) == 5//1
assert abs(toFloat(y) - 0.4814814814814815) < 1.0e-7
assert toInt(z) == 0
+
+ assert toRational(0.98765432) == 12345679 // 12500000
+ assert toRational(0.1, 1000000) == 1 // 10
+ assert toRational(0.9, 1000000) == 9 // 10
+ assert toRational(PI) == 80143857 // 25510582
diff --git a/lib/pure/strtabs.nim b/lib/pure/strtabs.nim
index 86f81aa433..1ce9067a78 100644
--- a/lib/pure/strtabs.nim
+++ b/lib/pure/strtabs.nim
@@ -173,6 +173,9 @@ proc clear*(s: StringTableRef, mode: StringTableMode) =
s.mode = mode
s.counter = 0
s.data.setLen(startSize)
+ for i in 0..