Searched refs:PushRequest (Results 1 – 8 of 8) sorted by relevance
82 Status rc = PushRequest(rq); in ~CacheClient()112 RETURN_IF_NOT_OK(PushRequest(rq)); in WriteRow()131 RETURN_IF_NOT_OK(PushRequest(rq)); in GetRows()138 Status rc2 = PushRequest(mfree_req); in GetRows()203 RETURN_IF_NOT_OK(PushRequest(rq)); in CreateCache()229 RETURN_IF_NOT_OK(PushRequest(rq)); in DestroyCache()241 RETURN_IF_NOT_OK(PushRequest(rq)); in GetStat()252 RETURN_IF_NOT_OK(PushRequest(rq)); in GetState()262 RETURN_IF_NOT_OK(PushRequest(rq)); in CacheSchema()271 RETURN_IF_NOT_OK(PushRequest(rq)); in FetchSchema()[all …]
62 RETURN_IF_NOT_OK(cc->PushRequest(mem_rq)); in SerializeCacheRowRequest()89 Status rc = cc->PushRequest(mfree_req); in SerializeCacheRowRequest()
159 RETURN_IF_NOT_OK(cs.PushRequest(cs.GetRandomWorker(), this)); in operator ()()
219 Status PushRequest(std::shared_ptr<BaseRequest> rq) const;
192 Status PushRequest(int32_t queue_id, CacheServerRequest *rq) { in PushRequest() function
474 RETURN_IF_NOT_OK(PushRequest(worker_id, cache_rq)); in BatchFetch()793 RETURN_IF_NOT_OK(PushRequest(GetRandomWorker(), cache_rq)); in BatchCacheRows()
264 rc = cc->PushRequest(cleaner_copy_); in AsyncSendCacheRequest()
484 RETURN_IF_NOT_OK(cc_->PushRequest(rq)); in Cleanup()