MCPcopy Create free account
hub / github.com/baidu/tera / ScheduleRowKey

Method ScheduleRowKey

src/observer/rowlockproxy/rowlock_proxy_impl.cc:70–78  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

68}
69
70std::string RowlockProxyImpl::ScheduleRowKey(uint64_t row_key) {
71 std::shared_ptr<std::vector<std::string>> server_addrs_copy;
72
73 MutexLock locker(&server_addrs_mutex_);
74 // copy for copy-on-write, ref +1
75 server_addrs_copy = server_addrs_;
76
77 return (*server_addrs_copy)[row_key % server_number_];
78}
79
80void RowlockProxyImpl::SetServerNumber(uint32_t number) {
81 MutexLock locker(&server_addrs_mutex_);

Callers 1

TESTFunction · 0.80

Calls

no outgoing calls

Tested by 1

TESTFunction · 0.64