cannam@147
|
1 // Copyright (c) 2013-2014 Sandstorm Development Group, Inc. and contributors
|
cannam@147
|
2 // Licensed under the MIT License:
|
cannam@147
|
3 //
|
cannam@147
|
4 // Permission is hereby granted, free of charge, to any person obtaining a copy
|
cannam@147
|
5 // of this software and associated documentation files (the "Software"), to deal
|
cannam@147
|
6 // in the Software without restriction, including without limitation the rights
|
cannam@147
|
7 // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
cannam@147
|
8 // copies of the Software, and to permit persons to whom the Software is
|
cannam@147
|
9 // furnished to do so, subject to the following conditions:
|
cannam@147
|
10 //
|
cannam@147
|
11 // The above copyright notice and this permission notice shall be included in
|
cannam@147
|
12 // all copies or substantial portions of the Software.
|
cannam@147
|
13 //
|
cannam@147
|
14 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
cannam@147
|
15 // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
cannam@147
|
16 // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
cannam@147
|
17 // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
cannam@147
|
18 // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
cannam@147
|
19 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
cannam@147
|
20 // THE SOFTWARE.
|
cannam@147
|
21
|
cannam@147
|
22 #ifndef CAPNP_RPC_TWOPARTY_H_
|
cannam@147
|
23 #define CAPNP_RPC_TWOPARTY_H_
|
cannam@147
|
24
|
cannam@147
|
25 #if defined(__GNUC__) && !defined(CAPNP_HEADER_WARNINGS)
|
cannam@147
|
26 #pragma GCC system_header
|
cannam@147
|
27 #endif
|
cannam@147
|
28
|
cannam@147
|
29 #include "rpc.h"
|
cannam@147
|
30 #include "message.h"
|
cannam@147
|
31 #include <kj/async-io.h>
|
cannam@147
|
32 #include <capnp/rpc-twoparty.capnp.h>
|
cannam@147
|
33
|
cannam@147
|
34 namespace capnp {
|
cannam@147
|
35
|
cannam@147
|
36 namespace rpc {
|
cannam@147
|
37 namespace twoparty {
|
cannam@147
|
38 typedef VatId SturdyRefHostId; // For backwards-compatibility with version 0.4.
|
cannam@147
|
39 }
|
cannam@147
|
40 }
|
cannam@147
|
41
|
cannam@147
|
42 typedef VatNetwork<rpc::twoparty::VatId, rpc::twoparty::ProvisionId,
|
cannam@147
|
43 rpc::twoparty::RecipientId, rpc::twoparty::ThirdPartyCapId, rpc::twoparty::JoinResult>
|
cannam@147
|
44 TwoPartyVatNetworkBase;
|
cannam@147
|
45
|
cannam@147
|
46 class TwoPartyVatNetwork: public TwoPartyVatNetworkBase,
|
cannam@147
|
47 private TwoPartyVatNetworkBase::Connection {
|
cannam@147
|
48 // A `VatNetwork` that consists of exactly two parties communicating over an arbitrary byte
|
cannam@147
|
49 // stream. This is used to implement the common case of a client/server network.
|
cannam@147
|
50 //
|
cannam@147
|
51 // See `ez-rpc.h` for a simple interface for setting up two-party clients and servers.
|
cannam@147
|
52 // Use `TwoPartyVatNetwork` only if you need the advanced features.
|
cannam@147
|
53
|
cannam@147
|
54 public:
|
cannam@147
|
55 TwoPartyVatNetwork(kj::AsyncIoStream& stream, rpc::twoparty::Side side,
|
cannam@147
|
56 ReaderOptions receiveOptions = ReaderOptions());
|
cannam@147
|
57 KJ_DISALLOW_COPY(TwoPartyVatNetwork);
|
cannam@147
|
58
|
cannam@147
|
59 kj::Promise<void> onDisconnect() { return disconnectPromise.addBranch(); }
|
cannam@147
|
60 // Returns a promise that resolves when the peer disconnects.
|
cannam@147
|
61
|
cannam@147
|
62 rpc::twoparty::Side getSide() { return side; }
|
cannam@147
|
63
|
cannam@147
|
64 // implements VatNetwork -----------------------------------------------------
|
cannam@147
|
65
|
cannam@147
|
66 kj::Maybe<kj::Own<TwoPartyVatNetworkBase::Connection>> connect(
|
cannam@147
|
67 rpc::twoparty::VatId::Reader ref) override;
|
cannam@147
|
68 kj::Promise<kj::Own<TwoPartyVatNetworkBase::Connection>> accept() override;
|
cannam@147
|
69
|
cannam@147
|
70 private:
|
cannam@147
|
71 class OutgoingMessageImpl;
|
cannam@147
|
72 class IncomingMessageImpl;
|
cannam@147
|
73
|
cannam@147
|
74 kj::AsyncIoStream& stream;
|
cannam@147
|
75 rpc::twoparty::Side side;
|
cannam@147
|
76 MallocMessageBuilder peerVatId;
|
cannam@147
|
77 ReaderOptions receiveOptions;
|
cannam@147
|
78 bool accepted = false;
|
cannam@147
|
79
|
cannam@147
|
80 kj::Maybe<kj::Promise<void>> previousWrite;
|
cannam@147
|
81 // Resolves when the previous write completes. This effectively serves as the write queue.
|
cannam@147
|
82 // Becomes null when shutdown() is called.
|
cannam@147
|
83
|
cannam@147
|
84 kj::Own<kj::PromiseFulfiller<kj::Own<TwoPartyVatNetworkBase::Connection>>> acceptFulfiller;
|
cannam@147
|
85 // Fulfiller for the promise returned by acceptConnectionAsRefHost() on the client side, or the
|
cannam@147
|
86 // second call on the server side. Never fulfilled, because there is only one connection.
|
cannam@147
|
87
|
cannam@147
|
88 kj::ForkedPromise<void> disconnectPromise = nullptr;
|
cannam@147
|
89
|
cannam@147
|
90 class FulfillerDisposer: public kj::Disposer {
|
cannam@147
|
91 // Hack: TwoPartyVatNetwork is both a VatNetwork and a VatNetwork::Connection. When the RPC
|
cannam@147
|
92 // system detects (or initiates) a disconnection, it drops its reference to the Connection.
|
cannam@147
|
93 // When all references have been dropped, then we want disconnectPromise to be fulfilled.
|
cannam@147
|
94 // So we hand out Own<Connection>s with this disposer attached, so that we can detect when
|
cannam@147
|
95 // they are dropped.
|
cannam@147
|
96
|
cannam@147
|
97 public:
|
cannam@147
|
98 mutable kj::Own<kj::PromiseFulfiller<void>> fulfiller;
|
cannam@147
|
99 mutable uint refcount = 0;
|
cannam@147
|
100
|
cannam@147
|
101 void disposeImpl(void* pointer) const override;
|
cannam@147
|
102 };
|
cannam@147
|
103 FulfillerDisposer disconnectFulfiller;
|
cannam@147
|
104
|
cannam@147
|
105 kj::Own<TwoPartyVatNetworkBase::Connection> asConnection();
|
cannam@147
|
106 // Returns a pointer to this with the disposer set to disconnectFulfiller.
|
cannam@147
|
107
|
cannam@147
|
108 // implements Connection -----------------------------------------------------
|
cannam@147
|
109
|
cannam@147
|
110 rpc::twoparty::VatId::Reader getPeerVatId() override;
|
cannam@147
|
111 kj::Own<OutgoingRpcMessage> newOutgoingMessage(uint firstSegmentWordSize) override;
|
cannam@147
|
112 kj::Promise<kj::Maybe<kj::Own<IncomingRpcMessage>>> receiveIncomingMessage() override;
|
cannam@147
|
113 kj::Promise<void> shutdown() override;
|
cannam@147
|
114 };
|
cannam@147
|
115
|
cannam@147
|
116 class TwoPartyServer: private kj::TaskSet::ErrorHandler {
|
cannam@147
|
117 // Convenience class which implements a simple server which accepts connections on a listener
|
cannam@147
|
118 // socket and serices them as two-party connections.
|
cannam@147
|
119
|
cannam@147
|
120 public:
|
cannam@147
|
121 explicit TwoPartyServer(Capability::Client bootstrapInterface);
|
cannam@147
|
122
|
cannam@147
|
123 void accept(kj::Own<kj::AsyncIoStream>&& connection);
|
cannam@147
|
124 // Accepts the connection for servicing.
|
cannam@147
|
125
|
cannam@147
|
126 kj::Promise<void> listen(kj::ConnectionReceiver& listener);
|
cannam@147
|
127 // Listens for connections on the given listener. The returned promise never resolves unless an
|
cannam@147
|
128 // exception is thrown while trying to accept. You may discard the returned promise to cancel
|
cannam@147
|
129 // listening.
|
cannam@147
|
130
|
cannam@147
|
131 private:
|
cannam@147
|
132 Capability::Client bootstrapInterface;
|
cannam@147
|
133 kj::TaskSet tasks;
|
cannam@147
|
134
|
cannam@147
|
135 struct AcceptedConnection;
|
cannam@147
|
136
|
cannam@147
|
137 void taskFailed(kj::Exception&& exception) override;
|
cannam@147
|
138 };
|
cannam@147
|
139
|
cannam@147
|
140 class TwoPartyClient {
|
cannam@147
|
141 // Convenience class which implements a simple client.
|
cannam@147
|
142
|
cannam@147
|
143 public:
|
cannam@147
|
144 explicit TwoPartyClient(kj::AsyncIoStream& connection);
|
cannam@147
|
145 TwoPartyClient(kj::AsyncIoStream& connection, Capability::Client bootstrapInterface,
|
cannam@147
|
146 rpc::twoparty::Side side = rpc::twoparty::Side::CLIENT);
|
cannam@147
|
147
|
cannam@147
|
148 Capability::Client bootstrap();
|
cannam@147
|
149 // Get the server's bootstrap interface.
|
cannam@147
|
150
|
cannam@147
|
151 inline kj::Promise<void> onDisconnect() { return network.onDisconnect(); }
|
cannam@147
|
152
|
cannam@147
|
153 private:
|
cannam@147
|
154 TwoPartyVatNetwork network;
|
cannam@147
|
155 RpcSystem<rpc::twoparty::VatId> rpcSystem;
|
cannam@147
|
156 };
|
cannam@147
|
157
|
cannam@147
|
158 } // namespace capnp
|
cannam@147
|
159
|
cannam@147
|
160 #endif // CAPNP_RPC_TWOPARTY_H_
|