blob: d86b7500d0dbc2fe5235df1f9cd7c39b06b84ac1 (
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
|
// Copyright 2015 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 BLIMP_NET_BLIMP_MESSAGE_PUMP_H_
#define BLIMP_NET_BLIMP_MESSAGE_PUMP_H_
#include "base/macros.h"
#include "base/memory/ref_counted.h"
#include "base/memory/scoped_ptr.h"
#include "blimp/net/blimp_net_export.h"
#include "net/base/completion_callback.h"
namespace net {
class GrowableIOBuffer;
}
namespace blimp {
class BlimpMessageProcessor;
class ConnectionErrorObserver;
class PacketReader;
// Reads and deserializes incoming packets from |reader_|, and forwards parsed
// BlimpMessages to |processor_|. When |processor_| is ready to take the next
// message, the BlimpMessagePump reads the next packet.
class BLIMP_NET_EXPORT BlimpMessagePump {
public:
// Caller ensures that |reader| outlives this object.
explicit BlimpMessagePump(PacketReader* reader);
~BlimpMessagePump();
// Sets the processor which will take BlimpMessages. Can only be set once.
// Caller retains the ownership of |processor|.
void SetMessageProcessor(BlimpMessageProcessor* processor);
void set_error_observer(ConnectionErrorObserver* observer) {
error_observer_ = observer;
}
private:
// Read next packet from |reader_|.
void ReadNextPacket();
// Callback when next packet is ready in |buffer_|.
void OnReadPacketComplete(int result);
// Callback when |processor_| finishes processing a BlimpMessage.
void OnProcessMessageComplete(int result);
PacketReader* reader_;
ConnectionErrorObserver* error_observer_;
BlimpMessageProcessor* processor_;
scoped_refptr<net::GrowableIOBuffer> buffer_;
// Cancelled in the event that the connection is destroyed (along with
// |this|) while a inflight callback is held by |processor_|.
net::CancelableCompletionCallback process_msg_callback_;
// Cancelled to guard against |this| being called back from a completed read
// operation.
net::CancelableCompletionCallback read_callback_;
DISALLOW_COPY_AND_ASSIGN(BlimpMessagePump);
};
} // namespace blimp
#endif // BLIMP_NET_BLIMP_MESSAGE_PUMP_H_
|
