Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(224)

Side by Side Diff: third_party/mojo/src/mojo/edk/system/data_pipe_consumer_dispatcher.h

Issue 1676913002: [mojo] Delete third_party/mojo (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: let's try that again Created 4 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
(Empty)
1 // Copyright 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #ifndef THIRD_PARTY_MOJO_SRC_MOJO_EDK_SYSTEM_DATA_PIPE_CONSUMER_DISPATCHER_H_
6 #define THIRD_PARTY_MOJO_SRC_MOJO_EDK_SYSTEM_DATA_PIPE_CONSUMER_DISPATCHER_H_
7
8 #include "base/memory/ref_counted.h"
9 #include "mojo/public/cpp/system/macros.h"
10 #include "third_party/mojo/src/mojo/edk/system/dispatcher.h"
11 #include "third_party/mojo/src/mojo/edk/system/system_impl_export.h"
12
13 namespace mojo {
14 namespace system {
15
16 class DataPipe;
17
18 // This is the |Dispatcher| implementation for the consumer handle for data
19 // pipes (created by the Mojo primitive |MojoCreateDataPipe()|). This class is
20 // thread-safe.
21 class MOJO_SYSTEM_IMPL_EXPORT DataPipeConsumerDispatcher final
22 : public Dispatcher {
23 public:
24 static scoped_refptr<DataPipeConsumerDispatcher> Create() {
25 return make_scoped_refptr(new DataPipeConsumerDispatcher());
26 }
27
28 // Must be called before any other methods.
29 void Init(scoped_refptr<DataPipe> data_pipe) MOJO_NOT_THREAD_SAFE;
30
31 // |Dispatcher| public methods:
32 Type GetType() const override;
33
34 // The "opposite" of |SerializeAndClose()|. (Typically this is called by
35 // |Dispatcher::Deserialize()|.)
36 static scoped_refptr<DataPipeConsumerDispatcher>
37 Deserialize(Channel* channel, const void* source, size_t size);
38
39 // Get access to the |DataPipe| for testing.
40 DataPipe* GetDataPipeForTest();
41
42 private:
43 DataPipeConsumerDispatcher();
44 ~DataPipeConsumerDispatcher() override;
45
46 // |Dispatcher| protected methods:
47 void CancelAllAwakablesNoLock() override;
48 void CloseImplNoLock() override;
49 scoped_refptr<Dispatcher> CreateEquivalentDispatcherAndCloseImplNoLock()
50 override;
51 MojoResult ReadDataImplNoLock(UserPointer<void> elements,
52 UserPointer<uint32_t> num_bytes,
53 MojoReadDataFlags flags) override;
54 MojoResult BeginReadDataImplNoLock(UserPointer<const void*> buffer,
55 UserPointer<uint32_t> buffer_num_bytes,
56 MojoReadDataFlags flags) override;
57 MojoResult EndReadDataImplNoLock(uint32_t num_bytes_read) override;
58 HandleSignalsState GetHandleSignalsStateImplNoLock() const override;
59 MojoResult AddAwakableImplNoLock(Awakable* awakable,
60 MojoHandleSignals signals,
61 uintptr_t context,
62 HandleSignalsState* signals_state) override;
63 void RemoveAwakableImplNoLock(Awakable* awakable,
64 HandleSignalsState* signals_state) override;
65 void StartSerializeImplNoLock(Channel* channel,
66 size_t* max_size,
67 size_t* max_platform_handles) override
68 MOJO_NOT_THREAD_SAFE;
69 bool EndSerializeAndCloseImplNoLock(
70 Channel* channel,
71 void* destination,
72 size_t* actual_size,
73 embedder::PlatformHandleVector* platform_handles) override
74 MOJO_NOT_THREAD_SAFE;
75 bool IsBusyNoLock() const override;
76
77 // This will be null if closed.
78 scoped_refptr<DataPipe> data_pipe_ MOJO_GUARDED_BY(mutex());
79
80 MOJO_DISALLOW_COPY_AND_ASSIGN(DataPipeConsumerDispatcher);
81 };
82
83 } // namespace system
84 } // namespace mojo
85
86 #endif // THIRD_PARTY_MOJO_SRC_MOJO_EDK_SYSTEM_DATA_PIPE_CONSUMER_DISPATCHER_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698