config_json.go 1.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. // +build json
  2. package kcp
  3. import (
  4. "encoding/json"
  5. "github.com/v2ray/v2ray-core/common"
  6. "github.com/v2ray/v2ray-core/common/log"
  7. )
  8. func (this *Config) UnmarshalJSON(data []byte) error {
  9. type JSONConfig struct {
  10. Mtu *uint32 `json:"mtu"`
  11. Tti *uint32 `json:"tti"`
  12. UpCap *uint32 `json:"uplinkCapacity"`
  13. DownCap *uint32 `json:"downlinkCapacity"`
  14. Congestion *bool `json:"congestion"`
  15. }
  16. jsonConfig := new(JSONConfig)
  17. if err := json.Unmarshal(data, &jsonConfig); err != nil {
  18. return err
  19. }
  20. if jsonConfig.Mtu != nil {
  21. mtu := *jsonConfig.Mtu
  22. if mtu < 576 || mtu > 1460 {
  23. log.Error("KCP|Config: Invalid MTU size: ", mtu)
  24. return common.ErrBadConfiguration
  25. }
  26. this.Mtu = mtu
  27. }
  28. if jsonConfig.Tti != nil {
  29. tti := *jsonConfig.Tti
  30. if tti < 10 || tti > 100 {
  31. log.Error("KCP|Config: Invalid TTI: ", tti)
  32. return common.ErrBadConfiguration
  33. }
  34. this.Tti = tti
  35. }
  36. if jsonConfig.UpCap != nil {
  37. this.UplinkCapacity = *jsonConfig.UpCap
  38. }
  39. if jsonConfig.DownCap != nil {
  40. this.DownlinkCapacity = *jsonConfig.DownCap
  41. }
  42. if jsonConfig.Congestion != nil {
  43. this.Congestion = *jsonConfig.Congestion
  44. }
  45. return nil
  46. }