Mercurial > hg > orthanc

comparison OrthancFramework/Sources/FileStorage/StorageAccessor.cpp @ 5337:b376abae664a

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Metrics can be stored either as floating-point numbers, or as integers
author Sebastien Jodogne <s.jodogne@gmail.com>
date Tue, 27 Jun 2023 17:55:09 +0200
parents d0752fd53aec
children aaf7c49a9ddc d37dff2c0028
comparison
equal deleted inserted replaced
5336:dd9795dc380d 5337:b376abae664a
123 area_.Create(uuid, data, size, type); 123 area_.Create(uuid, data, size, type);
124 } 124 }
125 125
126 if (metrics_ != NULL) 126 if (metrics_ != NULL)
127 { 127 {
128 metrics_->IncrementValue(METRICS_WRITTEN_BYTES, size); 128 metrics_->IncrementIntegerValue(METRICS_WRITTEN_BYTES, size);
129 } 129 }
130 130
131 if (cache_ != NULL) 131 if (cache_ != NULL)
132 { 132 {
133 cache_->Add(uuid, type, data, size); 133 cache_->Add(uuid, type, data, size);
163 } 163 }
164 } 164 }
165 165
166 if (metrics_ != NULL) 166 if (metrics_ != NULL)
167 { 167 {
168 metrics_->IncrementValue(METRICS_WRITTEN_BYTES, compressed.size()); 168 metrics_->IncrementIntegerValue(METRICS_WRITTEN_BYTES, compressed.size());
169 } 169 }
170 170
171 if (cache_ != NULL) 171 if (cache_ != NULL)
172 { 172 {
173 cache_->Add(uuid, type, data, size); // always add uncompressed data to cache 173 cache_->Add(uuid, type, data, size); // always add uncompressed data to cache
209 buffer.reset(area_.Read(info.GetUuid(), info.GetContentType())); 209 buffer.reset(area_.Read(info.GetUuid(), info.GetContentType()));
210 } 210 }
211 211
212 if (metrics_ != NULL) 212 if (metrics_ != NULL)
213 { 213 {
214 metrics_->IncrementValue(METRICS_READ_BYTES, buffer->GetSize()); 214 metrics_->IncrementIntegerValue(METRICS_READ_BYTES, buffer->GetSize());
215 } 215 }
216 216
217 buffer->MoveToString(content); 217 buffer->MoveToString(content);
218 218
219 break; 219 break;
230 compressed.reset(area_.Read(info.GetUuid(), info.GetContentType())); 230 compressed.reset(area_.Read(info.GetUuid(), info.GetContentType()));
231 } 231 }
232 232
233 if (metrics_ != NULL) 233 if (metrics_ != NULL)
234 { 234 {
235 metrics_->IncrementValue(METRICS_READ_BYTES, compressed->GetSize()); 235 metrics_->IncrementIntegerValue(METRICS_READ_BYTES, compressed->GetSize());
236 } 236 }
237 237
238 zlib.Uncompress(content, compressed->GetData(), compressed->GetSize()); 238 zlib.Uncompress(content, compressed->GetData(), compressed->GetSize());
239 239
240 break; 240 break;
269 buffer.reset(area_.Read(info.GetUuid(), info.GetContentType())); 269 buffer.reset(area_.Read(info.GetUuid(), info.GetContentType()));
270 } 270 }
271 271
272 if (metrics_ != NULL) 272 if (metrics_ != NULL)
273 { 273 {
274 metrics_->IncrementValue(METRICS_READ_BYTES, buffer->GetSize()); 274 metrics_->IncrementIntegerValue(METRICS_READ_BYTES, buffer->GetSize());
275 } 275 }
276 276
277 buffer->MoveToString(content); 277 buffer->MoveToString(content);
278 } 278 }
279 } 279 }
315 assert(buffer->GetSize() == end); 315 assert(buffer->GetSize() == end);
316 } 316 }
317 317
318 if (metrics_ != NULL) 318 if (metrics_ != NULL)
319 { 319 {
320 metrics_->IncrementValue(METRICS_READ_BYTES, buffer->GetSize()); 320 metrics_->IncrementIntegerValue(METRICS_READ_BYTES, buffer->GetSize());
321 } 321 }
322 322
323 buffer->MoveToString(target); 323 buffer->MoveToString(target);
324 324
325 if (cache_ != NULL) 325 if (cache_ != NULL)