// Copyright (c) 2021 Tigera, Inc. All rights reserved.
//
// Based on the version in the Weave project, Copyright Weaveworks:
// https://github.com/weaveworks/weave/blob/c69e140e9e43d456b6fe5812a2bc61bc67953b93/net/ethtool.go
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package ethtool

import (
	"fmt"
	"unsafe"

	"github.com/safchain/ethtool"
	"github.com/sirupsen/logrus"
	"golang.org/x/sys/unix"
	"modernc.org/memory"
)

const (
	EthtoolRxGRO = "rx-gro"
)

// IFReqData represents linux/if.h 'struct ifreq'
type IFReqData struct {
	Name [unix.IFNAMSIZ]byte
	Data uintptr
}

// EthtoolValue represents linux/ethtool.h 'struct ethtool_value'
type EthtoolValue struct {
	Cmd  uint32
	Data uint32
}

func ioctlEthtool(fd int, argp *IFReqData) error {
	// Important that the cast to uintptr is _syntactically_ within the Syscall() invocation in order to guarantee
	// safety.  (See notes in the unsafe.Pointer docs.)
	_, _, errno := unix.Syscall(unix.SYS_IOCTL, uintptr(fd), uintptr(unix.SIOCETHTOOL), uintptr(unsafe.Pointer(argp)))
	if errno != 0 {
		return errno
	}
	return nil
}

// EthtoolTXOff disables the TX checksum offload on the specified interface
func EthtoolTXOff(name string) error {
	if len(name)+1 > unix.IFNAMSIZ {
		return fmt.Errorf("name too long")
	}

	// To access the IOCTL, we need a socket file descriptor.
	socket, err := unix.Socket(unix.AF_INET, unix.SOCK_DGRAM, 0)
	if err != nil {
		return err
	}
	defer func() {
		err := unix.Close(socket)
		if err != nil {
			// Super unlikely; normally a failure from Close means that some data couldn't be flushed
			// but we didn't send any.
			logrus.WithError(err).Warn("unix.Close(socket) failed")
		}
	}()

	// Allocate an EthtoolValue using manual memory management.  This is required because we need to pass
	// a struct to the Syscall that in turn points to the EthtoolValue.  If we allocate the EthtooValue on the
	// go stack/heap then it would not be protected from being moved by the GC while the syscall is in progress.
	// (Only the directly-passed struct is protected from being moved during the syscall.)
	alloc := memory.Allocator{}
	defer func() {
		err := alloc.Close()
		if err != nil {
			logrus.WithError(err).Panic("Failed to release memory to the system")
		}
	}()
	valueUPtr, err := alloc.UnsafeCalloc(int(unsafe.Sizeof(EthtoolValue{})))
	if err != nil {
		return fmt.Errorf("failed to allocate memory: %w", err)
	}
	defer func() {
		err := alloc.UnsafeFree(valueUPtr)
		if err != nil {
			logrus.WithError(err).Warn("UnsafeFree() failed")
		}
	}()
	value := (*EthtoolValue)(valueUPtr)

	// Get the current value so we only set it if it needs to change.
	*value = EthtoolValue{Cmd: unix.ETHTOOL_GTXCSUM}
	request := IFReqData{Data: uintptr(valueUPtr)}
	copy(request.Name[:], name)
	if err := ioctlEthtool(socket, &request); err != nil {
		return err
	}
	if value.Data == 0 { // if already off, don't try to change
		return nil
	}

	// Set the value.
	*value = EthtoolValue{Cmd: unix.ETHTOOL_STXCSUM, Data: 0 /* off */}
	return ioctlEthtool(socket, &request)
}

func EthtoolChangeImpl(iface string, config map[string]bool) error {
	ethHandle, err := ethtool.NewEthtool()
	if err != nil {
		logrus.WithError(err).Warn("ethtool.NewEthtool() failed")
	}
	defer ethHandle.Close()
	if err != nil {
		logrus.WithError(err).Warn("ethtool.Close() failed")
	}

	logrus.WithField(iface, config).Debug("ethtool.Change()")
	err = ethHandle.Change(iface, config)
	if err != nil {
		logrus.WithError(err).Warnf("ethtool.Change('%s'=>'%v') failed", iface, config)
	}

	return err
}