| Index: google_apis/gcm/engine/rmq_store.h
|
| diff --git a/google_apis/gcm/engine/rmq_store.h b/google_apis/gcm/engine/rmq_store.h
|
| deleted file mode 100644
|
| index 93b509998124ca302422ab749cf72c1e3ab38f00..0000000000000000000000000000000000000000
|
| --- a/google_apis/gcm/engine/rmq_store.h
|
| +++ /dev/null
|
| @@ -1,113 +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;
|
| - int64 next_serial_number;
|
| - std::map<std::string, int64> user_serial_numbers;
|
| - };
|
| -
|
| - 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);
|
| -
|
| - // User serial number handling.
|
| - void SetNextSerialNumber(int64 next_serial_number,
|
| - const UpdateCallback& callback);
|
| - void AddUserSerialNumber(const std::string& username,
|
| - int64 serial_number,
|
| - const UpdateCallback& callback);
|
| - void RemoveUserSerialNumber(const std::string& username,
|
| - 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_
|
|
|