diff options
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/PostProcessor.hpp | 4 | ||||
| -rw-r--r-- | src/server/Request.hpp | 12 | ||||
| -rw-r--r-- | src/server/events/Disconnect.cpp | 22 |
3 files changed, 19 insertions, 19 deletions
diff --git a/src/server/PostProcessor.hpp b/src/server/PostProcessor.hpp index a48c89f8..f06a182e 100644 --- a/src/server/PostProcessor.hpp +++ b/src/server/PostProcessor.hpp @@ -48,8 +48,8 @@ public: /** Push a list of events on to the process queue, realtime-safe, not thread-safe. */ inline void append(Raul::List<Event*>* l) { _events.append(*l); } - /** Post-process and delete all pending events */ - void process(); + /** Post-process and delete all pending events */ + void process(); /** Set the latest event time that should be post-processed */ void set_end_time(FrameTime time) { _max_time = time; } diff --git a/src/server/Request.hpp b/src/server/Request.hpp index 5b91798d..185c250c 100644 --- a/src/server/Request.hpp +++ b/src/server/Request.hpp @@ -42,7 +42,7 @@ public: ClientInterface* client=0, int32_t id=1) : _source(source) - , _client(client) + , _client(client) , _id(id) {} @@ -53,10 +53,10 @@ public: ClientInterface* client() const { return _client; } void set_client(ClientInterface* client) { _client = client; } - void unblock() { - if (_source) - _source->unblock(); - } + void unblock() { + if (_source) + _source->unblock(); + } void respond_ok() { if (_client) @@ -69,7 +69,7 @@ public: } private: - EventSource* _source; + EventSource* _source; ClientInterface* _client; int32_t _id; }; diff --git a/src/server/events/Disconnect.cpp b/src/server/events/Disconnect.cpp index e9374648..e7177fab 100644 --- a/src/server/events/Disconnect.cpp +++ b/src/server/events/Disconnect.cpp @@ -225,13 +225,13 @@ Disconnect::execute(ProcessContext& context) void Disconnect::post_process() { - if (_error == NO_ERROR) { - if (_request) - _request->respond_ok(); - _engine.broadcaster()->disconnect(_src_port->path(), _dst_port->path()); - } else { - string msg("Unable to disconnect "); - msg.append(_src_port_path.str() + " => " + _dst_port_path.str()); + if (_error == NO_ERROR) { + if (_request) + _request->respond_ok(); + _engine.broadcaster()->disconnect(_src_port->path(), _dst_port->path()); + } else { + string msg("Unable to disconnect "); + msg.append(_src_port_path.str() + " => " + _dst_port_path.str()); msg.append(" ("); switch (_error) { case PARENT_PATCH_DIFFERENT: @@ -256,11 +256,11 @@ Disconnect::post_process() break; } msg.append(")"); - if (_request) - _request->respond_error(msg); - } + if (_request) + _request->respond_error(msg); + } - delete _impl; + delete _impl; } } // namespace Server |