Searched refs:streams_resource (Results 1 – 2 of 2) sorted by relevance
302 QuantileStreamResource* streams_resource; in Compute() local305 LookupResource(context, handle, &streams_resource)); in Compute()307 mutex_lock l(*streams_resource->mutex()); in Compute()308 core::ScopedUnref unref_me(streams_resource); in Compute()311 if (!streams_resource->is_stamp_valid(stamp_token)) { in Compute()315 << "Current token: " << streams_resource->stamp(); in Compute()337 streams_resource->stream(stamp_token)->PushSummary(entries); in Compute()470 QuantileStreamResource* streams_resource; in Compute() local473 &streams_resource)); in Compute()475 mutex_lock l(*streams_resource->mutex()); in Compute()[all …]
284 QuantileStreamResource* streams_resource; in Compute() local287 &streams_resource)); in Compute()289 mutex_lock l(*streams_resource->mutex()); in Compute()290 core::ScopedUnref unref_me(streams_resource); in Compute()306 streams_resource->set_boundaries(result, stream_idx); in Compute()