Home
last modified time | relevance | path

Searched refs:incoming2 (Results 1 – 16 of 16) sorted by relevance

/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/network/p2p/
H A Dsocket_tcp_server_unittest.cc158 FakeSocket* incoming2 = new FakeSocket(nullptr); in TEST_F() local
159 incoming2->SetLocalAddress(ParseAddress(kTestLocalIpAddress, kTestPort1)); in TEST_F()
161 incoming2->SetPeerAddress(addr2); in TEST_F()
164 socket_->AddIncoming(incoming2); in TEST_F()
175 EXPECT_EQ(incoming2, GetSocketFromTcpSocket(reinterpret_cast<P2PSocketTcp*>( in TEST_F()
/dports/www/chromium-legacy/chromium-88.0.4324.182/services/network/p2p/
H A Dsocket_tcp_server_unittest.cc160 FakeSocket* incoming2 = new FakeSocket(nullptr); in TEST_F() local
161 incoming2->SetLocalAddress(ParseAddress(kTestLocalIpAddress, kTestPort1)); in TEST_F()
163 incoming2->SetPeerAddress(addr2); in TEST_F()
166 socket_->AddIncoming(incoming2); in TEST_F()
177 EXPECT_EQ(incoming2, GetSocketFromTcpSocket(reinterpret_cast<P2PSocketTcp*>( in TEST_F()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/stream-cancel-0.4.4/src/
H A Dlib.rs234 let incoming2 = valve.wrap(listener2.incoming()); in multi_interrupt() localVariable
239 .select(incoming2) in multi_interrupt()
321 let incoming2 = valve.wrap(listener2.incoming()); in yields_some() localVariable
328 .select(incoming2) in yields_some()
/dports/science/lammps/lammps-stable_29Sep2021/src/
H A Drcb.cpp113 int keep,outgoing,incoming,incoming2; in compute() local
524 MPI_Recv(&incoming2,1,MPI_INT,procpartner2,0,world,MPI_STATUS_IGNORE); in compute()
525 incoming += incoming2; in compute()
568 keep += incoming - incoming2; in compute()
569 MPI_Irecv(&dots[keep],incoming2*sizeof(Dot),MPI_CHAR, in compute()
650 int keep,outgoing,incoming,incoming2; in compute_old() local
1016 MPI_Recv(&incoming2,1,MPI_INT,procpartner2,0,world,MPI_STATUS_IGNORE); in compute_old()
1017 incoming += incoming2; in compute_old()
1060 keep += incoming - incoming2; in compute_old()
1061 MPI_Irecv(&dots[keep],incoming2*sizeof(Dot),MPI_CHAR, in compute_old()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/stream-cancel-0.4.4/
H A DREADME.md104 let incoming2 = valve.wrap(listener2.incoming());
109 .select(incoming2)
121 // the runtime will not become idle until both incoming1 and incoming2 have stopped
/dports/math/moab/fathomteam-moab-7bde9dfb84a8/src/parallel/moab/
H A DParallelComm.hpp156 int &incoming2, // newly added
163 int& incoming1, int& incoming2,
182 int& incoming2,
193 int incoming1, int incoming2,
210 int& incoming2,
220 int& incoming2,
/dports/mail/balsa/balsa-2.5.1/src/
H A Dfilter-run-callbacks.c481 gboolean incoming2, closing2; in fr_swap() local
489 INCOMING_COLUMN, &incoming2, in fr_swap()
494 INCOMING_COLUMN, incoming2, in fr_swap()
/dports/science/sparta/sparta-20Oct2021/src/
H A Drcb.cpp112 int keep,outgoing,incoming,incoming2; in compute() local
493 MPI_Recv(&incoming2,1,MPI_INT,procpartner2,0,world,&status); in compute()
494 incoming += incoming2; in compute()
537 keep += incoming - incoming2; in compute()
538 MPI_Irecv(&dots[keep],incoming2*sizeof(Dot),MPI_CHAR, in compute()
/dports/security/silktools/silk-3.19.1/src/rwflowpack/tests/
H A Drwflowpack-pack-multiple2.pl90 poll-directory ${incoming2}
H A Drwflowpack-pack-multiple.pl97 poll-directory ${incoming2}
/dports/cad/sumo/sumo-1.2.0/src/netbuild/
H A DNBTrafficLightDefinition.cpp343 std::vector<NBNode*>::const_iterator incoming2 = in forbids() local
345 if (incoming2 == myControlledNodes.end()) { in forbids()
348 NBNode* incnode2 = *incoming2; in forbids()
H A DNBNodeShapeComputer.cpp597 const bool incoming2 = (*j)->getToNode() == &myNode; in joinSameDirectionEdges() local
599 const Position positionAtNode2 = (*j)->getGeometry()[incoming2 ? -1 : 0]; in joinSameDirectionEdges()
609 const bool differentDirs = (incoming != incoming2); in joinSameDirectionEdges()
/dports/math/moab/fathomteam-moab-7bde9dfb84a8/src/parallel/
H A DParallelComm.cpp1162 incoming2++; in recv_entities()
1226 while (incoming2) { in recv_entities()
1234 incoming2--; in recv_entities()
1370 while (incoming2) { in recv_remote_handle_messages()
1380 incoming2--; in recv_remote_handle_messages()
5684 incoming2++; in exchange_ghost_cells()
5809 while (incoming2) { in exchange_ghost_cells()
5817 incoming2--; in exchange_ghost_cells()
6900 incoming2++; in exchange_owned_mesh()
6976 while (incoming2) { in exchange_owned_mesh()
[all …]
/dports/net/cjdns/cjdns-cjdns-v21.1/util/events/libuv/
H A DPipe.c237 static void incoming2(uv_pipe_t* stream, ssize_t nread, const uv_buf_t* buf, uv_handle_type _) in incoming2() function
261 return uv_read2_start((uv_stream_t*)&pipe->peer, allocate, incoming2); in startPipe()
/dports/games/scorched3d/scorched/
H A DMakefile.am2702 data/globalmods/awe/data/wav/event/incoming2.wav \
H A DMakefile.in3833 data/globalmods/awe/data/wav/event/incoming2.wav \