| /dports/www/chromium-legacy/chromium-88.0.4324.182/services/network/ |
| H A D | quic_transport.cc | 55 if (stream_->outgoing_) { in ~StreamVisitor()
90 outgoing_(stream), in Stream()
96 DCHECK(outgoing_); in Stream()
109 outgoing_(outgoing), in Stream()
113 DCHECK(outgoing_); in Stream()
145 outgoing_ = nullptr; in Abort()
163 if (outgoing_) { in Init()
194 while (outgoing_ && outgoing_->CanWrite()) { in Send()
227 if (!outgoing_) { in MaySendFin()
233 if (outgoing_->SendFin()) { in MaySendFin()
[all …]
|
| /dports/devel/php-ice37/ice-3.7.2/csharp/src/Ice/ |
| H A D | AsyncResult.cs | 87 Debug.Assert(outgoing_ != null); in cancel()
88 outgoing_.cancel(); in cancel()
157 Debug.Assert(outgoing_ != null); in sentSynchronously()
158 return outgoing_.sentSynchronously(); // No lock needed in sentSynchronously()
176 Debug.Assert(outgoing_ != null);
181 return outgoing_.sentSynchronously();
216 return outgoing_;
239 if(outgoing_.sentSynchronously()) in whenSent()
289 if(outgoing_.sentSynchronously()) in whenSent()
478 protected OutgoingAsyncBase outgoing_; field in IceInternal.AsyncResultI
|
| /dports/devel/ice37/ice-3.7.2/csharp/src/Ice/ |
| H A D | AsyncResult.cs | 87 Debug.Assert(outgoing_ != null); in cancel()
88 outgoing_.cancel(); in cancel()
157 Debug.Assert(outgoing_ != null); in sentSynchronously()
158 return outgoing_.sentSynchronously(); // No lock needed in sentSynchronously()
176 Debug.Assert(outgoing_ != null);
181 return outgoing_.sentSynchronously();
216 return outgoing_;
239 if(outgoing_.sentSynchronously()) in whenSent()
289 if(outgoing_.sentSynchronously()) in whenSent()
478 protected OutgoingAsyncBase outgoing_; field in IceInternal.AsyncResultI
|
| /dports/devel/py-ice37/ice-3.7.2/csharp/src/Ice/ |
| H A D | AsyncResult.cs | 87 Debug.Assert(outgoing_ != null); in cancel()
88 outgoing_.cancel(); in cancel()
157 Debug.Assert(outgoing_ != null); in sentSynchronously()
158 return outgoing_.sentSynchronously(); // No lock needed in sentSynchronously()
176 Debug.Assert(outgoing_ != null);
181 return outgoing_.sentSynchronously();
216 return outgoing_;
239 if(outgoing_.sentSynchronously()) in whenSent()
289 if(outgoing_.sentSynchronously()) in whenSent()
478 protected OutgoingAsyncBase outgoing_; field in IceInternal.AsyncResultI
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/services/network/ |
| H A D | quic_transport.cc | 38 if (stream_->outgoing_) { in ~StreamVisitor()
73 outgoing_(stream), in Stream()
79 DCHECK(outgoing_); in Stream()
92 outgoing_(outgoing), in Stream()
96 DCHECK(outgoing_); in Stream()
127 if (outgoing_) { in Init()
156 while (outgoing_ && outgoing_->CanWrite()) { in Send()
188 if (!outgoing_) { in MaySendFin()
194 if (outgoing_->SendFin()) { in MaySendFin()
195 outgoing_ = nullptr; in MaySendFin()
[all …]
|
| /dports/math/vtk8/VTK-8.2.0/ThirdParty/vtkm/vtk-m/vtkm/thirdparty/diy/vtkmdiy/include/vtkmdiy/ |
| H A D | proxy.hpp | 17 outgoing_(&master__->outgoing(gid__)), in Proxy()
28 { OutgoingQueues& out = *outgoing_; save(out[to], x); } in enqueue()
66 OutgoingQueues* outgoing() const { return outgoing_; } in outgoing()
67 MemoryBuffer& outgoing(const BlockID& to) const { return (*outgoing_)[to]; } in outgoing()
108 OutgoingQueues* outgoing_; member
203 OutgoingQueues& out = *outgoing_; in enqueue()
|
| H A D | master.hpp | 279 … gid__) const { OutgoingQueuesMap::const_iterator it = outgoing_.find(gid__); if (it == outgoing_.… in outgoing_count()
322 OutgoingQueuesMap outgoing_; member in diy::Master
546 OutgoingQueuesRecord& out_qr = outgoing_[gid__]; in unload_outgoing()
638 OutgoingQueuesRecord& out_qr = outgoing_[gid__]; in load_outgoing()
827 OutgoingQueues& outgoing_queues = outgoing_[gid(i)].queues; in exchange()
970 …for (OutQueueRecords::iterator it = outgoing_[from].external_local.begin(); it != outgoing_[from].… in send_outgoing_queues()
994 outgoing_[from].external_local.clear(); in send_outgoing_queues()
996 if (outgoing_[from].external != -1) in send_outgoing_queues()
1000 OutgoingQueues& outgoing = outgoing_[from].queues; in send_outgoing_queues()
1190 for (OutgoingQueuesMap::iterator it = outgoing_.begin(); it != outgoing_.end(); ++it) in flush()
[all …]
|
| /dports/math/vtk9/VTK-9.1.0/ThirdParty/vtkm/vtkvtkm/vtk-m/vtkm/thirdparty/diy/vtkmdiy/include/vtkmdiy/ |
| H A D | proxy.hpp | 32 outgoing_.emplace(x.first, access->back().move()); in Proxy()
52 for (auto& x : outgoing_) in ~Proxy()
97 save(outgoing_[to], x); in enqueue()
154 OutgoingQueues* outgoing() const { return &outgoing_; } in outgoing()
155 MemoryBuffer& outgoing(const BlockID& to) const { return outgoing_[to]; } in outgoing()
205 mutable OutgoingQueues outgoing_; member
328 BinaryBuffer& bb = outgoing_[to]; in enqueue()
|
| /dports/math/vtk8/VTK-8.2.0/ThirdParty/diy2/vtkdiy2/include/vtkdiy2/ |
| H A D | proxy.hpp | 17 outgoing_(&master__->outgoing(gid__)), in Proxy()
28 { OutgoingQueues& out = *outgoing_; save(out[to], x); } in enqueue()
84 OutgoingQueues* outgoing() const { return outgoing_; } in outgoing()
85 MemoryBuffer& outgoing(const BlockID& to) const { return (*outgoing_)[to]; } in outgoing()
126 OutgoingQueues* outgoing_; member
223 OutgoingQueues& out = *outgoing_; in enqueue()
|
| H A D | master.hpp | 319 OutgoingQueuesMap outgoing_; member in diy::Master
438 OutgoingQueuesRecord& out_qr = outgoing_[gid__]; in unload_outgoing()
530 OutgoingQueuesRecord& out_qr = outgoing_[gid__]; in load_outgoing()
647 OutgoingQueues& outgoing_queues = outgoing_[gid(i)].queues; in touch_queues()
726 outgoing_.clear(); in iexchange_()
808 for (OutgoingQueuesMap::iterator it = outgoing_.begin(); it != outgoing_.end(); ++it) in order_gids()
871 if (outgoing_[from].external != -1) in send_outgoing_queues()
874 OutgoingQueues& outgoing = outgoing_[from].queues; in send_outgoing_queues()
906 for (auto& x : outgoing_[from].external_local) in move_external_local()
930 outgoing_[from].external_local.clear(); in move_external_local()
[all …]
|
| /dports/math/vtk9/VTK-9.1.0/ThirdParty/diy2/vtkdiy2/include/vtkdiy2/ |
| H A D | proxy.hpp | 19 outgoing_(&master__->outgoing(gid__)), in Proxy()
31 OutgoingQueues& out = *outgoing_; save(out[to], x); in enqueue()
94 OutgoingQueues* outgoing() const { return outgoing_; } in outgoing()
95 MemoryBuffer& outgoing(const BlockID& to) const { return (*outgoing_)[to]; } in outgoing()
143 OutgoingQueues* outgoing_; member
265 OutgoingQueues& out = *outgoing_; in enqueue()
|
| H A D | master.hpp | 333 OutgoingQueuesMap outgoing_; member in diy::Master
454 OutgoingQueuesRecord& out_qr = outgoing_[gid__]; in unload_outgoing()
546 OutgoingQueuesRecord& out_qr = outgoing_[gid__]; in load_outgoing()
665 OutgoingQueues& outgoing_queues = outgoing_[gid(i)].queues; in touch_queues()
744 outgoing_.clear(); in iexchange_()
834 for (OutgoingQueuesMap::iterator it = outgoing_.begin(); it != outgoing_.end(); ++it) in order_gids()
949 if (outgoing_[from_gid].external != -1) in send_outgoing_queues()
952 OutgoingQueues& outgoing = outgoing_[from_gid].queues; in send_outgoing_queues()
973 for (auto& x : outgoing_[from].external_local) in move_external_local()
997 outgoing_[from].external_local.clear(); in move_external_local()
[all …]
|
| /dports/devel/grpc/grpc-1.42.0/src/core/lib/http/ |
| H A D | httpcli.cc | 68 grpc_slice_buffer_init(&outgoing_); in InternalRequest()
92 grpc_slice_buffer_destroy_internal(&outgoing_); in ~InternalRequest()
162 grpc_slice_buffer_add(&outgoing_, request_text_); in StartWrite()
163 grpc_endpoint_write(ep_, &outgoing_, &done_write_, nullptr); in StartWrite()
238 grpc_slice_buffer outgoing_; member in grpc_core::__anonf9f3f67f0111::InternalRequest
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/lib/http/ |
| H A D | httpcli.cc | 68 grpc_slice_buffer_init(&outgoing_); in InternalRequest()
92 grpc_slice_buffer_destroy_internal(&outgoing_); in ~InternalRequest()
162 grpc_slice_buffer_add(&outgoing_, request_text_); in StartWrite()
163 grpc_endpoint_write(ep_, &outgoing_, &done_write_, nullptr); in StartWrite()
238 grpc_slice_buffer outgoing_; member in grpc_core::__anon45a909b00111::InternalRequest
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/lib/http/ |
| H A D | httpcli.cc | 71 grpc_slice_buffer_init(&outgoing_); in InternalRequest()
95 grpc_slice_buffer_destroy_internal(&outgoing_); in ~InternalRequest()
164 grpc_slice_buffer_add(&outgoing_, request_text_); in StartWrite()
165 grpc_endpoint_write(ep_, &outgoing_, &done_write_, nullptr); in StartWrite()
246 grpc_slice_buffer outgoing_; member in grpc_core::__anon443c8ae60111::InternalRequest
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/security/transport/ |
| H A D | security_handshaker.cc | 94 grpc_slice_buffer outgoing_; member in grpc_core::__anonc905c08c0111::SecurityHandshaker
110 grpc_slice_buffer_init(&outgoing_); in SecurityHandshaker()
133 grpc_slice_buffer_destroy_internal(&outgoing_); in ~SecurityHandshaker()
302 grpc_slice_buffer_reset_and_unref_internal(&outgoing_); in OnHandshakeNextDoneLocked()
303 grpc_slice_buffer_add(&outgoing_, to_send); in OnHandshakeNextDoneLocked()
304 grpc_endpoint_write(args_->endpoint, &outgoing_, in OnHandshakeNextDoneLocked()
|
| /dports/lang/spidermonkey60/firefox-60.9.0/media/webrtc/trunk/webrtc/p2p/base/ |
| H A D | tcpport.cc | 313 outgoing_(socket == NULL), in TCPConnection()
317 if (outgoing_) { in TCPConnection()
467 if (connected() || connection_pending_ || !outgoing_) { in MaybeReconnect()
492 RTC_DCHECK(outgoing_); in CreateOutgoingTcpSocket()
514 if (outgoing_) { in ConnectSocketSignals()
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/lib/security/transport/ |
| H A D | security_handshaker.cc | 100 grpc_slice_buffer outgoing_; member in grpc_core::__anon90506cc50111::SecurityHandshaker
124 grpc_slice_buffer_init(&outgoing_); in SecurityHandshaker()
141 grpc_slice_buffer_destroy_internal(&outgoing_); in ~SecurityHandshaker()
318 grpc_slice_buffer_reset_and_unref_internal(&outgoing_); in OnHandshakeNextDoneLocked()
319 grpc_slice_buffer_add(&outgoing_, to_send); in OnHandshakeNextDoneLocked()
321 args_->endpoint, &outgoing_, in OnHandshakeNextDoneLocked()
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/lib/security/transport/ |
| H A D | security_handshaker.cc | 100 grpc_slice_buffer outgoing_; member in grpc_core::__anon694cf99e0111::SecurityHandshaker
124 grpc_slice_buffer_init(&outgoing_); in SecurityHandshaker()
141 grpc_slice_buffer_destroy_internal(&outgoing_); in ~SecurityHandshaker()
318 grpc_slice_buffer_reset_and_unref_internal(&outgoing_); in OnHandshakeNextDoneLocked()
319 grpc_slice_buffer_add(&outgoing_, to_send); in OnHandshakeNextDoneLocked()
321 args_->endpoint, &outgoing_, in OnHandshakeNextDoneLocked()
|
| /dports/databases/cassandra-cpp-driver/cpp-driver-2.16.0/src/ |
| H A D | ssl.hpp | 59 rb::RingBuffer& outgoing() { return outgoing_; } in outgoing()
67 rb::RingBuffer outgoing_; member in datastax::internal::core::SslSession
|
| /dports/devel/grpc/grpc-1.42.0/src/core/lib/security/transport/ |
| H A D | security_handshaker.cc | 103 grpc_slice_buffer outgoing_; member in grpc_core::__anon6e7e52cb0111::SecurityHandshaker
123 grpc_slice_buffer_init(&outgoing_);
139 grpc_slice_buffer_destroy_internal(&outgoing_); in ~SecurityHandshaker()
378 grpc_slice_buffer_reset_and_unref_internal(&outgoing_); in OnHandshakeNextDoneLocked()
379 grpc_slice_buffer_add(&outgoing_, to_send); in OnHandshakeNextDoneLocked()
381 args_->endpoint, &outgoing_, in OnHandshakeNextDoneLocked()
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/lib/security/transport/ |
| H A D | security_handshaker.cc | 103 grpc_slice_buffer outgoing_; member in grpc_core::__anona15a993c0111::SecurityHandshaker
123 grpc_slice_buffer_init(&outgoing_);
139 grpc_slice_buffer_destroy_internal(&outgoing_); in ~SecurityHandshaker()
378 grpc_slice_buffer_reset_and_unref_internal(&outgoing_); in OnHandshakeNextDoneLocked()
379 grpc_slice_buffer_add(&outgoing_, to_send); in OnHandshakeNextDoneLocked()
381 args_->endpoint, &outgoing_, in OnHandshakeNextDoneLocked()
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/lib/security/transport/ |
| H A D | security_handshaker.cc | 103 grpc_slice_buffer outgoing_; member in grpc_core::__anon99f041f20111::SecurityHandshaker
123 grpc_slice_buffer_init(&outgoing_);
139 grpc_slice_buffer_destroy_internal(&outgoing_); in ~SecurityHandshaker()
378 grpc_slice_buffer_reset_and_unref_internal(&outgoing_); in OnHandshakeNextDoneLocked()
379 grpc_slice_buffer_add(&outgoing_, to_send); in OnHandshakeNextDoneLocked()
381 args_->endpoint, &outgoing_, in OnHandshakeNextDoneLocked()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/webrtc/p2p/base/ |
| H A D | tcp_port.cc | 355 outgoing_(socket == NULL), in TCPConnection()
359 if (outgoing_) { in TCPConnection()
535 if (connected() || connection_pending_ || !outgoing_) { in MaybeReconnect()
562 RTC_DCHECK(outgoing_); in CreateOutgoingTcpSocket()
594 if (outgoing_) { in ConnectSocketSignals()
|
| /dports/net-im/tg_owt/tg_owt-d578c76/src/p2p/base/ |
| H A D | tcp_port.cc | 355 outgoing_(socket == NULL), in TCPConnection()
359 if (outgoing_) { in TCPConnection()
537 if (connected() || connection_pending_ || !outgoing_) { in MaybeReconnect()
564 RTC_DCHECK(outgoing_); in CreateOutgoingTcpSocket()
596 if (outgoing_) { in ConnectSocketSignals()
|