MCPcopy Create free account
hub / github.com/catboost/catboost / ~TThreadedResolver

Method ~TThreadedResolver

library/cpp/dns/thread.cpp:67–83  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

65 }
66
67 inline ~TThreadedResolver() override {
68 Schedule(nullptr);
69
70 for (size_t i = 0; i < T_.size(); ++i) {
71 T_[i]->Join();
72 }
73
74 {
75 TResolveRequest* rr = nullptr;
76
77 while (Q_.Dequeue(&rr)) {
78 if (rr) {
79 rr->Wake();
80 }
81 }
82 }
83 }
84
85 static inline TThreadedResolver* Instance() {
86 return Singleton<TThreadedResolver>();

Callers

nothing calls this directly

Calls 4

sizeMethod · 0.45
JoinMethod · 0.45
DequeueMethod · 0.45
WakeMethod · 0.45

Tested by

no test coverage detected