Home
last modified time | relevance | path

Searched refs:TCPConnection (Results 1 – 25 of 135) sorted by relevance

123456

/dports/net-mgmt/tcptrack/tcptrack-1.4.2/src/
H A DTCPConnection.cc42 TCPConnection::~TCPConnection() in ~TCPConnection()
49 bool TCPConnection::fastMode() in fastMode()
54 bool TCPConnection::isFinished() in isFinished()
61 IPAddress & TCPConnection::srcAddr() in srcAddr()
66 portnum_t TCPConnection::srcPort() in srcPort()
71 IPAddress & TCPConnection::dstAddr() in dstAddr()
76 portnum_t TCPConnection::dstPort() in dstPort()
81 int TCPConnection::getPacketCount() in getPacketCount()
91 int TCPConnection::getState() in getState()
96 TCPConnection::TCPConnection( TCPCapture &p ) in TCPConnection() function in TCPConnection
[all …]
H A DSortedIterator.cc32 cons = (TCPConnection **) malloc(numcons*sizeof(TCPConnection *)); in SortedIterator()
51 qsort(cons,numcons,sizeof(TCPConnection *),compare_rate); in sort()
59 TCPConnection * SortedIterator::getNext() in getNext()
83 TCPConnection * con1; in compare_rate()
84 TCPConnection * con2; in compare_rate()
86 con1=* (TCPConnection **) c1; in compare_rate()
87 con2=* (TCPConnection **) c2; in compare_rate()
109 TCPConnection * con1; in compare_bytes()
110 TCPConnection * con2; in compare_bytes()
112 con1=* (TCPConnection **) c1; in compare_bytes()
[all …]
H A DTCContainer.cc89 TCPConnection *rm = (*i).second; in ~TCContainer()
118 TCPConnection *ic = (*i).second; in processPacket()
128 TCPConnection *newcon = new TCPConnection( p ); in processPacket()
137 TCPConnection *newcon = guesser.addPacket(p); in processPacket()
175 TCPConnection *ic=(*i).second; in maint_thread_run()
187 TCPConnection *rm = ic; in maint_thread_run()
H A DSortedIterator.h30 class TCPConnection; variable
40 TCPConnection * getNext();
44 TCPConnection **cons;
H A DGuesser.cc21 TCPConnection * Guesser::addPacket( TCPCapture &p ) in addPacket()
63 TCPConnection *nc; in addPacket()
79 nc=new TCPConnection(p); in addPacket()
84 nc=new TCPConnection(*ocp); in addPacket()
/dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/p2p/base/
H A Dtcpport.cc158 TCPConnection* conn = NULL; in CreateConnection()
162 conn = new TCPConnection(this, address, socket); in CreateConnection()
164 conn = new TCPConnection(this, address); in CreateConnection()
201 TCPConnection* conn = static_cast<TCPConnection*>(GetConnection(addr)); in SendTo()
307 TCPConnection::TCPConnection(TCPPort* port, in TCPConnection() function in cricket::TCPConnection
329 TCPConnection::~TCPConnection() { in ~TCPConnection()
366 int TCPConnection::GetError() { in GetError()
449 void TCPConnection::OnMessage(rtc::Message* pmsg) { in OnMessage()
464 void TCPConnection::MaybeReconnect() { in MaybeReconnect()
478 void TCPConnection::OnReadPacket( in OnReadPacket()
[all …]
/dports/devel/elixir-connection/connection-1.0.4/examples/tcp_connection/
H A DREADME.md1 TCPConnection chapter
11 {:ok, conn} = TCPConnection.start_link({127,0,0,1}, 8000, [mode: :binary], 1000)
12 {:error, closed} = TCPConnection.send(conn, "hello")
13 {:error, closed} = TCPConnection.recv(conn, 0, 1000)
20 {:ok, "hello"} = TCPConnection.recv(conn, 5, 1000)
21 :ok = TCPConnection.send(conn, "hi")
23 :ok = TCPConnection.close(conn)
26 The TCPConnection process will automatically reconnect (retries every
30 :ok = TCPConnection.send(conn, "back!")
/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/p2p/base/
H A Dtcpport.cc86 TCPConnection* conn = NULL; in CreateConnection()
90 conn = new TCPConnection(this, address, socket); in CreateConnection()
92 conn = new TCPConnection(this, address); in CreateConnection()
118 if (TCPConnection * conn = static_cast<TCPConnection*>(GetConnection(addr))) { in SendTo()
198 TCPConnection::TCPConnection(TCPPort* port, const Candidate& candidate, in TCPConnection() function in cricket::TCPConnection
214 socket_->SignalConnect.connect(this, &TCPConnection::OnConnect); in TCPConnection()
226 socket_->SignalClose.connect(this, &TCPConnection::OnClose); in TCPConnection()
230 TCPConnection::~TCPConnection() { in ~TCPConnection()
234 int TCPConnection::Send(const void* data, size_t size) { in Send()
254 int TCPConnection::GetError() { in GetError()
[all …]
H A Dtcpport.h38 class TCPConnection; variable
113 friend class TCPConnection; variable
116 class TCPConnection : public Connection {
119 TCPConnection(TCPPort* port, const Candidate& candidate,
121 virtual ~TCPConnection();
/dports/www/firefox-legacy/firefox-52.8.0esr/media/webrtc/trunk/webrtc/p2p/base/
H A Dtcpport.cc96 TCPConnection* conn = NULL; in CreateConnection()
100 conn = new TCPConnection(this, address, socket); in CreateConnection()
102 conn = new TCPConnection(this, address); in CreateConnection()
137 if (TCPConnection * conn = static_cast<TCPConnection*>(GetConnection(addr))) { in SendTo()
225 TCPConnection::TCPConnection(TCPPort* port, const Candidate& candidate, in TCPConnection() function in cricket::TCPConnection
255 socket_->SignalClose.connect(this, &TCPConnection::OnClose); in TCPConnection()
259 TCPConnection::~TCPConnection() { in ~TCPConnection()
263 int TCPConnection::Send(const void* data, size_t size, in Send()
286 int TCPConnection::GetError() { in GetError()
290 void TCPConnection::OnConnect(rtc::AsyncPacketSocket* socket) { in OnConnect()
[all …]
H A Dtcpport.h21 class TCPConnection; variable
108 friend class TCPConnection; variable
111 class TCPConnection : public Connection {
114 TCPConnection(TCPPort* port, const Candidate& candidate,
116 virtual ~TCPConnection();
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/p2p/base/
H A Dtcp_port.cc147 TCPConnection* conn = NULL; in CreateConnection()
153 conn = new TCPConnection(this, address, socket); in CreateConnection()
157 conn = new TCPConnection(this, address); in CreateConnection()
204 TCPConnection* conn = static_cast<TCPConnection*>(GetConnection(addr)); in SendTo()
349 TCPConnection::TCPConnection(TCPPort* port, in TCPConnection() function in cricket::TCPConnection
375 TCPConnection::~TCPConnection() {} in ~TCPConnection()
377 int TCPConnection::Send(const void* data, in Send()
415 int TCPConnection::GetError() { in GetError()
514 void TCPConnection::OnMessage(rtc::Message* pmsg) { in OnMessage()
532 void TCPConnection::MaybeReconnect() { in MaybeReconnect()
[all …]
H A Dtcp_port.h25 class TCPConnection; variable
113 friend class TCPConnection; variable
116 class TCPConnection : public Connection {
119 TCPConnection(TCPPort* port,
122 ~TCPConnection() override;
/dports/net-im/tg_owt/tg_owt-d578c76/src/p2p/base/
H A Dtcp_port.cc147 TCPConnection* conn = NULL; in CreateConnection()
153 conn = new TCPConnection(this, address, socket); in CreateConnection()
157 conn = new TCPConnection(this, address); in CreateConnection()
204 TCPConnection* conn = static_cast<TCPConnection*>(GetConnection(addr)); in SendTo()
349 TCPConnection::TCPConnection(TCPPort* port, in TCPConnection() function in cricket::TCPConnection
375 TCPConnection::~TCPConnection() {} in ~TCPConnection()
377 int TCPConnection::Send(const void* data, in Send()
417 int TCPConnection::GetError() { in GetError()
516 void TCPConnection::OnMessage(rtc::Message* pmsg) { in OnMessage()
534 void TCPConnection::MaybeReconnect() { in MaybeReconnect()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/webrtc/p2p/base/
H A Dtcp_port.cc147 TCPConnection* conn = NULL; in CreateConnection()
153 conn = new TCPConnection(this, address, socket); in CreateConnection()
157 conn = new TCPConnection(this, address); in CreateConnection()
204 TCPConnection* conn = static_cast<TCPConnection*>(GetConnection(addr)); in SendTo()
349 TCPConnection::TCPConnection(TCPPort* port, in TCPConnection() function in cricket::TCPConnection
375 TCPConnection::~TCPConnection() {} in ~TCPConnection()
377 int TCPConnection::Send(const void* data, in Send()
415 int TCPConnection::GetError() { in GetError()
514 void TCPConnection::OnMessage(rtc::Message* pmsg) { in OnMessage()
532 void TCPConnection::MaybeReconnect() { in MaybeReconnect()
[all …]
/dports/misc/gedkeeper/GEDKeeper-2.19.1/projects/GKCommunicator/GKNetCore/TCP/
H A DTCPDuplexClient.cs34 private readonly List<TCPConnection> fConnections;
45 fConnections = new List<TCPConnection>(); in TCPDuplexClient()
78 protected internal void AddConnection(TCPConnection connection) in AddConnection()
84 protected internal void RemoveConnection(TCPConnection connection) in RemoveConnection()
99 TCPConnection newConn = new TCPConnection(this, sock.EndAccept(result)); in OnConnectRequest()
104 public TCPConnection GetConnection(IPEndPoint point, bool canCreate = true) in GetConnection()
117 public TCPConnection CreateConnection(IPEndPoint point) in CreateConnection()
122 return new TCPConnection(this, extSocket, false); in CreateConnection()
/dports/databases/elixir-db_connection/db_connection-1.1.3/examples/tcp_connection/
H A DREADME.md1 TCPConnection chapter
4 `TCPConnection` is a simple `DBConnection` process that behaves in a
11 {:ok, pid} = TCPConnection.start_link("localhost", 8000)
15 {:ok, "hello"} = TCPConnection.recv(pid, 5, 1000)
16 :ok = TCPConnection.send(pid, "hi")
19 The TCPConnection process will automatically reconnect:
23 :ok = TCPConnection.send(pid, "back!")
/dports/textproc/metauml/
H A DState1.mp21 Class.TCPConnection("TCPConnection")()
32 TCPState.w = TCPConnection.e + (150, 0);
40 noteOpen.n = TCPConnection.sw - (0, 50);
42 drawObjects(TCPConnection, TCPState, established, listen, closed, noteOpen);
44 clink(compositionUni)(TCPState, TCPConnection);
49 link(dashedLink)(TCPConnection.methodStack.pict[0].w - (9, 0)-- noteOpen.nw + (10, 0));
/dports/devel/elixir-connection/connection-1.0.4/examples/tcp_connection/test/
H A Dtcp_connection_test.exs7 {:ok, conn} = TCPConnection.start_link({127,0,0,1}, port, [mode: :binary])
11 assert TCPConnection.recv(conn, 5, 1000) == {:ok, "hello"}
12 assert TCPConnection.send(conn, "hi") == :ok
14 assert TCPConnection.close(conn) == :ok
19 assert TCPConnection.send(conn, "back!") == :ok
/dports/games/wop/wop-0.4.3/src/
H A Dclientconnectiontcp.cpp35 int result = TCPConnection::recvMessage( m_socket, message ); in openConnection()
49 TCPConnection::sendMessage( m_socket, &connectMessage ); in openConnection()
63 TCPConnection::sendMessage( m_socket, &quitMessage ); in closeConnection()
105 TCPConnection::sendMessage( m_socket, message, m_compress, m_listener ); in sendMessage()
110 TCPConnection::sendMessage( m_socket, echoMessage, m_compress, m_listener ); in sendEchoMessage()
118 int result = TCPConnection::recvMessage( m_socket, message, m_listener ); in recvMessage()
H A Dserverconnectiontcp.cpp49 TCPConnection::sendMessage( m_socket, &requestMessage ); in openConnection()
52 int result = TCPConnection::recvMessage( m_socket, message ); in openConnection()
69 TCPConnection::sendMessage( m_socket, &quitMessage ); in closeConnection()
81 TCPConnection::sendMessage( m_socket, message, m_compress, m_listener ); in sendMessage()
127 int result = TCPConnection::recvMessage( m_socket, message, m_listener ); in recvMessage()
/dports/databases/elixir-db_connection/db_connection-1.1.3/examples/tcp_connection/lib/
H A Dtcp_connection.ex1 defmodule TCPConnection do module
55 {:error, TCPConnection.Error.exception({:connect, reason})}
93 {:disconnect, TCPConnection.Error.exception({:send, reason}), state}
109 {:error, TCPConnection.Error.exception({:recv, :timeout}), state}
111 {:disconnect, TCPConnection.Error.exception({:recv, reason}), state}
134 {:error, TCPConnection.Error.exception({:recv, :timeout}), state}
136 {:disconnect, TCPConnection.Error.exception({:recv, reason}), state}
156 {:disconnect, TCPConnection.Error.exception({:recv, :closed}), state}
159 {:disconnect, TCPConnection.Error.exception({:recv, reason}), state}
189 defimpl DBConnection.Query, for: TCPConnection.Query do
[all …]
/dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/blocks/
H A DTCPConnectionMap.java160 TCPConnection conn; in send()
242 TCPConnection conn=null; in run()
246 conn=new TCPConnection(client_sock); in run()
353 public class TCPConnection implements Connection { class in TCPConnectionMap
368 TCPConnection(Address peer_addr) throws Exception { in TCPConnection() method in TCPConnectionMap.TCPConnection
382 TCPConnection(Socket s) throws Exception { in TCPConnection() method in TCPConnectionMap.TCPConnection
600 Util.close(TCPConnection.this); in run()
663 Util.close(TCPConnection.this); in run()
744 TCPConnection conn = null; in getConnection()
751 conn = new TCPConnection(dest); in getConnection()
[all …]
/dports/astro/py-ro/RO-3.6.9/python/RO/Comm/
H A DVMSTelnet.py34 from TCPConnection import TCPConnection
36 class VMSTelnet(TCPConnection):
64 TCPConnection.__init__(self,
102 TCPConnection.connect(self, host, port)
184 class NullConnection(TCPConnection):
/dports/misc/fq/fq-0.0.2/format/inet/flowsdecoder/
H A Dflowsdecoder.go19 type TCPConnection struct { struct
31 func (t *TCPConnection) Accept(tcp *layers.TCP, ci gopacket.CaptureInfo, dir reassembly.TCPFlowDire… argument
48 func (t *TCPConnection) ReassembledSG(sg reassembly.ScatterGather, ac reassembly.AssemblerContext) { argument
67 func (t *TCPConnection) ReassemblyComplete(ac reassembly.AssemblerContext) bool { argument
95 stream := &TCPConnection{
119 TCPConnections []*TCPConnection

123456