Cloudpods/backend/vendor/github.com/anacrolix/go-libutp/libapi.go

package utp

/*
#include "utp.h"
*/
import "C"

import (
	"errors"

	"github.com/anacrolix/sync"
)

type Option = C.int

const (
	LogNormal   Option = C.UTP_LOG_NORMAL
	LogMtu      Option = C.UTP_LOG_MTU
	LogDebug    Option = C.UTP_LOG_DEBUG
	SendBuffer  Option = C.UTP_SNDBUF
	RecvBuffer  Option = C.UTP_RCVBUF
	TargetDelay Option = C.UTP_TARGET_DELAY

	TimedOut = C.UTP_ETIMEDOUT
)

var (
	mu                 sync.Mutex
	libContextToSocket = map[*utpContext]*Socket{}
)

func getSocketForLibContext(uc *utpContext) *Socket {
	return libContextToSocket[uc]
}

func errorForCode(code C.int) error {
	return errors.New(libErrorCodeNames(code))
}