75     LogTimeEntry *me = reinterpret_cast<LogTimeEntry *>(obj);  in threadStop()  local
79     if (me->mNonBlock) {  in threadStop()
80         me->error_Locked();  in threadStop()
83     SocketClient *client = me->mClient;  in threadStop()
85     if (me->isError_Locked()) {  in threadStop()
86         LogReader &reader = me->mReader;  in threadStop()
91             if (*it == me) {  in threadStop()
93                 me->release_nodelete_Locked();  in threadStop()
99         me->mClient = NULL;  in threadStop()
107     me->threadRunning = false;  in threadStop()
108     me->decRef_Locked();  in threadStop()
116     LogTimeEntry *me = reinterpret_cast<LogTimeEntry *>(obj);  in threadStart()  local
120     SocketClient *client = me->mClient;  in threadStart()
122         me->error();  in threadStart()
126     LogBuffer &logbuf = me->mReader.logbuf();  in threadStart()
131     me->leadingDropped = true;  in threadStart()
135     uint64_t start = me->mStart;  in threadStart()
137     while (me->threadRunning && !me->isError_Locked()) {  in threadStart()
139         if (me->mTimeout.tv_sec || me->mTimeout.tv_nsec) {  in threadStart()
140             if (pthread_cond_timedwait(&me->threadTriggeredCondition,  in threadStart()
142                                        &me->mTimeout) == ETIMEDOUT) {  in threadStart()
143                 me->mTimeout.tv_sec = 0;  in threadStart()
144                 me->mTimeout.tv_nsec = 0;  in threadStart()
146             if (!me->threadRunning || me->isError_Locked()) {  in threadStart()
153         if (me->mTail) {  in threadStart()
154             logbuf.flushTo(client, start, privileged, security, FilterFirstPass, me);  in threadStart()
155             me->leadingDropped = true;  in threadStart()
157         start = logbuf.flushTo(client, start, privileged, security, FilterSecondPass, me);  in threadStart()
162             me->error_Locked();  in threadStart()
166         me->mStart = start + 1;  in threadStart()
168         if (me->mNonBlock || !me->threadRunning || me->isError_Locked()) {  in threadStart()
172         me->cleanSkip_Locked();  in threadStart()
174         if (!me->mTimeout.tv_sec && !me->mTimeout.tv_nsec) {  in threadStart()
175             pthread_cond_wait(&me->threadTriggeredCondition, &timesLock);  in threadStart()
188     LogTimeEntry *me = reinterpret_cast<LogTimeEntry *>(obj);  in FilterFirstPass()  local
192     if (me->leadingDropped) {  in FilterFirstPass()
197         me->leadingDropped = false;  in FilterFirstPass()
200     if (me->mCount == 0) {  in FilterFirstPass()
201         me->mStart = element->getSequence();  in FilterFirstPass()
204     if ((!me->mPid || (me->mPid == element->getPid()))  in FilterFirstPass()
205             && (me->isWatching(element->getLogId()))) {  in FilterFirstPass()
206         ++me->mCount;  in FilterFirstPass()
216     LogTimeEntry *me = reinterpret_cast<LogTimeEntry *>(obj);  in FilterSecondPass()  local
220     me->mStart = element->getSequence();  in FilterSecondPass()
222     if (me->skipAhead[element->getLogId()]) {  in FilterSecondPass()
223         me->skipAhead[element->getLogId()]--;  in FilterSecondPass()
227     if (me->leadingDropped) {  in FilterSecondPass()
231         me->leadingDropped = false;  in FilterSecondPass()
235     if (me->mNonBlock && me->mTail && (me->mIndex >= me->mCount)) {  in FilterSecondPass()
239     if (!me->isWatching(element->getLogId())) {  in FilterSecondPass()
243     if (me->mPid && (me->mPid != element->getPid())) {  in FilterSecondPass()
247     if (me->isError_Locked()) {  in FilterSecondPass()
251     if (!me->mTail) {  in FilterSecondPass()
255     ++me->mIndex;  in FilterSecondPass()
257     if ((me->mCount > me->mTail) && (me->mIndex <= (me->mCount - me->mTail))) {  in FilterSecondPass()
261     if (!me->mNonBlock) {  in FilterSecondPass()
262         me->mTail = 0;  in FilterSecondPass()
266     if (!me->skipAhead[element->getLogId()]) {  in FilterSecondPass()