Home
last modified time | relevance | path

Searched refs:reader (Results 1 – 25 of 42) sorted by relevance

12

/system/bt/osi/src/
Deager_reader.c61 static bool has_byte(const eager_reader_t *reader);
118 void eager_reader_free(eager_reader_t *reader) { in eager_reader_free() argument
119 if (!reader) in eager_reader_free()
122 eager_reader_unregister(reader); in eager_reader_free()
125 if (reader->inbound_read_object) in eager_reader_free()
126 reactor_unregister(reader->inbound_read_object); in eager_reader_free()
128 if (reader->bytes_available_fd != INVALID_FD) in eager_reader_free()
129 close(reader->bytes_available_fd); in eager_reader_free()
133 if (reader->current_buffer) in eager_reader_free()
134 reader->allocator->free(reader->current_buffer); in eager_reader_free()
[all …]
/system/bt/osi/test/
Deager_reader_test.cpp87 static void expect_data(eager_reader_t *reader, void *context) { in expect_data() argument
93 EXPECT_EQ((size_t)1, eager_reader_read(reader, &byte, 1)); in expect_data()
100 static void expect_data_multibyte(eager_reader_t *reader, void *context) { in expect_data_multibyte() argument
107 size_t bytes_read = eager_reader_read(reader, buffer, bytes_to_read); in expect_data_multibyte()
118 …eager_reader_t *reader = eager_reader_new(pipefd[0], &allocator_malloc, BUFFER_SIZE, SIZE_MAX, "te… in TEST_F() local
119 ASSERT_TRUE(reader != NULL); in TEST_F()
120 eager_reader_free(reader); in TEST_F()
124 …eager_reader_t *reader = eager_reader_new(pipefd[0], &allocator_malloc, BUFFER_SIZE, SIZE_MAX, "te… in TEST_F() local
127 eager_reader_register(reader, thread_get_reactor(read_thread), expect_data, (void *)small_data); in TEST_F()
132 eager_reader_free(reader); in TEST_F()
[all …]
/system/bt/osi/include/
Deager_reader.h31 typedef void (*eager_reader_cb)(eager_reader_t *reader, void *context);
48 void eager_reader_free(eager_reader_t *reader);
53 void eager_reader_register(eager_reader_t *reader, reactor_t *reactor, eager_reader_cb read_cb, voi…
57 void eager_reader_unregister(eager_reader_t *reader);
63 size_t eager_reader_read(eager_reader_t *reader, uint8_t *buffer, size_t max_size);
67 thread_t* eager_reader_get_read_thread(const eager_reader_t *reader);
/system/extras/simpleperf/
Drecord_file_test.cpp79 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile_.path); in TEST_F() local
80 ASSERT_TRUE(reader != nullptr); in TEST_F()
81 const std::vector<FileAttr>& file_attrs = reader->AttrSection(); in TEST_F()
85 ASSERT_TRUE(reader->ReadIdsForAttr(file_attrs[0], &ids)); in TEST_F()
89 std::vector<std::unique_ptr<Record>> records = reader->DataSection(); in TEST_F()
94 std::vector<BuildIdRecord> build_id_records = reader->ReadBuildIdFeature(); in TEST_F()
98 ASSERT_TRUE(reader->Close()); in TEST_F()
126 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile_.path); in TEST_F() local
127 ASSERT_TRUE(reader != nullptr); in TEST_F()
128 std::vector<std::unique_ptr<Record>> records = reader->DataSection(); in TEST_F()
[all …]
Denvironment.cpp76 LineReader reader(fp); in GetOnlineCpus() local
78 if ((line = reader.ReadLine()) != nullptr) { in GetOnlineCpus()
120 LineReader reader(fp); in ProcessKernelSymbols() local
122 while ((line = reader.ReadLine()) != nullptr) { in ProcessKernelSymbols()
124 char name[reader.MaxLineSize()]; in ProcessKernelSymbols()
125 char module[reader.MaxLineSize()]; in ProcessKernelSymbols()
156 LineReader reader(fp); in GetLoadedModules() local
158 while ((line = reader.ReadLine()) != nullptr) { in GetLoadedModules()
160 char name[reader.MaxLineSize()]; in GetLoadedModules()
260 LineReader reader(fp); in ReadThreadNameAndTgid() local
[all …]
Dcmd_record_test.cpp82 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile.path); in TEST() local
83 ASSERT_TRUE(reader != nullptr); in TEST()
84 std::vector<std::unique_ptr<Record>> records = reader->DataSection(); in TEST()
102 std::unique_ptr<RecordFileReader> reader = RecordFileReader::CreateInstance(tmpfile.path); in TEST() local
103 ASSERT_TRUE(reader != nullptr); in TEST()
104 const FileHeader& file_header = reader->FileHeader(); in TEST()
106 ASSERT_GT(reader->FeatureSectionDescriptors().size(), 0u); in TEST()
Drecord_file_reader.cpp39 auto reader = std::unique_ptr<RecordFileReader>(new RecordFileReader(filename, fp)); in CreateInstance() local
40 if (!reader->ReadHeader() || !reader->ReadAttrSection() || in CreateInstance()
41 !reader->ReadFeatureSectionDescriptors()) { in CreateInstance()
44 return reader; in CreateInstance()
/system/tpm/attestation/server/
Ddbus_service_test.cc106 dbus::MessageReader reader(response.get()); in TEST_F() local
108 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&reply)); in TEST_F()
129 dbus::MessageReader reader(response.get()); in TEST_F() local
131 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&reply)); in TEST_F()
158 dbus::MessageReader reader(response.get()); in TEST_F() local
160 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&reply)); in TEST_F()
189 dbus::MessageReader reader(response.get()); in TEST_F() local
191 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&reply)); in TEST_F()
219 dbus::MessageReader reader(response.get()); in TEST_F() local
221 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&reply)); in TEST_F()
[all …]
/system/tpm/tpm_manager/client/
Dtpm_nvram_dbus_proxy_test.cc54 dbus::MessageReader reader(method_call); in TEST_F() local
56 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request)); in TEST_F()
90 dbus::MessageReader reader(method_call); in TEST_F() local
92 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request)); in TEST_F()
123 dbus::MessageReader reader(method_call); in TEST_F() local
125 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request)); in TEST_F()
160 dbus::MessageReader reader(method_call); in TEST_F() local
162 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request)); in TEST_F()
197 dbus::MessageReader reader(method_call); in TEST_F() local
199 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request)); in TEST_F()
[all …]
Dtpm_ownership_dbus_proxy_test.cc52 dbus::MessageReader reader(method_call); in TEST_F() local
54 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request)); in TEST_F()
94 dbus::MessageReader reader(method_call); in TEST_F() local
96 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request)); in TEST_F()
125 dbus::MessageReader reader(method_call); in TEST_F() local
127 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request)); in TEST_F()
/system/tpm/attestation/client/
Ddbus_proxy_test.cc51 dbus::MessageReader reader(method_call); in TEST_F() local
53 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request_proto)); in TEST_F()
98 dbus::MessageReader reader(method_call); in TEST_F() local
100 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request_proto)); in TEST_F()
144 dbus::MessageReader reader(method_call); in TEST_F() local
146 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request_proto)); in TEST_F()
180 dbus::MessageReader reader(method_call); in TEST_F() local
182 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request_proto)); in TEST_F()
222 dbus::MessageReader reader(method_call); in TEST_F() local
224 EXPECT_TRUE(reader.PopArrayOfBytesAsProto(&request_proto)); in TEST_F()
[all …]
/system/core/logd/
DLogListener.cpp34 LogListener::LogListener(LogBuffer *buf, LogReader *reader) : in LogListener() argument
37 reader(reader) { in LogListener()
115 reader->notifyNewLog(); in onDataAvailable()
DLogListener.h25 LogReader *reader; variable
28 LogListener(LogBuffer *buf, LogReader *reader);
DLogAudit.h28 LogReader *reader; variable
33 LogAudit(LogBuffer *buf, LogReader *reader, int fdDmesg);
DLogTimes.cpp27 LogTimeEntry::LogTimeEntry(LogReader &reader, SocketClient *client, in LogTimeEntry() argument
36 mReader(reader), in LogTimeEntry()
86 LogReader &reader = me->mReader; in threadStop() local
87 LastLogTimes &times = reader.logbuf().mTimes; in threadStop()
100 reader.release(client); in threadStop()
DLogKlog.h30 LogReader *reader; variable
44 LogKlog(LogBuffer *buf, LogReader *reader, int fdWrite, int fdRead, bool auditd);
Dmain.cpp469 LogReader *reader = new LogReader(logBuf); in main() local
470 if (reader->startListener()) { in main()
478 LogListener *swl = new LogListener(logBuf, reader); in main()
487 CommandListener *cl = new CommandListener(logBuf, reader, swl); in main()
501 al = new LogAudit(logBuf, reader, in main()
511 kl = new LogKlog(logBuf, reader, fdDmesg, fdPmesg, al != NULL); in main()
DCommandListener.h32 CommandListener(LogBuffer *buf, LogReader *reader, LogListener *swl);
43 ShutdownCmd(LogReader *reader, LogListener *swl);
DFlushCommand.cpp29 FlushCommand::FlushCommand(LogReader &reader, in FlushCommand() argument
36 mReader(reader), in FlushCommand()
DLogAudit.cpp44 LogAudit::LogAudit(LogBuffer *buf, LogReader *reader, int fdDmesg) : in LogAudit() argument
47 reader(reader), in LogAudit()
243 reader->notifyNewLog(); in logPrint()
/system/core/metricsd/uploader/
Dsystem_profile_cache.cc75 brillo::OsReleaseReader reader; in Initialize() local
78 reader.LoadTestingOnly(metrics_directory_); in Initialize()
81 reader.Load(); in Initialize()
93 if (!reader.GetString(metrics::kProductId, &profile_.product_id) in Initialize()
99 if (!reader.GetString(metrics::kProductVersion, &profile_.version)) { in Initialize()
/system/bt/hci/src/
Dhci_hal_mct.c48 static void event_event_stream_has_bytes(eager_reader_t *reader, void *context);
49 static void event_acl_stream_has_bytes(eager_reader_t *reader, void *context);
183 static void event_event_stream_has_bytes(UNUSED_ATTR eager_reader_t *reader, UNUSED_ATTR void *cont… in event_event_stream_has_bytes() argument
187 static void event_acl_stream_has_bytes(UNUSED_ATTR eager_reader_t *reader, UNUSED_ATTR void *contex… in event_acl_stream_has_bytes() argument
Dhci_hal_h4.c55 static void event_uart_has_bytes(eager_reader_t *reader, void *context);
222 static void event_uart_has_bytes(eager_reader_t *reader, UNUSED_ATTR void *context) { in event_uart_has_bytes() argument
227 if (eager_reader_read(reader, &type_byte, 1) == 0) { in event_uart_has_bytes()
/system/connectivity/shill/dbus/
Dchromeos_dhcpcd_listener.cc115 dbus::MessageReader reader(signal.get()); in HandleMessage() local
121 if (brillo::dbus_utils::ExtractMessageParameters(&reader, in HandleMessage()
135 if (brillo::dbus_utils::ExtractMessageParameters(&reader, in HandleMessage()
/system/core/adb/
Dfdevent_test.cpp121 int reader = fd_pair2[0]; in TEST_F() local
131 ASSERT_TRUE(ReadFdExactly(reader, &write_buffer[0], write_buffer.size())); in TEST_F()
137 ASSERT_EQ(0, adb_close(reader)); in TEST_F()

12