winrio

Documentation

Index

• Constants
• func CloseCompletionQueue(cq Cq)
• func DequeueCompletion(cq Cq, results []Result) uint32
• func DeregisterBuffer(id BufferId)
• func Initialize() bool
• func Notify(cq Cq) error
• func ReceiveEx(rq Rq, buf *Buffer, dataBufferCount uint32, ...) error
• func SendEx(rq Rq, buf *Buffer, dataBufferCount uint32, ...) error
• func Socket(af, typ, proto int32) (windows.Handle, error)
• type Buffer
• type BufferId
  • func RegisterBuffer(buffer []byte) (BufferId, error)
  • func RegisterPointer(ptr unsafe.Pointer, size uint32) (BufferId, error)
• type Cq
  • func CreateEventCompletionQueue(queueSize uint32, event windows.Handle, notifyReset bool) (Cq, error)
  • func CreateIOCPCompletionQueue(queueSize uint32, iocp windows.Handle, key uintptr, ...) (Cq, error)
  • func CreatePolledCompletionQueue(queueSize uint32) (Cq, error)
• type Result
• type Rq
  • func CreateRequestQueue(socket windows.Handle, ...) (Rq, error)

Constants

const (
	MsgDontNotify = 1
	MsgDefer      = 2
	MsgWaitAll    = 4
	MsgCommitOnly = 8

	MaxCqSize = 0x8000000
)

Functions

func CloseCompletionQueue

func CloseCompletionQueue(cq Cq)

func DequeueCompletion

func DequeueCompletion(cq Cq, results []Result) uint32

func DeregisterBuffer

func DeregisterBuffer(id BufferId)

func Initialize

func Initialize() bool

func Notify

func Notify(cq Cq) error

func ReceiveEx

func ReceiveEx(rq Rq, buf *Buffer, dataBufferCount uint32, localAddress, remoteAddress, controlContext, flags *Buffer, sflags uint32, requestContext uintptr) error

func SendEx

func SendEx(rq Rq, buf *Buffer, dataBufferCount uint32, localAddress, remoteAddress, controlContext, flags *Buffer, sflags uint32, requestContext uintptr) error

func Socket

func Socket(af, typ, proto int32) (windows.Handle, error)

Types

type Buffer

type Buffer struct {
	Id     BufferId
	Offset uint32
	Length uint32
}

type BufferId

type BufferId uintptr

func RegisterBuffer

func RegisterBuffer(buffer []byte) (BufferId, error)

func RegisterPointer

func RegisterPointer(ptr unsafe.Pointer, size uint32) (BufferId, error)

type Cq

type Cq uintptr

func CreateEventCompletionQueue

func CreateEventCompletionQueue(queueSize uint32, event windows.Handle, notifyReset bool) (Cq, error)

func CreateIOCPCompletionQueue

func CreateIOCPCompletionQueue(queueSize uint32, iocp windows.Handle, key uintptr, overlapped *windows.Overlapped) (Cq, error)

func CreatePolledCompletionQueue

func CreatePolledCompletionQueue(queueSize uint32) (Cq, error)

type Result

type Result struct {
	Status           int32
	BytesTransferred uint32
	SocketContext    uint64
	RequestContext   uint64
}

type Rq

type Rq uintptr

func CreateRequestQueue

func CreateRequestQueue(socket windows.Handle, maxOutstandingReceive, maxReceiveDataBuffers, maxOutstandingSend, maxSendDataBuffers uint32, receiveCq, sendCq Cq, socketContext uintptr) (Rq, error)