OpenFlushWriter 打开从其他媒介直接刷入的写入器
(key string, expiresAt int64, status int, headerSize int, bodySize int64)
| 181 | |
| 182 | // OpenFlushWriter 打开从其他媒介直接刷入的写入器 |
| 183 | func (this *MemoryStorage) OpenFlushWriter(key string, expiresAt int64, status int, headerSize int, bodySize int64) (Writer, error) { |
| 184 | return this.openWriter(key, expiresAt, status, headerSize, bodySize, -1, true) |
| 185 | } |
| 186 | |
| 187 | func (this *MemoryStorage) openWriter(key string, expiresAt int64, status int, headerSize int, bodySize int64, maxSize int64, isDirty bool) (Writer, error) { |
| 188 | // 待写入队列是否已满 |
nothing calls this directly
no test coverage detected