Lines Matching refs:SyncChannel
33 // To work around this, when SyncChannel filters a sync message, it sets
40 // SyncChannel objects on the same thread (since one object can receive a
43 class SyncChannel::ReceivedSyncMsgQueue :
50 // SyncChannel objects can block the same thread).
61 void QueueMessage(const Message& msg, SyncChannel::SyncContext* context) {
83 void QueueReply(const Message &msg, SyncChannel::SyncContext* context) {
103 scoped_refptr<SyncChannel::SyncContext> context;
131 // SyncChannel calls this in its destructor.
185 // See the comment in SyncChannel::SyncChannel for why this event is created
202 scoped_refptr<SyncChannel::SyncContext> context;
226 base::LazyInstance<base::ThreadLocalPointer<SyncChannel::ReceivedSyncMsgQueue> >
227 SyncChannel::ReceivedSyncMsgQueue::lazy_tls_ptr_ =
230 SyncChannel::SyncContext::SyncContext(
240 SyncChannel::SyncContext::~SyncContext() {
248 void SyncChannel::SyncContext::Push(SyncMessage* sync_msg) {
264 bool SyncChannel::SyncContext::Pop() {
288 WaitableEvent* SyncChannel::SyncContext::GetSendDoneEvent() {
293 WaitableEvent* SyncChannel::SyncContext::GetDispatchEvent() {
297 void SyncChannel::SyncContext::DispatchMessages() {
301 bool SyncChannel::SyncContext::TryToUnblockListener(const Message* msg) {
323 void SyncChannel::SyncContext::Clear() {
329 bool SyncChannel::SyncContext::OnMessageReceived(const Message& msg) {
350 void SyncChannel::SyncContext::OnChannelError() {
356 void SyncChannel::SyncContext::OnChannelOpened() {
359 base::Bind(&SyncChannel::SyncContext::OnWaitableEventSignaled,
364 void SyncChannel::SyncContext::OnChannelClosed() {
370 void SyncChannel::SyncContext::OnSendTimeout(int message_id) {
382 void SyncChannel::SyncContext::CancelPendingSends() {
391 void SyncChannel::SyncContext::OnWaitableEventSignaled(WaitableEvent* event) {
404 SyncChannel::SyncContext::MakeWaitableEventCallback() {
405 return base::Bind(&SyncChannel::SyncContext::OnWaitableEventSignaled, this);
409 scoped_ptr<SyncChannel> SyncChannel::Create(
416 scoped_ptr<SyncChannel> channel =
423 scoped_ptr<SyncChannel> SyncChannel::Create(
429 scoped_ptr<SyncChannel> channel =
436 scoped_ptr<SyncChannel> SyncChannel::Create(
441 new SyncChannel(listener, ipc_task_runner, shutdown_event));
444 SyncChannel::SyncChannel(
455 SyncChannel::~SyncChannel() {
458 void SyncChannel::SetRestrictDispatchChannelGroup(int group) {
462 bool SyncChannel::Send(Message* message) {
467 TRACE_EVENT1("ipc", "SyncChannel::Send", "name", name);
469 TRACE_EVENT2("ipc", "SyncChannel::Send",
499 void SyncChannel::WaitForReply(
526 void SyncChannel::WaitForReplyWithNestedMessageLoop(SyncContext* context) {
564 void SyncChannel::OnWaitableEventSignaled(WaitableEvent* event) {
573 void SyncChannel::StartWatching() {
581 base::Bind(&SyncChannel::OnWaitableEventSignaled,
