@@ -103,31 +103,64 @@ class ContextBase {
103103 // General stream downcall on a new stream.
104104 virtual void onCreate (uint32_t root_context_id);
105105 // Network
106- virtual FilterStatus onNetworkNewConnection ();
107- virtual FilterStatus onDownstreamData (int data_length, bool end_of_stream);
108- virtual FilterStatus onUpstreamData (int data_length, bool end_of_stream);
106+ virtual FilterStatus onNetworkNewConnection () {
107+ unimplemented ();
108+ return FilterStatus::Continue;
109+ }
110+ virtual FilterStatus onDownstreamData (int /* data_length */ , bool /* end_of_stream */ ) {
111+ unimplemented ();
112+ return FilterStatus::Continue;
113+ }
114+ virtual FilterStatus onUpstreamData (int /* data_length */ , bool /* end_of_stream */ ) {
115+ unimplemented ();
116+ return FilterStatus::Continue;
117+ }
109118 enum class PeerType : uint32_t {
110119 Unknown = 0 ,
111120 Local = 1 ,
112121 Remote = 2 ,
113122 };
114- virtual void onDownstreamConnectionClose (PeerType);
115- virtual void onUpstreamConnectionClose (PeerType);
123+ virtual void onDownstreamConnectionClose (PeerType) { unimplemented (); }
124+ virtual void onUpstreamConnectionClose (PeerType) { unimplemented (); }
116125 // HTTP Filter Stream Request Downcalls.
117- virtual FilterHeadersStatus onRequestHeaders ();
118- virtual FilterDataStatus onRequestBody (int body_buffer_length, bool end_of_stream);
119- virtual FilterTrailersStatus onRequestTrailers ();
120- virtual FilterMetadataStatus onRequestMetadata ();
126+ virtual FilterHeadersStatus onRequestHeaders () {
127+ unimplemented ();
128+ return FilterHeadersStatus::Continue;
129+ }
130+ virtual FilterDataStatus onRequestBody (int /* body_buffer_length */ , bool /* end_of_stream */ ) {
131+ unimplemented ();
132+ return FilterDataStatus::Continue;
133+ }
134+ virtual FilterTrailersStatus onRequestTrailers () {
135+ unimplemented ();
136+ return FilterTrailersStatus::Continue;
137+ }
138+ virtual FilterMetadataStatus onRequestMetadata () {
139+ unimplemented ();
140+ return FilterMetadataStatus::Continue;
141+ }
121142 // HTTP Filter Stream Response Downcalls.
122- virtual FilterHeadersStatus onResponseHeaders ();
123- virtual FilterDataStatus onResponseBody (int body_buffer_length, bool end_of_stream);
124- virtual FilterTrailersStatus onResponseTrailers ();
125- virtual FilterMetadataStatus onResponseMetadata ();
143+ virtual FilterHeadersStatus onResponseHeaders () {
144+ unimplemented ();
145+ return FilterHeadersStatus::Continue;
146+ }
147+ virtual FilterDataStatus onResponseBody (int /* body_buffer_length */ , bool /* end_of_stream */ ) {
148+ unimplemented ();
149+ return FilterDataStatus::Continue;
150+ }
151+ virtual FilterTrailersStatus onResponseTrailers () {
152+ unimplemented ();
153+ return FilterTrailersStatus::Continue;
154+ }
155+ virtual FilterMetadataStatus onResponseMetadata () {
156+ unimplemented ();
157+ return FilterMetadataStatus::Continue;
158+ }
126159 // Async call response.
127- virtual void onHttpCallResponse (uint32_t token, uint32_t headers, uint32_t body_size ,
128- uint32_t trailers);
160+ virtual void onHttpCallResponse (uint32_t /* token */ , uint32_t /* headers */ ,
161+ uint32_t /* body_size */ , uint32_t /* trailers */ ) {}
129162 // Inter-VM shared queue message arrival.
130- virtual void onQueueReady (uint32_t token);
163+ virtual void onQueueReady (uint32_t /* token */ ) { unimplemented (); }
131164 // General stream downcall when the stream/vm has ended.
132165 virtual bool onDone ();
133166 // General stream downcall for logging. Occurs after onDone().
@@ -145,9 +178,13 @@ class ContextBase {
145178 // General Callbacks.
146179 //
147180 virtual WasmResult log (uint64_t /* level */ , string_view /* message */ ) {
181+ unimplemented ();
182+ return WasmResult::Unimplemented;
183+ }
184+ virtual WasmResult setTimerPeriod (std::chrono::milliseconds /* period */ ) {
185+ unimplemented ();
148186 return WasmResult::Unimplemented;
149187 }
150- virtual WasmResult setTimerPeriod (std::chrono::milliseconds period);
151188 virtual uint64_t getCurrentTimeNanoseconds () {
152189 struct timespec tpe;
153190 clock_gettime (CLOCK_REALTIME, &tpe);
@@ -156,11 +193,20 @@ class ContextBase {
156193 t += tpe.tv_nsec ;
157194 return t;
158195 }
159- virtual std::pair<uint32_t , string_view> getStatus ();
196+ virtual std::pair<uint32_t , string_view> getStatus () {
197+ unimplemented ();
198+ return std::make_pair (1 , " unimplmemented" );
199+ }
160200
161201 // Buffer
162- virtual const BufferInterface *getBuffer (WasmBufferType type);
163- virtual bool end_of_stream ();
202+ virtual const BufferInterface *getBuffer (WasmBufferType /* type */ ) {
203+ unimplemented ();
204+ return nullptr ;
205+ }
206+ virtual bool end_of_stream () {
207+ unimplemented ();
208+ return true ;
209+ }
164210
165211 // HTTP
166212 // Returns a token which will be used with the corresponding onHttpCallResponse.
@@ -200,14 +246,33 @@ class ContextBase {
200246 }
201247
202248 // Metrics
203- virtual WasmResult defineMetric (MetricType type, string_view name, uint32_t *metric_id_ptr);
204- virtual WasmResult incrementMetric (uint32_t metric_id, int64_t offset);
205- virtual WasmResult recordMetric (uint32_t metric_id, uint64_t value);
206- virtual WasmResult getMetric (uint32_t metric_id, uint64_t *value_ptr);
207-
208- // State accessors
209- virtual WasmResult getProperty (string_view path, std::string *result);
210- virtual WasmResult setProperty (string_view key, string_view serialized_value);
249+ virtual WasmResult defineMetric (MetricType /* type */ , string_view /* name */ ,
250+ uint32_t * /* metric_id_ptr */ ) {
251+ unimplemented ();
252+ return WasmResult::Unimplemented;
253+ }
254+ virtual WasmResult incrementMetric (uint32_t /* metric_id */ , int64_t /* offset */ ) {
255+ unimplemented ();
256+ return WasmResult::Unimplemented;
257+ }
258+ virtual WasmResult recordMetric (uint32_t /* metric_id */ , uint64_t /* value */ ) {
259+ unimplemented ();
260+ return WasmResult::Unimplemented;
261+ }
262+ virtual WasmResult getMetric (uint32_t /* metric_id */ , uint64_t * /* value_ptr */ ) {
263+ unimplemented ();
264+ return WasmResult::Unimplemented;
265+ }
266+
267+ // Properties
268+ virtual WasmResult getProperty (string_view /* path */ , std::string * /* result */ ) {
269+ unimplemented ();
270+ return WasmResult::Unimplemented;
271+ }
272+ virtual WasmResult setProperty (string_view /* key */ , string_view /* serialized_value */ ) {
273+ unimplemented ();
274+ return WasmResult::Unimplemented;
275+ }
211276
212277 // Continue
213278 virtual void continueRequest () { unimplemented (); }
0 commit comments