57 lines
2.1 KiB
Go
57 lines
2.1 KiB
Go
package utp
|
|
|
|
/*
|
|
#cgo CPPFLAGS: -DPOSIX -DUTP_DEBUG_LOGGING=0
|
|
#cgo CFLAGS: -Wall -O3
|
|
// These are all copied from the libutp Makefile.
|
|
#cgo CXXFLAGS: -Wall -O3 -fPIC -Wno-sign-compare
|
|
// There are some variables that aren't used unless UTP_DEBUG_LOGGING is defined.
|
|
#cgo CXXFLAGS: -Wno-unused-const-variable
|
|
// Windows additional flags
|
|
#cgo windows LDFLAGS: -lws2_32
|
|
#cgo windows CXXFLAGS: -D_WIN32_WINNT=0x600
|
|
#include "utp.h"
|
|
|
|
uint64_t firewallCallback(utp_callback_arguments *);
|
|
uint64_t errorCallback(utp_callback_arguments *);
|
|
uint64_t logCallback(utp_callback_arguments *);
|
|
uint64_t acceptCallback(utp_callback_arguments *);
|
|
uint64_t sendtoCallback(utp_callback_arguments *);
|
|
uint64_t stateChangeCallback(utp_callback_arguments *);
|
|
uint64_t readCallback(utp_callback_arguments *);
|
|
uint64_t getReadBufferSizeCallback(utp_callback_arguments *);
|
|
*/
|
|
import "C"
|
|
import "unsafe"
|
|
|
|
type socklen C.socklen_t
|
|
|
|
type utpContext C.utp_context
|
|
|
|
func (ctx *utpContext) asCPtr() *C.utp_context {
|
|
return (*C.utp_context)(ctx)
|
|
}
|
|
|
|
func (ctx *utpContext) setCallbacks() {
|
|
C.utp_set_callback(ctx.asCPtr(), C.UTP_ON_FIREWALL, (*C.utp_callback_t)(C.firewallCallback))
|
|
C.utp_set_callback(ctx.asCPtr(), C.UTP_LOG, (*C.utp_callback_t)(C.logCallback))
|
|
C.utp_set_callback(ctx.asCPtr(), C.UTP_ON_ACCEPT, (*C.utp_callback_t)(C.acceptCallback))
|
|
C.utp_set_callback(ctx.asCPtr(), C.UTP_SENDTO, (*C.utp_callback_t)(C.sendtoCallback))
|
|
C.utp_set_callback(ctx.asCPtr(), C.UTP_ON_STATE_CHANGE, (*C.utp_callback_t)(C.stateChangeCallback))
|
|
C.utp_set_callback(ctx.asCPtr(), C.UTP_ON_READ, (*C.utp_callback_t)(C.readCallback))
|
|
C.utp_set_callback(ctx.asCPtr(), C.UTP_ON_ERROR, (*C.utp_callback_t)(C.errorCallback))
|
|
C.utp_set_callback(ctx.asCPtr(), C.UTP_GET_READ_BUFFER_SIZE, (*C.utp_callback_t)(C.getReadBufferSizeCallback))
|
|
}
|
|
|
|
func (ctx *utpContext) setOption(opt Option, val int) int {
|
|
return int(C.utp_context_set_option(ctx.asCPtr(), opt, C.int(val)))
|
|
}
|
|
|
|
func libStateName(state C.int) string {
|
|
return C.GoString((*[5]*C.char)(unsafe.Pointer(&C.utp_state_names))[state])
|
|
}
|
|
|
|
func libErrorCodeNames(errorCode C.int) string {
|
|
return C.GoString((*[3]*C.char)(unsafe.Pointer(&C.utp_error_code_names))[errorCode])
|
|
}
|