ipc/ipc_message.cc

   1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "ipc/ipc_message.h"
   6
   7 //#include "base/logging.h"
   8 #include "log.h"
   9 #include "build/build_config.h"
  10
  11 #if defined(OS_POSIX)
  12 //#include "ipc/file_descriptor_set_posix.h"
  13 #endif
  14
  15 namespace IPC {
  16
  17 //------------------------------------------------------------------------------
  18
  19 Message::~Message() {
  20 }
  21
  22 Message::Message()
  23     : Pickle(sizeof(Header)) {
  24   header()->routing = header()->type = header()->flags = 0;
  25 #if defined(OS_POSIX)
  26   header()->num_fds = 0;
  27   header()->pad = 0;
  28 #endif
  29   InitLoggingVariables();
  30 }
  31
  32 Message::Message(int32 routing_id, uint32 type, PriorityValue priority)
  33     : Pickle(sizeof(Header)) {
  34   header()->routing = routing_id;
  35   header()->type = type;
  36   header()->flags = priority;
  37 #if defined(OS_POSIX)
  38   header()->num_fds = 0;
  39   header()->pad = 0;
  40 #endif
  41   InitLoggingVariables();
  42 }
  43
  44 Message::Message(const char* data, int data_len) : Pickle(data, data_len) {
  45   InitLoggingVariables();
  46 }
  47
  48 Message::Message(const Message& other) : Pickle(other) {
  49   InitLoggingVariables();
  50 #if defined(OS_POSIX)
  51 //  file_descriptor_set_ = other.file_descriptor_set_;
  52 #endif
  53 }
  54
  55 void Message::InitLoggingVariables() {
  56 #ifdef IPC_MESSAGE_LOG_ENABLED
  57   received_time_ = 0;
  58   dont_log_ = false;
  59   log_data_ = NULL;
  60 #endif
  61 }
  62
  63 Message& Message::operator=(const Message& other) {
  64   *static_cast<Pickle*>(this) = other;
  65 #if defined(OS_POSIX)
  66 //  file_descriptor_set_ = other.file_descriptor_set_;
  67 #endif
  68   return *this;
  69 }
  70
  71 #ifdef IPC_MESSAGE_LOG_ENABLED
  72 void Message::set_sent_time(int64 time) {
  73   DCHECK((header()->flags & HAS_SENT_TIME_BIT) == 0);
  74   header()->flags |= HAS_SENT_TIME_BIT;
  75   WriteInt64(time);
  76 }
  77
  78 int64 Message::sent_time() const {
  79   if ((header()->flags & HAS_SENT_TIME_BIT) == 0)
  80     return 0;
  81
  82   const char* data = end_of_payload();
  83   data -= sizeof(int64);
  84   return *(reinterpret_cast<const int64*>(data));
  85 }
  86
  87 void Message::set_received_time(int64 time) const {
  88   received_time_ = time;
  89 }
  90 #endif
  91
  92 #if defined(OS_POSIX)
  93 /*
  94 bool Message::WriteFileDescriptor(const base::FileDescriptor& descriptor) {
  95   // We write the index of the descriptor so that we don't have to
  96   // keep the current descriptor as extra decoding state when deserialising.
  97   WriteInt(file_descriptor_set()->size());
  98   if (descriptor.auto_close) {
  99     return file_descriptor_set()->AddAndAutoClose(descriptor.fd);
 100   } else {
 101     return file_descriptor_set()->Add(descriptor.fd);
 102   }
 103 }
 104
 105 bool Message::ReadFileDescriptor(void** iter,
 106                                  base::FileDescriptor* descriptor) const {
 107   int descriptor_index;
 108   if (!ReadInt(iter, &descriptor_index))
 109     return false;
 110
 111   FileDescriptorSet* file_descriptor_set = file_descriptor_set_.get();
 112   if (!file_descriptor_set)
 113     return false;
 114
 115   descriptor->fd = file_descriptor_set->GetDescriptorAt(descriptor_index);
 116   descriptor->auto_close = true;
 117
 118   return descriptor->fd >= 0;
 119 }
 120
 121 void Message::EnsureFileDescriptorSet() {
 122   if (file_descriptor_set_.get() == NULL)
 123     file_descriptor_set_ = new FileDescriptorSet;
 124 }
 125 */
 126 #endif
 127
 128 }  // namespace IPC