MCPcopy Create free account
hub / github.com/catboost/catboost / Dequeue

Function Dequeue

library/cpp/neh/tcp.cpp:120–137  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

118
119 template <class Q, class C>
120 inline bool Dequeue(Q& q, C& c, size_t len) {
121 typename C::value_type t;
122 size_t slen = 0;
123
124 if (q.Dequeue(t)) {
125 slen += t->Length();
126 c.push_back(t);
127
128 while (slen < len && q.TryDequeue(t)) {
129 slen += t->Length();
130 c.push_back(t);
131 }
132
133 return true;
134 }
135
136 return false;
137 }
138
139 struct TServer: public IRequester, public TContListener::ICallBack {
140 struct TLink;

Callers 8

~TAutoLockFreeQueueMethod · 0.70
DequeueSafeMethod · 0.70
DequeueSafeMethod · 0.70
DoSendCycleMethod · 0.70
DoSendCycleMethod · 0.70
~TAutoQueueBaseMethod · 0.50
~TAutoLockFreeQueueMethod · 0.50
WorkerMethod · 0.50

Calls 4

TryDequeueMethod · 0.80
DequeueMethod · 0.45
LengthMethod · 0.45
push_backMethod · 0.45

Tested by

no test coverage detected