MCPcopy Create free account
hub / github.com/apache/datafusion / take_requests

Method take_requests

datafusion-cli/src/object_storage/instrumented.rs:162–166  ·  view source on GitHub ↗

Returns all [`RequestDetails`] accumulated in this [`InstrumentedObjectStore`] and clears the stored requests

(&self)

Source from the content-addressed store, hash-verified

160 /// Returns all [`RequestDetails`] accumulated in this [`InstrumentedObjectStore`] and clears
161 /// the stored requests
162 pub fn take_requests(&self) -> Vec<RequestDetails> {
163 let mut req = self.requests.lock();
164
165 req.drain(..).collect()
166 }
167
168 fn enabled(&self) -> bool {
169 self.instrument_mode.load(Ordering::Relaxed)

Calls 2

collectMethod · 0.80
drainMethod · 0.80

Tested by

no test coverage detected