| /dports/irc/quassel/quassel-0.14-rc2/src/common/ |
| H A D | remotepeer.cpp | 83 QString RemotePeer::description() const in description()
88 QHostAddress RemotePeer::hostAddress() const in hostAddress()
100 QString RemotePeer::address() const in address()
111 quint16 RemotePeer::port() const in port()
162 int RemotePeer::lag() const in lag()
167 QTcpSocket* RemotePeer::socket() const in socket()
172 bool RemotePeer::isSecure() const in isSecure()
184 bool RemotePeer::isLocal() const in isLocal()
190 bool RemotePeer::isOpen() const in isOpen()
206 void RemotePeer::onReadyRead() in onReadyRead()
[all …]
|
| H A D | peerfactory.h | 34 class RemotePeer; variable
45 static RemotePeer* createPeer(const ProtoDescriptor& protocol,
50 static RemotePeer* createPeer(const ProtoList& protocols,
|
| H A D | peerfactory.cpp | 34 RemotePeer* PeerFactory::createPeer( in createPeer()
40 RemotePeer* PeerFactory::createPeer( in createPeer()
|
| /dports/irc/quassel-core/quassel-0.14-rc2/src/common/ |
| H A D | remotepeer.cpp | 83 QString RemotePeer::description() const in description()
88 QHostAddress RemotePeer::hostAddress() const in hostAddress()
100 QString RemotePeer::address() const in address()
111 quint16 RemotePeer::port() const in port()
162 int RemotePeer::lag() const in lag()
167 QTcpSocket* RemotePeer::socket() const in socket()
172 bool RemotePeer::isSecure() const in isSecure()
184 bool RemotePeer::isLocal() const in isLocal()
190 bool RemotePeer::isOpen() const in isOpen()
206 void RemotePeer::onReadyRead() in onReadyRead()
[all …]
|
| H A D | peerfactory.h | 34 class RemotePeer; variable
45 static RemotePeer* createPeer(const ProtoDescriptor& protocol,
50 static RemotePeer* createPeer(const ProtoList& protocols,
|
| H A D | peerfactory.cpp | 34 RemotePeer* PeerFactory::createPeer( in createPeer()
40 RemotePeer* PeerFactory::createPeer( in createPeer()
|
| /dports/irc/quassel-core/quassel-0.14-rc2/src/client/ |
| H A D | clientauthhandler.h | 29 class RemotePeer; variable
64 void handshakeComplete(RemotePeer* peer, const Protocol::SessionState& sessionState);
88 void setPeer(RemotePeer* peer);
107 RemotePeer* _peer;
|
| H A D | clientauthhandler.cpp | 191 …connect(peer, &RemotePeer::protocolVersionMismatch, this, &ClientAuthHandler::onProtocolVersionMis… in onSocketConnected()
221 …RemotePeer* peer = PeerFactory::createPeer(PeerFactory::ProtoDescriptor(type, protoFeatures), this… in onReadyRead()
232 …connect(peer, &RemotePeer::protocolVersionMismatch, this, &ClientAuthHandler::onProtocolVersionMis… in onReadyRead()
247 void ClientAuthHandler::setPeer(RemotePeer* peer) in setPeer()
252 connect(_peer, &RemotePeer::transferProgress, this, &ClientAuthHandler::transferProgress); in setPeer()
|
| /dports/irc/quassel/quassel-0.14-rc2/src/client/ |
| H A D | clientauthhandler.h | 29 class RemotePeer; variable
64 void handshakeComplete(RemotePeer* peer, const Protocol::SessionState& sessionState);
88 void setPeer(RemotePeer* peer);
107 RemotePeer* _peer;
|
| H A D | clientauthhandler.cpp | 191 …connect(peer, &RemotePeer::protocolVersionMismatch, this, &ClientAuthHandler::onProtocolVersionMis… in onSocketConnected()
221 …RemotePeer* peer = PeerFactory::createPeer(PeerFactory::ProtoDescriptor(type, protoFeatures), this… in onReadyRead()
232 …connect(peer, &RemotePeer::protocolVersionMismatch, this, &ClientAuthHandler::onProtocolVersionMis… in onReadyRead()
247 void ClientAuthHandler::setPeer(RemotePeer* peer) in setPeer()
252 connect(_peer, &RemotePeer::transferProgress, this, &ClientAuthHandler::transferProgress); in setPeer()
|
| /dports/irc/quassel/quassel-0.14-rc2/src/core/ |
| H A D | coreauthhandler.h | 41 void handshakeComplete(RemotePeer* peer, UserId uid);
50 void setPeer(RemotePeer* peer);
64 RemotePeer* _peer;
|
| H A D | coreauthhandler.cpp | 89 …RemotePeer* peer = PeerFactory::createPeer(PeerFactory::ProtoDescriptor(Protocol::LegacyProtocol, … in onReadyRead()
94 …connect(peer, &RemotePeer::protocolVersionMismatch, this, &CoreAuthHandler::onProtocolVersionMisma… in onReadyRead()
127 … RemotePeer* peer = PeerFactory::createPeer(_supportedProtos, this, socket(), level, this); in onReadyRead()
136 …connect(peer, &RemotePeer::protocolVersionMismatch, this, &CoreAuthHandler::onProtocolVersionMisma… in onReadyRead()
153 void CoreAuthHandler::setPeer(RemotePeer* peer) in setPeer()
|
| /dports/irc/quassel-core/quassel-0.14-rc2/src/core/ |
| H A D | coreauthhandler.h | 41 void handshakeComplete(RemotePeer* peer, UserId uid);
50 void setPeer(RemotePeer* peer);
64 RemotePeer* _peer;
|
| H A D | coreauthhandler.cpp | 89 …RemotePeer* peer = PeerFactory::createPeer(PeerFactory::ProtoDescriptor(Protocol::LegacyProtocol, … in onReadyRead()
94 …connect(peer, &RemotePeer::protocolVersionMismatch, this, &CoreAuthHandler::onProtocolVersionMisma… in onReadyRead()
127 … RemotePeer* peer = PeerFactory::createPeer(_supportedProtos, this, socket(), level, this); in onReadyRead()
136 …connect(peer, &RemotePeer::protocolVersionMismatch, this, &CoreAuthHandler::onProtocolVersionMisma… in onReadyRead()
153 void CoreAuthHandler::setPeer(RemotePeer* peer) in setPeer()
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-libp2p-pubsub/ |
| H A D | comm.go | 44 peer := s.Conn().RemotePeer()
70 log.Debugf("error reading rpc from %s: %s", s.Conn().RemotePeer(), err)
125 case p.peerDead <- s.Conn().RemotePeer():
130 log.Debugf("unexpected message from %s", s.Conn().RemotePeer())
158 log.Debugf("writing message to %s: %s", s.Conn().RemotePeer(), err)
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-libp2p-circuit/ |
| H A D | conn.go | 66 Relay: c.stream.Conn().RemotePeer().Pretty(),
79 p := c.stream.Conn().RemotePeer()
92 p := c.stream.Conn().RemotePeer()
105 c.stream.Conn().RemotePeer().Pretty(),
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-libp2p/p2p/protocol/identify/ |
| H A D | id.go | 345 if p := c.RemotePeer(); err == nil {
368 log.Event(context.TODO(), "IdentifyOpenFailed", c.RemotePeer(), logging.Metadata{"error": err})
389 case ids.addPeerHandlerCh <- addPeerHandlerReq{c.RemotePeer(), phCh}:
408 log.Debugf("%s sent message to %s %s", ID, c.RemotePeer(), c.RemoteMultiaddr())
425 log.Debugf("%s received message from %s %s", s.Protocol(), c.RemotePeer(), c.RemoteMultiaddr())
551 p := c.RemotePeer()
619 log.Debugf("%s received listen addrs for %s: %s", c.LocalPeer(), c.RemotePeer(), lmaddrs)
634 rp := c.RemotePeer()
787 if ids.Host.Network().Connectedness(v.RemotePeer()) != network.Connected {
790 case ids.rmPeerHandlerCh <- rmPeerHandlerReq{v.RemotePeer()}:
[all …]
|
| H A D | id_delta.go | 30 log.Debugf("%s received message from %s %s", s.Protocol(), c.RemotePeer(), c.RemoteMultiaddr())
37 p := s.Conn().RemotePeer()
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-libp2p-swarm/ |
| H A D | swarm_conn.go | 47 return fmt.Sprintf("%s-%d", c.RemotePeer().Pretty()[0:10], c.id)
139 c.conn.RemotePeer().Pretty(),
159 func (c *Conn) RemotePeer() peer.ID { func
160 return c.conn.RemotePeer()
|
| H A D | swarm_stream.go | 46 s.conn.RemotePeer(),
61 s.conn.swarm.bwc.LogRecvMessageStream(int64(n), s.Protocol(), s.Conn().RemotePeer())
72 s.conn.swarm.bwc.LogSentMessageStream(int64(n), s.Protocol(), s.Conn().RemotePeer())
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-libp2p/p2p/net/mock/ |
| H A D | mock_notif_test.go | 55 nfp := notifs[c.RemotePeer()]
56 notifs[c.RemotePeer()] = append(nfp, c)
106 …t.Logf("%s %s <--%p--> %s %s", c.LocalPeer(), c.LocalMultiaddr(), st1, c.RemotePeer(), c.RemoteMul…
146 n2 := notifiees[str1.Conn().RemotePeer()]
|
| H A D | mock_peernet.go | 162 log.Debugf("%s opening connection to %s", pn.LocalPeer(), lc.RemotePeer())
169 log.Debugf("%s accepting connection from %s", pn.LocalPeer(), c.RemotePeer())
179 _, found := pn.connsByPeer[c.RemotePeer()]
181 pn.connsByPeer[c.RemotePeer()] = map[*conn]struct{}{}
183 pn.connsByPeer[c.RemotePeer()][c] = struct{}{}
|
| /dports/irc/quassel/quassel-0.14-rc2/src/common/protocols/legacy/ |
| H A D | legacypeer.h | 26 class LegacyPeer : public RemotePeer
71 using RemotePeer::writeMessage;
|
| /dports/irc/quassel-core/quassel-0.14-rc2/src/common/protocols/legacy/ |
| H A D | legacypeer.h | 26 class LegacyPeer : public RemotePeer
71 using RemotePeer::writeMessage;
|
| /dports/irc/quassel-core/quassel-0.14-rc2/src/common/protocols/datastream/ |
| H A D | datastreampeer.h | 28 class DataStreamPeer : public RemotePeer
75 using RemotePeer::writeMessage;
|