Searched refs:UnixSocketMessage (Results 1 – 6 of 6) sorted by relevance
45 send_msg.len = sizeof(UnixSocketMessage) + n; in TEST()48 *reinterpret_cast<UnixSocketMessage*>(&send_msg))) { in TEST()67 read_func(sizeof(UnixSocketMessage)); in TEST()72 ASSERT_EQ(msg->len, msg->type + sizeof(UnixSocketMessage)); in TEST()86 auto receive_message_callback = [&](const UnixSocketMessage& msg) { in ClientToTestUndelayedMessage()87 if (msg.len != sizeof(UnixSocketMessage)) { in ClientToTestUndelayedMessage()90 UnixSocketMessage reply_msg; in ClientToTestUndelayedMessage()91 reply_msg.len = sizeof(UnixSocketMessage); in ClientToTestUndelayedMessage()116 auto receive_message_callback = [&](const UnixSocketMessage& msg) { in TEST()117 if (msg.len != sizeof(UnixSocketMessage) || msg.type != need_reply_type) { in TEST()[all …]
69 bool HandleMessage(const UnixSocketMessage& msg);70 bool ParseStartProfilingMessage(const UnixSocketMessage& msg);97 auto read_callback = [&](const UnixSocketMessage& msg) { in Run()109 bool SampleManager::HandleMessage(const UnixSocketMessage& msg) { in HandleMessage()130 bool SampleManager::ParseStartProfilingMessage(const UnixSocketMessage& msg) { in ParseStartProfilingMessage()175 size_t size = sizeof(UnixSocketMessage) + strlen(s) + 1; in SendStartProfilingReplyMessage()177 UnixSocketMessage* msg = reinterpret_cast<UnixSocketMessage*>(data.get()); in SendStartProfilingReplyMessage()238 size_t size = sizeof(UnixSocketMessage) + sizeof(uint64_t) + sizeof(uint32_t) + in CheckThreadNameChange()241 UnixSocketMessage* msg = reinterpret_cast<UnixSocketMessage*>(data.get()); in CheckThreadNameChange()277 size_t size = sizeof(UnixSocketMessage) + sizeof(uint64_t) * 4 + map.name.size() + 1; in CheckMapChange()[all …]
75 auto read_callback = [&](const UnixSocketMessage& msg) { in StartPolling()116 size_t size = sizeof(UnixSocketMessage) + options.size() + 1; in SendStartProfilingMessage()118 UnixSocketMessage* msg = reinterpret_cast<UnixSocketMessage*>(data.get()); in SendStartProfilingMessage()127 auto read_callback = [&](const UnixSocketMessage& msg) { in StopProfiling()134 UnixSocketMessage msg; in StopProfiling()135 msg.len = sizeof(UnixSocketMessage); in StopProfiling()140 bool InplaceSamplerClient::HandleMessage(const UnixSocketMessage& msg) { in HandleMessage()
38 struct UnixSocketMessage { struct64 bool StoreMessage(const UnixSocketMessage& message) { in StoreMessage()158 const std::function<bool(const UnixSocketMessage&)>&166 bool SendMessage(const UnixSocketMessage& message, bool undelayed) { in SendMessage()222 std::function<bool(const UnixSocketMessage&)> read_callback_;
106 IOEventLoop& loop, const std::function<bool(const UnixSocketMessage&)>& in PrepareForIO()184 while (left_size >= sizeof(UnixSocketMessage)) { in ConsumeDataInReadBuffer()185 UnixSocketMessage* msg = reinterpret_cast<UnixSocketMessage*>(p); in ConsumeDataInReadBuffer()
44 bool HandleMessage(const UnixSocketMessage& msg);