diff options
Diffstat (limited to 'common/resourceaccess.h')
-rw-r--r-- | common/resourceaccess.h | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/common/resourceaccess.h b/common/resourceaccess.h index 755c8a7..4229161 100644 --- a/common/resourceaccess.h +++ b/common/resourceaccess.h | |||
@@ -29,6 +29,7 @@ | |||
29 | 29 | ||
30 | #include <flatbuffers/flatbuffers.h> | 30 | #include <flatbuffers/flatbuffers.h> |
31 | #include "notification.h" | 31 | #include "notification.h" |
32 | #include "flush.h" | ||
32 | #include "query.h" | 33 | #include "query.h" |
33 | #include "log.h" | 34 | #include "log.h" |
34 | 35 | ||
@@ -50,7 +51,6 @@ public: | |||
50 | } | 51 | } |
51 | virtual KAsync::Job<void> sendCommand(int commandId) = 0; | 52 | virtual KAsync::Job<void> sendCommand(int commandId) = 0; |
52 | virtual KAsync::Job<void> sendCommand(int commandId, flatbuffers::FlatBufferBuilder &fbb) = 0; | 53 | virtual KAsync::Job<void> sendCommand(int commandId, flatbuffers::FlatBufferBuilder &fbb) = 0; |
53 | virtual KAsync::Job<void> synchronizeResource(bool remoteSync, bool localSync) = 0; | ||
54 | virtual KAsync::Job<void> synchronizeResource(const Sink::QueryBase &filter) = 0; | 54 | virtual KAsync::Job<void> synchronizeResource(const Sink::QueryBase &filter) = 0; |
55 | 55 | ||
56 | virtual KAsync::Job<void> sendCreateCommand(const QByteArray &uid, const QByteArray &resourceBufferType, const QByteArray &buffer) | 56 | virtual KAsync::Job<void> sendCreateCommand(const QByteArray &uid, const QByteArray &resourceBufferType, const QByteArray &buffer) |
@@ -75,6 +75,11 @@ public: | |||
75 | return KAsync::null<void>(); | 75 | return KAsync::null<void>(); |
76 | }; | 76 | }; |
77 | 77 | ||
78 | virtual KAsync::Job<void> sendFlushCommand(int flushType, const QByteArray &flushId) | ||
79 | { | ||
80 | return KAsync::null<void>(); | ||
81 | } | ||
82 | |||
78 | int getResourceStatus() const | 83 | int getResourceStatus() const |
79 | { | 84 | { |
80 | return mResourceStatus; | 85 | return mResourceStatus; |
@@ -108,7 +113,6 @@ public: | |||
108 | 113 | ||
109 | KAsync::Job<void> sendCommand(int commandId) Q_DECL_OVERRIDE; | 114 | KAsync::Job<void> sendCommand(int commandId) Q_DECL_OVERRIDE; |
110 | KAsync::Job<void> sendCommand(int commandId, flatbuffers::FlatBufferBuilder &fbb) Q_DECL_OVERRIDE; | 115 | KAsync::Job<void> sendCommand(int commandId, flatbuffers::FlatBufferBuilder &fbb) Q_DECL_OVERRIDE; |
111 | KAsync::Job<void> synchronizeResource(bool remoteSync, bool localSync) Q_DECL_OVERRIDE; | ||
112 | KAsync::Job<void> synchronizeResource(const Sink::QueryBase &filter) Q_DECL_OVERRIDE; | 116 | KAsync::Job<void> synchronizeResource(const Sink::QueryBase &filter) Q_DECL_OVERRIDE; |
113 | KAsync::Job<void> sendCreateCommand(const QByteArray &uid, const QByteArray &resourceBufferType, const QByteArray &buffer) Q_DECL_OVERRIDE; | 117 | KAsync::Job<void> sendCreateCommand(const QByteArray &uid, const QByteArray &resourceBufferType, const QByteArray &buffer) Q_DECL_OVERRIDE; |
114 | KAsync::Job<void> | 118 | KAsync::Job<void> |
@@ -117,6 +121,7 @@ public: | |||
117 | KAsync::Job<void> sendRevisionReplayedCommand(qint64 revision) Q_DECL_OVERRIDE; | 121 | KAsync::Job<void> sendRevisionReplayedCommand(qint64 revision) Q_DECL_OVERRIDE; |
118 | KAsync::Job<void> | 122 | KAsync::Job<void> |
119 | sendInspectionCommand(int inspectionType,const QByteArray &inspectionId, const QByteArray &domainType, const QByteArray &entityId, const QByteArray &property, const QVariant &expecedValue) Q_DECL_OVERRIDE; | 123 | sendInspectionCommand(int inspectionType,const QByteArray &inspectionId, const QByteArray &domainType, const QByteArray &entityId, const QByteArray &property, const QVariant &expecedValue) Q_DECL_OVERRIDE; |
124 | KAsync::Job<void> sendFlushCommand(int flushType, const QByteArray &flushId) Q_DECL_OVERRIDE; | ||
120 | /** | 125 | /** |
121 | * Tries to connect to server, and returns a connected socket on success. | 126 | * Tries to connect to server, and returns a connected socket on success. |
122 | */ | 127 | */ |