INNER CODE UNIT · Go

len

go-graphite/go-carbon · cache/cache.go:402

		if shard.notConfirmedUsed < len(shard.notConfirmed) {
			shard.notConfirmed[shard.notConfirmedUsed] = p
		} else {
			shard.notConfirmed = append(shard.notConfirmed, p)
		}
		shard.notConfirmedUsed++
	}
	shard.mu.Unlock()

	if exists {
		atomic.AddInt64(&c.stat.size, -int64(len(p.Data)))
	}

	return p, exists
}

func (c *Cache) WriteoutQueue() *WriteoutQueue {
	return c.writeoutQueue

View source record →