blob: 2316ec6173ceb081e8425d900e096f3823604130 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
// Copyright (c) 2011 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.
//
// Class that handles the details of sending and receiving client
// invalidation packets.
#ifndef CHROME_BROWSER_SYNC_NOTIFIER_CACHE_INVALIDATION_PACKET_HANDLER_H_
#define CHROME_BROWSER_SYNC_NOTIFIER_CACHE_INVALIDATION_PACKET_HANDLER_H_
#pragma once
#include <string>
#include "base/basictypes.h"
#include "base/gtest_prod_util.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/weak_ptr.h"
#include "base/threading/non_thread_safe.h"
#include "google/cacheinvalidation/v2/system-resources.h"
namespace buzz {
class XmppTaskParentInterface;
} // namespace buzz
namespace sync_notifier {
class CacheInvalidationPacketHandler {
public:
// Starts routing packets from |invalidation_client| using
// |base_task|. |base_task.get()| must still be non-NULL.
// |invalidation_client| must not already be routing packets through
// something. Does not take ownership of |invalidation_client|.
CacheInvalidationPacketHandler(
base::WeakPtr<buzz::XmppTaskParentInterface> base_task);
// Makes the invalidation client passed into the constructor not
// route packets through the XMPP client passed into the constructor
// anymore.
virtual ~CacheInvalidationPacketHandler();
// If |base_task| is non-NULL, sends the outgoing message.
virtual void SendMessage(const std::string& outgoing_message);
virtual void SetMessageReceiver(
invalidation::MessageCallback* incoming_receiver);
private:
FRIEND_TEST_ALL_PREFIXES(CacheInvalidationPacketHandlerTest, Basic);
void HandleInboundPacket(const std::string& packet);
void HandleChannelContextChange(const std::string& context);
base::NonThreadSafe non_thread_safe_;
base::WeakPtrFactory<CacheInvalidationPacketHandler> weak_factory_;
base::WeakPtr<buzz::XmppTaskParentInterface> base_task_;
scoped_ptr<invalidation::MessageCallback> incoming_receiver_;
// Parameters for sent messages.
// Monotonically increasing sequence number.
int seq_;
// Unique session token.
const std::string sid_;
// Channel context.
std::string channel_context_;
DISALLOW_COPY_AND_ASSIGN(CacheInvalidationPacketHandler);
};
} // namespace sync_notifier
#endif // CHROME_BROWSER_SYNC_NOTIFIER_CACHE_INVALIDATION_PACKET_HANDLER_H_
|
