/dports/net-mgmt/tcptrack/tcptrack-1.4.2/src/ |
H A D | TCPConnection.cc | 42 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 D | SortedIterator.cc | 32 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 D | TCContainer.cc | 89 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 D | SortedIterator.h | 30 class TCPConnection; variable 40 TCPConnection * getNext(); 44 TCPConnection **cons;
|
H A D | Guesser.cc | 21 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 D | tcpport.cc | 158 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 D | README.md | 1 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 D | tcpport.cc | 86 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 D | tcpport.h | 38 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 D | tcpport.cc | 96 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 D | tcpport.h | 21 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 D | tcp_port.cc | 147 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 D | tcp_port.h | 25 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 D | tcp_port.cc | 147 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 D | tcp_port.cc | 147 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 D | TCPDuplexClient.cs | 34 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 D | README.md | 1 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 D | State1.mp | 21 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 D | tcp_connection_test.exs | 7 {: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 D | clientconnectiontcp.cpp | 35 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 D | serverconnectiontcp.cpp | 49 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 D | tcp_connection.ex | 1 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 D | TCPConnectionMap.java | 160 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 D | VMSTelnet.py | 34 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 D | flowsdecoder.go | 19 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
|