summaryrefslogtreecommitdiffstats
path: root/chromium/google_apis/gcm/engine/rmq_store.h
diff options
context:
space:
mode:
Diffstat (limited to 'chromium/google_apis/gcm/engine/rmq_store.h')
-rw-r--r--chromium/google_apis/gcm/engine/rmq_store.h102
1 files changed, 0 insertions, 102 deletions
diff --git a/chromium/google_apis/gcm/engine/rmq_store.h b/chromium/google_apis/gcm/engine/rmq_store.h
deleted file mode 100644
index d3762a199c7..00000000000
--- a/chromium/google_apis/gcm/engine/rmq_store.h
+++ /dev/null
@@ -1,102 +0,0 @@
-// Copyright 2013 The Chromium Authors. All rights reserved.
-// Use of this source code is governed by a BSD-style license that can be
-// found in the LICENSE file.
-
-#ifndef GOOGLE_APIS_GCM_ENGINE_RMQ_STORE_H_
-#define GOOGLE_APIS_GCM_ENGINE_RMQ_STORE_H_
-
-#include <map>
-#include <string>
-#include <vector>
-
-#include "base/basictypes.h"
-#include "base/callback_forward.h"
-#include "base/memory/ref_counted.h"
-#include "google_apis/gcm/base/gcm_export.h"
-
-namespace base {
-class FilePath;
-class SequencedTaskRunner;
-} // namespace base
-
-namespace google {
-namespace protobuf {
-class MessageLite;
-} // namespace protobuf
-} // namespace google
-
-namespace gcm {
-
-class MCSMessage;
-
-// A Reliable Message Queue store.
-// Will perform all blocking operations on the blocking task runner, and will
-// post all callbacks to the thread on which the RMQStore is created.
-class GCM_EXPORT RMQStore {
- public:
- // Container for Load(..) results.
- struct GCM_EXPORT LoadResult {
- LoadResult();
- ~LoadResult();
-
- bool success;
- uint64 device_android_id;
- uint64 device_security_token;
- std::vector<std::string> incoming_messages;
- std::map<std::string, google::protobuf::MessageLite*>
- outgoing_messages;
- };
-
- typedef std::vector<std::string> PersistentIdList;
- // Note: callee receives ownership of |outgoing_messages|' values.
- typedef base::Callback<void(const LoadResult& result)> LoadCallback;
- typedef base::Callback<void(bool success)> UpdateCallback;
-
- RMQStore(const base::FilePath& path,
- scoped_refptr<base::SequencedTaskRunner> blocking_task_runner);
- ~RMQStore();
-
- // Load the directory and pass the initial state back to caller.
- void Load(const LoadCallback& callback);
-
- // Clears the RMQ store of all data and destroys any LevelDB files associated
- // with this store.
- // WARNING: this will permanently destroy any pending outgoing messages
- // and require the device to re-create credentials.
- void Destroy(const UpdateCallback& callback);
-
- // Sets this device's messaging credentials.
- void SetDeviceCredentials(uint64 device_android_id,
- uint64 device_security_token,
- const UpdateCallback& callback);
-
- // Unacknowledged incoming message handling.
- void AddIncomingMessage(const std::string& persistent_id,
- const UpdateCallback& callback);
- void RemoveIncomingMessage(const std::string& persistent_id,
- const UpdateCallback& callback);
- void RemoveIncomingMessages(const PersistentIdList& persistent_ids,
- const UpdateCallback& callback);
-
- // Unacknowledged outgoing messages handling.
- // TODO(zea): implement per-app limits on the number of outgoing messages.
- void AddOutgoingMessage(const std::string& persistent_id,
- const MCSMessage& message,
- const UpdateCallback& callback);
- void RemoveOutgoingMessage(const std::string& persistent_id,
- const UpdateCallback& callback);
- void RemoveOutgoingMessages(const PersistentIdList& persistent_ids,
- const UpdateCallback& callback);
-
- private:
- class Backend;
-
- scoped_refptr<Backend> backend_;
- scoped_refptr<base::SequencedTaskRunner> blocking_task_runner_;
-
- DISALLOW_COPY_AND_ASSIGN(RMQStore);
-};
-
-} // namespace gcm
-
-#endif // GOOGLE_APIS_GCM_ENGINE_RMQ_STORE_H_