mirror of
https://github.com/status-im/nim-task-runner.git
synced 2025-02-18 01:27:06 +00:00
b2442ecba8
Involves some adjustments necessary for the code to compile with the version of Nim compiler (1.2.6) provided by latest status-im/nimbus-build-system and to be compatible with latest status-im/nim-chronos. Does not include "transport" code added with respect to asynchronous channels introduced in https://github.com/status-im/nim-chronos/pull/45. That code will likely be added to this repo in the future. Note that at present vendor/nim-chronos points to a GitHub fork of status-im/nim-chronos as two small changes were needed in vendor/nim-chronos. See: https://github.com/status-im/nim-chronos/pull/154.
70 lines
2.3 KiB
Nim
70 lines
2.3 KiB
Nim
# Task Runner OS API declarations
|
|
# adapted from
|
|
# Chronos OS API declarations
|
|
# (github.com/status-im/nim-chronos/pull/45)
|
|
#
|
|
# (c) Copyright 2018-Present
|
|
# Status Research & Development GmbH
|
|
#
|
|
# Licensed under either of
|
|
# Apache License, version 2.0, (LICENSE-APACHEv2)
|
|
# MIT license (LICENSE-MIT)
|
|
|
|
## This module implements a small wrapper for some needed Windows/*nix API
|
|
## procedures, which are not defined in Nim stdlib modules, or its definition
|
|
## is wrong.
|
|
when defined(windows):
|
|
import winlean
|
|
|
|
const
|
|
TCP_NODELAY* = 1
|
|
IPPROTO_TCP* = 6
|
|
PIPE_TYPE_BYTE* = 0x00000000'i32
|
|
PIPE_READMODE_BYTE* = 0x00000000'i32
|
|
PIPE_WAIT* = 0x00000000'i32
|
|
DEFAULT_PIPE_SIZE* = 65536'i32
|
|
ERROR_PIPE_CONNECTED* = 535
|
|
ERROR_PIPE_BUSY* = 231
|
|
ERROR_OPERATION_ABORTED* = 995
|
|
ERROR_SUCCESS* = 0
|
|
ERROR_CONNECTION_REFUSED* = 1225
|
|
PIPE_TYPE_MESSAGE* = 0x4
|
|
PIPE_READMODE_MESSAGE* = 0x2
|
|
PIPE_UNLIMITED_INSTANCES* = 255
|
|
ERROR_BROKEN_PIPE* = 109
|
|
ERROR_PIPE_NOT_CONNECTED* = 233
|
|
ERROR_NO_DATA* = 232
|
|
ERROR_CONNECTION_ABORTED* = 1236
|
|
|
|
proc createEvent*(lpEventAttributes: ptr SECURITY_ATTRIBUTES,
|
|
bManualReset: DWORD, bInitialState: DWORD,
|
|
lpName: ptr Utf16Char): Handle
|
|
{.stdcall, dynlib: "kernel32", importc: "CreateEventW".}
|
|
|
|
proc connectNamedPipe*(hNamedPipe: Handle, lpOverlapped: pointer): WINBOOL
|
|
{.importc: "ConnectNamedPipe", stdcall, dynlib: "kernel32".}
|
|
|
|
proc cancelIo*(hFile: HANDLE): WINBOOL
|
|
{.stdcall, dynlib: "kernel32", importc: "CancelIo".}
|
|
|
|
proc disconnectNamedPipe*(hPipe: HANDLE): WINBOOL
|
|
{.stdcall, dynlib: "kernel32", importc: "DisconnectNamedPipe".}
|
|
|
|
proc setNamedPipeHandleState*(hPipe: HANDLE, lpMode, lpMaxCollectionCount,
|
|
lpCollectDataTimeout: ptr DWORD): WINBOOL
|
|
{.stdcall, dynlib: "kernel32", importc: "SetNamedPipeHandleState".}
|
|
|
|
proc resetEvent*(hEvent: HANDLE): WINBOOL
|
|
{.stdcall, dynlib: "kernel32", importc: "ResetEvent".}
|
|
|
|
else:
|
|
import posix
|
|
|
|
const
|
|
TCP_NODELAY* = 1
|
|
IPPROTO_TCP* = 6
|
|
|
|
when defined(linux):
|
|
proc eventfd*(count: cuint, flags: cint): cint
|
|
{.cdecl, importc: "eventfd", header: "<sys/eventfd.h>".}
|