logd/LogBufferElement.cpp

   1 /*
   2  * Copyright (C) 2012-2014 The Android Open Source Project
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *      http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 #include <stdio.h>
  18 #include <string.h>
  19 #include <time.h>
  20 #include <unistd.h>
  21
  22 #include <log/logger.h>
  23
  24 #include "LogBufferElement.h"
  25 #include "LogReader.h"
  26
  27 const log_time LogBufferElement::FLUSH_ERROR((uint32_t)0, (uint32_t)0);
  28
  29 LogBufferElement::LogBufferElement(log_id_t log_id, log_time realtime,
  30                                    uid_t uid, pid_t pid, pid_t tid,
  31                                    const char *msg, unsigned short len)
  32         : mLogId(log_id)
  33         , mUid(uid)
  34         , mPid(pid)
  35         , mTid(tid)
  36         , mMsgLen(len)
  37         , mMonotonicTime(CLOCK_MONOTONIC)
  38         , mRealTime(realtime) {
  39     mMsg = new char[len];
  40     memcpy(mMsg, msg, len);
  41 }
  42
  43 LogBufferElement::~LogBufferElement() {
  44     delete [] mMsg;
  45 }
  46
  47 log_time LogBufferElement::flushTo(SocketClient *reader) {
  48     struct logger_entry_v3 entry;
  49     memset(&entry, 0, sizeof(struct logger_entry_v3));
  50     entry.hdr_size = sizeof(struct logger_entry_v3);
  51     entry.len = mMsgLen;
  52     entry.lid = mLogId;
  53     entry.pid = mPid;
  54     entry.tid = mTid;
  55     entry.sec = mRealTime.tv_sec;
  56     entry.nsec = mRealTime.tv_nsec;
  57
  58     struct iovec iovec[2];
  59     iovec[0].iov_base = &entry;
  60     iovec[0].iov_len = sizeof(struct logger_entry_v3);
  61     iovec[1].iov_base = mMsg;
  62     iovec[1].iov_len = mMsgLen;
  63     if (reader->sendDatav(iovec, 2)) {
  64         return FLUSH_ERROR;
  65     }
  66
  67     return mMonotonicTime;
  68 }