// ------------------------------------------------------------------------ // Project atila // Active Thing (activething.com) git.activething.com/go // // File name go.go // Created by DEV // Modified 16/01/2024 // // Copyright 2024 activething.com // ------------------------------------------------------------------------ // 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 bins import "errs" const ( minBitSize = 6 minSize = 1 << minBitSize maxSize = 1 << (minBitSize + poolSteps - 1) poolSteps = 20 poolThreshold = 42000 poolPercentile = 0.95 ) var ( G = struct { ErrOutOfRange errs.ErrCode ErrWriteCount errs.ErrCode ErrTooShort errs.ErrCode ErrTooLarge errs.ErrCode ErrNegativeRead errs.ErrCode ErrUnreadInvalid errs.ErrCode }{ ErrOutOfRange: errs.ErrCode("core:bins.out-of-range"), ErrWriteCount: errs.ErrCode("core:bins.write-count"), ErrTooShort: errs.ErrCode("core:bins.too-short"), ErrTooLarge: errs.ErrCode("core:bins.too-large"), ErrNegativeRead: errs.ErrCode("core:bins.negative-read"), ErrUnreadInvalid: errs.ErrCode("core:bins.unread-invalid"), } g = struct { bufferPool *BufferPool }{ bufferPool: NewBufferPool(), } ) func AcquireBuffer () *Buffer { return g.bufferPool.Get() } func ReleaseBuffer (buffer *Buffer) { g.bufferPool.Put(buffer) }