// @generated Code generated by gen-atomicwrapper. // Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "encoding/json" ) // Bool is an atomic type-safe wrapper for bool values. type Bool struct { _ nocmp // disallow non-atomic comparison v Uint32 } var _zeroBool bool // NewBool creates a new Bool. func NewBool(val bool) *Bool { x := &Bool{} if val != _zeroBool { x.Store(val) } return x } // Load atomically loads the wrapped bool. func (x *Bool) Load() bool { return truthy(x.v.Load()) } // Store atomically stores the passed bool. func (x *Bool) Store(val bool) { x.v.Store(boolToInt(val)) } // CAS is an atomic compare-and-swap for bool values. // // Deprecated: Use CompareAndSwap. func (x *Bool) CAS(old, new bool) (swapped bool) { return x.CompareAndSwap(old, new) } // CompareAndSwap is an atomic compare-and-swap for bool values. func (x *Bool) CompareAndSwap(old, new bool) (swapped bool) { return x.v.CompareAndSwap(boolToInt(old), boolToInt(new)) } // Swap atomically stores the given bool and returns the old // value. func (x *Bool) Swap(val bool) (old bool) { return truthy(x.v.Swap(boolToInt(val))) } // MarshalJSON encodes the wrapped bool into JSON. func (x *Bool) MarshalJSON() ([]byte, error) { return json.Marshal(x.Load()) } // UnmarshalJSON decodes a bool from JSON. func (x *Bool) UnmarshalJSON(b []byte) error { var v bool if err := json.Unmarshal(b, &v); err != nil { return err } x.Store(v) return nil }
// Copyright (c) 2020 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "strconv" ) //go:generate bin/gen-atomicwrapper -name=Bool -type=bool -wrapped=Uint32 -pack=boolToInt -unpack=truthy -cas -swap -json -file=bool.go func truthy(n uint32) bool { return n == 1 } func boolToInt(b bool) uint32 { if b { return 1 } return 0 } // Toggle atomically negates the Boolean and returns the previous value. func (b *Bool) Toggle() (old bool) { for { old := b.Load() if b.CAS(old, !old) { return old } } } // String encodes the wrapped value as a string. func (b *Bool) String() string { return strconv.FormatBool(b.Load()) }
// @generated Code generated by gen-atomicwrapper. // Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "encoding/json" "time" ) // Duration is an atomic type-safe wrapper for time.Duration values. type Duration struct { _ nocmp // disallow non-atomic comparison v Int64 } var _zeroDuration time.Duration // NewDuration creates a new Duration. func NewDuration(val time.Duration) *Duration { x := &Duration{} if val != _zeroDuration { x.Store(val) } return x } // Load atomically loads the wrapped time.Duration. func (x *Duration) Load() time.Duration { return time.Duration(x.v.Load()) } // Store atomically stores the passed time.Duration. func (x *Duration) Store(val time.Duration) { x.v.Store(int64(val)) } // CAS is an atomic compare-and-swap for time.Duration values. // // Deprecated: Use CompareAndSwap. func (x *Duration) CAS(old, new time.Duration) (swapped bool) { return x.CompareAndSwap(old, new) } // CompareAndSwap is an atomic compare-and-swap for time.Duration values. func (x *Duration) CompareAndSwap(old, new time.Duration) (swapped bool) { return x.v.CompareAndSwap(int64(old), int64(new)) } // Swap atomically stores the given time.Duration and returns the old // value. func (x *Duration) Swap(val time.Duration) (old time.Duration) { return time.Duration(x.v.Swap(int64(val))) } // MarshalJSON encodes the wrapped time.Duration into JSON. func (x *Duration) MarshalJSON() ([]byte, error) { return json.Marshal(x.Load()) } // UnmarshalJSON decodes a time.Duration from JSON. func (x *Duration) UnmarshalJSON(b []byte) error { var v time.Duration if err := json.Unmarshal(b, &v); err != nil { return err } x.Store(v) return nil }
// Copyright (c) 2020 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import "time" //go:generate bin/gen-atomicwrapper -name=Duration -type=time.Duration -wrapped=Int64 -pack=int64 -unpack=time.Duration -cas -swap -json -imports time -file=duration.go // Add atomically adds to the wrapped time.Duration and returns the new value. func (d *Duration) Add(delta time.Duration) time.Duration { return time.Duration(d.v.Add(int64(delta))) } // Sub atomically subtracts from the wrapped time.Duration and returns the new value. func (d *Duration) Sub(delta time.Duration) time.Duration { return time.Duration(d.v.Sub(int64(delta))) } // String encodes the wrapped value as a string. func (d *Duration) String() string { return d.Load().String() }
// @generated Code generated by gen-atomicwrapper. // Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic // Error is an atomic type-safe wrapper for error values. type Error struct { _ nocmp // disallow non-atomic comparison v Value } var _zeroError error // NewError creates a new Error. func NewError(val error) *Error { x := &Error{} if val != _zeroError { x.Store(val) } return x } // Load atomically loads the wrapped error. func (x *Error) Load() error { return unpackError(x.v.Load()) } // Store atomically stores the passed error. func (x *Error) Store(val error) { x.v.Store(packError(val)) } // CompareAndSwap is an atomic compare-and-swap for error values. func (x *Error) CompareAndSwap(old, new error) (swapped bool) { if x.v.CompareAndSwap(packError(old), packError(new)) { return true } if old == _zeroError { // If the old value is the empty value, then it's possible the // underlying Value hasn't been set and is nil, so retry with nil. return x.v.CompareAndSwap(nil, packError(new)) } return false } // Swap atomically stores the given error and returns the old // value. func (x *Error) Swap(val error) (old error) { return unpackError(x.v.Swap(packError(val))) }
// Copyright (c) 2020-2022 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic // atomic.Value panics on nil inputs, or if the underlying type changes. // Stabilize by always storing a custom struct that we control. //go:generate bin/gen-atomicwrapper -name=Error -type=error -wrapped=Value -pack=packError -unpack=unpackError -compareandswap -swap -file=error.go type packedError struct{ Value error } func packError(v error) interface{} { return packedError{v} } func unpackError(v interface{}) error { if err, ok := v.(packedError); ok { return err.Value } return nil }
// @generated Code generated by gen-atomicwrapper. // Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "encoding/json" "math" ) // Float32 is an atomic type-safe wrapper for float32 values. type Float32 struct { _ nocmp // disallow non-atomic comparison v Uint32 } var _zeroFloat32 float32 // NewFloat32 creates a new Float32. func NewFloat32(val float32) *Float32 { x := &Float32{} if val != _zeroFloat32 { x.Store(val) } return x } // Load atomically loads the wrapped float32. func (x *Float32) Load() float32 { return math.Float32frombits(x.v.Load()) } // Store atomically stores the passed float32. func (x *Float32) Store(val float32) { x.v.Store(math.Float32bits(val)) } // Swap atomically stores the given float32 and returns the old // value. func (x *Float32) Swap(val float32) (old float32) { return math.Float32frombits(x.v.Swap(math.Float32bits(val))) } // MarshalJSON encodes the wrapped float32 into JSON. func (x *Float32) MarshalJSON() ([]byte, error) { return json.Marshal(x.Load()) } // UnmarshalJSON decodes a float32 from JSON. func (x *Float32) UnmarshalJSON(b []byte) error { var v float32 if err := json.Unmarshal(b, &v); err != nil { return err } x.Store(v) return nil }
// Copyright (c) 2020-2022 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "math" "strconv" ) //go:generate bin/gen-atomicwrapper -name=Float32 -type=float32 -wrapped=Uint32 -pack=math.Float32bits -unpack=math.Float32frombits -swap -json -imports math -file=float32.go // Add atomically adds to the wrapped float32 and returns the new value. func (f *Float32) Add(delta float32) float32 { for { old := f.Load() new := old + delta if f.CAS(old, new) { return new } } } // Sub atomically subtracts from the wrapped float32 and returns the new value. func (f *Float32) Sub(delta float32) float32 { return f.Add(-delta) } // CAS is an atomic compare-and-swap for float32 values. // // Deprecated: Use CompareAndSwap func (f *Float32) CAS(old, new float32) (swapped bool) { return f.CompareAndSwap(old, new) } // CompareAndSwap is an atomic compare-and-swap for float32 values. // // Note: CompareAndSwap handles NaN incorrectly. NaN != NaN using Go's inbuilt operators // but CompareAndSwap allows a stored NaN to compare equal to a passed in NaN. // This avoids typical CompareAndSwap loops from blocking forever, e.g., // // for { // old := atom.Load() // new = f(old) // if atom.CompareAndSwap(old, new) { // break // } // } // // If CompareAndSwap did not match NaN to match, then the above would loop forever. func (f *Float32) CompareAndSwap(old, new float32) (swapped bool) { return f.v.CompareAndSwap(math.Float32bits(old), math.Float32bits(new)) } // String encodes the wrapped value as a string. func (f *Float32) String() string { // 'g' is the behavior for floats with %v. return strconv.FormatFloat(float64(f.Load()), 'g', -1, 32) }
// @generated Code generated by gen-atomicwrapper. // Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "encoding/json" "math" ) // Float64 is an atomic type-safe wrapper for float64 values. type Float64 struct { _ nocmp // disallow non-atomic comparison v Uint64 } var _zeroFloat64 float64 // NewFloat64 creates a new Float64. func NewFloat64(val float64) *Float64 { x := &Float64{} if val != _zeroFloat64 { x.Store(val) } return x } // Load atomically loads the wrapped float64. func (x *Float64) Load() float64 { return math.Float64frombits(x.v.Load()) } // Store atomically stores the passed float64. func (x *Float64) Store(val float64) { x.v.Store(math.Float64bits(val)) } // Swap atomically stores the given float64 and returns the old // value. func (x *Float64) Swap(val float64) (old float64) { return math.Float64frombits(x.v.Swap(math.Float64bits(val))) } // MarshalJSON encodes the wrapped float64 into JSON. func (x *Float64) MarshalJSON() ([]byte, error) { return json.Marshal(x.Load()) } // UnmarshalJSON decodes a float64 from JSON. func (x *Float64) UnmarshalJSON(b []byte) error { var v float64 if err := json.Unmarshal(b, &v); err != nil { return err } x.Store(v) return nil }
// Copyright (c) 2020-2022 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "math" "strconv" ) //go:generate bin/gen-atomicwrapper -name=Float64 -type=float64 -wrapped=Uint64 -pack=math.Float64bits -unpack=math.Float64frombits -swap -json -imports math -file=float64.go // Add atomically adds to the wrapped float64 and returns the new value. func (f *Float64) Add(delta float64) float64 { for { old := f.Load() new := old + delta if f.CAS(old, new) { return new } } } // Sub atomically subtracts from the wrapped float64 and returns the new value. func (f *Float64) Sub(delta float64) float64 { return f.Add(-delta) } // CAS is an atomic compare-and-swap for float64 values. // // Deprecated: Use CompareAndSwap func (f *Float64) CAS(old, new float64) (swapped bool) { return f.CompareAndSwap(old, new) } // CompareAndSwap is an atomic compare-and-swap for float64 values. // // Note: CompareAndSwap handles NaN incorrectly. NaN != NaN using Go's inbuilt operators // but CompareAndSwap allows a stored NaN to compare equal to a passed in NaN. // This avoids typical CompareAndSwap loops from blocking forever, e.g., // // for { // old := atom.Load() // new = f(old) // if atom.CompareAndSwap(old, new) { // break // } // } // // If CompareAndSwap did not match NaN to match, then the above would loop forever. func (f *Float64) CompareAndSwap(old, new float64) (swapped bool) { return f.v.CompareAndSwap(math.Float64bits(old), math.Float64bits(new)) } // String encodes the wrapped value as a string. func (f *Float64) String() string { // 'g' is the behavior for floats with %v. return strconv.FormatFloat(f.Load(), 'g', -1, 64) }
// @generated Code generated by gen-atomicint. // Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "encoding/json" "strconv" "sync/atomic" ) // Int32 is an atomic wrapper around int32. type Int32 struct { _ nocmp // disallow non-atomic comparison v int32 } // NewInt32 creates a new Int32. func NewInt32(val int32) *Int32 { return &Int32{v: val} } // Load atomically loads the wrapped value. func (i *Int32) Load() int32 { return atomic.LoadInt32(&i.v) } // Add atomically adds to the wrapped int32 and returns the new value. func (i *Int32) Add(delta int32) int32 { return atomic.AddInt32(&i.v, delta) } // Sub atomically subtracts from the wrapped int32 and returns the new value. func (i *Int32) Sub(delta int32) int32 { return atomic.AddInt32(&i.v, -delta) } // Inc atomically increments the wrapped int32 and returns the new value. func (i *Int32) Inc() int32 { return i.Add(1) } // Dec atomically decrements the wrapped int32 and returns the new value. func (i *Int32) Dec() int32 { return i.Sub(1) } // CAS is an atomic compare-and-swap. // // Deprecated: Use CompareAndSwap. func (i *Int32) CAS(old, new int32) (swapped bool) { return i.CompareAndSwap(old, new) } // CompareAndSwap is an atomic compare-and-swap. func (i *Int32) CompareAndSwap(old, new int32) (swapped bool) { return atomic.CompareAndSwapInt32(&i.v, old, new) } // Store atomically stores the passed value. func (i *Int32) Store(val int32) { atomic.StoreInt32(&i.v, val) } // Swap atomically swaps the wrapped int32 and returns the old value. func (i *Int32) Swap(val int32) (old int32) { return atomic.SwapInt32(&i.v, val) } // MarshalJSON encodes the wrapped int32 into JSON. func (i *Int32) MarshalJSON() ([]byte, error) { return json.Marshal(i.Load()) } // UnmarshalJSON decodes JSON into the wrapped int32. func (i *Int32) UnmarshalJSON(b []byte) error { var v int32 if err := json.Unmarshal(b, &v); err != nil { return err } i.Store(v) return nil } // String encodes the wrapped value as a string. func (i *Int32) String() string { v := i.Load() return strconv.FormatInt(int64(v), 10) }
// @generated Code generated by gen-atomicint. // Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "encoding/json" "strconv" "sync/atomic" ) // Int64 is an atomic wrapper around int64. type Int64 struct { _ nocmp // disallow non-atomic comparison v int64 } // NewInt64 creates a new Int64. func NewInt64(val int64) *Int64 { return &Int64{v: val} } // Load atomically loads the wrapped value. func (i *Int64) Load() int64 { return atomic.LoadInt64(&i.v) } // Add atomically adds to the wrapped int64 and returns the new value. func (i *Int64) Add(delta int64) int64 { return atomic.AddInt64(&i.v, delta) } // Sub atomically subtracts from the wrapped int64 and returns the new value. func (i *Int64) Sub(delta int64) int64 { return atomic.AddInt64(&i.v, -delta) } // Inc atomically increments the wrapped int64 and returns the new value. func (i *Int64) Inc() int64 { return i.Add(1) } // Dec atomically decrements the wrapped int64 and returns the new value. func (i *Int64) Dec() int64 { return i.Sub(1) } // CAS is an atomic compare-and-swap. // // Deprecated: Use CompareAndSwap. func (i *Int64) CAS(old, new int64) (swapped bool) { return i.CompareAndSwap(old, new) } // CompareAndSwap is an atomic compare-and-swap. func (i *Int64) CompareAndSwap(old, new int64) (swapped bool) { return atomic.CompareAndSwapInt64(&i.v, old, new) } // Store atomically stores the passed value. func (i *Int64) Store(val int64) { atomic.StoreInt64(&i.v, val) } // Swap atomically swaps the wrapped int64 and returns the old value. func (i *Int64) Swap(val int64) (old int64) { return atomic.SwapInt64(&i.v, val) } // MarshalJSON encodes the wrapped int64 into JSON. func (i *Int64) MarshalJSON() ([]byte, error) { return json.Marshal(i.Load()) } // UnmarshalJSON decodes JSON into the wrapped int64. func (i *Int64) UnmarshalJSON(b []byte) error { var v int64 if err := json.Unmarshal(b, &v); err != nil { return err } i.Store(v) return nil } // String encodes the wrapped value as a string. func (i *Int64) String() string { v := i.Load() return strconv.FormatInt(int64(v), 10) }
// Copyright (c) 2022 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. //go:build go1.18 // +build go1.18 package atomic import ( "encoding/json" "fmt" ) // String returns a human readable representation of a Pointer's underlying value. func (p *Pointer[T]) String() string { return fmt.Sprint(p.Load()) } // MarshalJSON encodes the wrapped pointer into JSON. func (p *Pointer[T]) MarshalJSON() ([]byte, error) { return json.Marshal(p.Load()) } // UnmarshalJSON decodes JSON into the wrapped pointer. func (p *Pointer[T]) UnmarshalJSON(b []byte) error { var v T if err := json.Unmarshal(b, &v); err != nil { return err } p.Store(&v) return nil }
// Copyright (c) 2022 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. //go:build go1.19 // +build go1.19 package atomic import "sync/atomic" // Pointer is an atomic pointer of type *T. type Pointer[T any] struct { _ nocmp // disallow non-atomic comparison p atomic.Pointer[T] } // NewPointer creates a new Pointer. func NewPointer[T any](v *T) *Pointer[T] { var p Pointer[T] if v != nil { p.p.Store(v) } return &p } // Load atomically loads the wrapped value. func (p *Pointer[T]) Load() *T { return p.p.Load() } // Store atomically stores the passed value. func (p *Pointer[T]) Store(val *T) { p.p.Store(val) } // Swap atomically swaps the wrapped pointer and returns the old value. func (p *Pointer[T]) Swap(val *T) (old *T) { return p.p.Swap(val) } // CompareAndSwap is an atomic compare-and-swap. func (p *Pointer[T]) CompareAndSwap(old, new *T) (swapped bool) { return p.p.CompareAndSwap(old, new) }
// @generated Code generated by gen-atomicwrapper. // Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic // String is an atomic type-safe wrapper for string values. type String struct { _ nocmp // disallow non-atomic comparison v Value } var _zeroString string // NewString creates a new String. func NewString(val string) *String { x := &String{} if val != _zeroString { x.Store(val) } return x } // Load atomically loads the wrapped string. func (x *String) Load() string { return unpackString(x.v.Load()) } // Store atomically stores the passed string. func (x *String) Store(val string) { x.v.Store(packString(val)) } // CompareAndSwap is an atomic compare-and-swap for string values. func (x *String) CompareAndSwap(old, new string) (swapped bool) { if x.v.CompareAndSwap(packString(old), packString(new)) { return true } if old == _zeroString { // If the old value is the empty value, then it's possible the // underlying Value hasn't been set and is nil, so retry with nil. return x.v.CompareAndSwap(nil, packString(new)) } return false } // Swap atomically stores the given string and returns the old // value. func (x *String) Swap(val string) (old string) { return unpackString(x.v.Swap(packString(val))) }
// Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic //go:generate bin/gen-atomicwrapper -name=String -type=string -wrapped Value -pack packString -unpack unpackString -compareandswap -swap -file=string.go func packString(s string) interface{} { return s } func unpackString(v interface{}) string { if s, ok := v.(string); ok { return s } return "" } // String returns the wrapped value. func (s *String) String() string { return s.Load() } // MarshalText encodes the wrapped string into a textual form. // // This makes it encodable as JSON, YAML, XML, and more. func (s *String) MarshalText() ([]byte, error) { return []byte(s.Load()), nil } // UnmarshalText decodes text and replaces the wrapped string with it. // // This makes it decodable from JSON, YAML, XML, and more. func (s *String) UnmarshalText(b []byte) error { s.Store(string(b)) return nil }
// @generated Code generated by gen-atomicwrapper. // Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "time" ) // Time is an atomic type-safe wrapper for time.Time values. type Time struct { _ nocmp // disallow non-atomic comparison v Value } var _zeroTime time.Time // NewTime creates a new Time. func NewTime(val time.Time) *Time { x := &Time{} if val != _zeroTime { x.Store(val) } return x } // Load atomically loads the wrapped time.Time. func (x *Time) Load() time.Time { return unpackTime(x.v.Load()) } // Store atomically stores the passed time.Time. func (x *Time) Store(val time.Time) { x.v.Store(packTime(val)) }
// Copyright (c) 2021 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import "time" //go:generate bin/gen-atomicwrapper -name=Time -type=time.Time -wrapped=Value -pack=packTime -unpack=unpackTime -imports time -file=time.go func packTime(t time.Time) interface{} { return t } func unpackTime(v interface{}) time.Time { if t, ok := v.(time.Time); ok { return t } return time.Time{} }
// @generated Code generated by gen-atomicint. // Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "encoding/json" "strconv" "sync/atomic" ) // Uint32 is an atomic wrapper around uint32. type Uint32 struct { _ nocmp // disallow non-atomic comparison v uint32 } // NewUint32 creates a new Uint32. func NewUint32(val uint32) *Uint32 { return &Uint32{v: val} } // Load atomically loads the wrapped value. func (i *Uint32) Load() uint32 { return atomic.LoadUint32(&i.v) } // Add atomically adds to the wrapped uint32 and returns the new value. func (i *Uint32) Add(delta uint32) uint32 { return atomic.AddUint32(&i.v, delta) } // Sub atomically subtracts from the wrapped uint32 and returns the new value. func (i *Uint32) Sub(delta uint32) uint32 { return atomic.AddUint32(&i.v, ^(delta - 1)) } // Inc atomically increments the wrapped uint32 and returns the new value. func (i *Uint32) Inc() uint32 { return i.Add(1) } // Dec atomically decrements the wrapped uint32 and returns the new value. func (i *Uint32) Dec() uint32 { return i.Sub(1) } // CAS is an atomic compare-and-swap. // // Deprecated: Use CompareAndSwap. func (i *Uint32) CAS(old, new uint32) (swapped bool) { return i.CompareAndSwap(old, new) } // CompareAndSwap is an atomic compare-and-swap. func (i *Uint32) CompareAndSwap(old, new uint32) (swapped bool) { return atomic.CompareAndSwapUint32(&i.v, old, new) } // Store atomically stores the passed value. func (i *Uint32) Store(val uint32) { atomic.StoreUint32(&i.v, val) } // Swap atomically swaps the wrapped uint32 and returns the old value. func (i *Uint32) Swap(val uint32) (old uint32) { return atomic.SwapUint32(&i.v, val) } // MarshalJSON encodes the wrapped uint32 into JSON. func (i *Uint32) MarshalJSON() ([]byte, error) { return json.Marshal(i.Load()) } // UnmarshalJSON decodes JSON into the wrapped uint32. func (i *Uint32) UnmarshalJSON(b []byte) error { var v uint32 if err := json.Unmarshal(b, &v); err != nil { return err } i.Store(v) return nil } // String encodes the wrapped value as a string. func (i *Uint32) String() string { v := i.Load() return strconv.FormatUint(uint64(v), 10) }
// @generated Code generated by gen-atomicint. // Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "encoding/json" "strconv" "sync/atomic" ) // Uint64 is an atomic wrapper around uint64. type Uint64 struct { _ nocmp // disallow non-atomic comparison v uint64 } // NewUint64 creates a new Uint64. func NewUint64(val uint64) *Uint64 { return &Uint64{v: val} } // Load atomically loads the wrapped value. func (i *Uint64) Load() uint64 { return atomic.LoadUint64(&i.v) } // Add atomically adds to the wrapped uint64 and returns the new value. func (i *Uint64) Add(delta uint64) uint64 { return atomic.AddUint64(&i.v, delta) } // Sub atomically subtracts from the wrapped uint64 and returns the new value. func (i *Uint64) Sub(delta uint64) uint64 { return atomic.AddUint64(&i.v, ^(delta - 1)) } // Inc atomically increments the wrapped uint64 and returns the new value. func (i *Uint64) Inc() uint64 { return i.Add(1) } // Dec atomically decrements the wrapped uint64 and returns the new value. func (i *Uint64) Dec() uint64 { return i.Sub(1) } // CAS is an atomic compare-and-swap. // // Deprecated: Use CompareAndSwap. func (i *Uint64) CAS(old, new uint64) (swapped bool) { return i.CompareAndSwap(old, new) } // CompareAndSwap is an atomic compare-and-swap. func (i *Uint64) CompareAndSwap(old, new uint64) (swapped bool) { return atomic.CompareAndSwapUint64(&i.v, old, new) } // Store atomically stores the passed value. func (i *Uint64) Store(val uint64) { atomic.StoreUint64(&i.v, val) } // Swap atomically swaps the wrapped uint64 and returns the old value. func (i *Uint64) Swap(val uint64) (old uint64) { return atomic.SwapUint64(&i.v, val) } // MarshalJSON encodes the wrapped uint64 into JSON. func (i *Uint64) MarshalJSON() ([]byte, error) { return json.Marshal(i.Load()) } // UnmarshalJSON decodes JSON into the wrapped uint64. func (i *Uint64) UnmarshalJSON(b []byte) error { var v uint64 if err := json.Unmarshal(b, &v); err != nil { return err } i.Store(v) return nil } // String encodes the wrapped value as a string. func (i *Uint64) String() string { v := i.Load() return strconv.FormatUint(uint64(v), 10) }
// @generated Code generated by gen-atomicint. // Copyright (c) 2020-2023 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "encoding/json" "strconv" "sync/atomic" ) // Uintptr is an atomic wrapper around uintptr. type Uintptr struct { _ nocmp // disallow non-atomic comparison v uintptr } // NewUintptr creates a new Uintptr. func NewUintptr(val uintptr) *Uintptr { return &Uintptr{v: val} } // Load atomically loads the wrapped value. func (i *Uintptr) Load() uintptr { return atomic.LoadUintptr(&i.v) } // Add atomically adds to the wrapped uintptr and returns the new value. func (i *Uintptr) Add(delta uintptr) uintptr { return atomic.AddUintptr(&i.v, delta) } // Sub atomically subtracts from the wrapped uintptr and returns the new value. func (i *Uintptr) Sub(delta uintptr) uintptr { return atomic.AddUintptr(&i.v, ^(delta - 1)) } // Inc atomically increments the wrapped uintptr and returns the new value. func (i *Uintptr) Inc() uintptr { return i.Add(1) } // Dec atomically decrements the wrapped uintptr and returns the new value. func (i *Uintptr) Dec() uintptr { return i.Sub(1) } // CAS is an atomic compare-and-swap. // // Deprecated: Use CompareAndSwap. func (i *Uintptr) CAS(old, new uintptr) (swapped bool) { return i.CompareAndSwap(old, new) } // CompareAndSwap is an atomic compare-and-swap. func (i *Uintptr) CompareAndSwap(old, new uintptr) (swapped bool) { return atomic.CompareAndSwapUintptr(&i.v, old, new) } // Store atomically stores the passed value. func (i *Uintptr) Store(val uintptr) { atomic.StoreUintptr(&i.v, val) } // Swap atomically swaps the wrapped uintptr and returns the old value. func (i *Uintptr) Swap(val uintptr) (old uintptr) { return atomic.SwapUintptr(&i.v, val) } // MarshalJSON encodes the wrapped uintptr into JSON. func (i *Uintptr) MarshalJSON() ([]byte, error) { return json.Marshal(i.Load()) } // UnmarshalJSON decodes JSON into the wrapped uintptr. func (i *Uintptr) UnmarshalJSON(b []byte) error { var v uintptr if err := json.Unmarshal(b, &v); err != nil { return err } i.Store(v) return nil } // String encodes the wrapped value as a string. func (i *Uintptr) String() string { v := i.Load() return strconv.FormatUint(uint64(v), 10) }
// Copyright (c) 2021-2022 Uber Technologies, Inc. // // Permission is hereby granted, free of charge, to any person obtaining a copy // of this software and associated documentation files (the "Software"), to deal // in the Software without restriction, including without limitation the rights // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell // copies of the Software, and to permit persons to whom the Software is // furnished to do so, subject to the following conditions: // // The above copyright notice and this permission notice shall be included in // all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN // THE SOFTWARE. package atomic import ( "sync/atomic" "unsafe" ) // UnsafePointer is an atomic wrapper around unsafe.Pointer. type UnsafePointer struct { _ nocmp // disallow non-atomic comparison v unsafe.Pointer } // NewUnsafePointer creates a new UnsafePointer. func NewUnsafePointer(val unsafe.Pointer) *UnsafePointer { return &UnsafePointer{v: val} } // Load atomically loads the wrapped value. func (p *UnsafePointer) Load() unsafe.Pointer { return atomic.LoadPointer(&p.v) } // Store atomically stores the passed value. func (p *UnsafePointer) Store(val unsafe.Pointer) { atomic.StorePointer(&p.v, val) } // Swap atomically swaps the wrapped unsafe.Pointer and returns the old value. func (p *UnsafePointer) Swap(val unsafe.Pointer) (old unsafe.Pointer) { return atomic.SwapPointer(&p.v, val) } // CAS is an atomic compare-and-swap. // // Deprecated: Use CompareAndSwap func (p *UnsafePointer) CAS(old, new unsafe.Pointer) (swapped bool) { return p.CompareAndSwap(old, new) } // CompareAndSwap is an atomic compare-and-swap. func (p *UnsafePointer) CompareAndSwap(old, new unsafe.Pointer) (swapped bool) { return atomic.CompareAndSwapPointer(&p.v, old, new) }