TRKJ/EdgeNode
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeNode.git synced 2025-11-20 04:50:26 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化代码

Browse Source
This commit is contained in:
GoEdgeLab
2024-03-22 09:21:45 +08:00
parent aef4abdbdd
commit 75a4cc490f
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
internal/nodes/api_stream.go
View File

@@ -209,7 +209,7 @@ func (this *APIStream) handleWriteCache(message *pb.NodeStreamMessage) error {
storage.AddToList(&caches.Item{ storage.AddToList(&caches.Item{
Type: writer.ItemType(), Type: writer.ItemType(),
Key: msg.Key, Key: msg.Key,
ExpiredAt: expiredAt, ExpiresAt: expiredAt,
HeaderSize: writer.HeaderSize(), HeaderSize: writer.HeaderSize(),
BodySize: writer.BodySize(), BodySize: writer.BodySize(),
}) })

8
internal/nodes/http_writer.go
View File

@@ -1168,7 +1168,7 @@ func (this *HTTPWriter) finishWebP() {
this.cacheStorage.AddToList(&caches.Item{ this.cacheStorage.AddToList(&caches.Item{
Type: webpCacheWriter.ItemType(), Type: webpCacheWriter.ItemType(),
Key: webpCacheWriter.Key(), Key: webpCacheWriter.Key(),
ExpiredAt: webpCacheWriter.ExpiredAt(), ExpiresAt: webpCacheWriter.ExpiredAt(),
StaleAt: webpCacheWriter.ExpiredAt() + int64(this.calculateStaleLife()), StaleAt: webpCacheWriter.ExpiredAt() + int64(this.calculateStaleLife()),
HeaderSize: webpCacheWriter.HeaderSize(), HeaderSize: webpCacheWriter.HeaderSize(),
BodySize: webpCacheWriter.BodySize(), BodySize: webpCacheWriter.BodySize(),
@@ -1207,7 +1207,7 @@ func (this *HTTPWriter) finishCache() {
this.cacheStorage.AddToList(&caches.Item{ this.cacheStorage.AddToList(&caches.Item{
Type: this.cacheWriter.ItemType(), Type: this.cacheWriter.ItemType(),
Key: this.cacheWriter.Key(), Key: this.cacheWriter.Key(),
ExpiredAt: expiredAt, ExpiresAt: expiredAt,
StaleAt: expiredAt + int64(this.calculateStaleLife()), StaleAt: expiredAt + int64(this.calculateStaleLife()),
HeaderSize: this.cacheWriter.HeaderSize(), HeaderSize: this.cacheWriter.HeaderSize(),
BodySize: this.cacheWriter.BodySize(), BodySize: this.cacheWriter.BodySize(),
@@ -1228,7 +1228,7 @@ func (this *HTTPWriter) finishCache() {
this.cacheStorage.AddToList(&caches.Item{ this.cacheStorage.AddToList(&caches.Item{
Type: this.cacheWriter.ItemType(), Type: this.cacheWriter.ItemType(),
Key: this.cacheWriter.Key(), Key: this.cacheWriter.Key(),
ExpiredAt: expiredAt, ExpiresAt: expiredAt,
StaleAt: expiredAt + int64(this.calculateStaleLife()), StaleAt: expiredAt + int64(this.calculateStaleLife()),
HeaderSize: this.cacheWriter.HeaderSize(), HeaderSize: this.cacheWriter.HeaderSize(),
BodySize: this.cacheWriter.BodySize(), BodySize: this.cacheWriter.BodySize(),
@@ -1251,7 +1251,7 @@ func (this *HTTPWriter) finishCompression() {
this.cacheStorage.AddToList(&caches.Item{ this.cacheStorage.AddToList(&caches.Item{
Type: this.compressionCacheWriter.ItemType(), Type: this.compressionCacheWriter.ItemType(),
Key: this.compressionCacheWriter.Key(), Key: this.compressionCacheWriter.Key(),
ExpiredAt: expiredAt, ExpiresAt: expiredAt,
StaleAt: expiredAt + int64(this.calculateStaleLife()), StaleAt: expiredAt + int64(this.calculateStaleLife()),
HeaderSize: this.compressionCacheWriter.HeaderSize(), HeaderSize: this.compressionCacheWriter.HeaderSize(),
BodySize: this.compressionCacheWriter.BodySize(), BodySize: this.compressionCacheWriter.BodySize(),