blob: 91f4769c7377f153a82c788bc3a5a0a3b693ae9c (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
// Copyright 2015 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chromeos/binder/transaction_data_from_driver.h"
#include <stddef.h>
#include <stdint.h>
#include "base/bind.h"
#include "base/location.h"
#include "base/logging.h"
#include "base/single_thread_task_runner.h"
#include "base/thread_task_runner_handle.h"
#include "chromeos/binder/command_stream.h"
namespace binder {
TransactionDataFromDriver::TransactionDataFromDriver(
const BufferDeleter& buffer_deleter)
: delete_task_runner_(base::ThreadTaskRunnerHandle::Get()),
buffer_deleter_(buffer_deleter) {
memset(&data_, 0, sizeof(data_));
}
TransactionDataFromDriver::~TransactionDataFromDriver() {
if (!HasStatus()) { // Need to free the payload.
// Close FDs.
for (size_t i = 0; i < GetNumObjectOffsets(); ++i) {
const auto& object = *reinterpret_cast<const flat_binder_object*>(
reinterpret_cast<const char*>(GetData()) + GetObjectOffsets()[i]);
if (object.type == BINDER_TYPE_FD) {
close(object.handle);
}
}
// Free data buffer.
if (delete_task_runner_->BelongsToCurrentThread()) {
buffer_deleter_.Run(GetData());
} else {
delete_task_runner_->PostTask(FROM_HERE,
base::Bind(buffer_deleter_, GetData()));
}
}
}
uintptr_t TransactionDataFromDriver::GetCookie() const {
return data_.cookie;
}
uint32_t TransactionDataFromDriver::GetCode() const {
return data_.code;
}
pid_t TransactionDataFromDriver::GetSenderPID() const {
return data_.sender_pid;
}
uid_t TransactionDataFromDriver::GetSenderEUID() const {
return data_.sender_euid;
}
bool TransactionDataFromDriver::IsOneWay() const {
return data_.flags & TF_ONE_WAY;
}
bool TransactionDataFromDriver::HasStatus() const {
return data_.flags & TF_STATUS_CODE;
}
Status TransactionDataFromDriver::GetStatus() const {
DCHECK(HasStatus());
return *reinterpret_cast<const Status*>(data_.data.ptr.buffer);
}
const void* TransactionDataFromDriver::GetData() const {
return reinterpret_cast<const void*>(data_.data.ptr.buffer);
}
size_t TransactionDataFromDriver::GetDataSize() const {
return data_.data_size;
}
const binder_uintptr_t* TransactionDataFromDriver::GetObjectOffsets() const {
return reinterpret_cast<const binder_uintptr_t*>(data_.data.ptr.offsets);
}
size_t TransactionDataFromDriver::GetNumObjectOffsets() const {
DCHECK_EQ(0u, data_.offsets_size % sizeof(binder_size_t));
return data_.offsets_size / sizeof(binder_size_t);
}
} // namespace binder
|
