()
| 220 | } |
| 221 | |
| 222 | func (device *Device) IsUnderLoad() bool { |
| 223 | // check if currently under load |
| 224 | now := time.Now() |
| 225 | underLoad := len(device.queue.handshake.c) >= QueueHandshakeSize/8 |
| 226 | if underLoad { |
| 227 | device.rate.underLoadUntil.Store(now.Add(UnderLoadAfterTime).UnixNano()) |
| 228 | return true |
| 229 | } |
| 230 | // check if recently under load |
| 231 | return device.rate.underLoadUntil.Load() > now.UnixNano() |
| 232 | } |
| 233 | |
| 234 | func (device *Device) SetPrivateKey(sk NoisePrivateKey) error { |
| 235 | // lock required resources |
no outgoing calls
no test coverage detected