Method openWriter

internal/caches/storage_memory.go:187–249

(key string, expiresAt int64, status int, headerSize int, bodySize int64, maxSize int64, isDirty bool)

}

func (this *MemoryStorage) openWriter(key string, expiresAt int64, status int, headerSize int, bodySize int64, maxSize int64, isDirty bool) (Writer, error) {
	// 待写入队列是否已满
	if isDirty &&
		this.parentStorage != nil &&
		this.dirtyQueueSize > 0 &&
		len(this.dirtyChan) >= this.dirtyQueueSize-64 /** delta **/ { // 缓存时间过长
		return nil, ErrWritingQueueFull
	}

	this.locker.Lock()
	defer this.locker.Unlock()

	// 是否正在写入
	var isWriting = false
	_, ok := this.writingKeyMap[key]
	if ok {
		return nil, fmt.Errorf("%w (005)", ErrFileIsWriting)
	}
	this.writingKeyMap[key] = zero.New()
	defer func() {
		if !isWriting {
			delete(this.writingKeyMap, key)
		}
	}()

	// 检查是否过期
	var hash = this.hash(key)
	item, ok := this.valuesMap[hash]
	if ok && !item.IsExpired() {
		var hashString = types.String(hash)
		exists, _, _ := this.list.Exist(hashString)
		if !exists {
			// remove from values map
			delete(this.valuesMap, hash)
			_ = this.list.Remove(hashString)
			item = nil
		} else {
			return nil, fmt.Errorf("%w (006)", ErrFileIsWriting)
		}
	}

	// 检查是否超出容量最大值
	var capacityBytes = this.memoryCapacityBytes()
	if bodySize < 0 {
		bodySize = 0
	}
	if capacityBytes > 0 && capacityBytes <= atomic.LoadInt64(&this.usedSize)+bodySize {
		return nil, NewCapacityError("write memory cache failed: over memory size: " + strconv.FormatInt(capacityBytes, 10) + ", current size: " + strconv.FormatInt(this.usedSize, 10) + " bytes")
	}

	// 先删除
	err := this.deleteWithoutLocker(key)
	if err != nil {
		return nil, err
	}

	isWriting = true
	return NewMemoryWriter(this, key, expiresAt, status, isDirty, bodySize, maxSize, func(valueItem *MemoryItem) {