blob: 3c3bfecdc771bc92b1fcc7548c2f9284a5b9bf3d (
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
|
// Copyright (c) 2010 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/scoped_callback_factory.h"
#include "base/weak_ptr.h"
#include "talk/xmpp/jid.h"
namespace invalidation {
class InvalidationClient;
class NetworkEndpoint;
} // namespace invalidation
namespace talk_base {
class Task;
} // namespace
namespace sync_notifier {
// TODO(akalin): Add a NonThreadSafe member to this class and use it.
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<talk_base::Task> base_task,
invalidation::InvalidationClient* invalidation_client);
// Makes the invalidation client passed into the constructor not
// route packets through the XMPP client passed into the constructor
// anymore.
~CacheInvalidationPacketHandler();
private:
void HandleOutboundPacket(
invalidation::NetworkEndpoint* const& network_endpoint);
void HandleInboundPacket(const std::string& packet);
base::ScopedCallbackFactory<CacheInvalidationPacketHandler>
scoped_callback_factory_;
base::WeakPtr<talk_base::Task> base_task_;
invalidation::InvalidationClient* invalidation_client_;
// Parameters for sent messages.
// Monotonically increasing sequence number.
int seq_;
// Unique session token.
const std::string sid_;
DISALLOW_COPY_AND_ASSIGN(CacheInvalidationPacketHandler);
};
} // namespace sync_notifier
#endif // CHROME_BROWSER_SYNC_NOTIFIER_CACHE_INVALIDATION_PACKET_HANDLER_H_
|
