blob: e54604405cf89d6526394f9b9b5fcc5d284d9f90 (
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
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* Copyright (C) 2014 Red Hat
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
*
*/
#ifndef CEPH_MSG_PIPECONNECTION_H
#define CEPH_MSG_PIPECONNECTION_H
#include "msg/Connection.h"
class Pipe;
class PipeConnection : public Connection {
Pipe* pipe;
friend class boost::intrusive_ptr<PipeConnection>;
friend class Pipe;
public:
PipeConnection(CephContext *cct, Messenger *m)
: Connection(cct, m),
pipe(NULL) { }
~PipeConnection() override;
Pipe* get_pipe();
bool try_get_pipe(Pipe** p);
bool clear_pipe(Pipe* old_p);
void reset_pipe(Pipe* p);
bool is_connected() override;
int send_message(Message *m) override;
void send_keepalive() override;
void mark_down() override;
void mark_disposable() override;
entity_addr_t get_peer_socket_addr() const override {
return peer_addrs->front();
}
}; /* PipeConnection */
typedef boost::intrusive_ptr<PipeConnection> PipeConnectionRef;
#endif
|
