Lines Matching defs:me
74 LogTimeEntry *me = reinterpret_cast<LogTimeEntry *>(obj);
78 if (me->mNonBlock) {
79 me->error_Locked();
82 SocketClient *client = me->mClient;
84 if (me->isError_Locked()) {
85 LogReader &reader = me->mReader;
90 if (*it == me) {
92 me->release_Locked();
98 me->mClient = NULL;
106 me->threadRunning = false;
107 me->decRef_Locked();
115 LogTimeEntry *me = reinterpret_cast<LogTimeEntry *>(obj);
119 SocketClient *client = me->mClient;
121 me->error();
125 LogBuffer &logbuf = me->mReader.logbuf();
131 while (me->threadRunning && !me->isError_Locked()) {
132 log_time start = me->mStart;
136 if (me->mTail) {
137 logbuf.flushTo(client, start, privileged, FilterFirstPass, me);
139 start = logbuf.flushTo(client, start, privileged, FilterSecondPass, me);
144 me->error_Locked();
147 if (me->mNonBlock || !me->threadRunning || me->isError_Locked()) {
151 pthread_cond_wait(&me->threadTriggeredCondition, ×Lock);
163 LogTimeEntry *me = reinterpret_cast<LogTimeEntry *>(obj);
167 if (me->mCount == 0) {
168 me->mStart = element->getMonotonicTime();
171 if ((!me->mPid || (me->mPid == element->getPid()))
172 && (me->mLogMask & (1 << element->getLogId()))) {
173 ++me->mCount;
183 LogTimeEntry *me = reinterpret_cast<LogTimeEntry *>(obj);
187 if (me->skipAhead) {
188 me->skipAhead--;
192 me->mStart = element->getMonotonicTime();
195 if (me->mNonBlock && me->mTail && (me->mIndex >= me->mCount)) {
199 if ((me->mLogMask & (1 << element->getLogId())) == 0) {
203 if (me->mPid && (me->mPid != element->getPid())) {
207 if (me->isError_Locked()) {
211 if (!me->mTail) {
215 ++me->mIndex;
217 if ((me->mCount > me->mTail) && (me->mIndex <= (me->mCount - me->mTail))) {
221 if (!me->mNonBlock) {
222 me->mTail = 0;
226 if (!me->skipAhead) {
