OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
defs:message_queue_
(Results
1 - 11
of
11
) sorted by null
/external/chromium_org/mojo/system/
local_message_pipe_endpoint.h
45
MessageInTransitQueue* message_queue() { return &
message_queue_
; }
54
MessageInTransitQueue
message_queue_
;
member in class:mojo::system::LocalMessagePipeEndpoint
raw_channel.h
147
// front of |
message_queue_
|).
149
// Gets platform handles to be sent (from the front of |
message_queue_
|).
162
// of |
message_queue_
|. Once they are completely written, the front
174
std::deque<MessageInTransit*>
message_queue_
;
member in class:mojo::system::RawChannel::WriteBuffer
/external/chromium_org/third_party/libjingle/source/talk/xmpp/
pingtask.h
62
talk_base::MessageQueue*
message_queue_
;
member in class:buzz::PingTask
/external/chromium_org/content/child/
webmessageportchannel_impl.h
85
MessageQueue
message_queue_
;
member in class:content::WebMessagePortChannelImpl
resource_dispatcher_unittest.cc
171
message_queue_
.push_back(IPC::Message(*msg));
176
size_t queued_messages() const { return
message_queue_
.size(); }
181
if (
message_queue_
.empty()) {
187
if (ResourceHostMsg_RequestResource::ID !=
message_queue_
[0].type() ||
188
!ResourceHostMsg_RequestResource::Read(&
message_queue_
[0], ¶ms)) {
194
message_queue_
.erase(
message_queue_
.begin());
199
ASSERT_FALSE(
message_queue_
.empty());
201
ASSERT_EQ(ResourceHostMsg_FollowRedirect::ID,
message_queue_
[0].type());
203
&
message_queue_
[0], &args))
346
std::vector<IPC::Message>
message_queue_
;
member in class:content::ResourceDispatcherTest
[
all
...]
/external/chromium_org/third_party/webrtc/system_wrappers/source/
trace_impl.h
124
char*
message_queue_
[WEBRTC_TRACE_NUM_ARRAY][WEBRTC_TRACE_MAX_QUEUE];
member in class:webrtc::TraceImpl
/external/chromium_org/content/public/test/
browser_test_utils.h
293
std::queue<std::string>
message_queue_
;
member in class:content::DOMMessageQueue
/external/chromium_org/third_party/libjingle/source/talk/base/
win32socketserver.h
142
MessageQueue *
message_queue_
;
member in class:talk_base::Win32SocketServer
/external/chromium_org/third_party/webrtc/base/
win32socketserver.h
125
MessageQueue *
message_queue_
;
member in class:rtc::Win32SocketServer
/external/chromium_org/content/browser/shared_worker/
shared_worker_service_impl_unittest.cc
111
: MessagePortMessageFilter(callback),
message_queue_
(message_queue) {}
114
if (!
message_queue_
) {
118
message_queue_
->push_back(message);
123
message_queue_
= NULL;
129
ScopedVector<IPC::Message>*
message_queue_
;
member in class:content::__anon11717::MockMessagePortMessageFilter
143
message_queue_
(message_queue) {}
146
if (!
message_queue_
) {
150
message_queue_
->push_back(message);
155
message_queue_
= NULL;
161
ScopedVector<IPC::Message>*
message_queue_
;
member in class:content::__anon11717::MockSharedWorkerMessageFilter
[
all
...]
/external/chromium_org/ipc/
ipc_sync_channel.cc
70
message_queue_
.push_back(QueuedMessage(new Message(msg), context));
106
it =
message_queue_
.begin();
109
for (; it !=
message_queue_
.end(); it++) {
115
it =
message_queue_
.erase(it);
134
SyncMessageQueue::iterator iter =
message_queue_
.begin();
135
while (iter !=
message_queue_
.end()) {
138
iter =
message_queue_
.erase(iter);
205
SyncMessageQueue
message_queue_
;
member in class:IPC::SyncChannel::ReceivedSyncMsgQueue
Completed in 631 milliseconds