| /dports/net/nsq/nsq-1.2.1/vendor/github.com/judwhite/go-svc/example/ |
| H A D | server.go | 22 go s.startReceiver()
53 func (s *server) startReceiver() { func
|
| /dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/receiver/ |
| H A D | ReceiverSupervisor.scala | 131 startReceiver()
144 def startReceiver(): Unit = synchronized { method
198 startReceiver()
|
| /dports/net/olsrd/olsrd-0.9.8/lib/pud/src/ |
| H A D | receiver.h | 67 bool startReceiver(void);
|
| H A D | pud.c | 346 if (!startReceiver()) { in initPud()
|
| /dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/protocols/ |
| H A D | BPING.java | 85 startReceiver(); in start()
90 private void startReceiver() { in startReceiver() method in BPING
|
| H A D | MPING.java | 229 startReceiver(); in start()
250 private void startReceiver() { in startReceiver() method in MPING
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/multicast/ |
| H A D | impl.h | 53 void startReceiver();
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/multicast/ |
| H A D | impl.h | 53 void startReceiver();
|
| /dports/databases/py-carbon/carbon-1.1.8/lib/carbon/ |
| H A D | amqp_listener.py | 216 def startReceiver(host, port, username, password, vhost, exchange_name, function
258 startReceiver(options.host, options.port, options.username,
|
| /dports/net/norm/norm-1.5r6/examples/python/ |
| H A D | normFileRecv.py | 42 session.startReceiver(1024*1024)
|
| H A D | fileRecvManager.py | 63 session.startReceiver(1024*1024)
|
| H A D | streamChat.py | 47 session.startReceiver(1024*1024)
|
| H A D | normFileFeedback.py | 54 session.startReceiver(1024*1024)
|
| H A D | normMsgr.py | 121 self.normSession.startReceiver(10*1024*1024)
|
| /dports/net/norm/norm-1.5r6/examples/java/ |
| H A D | NormFileRecv.java | 27 session.startReceiver(1024 * 1024); in main()
|
| H A D | NormFileSendRecv.java | 45 session.startReceiver(1024 * 1024); in receive()
|
| H A D | NormStreamRecv.java | 49 session.startReceiver(SESSION_BUFFER_SIZE); in main()
|
| /dports/devel/spark/spark-2.1.1/streaming/src/main/scala/org/apache/spark/streaming/scheduler/ |
| H A D | ReceiverTracker.scala | 484 startReceiver(receiver, executors)
506 startReceiver(receiver, scheduledLocations)
577 private def startReceiver( method
|
| /dports/net/norm/norm-1.5r6/src/java/src/mil/navy/nrl/norm/ |
| H A D | NormSession.java | 181 public native void startReceiver(long bufferSpace) throws IOException; in startReceiver() method in NormSession
|
| /dports/net/norm/norm-1.5r6/src/java/src/mil/navy/nrl/norm/io/ |
| H A D | NormInputStream.java | 136 normSession.startReceiver(bufferSpace); in open()
|
| /dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/demos/ |
| H A D | TotalOrder.java | 292 startReceiver(); in TotalOrder()
310 void startReceiver() { in startReceiver() method in TotalOrder
|
| /dports/net/norm/norm-1.5r6/src/pynorm/ |
| H A D | session.py | 155 def startReceiver(self, bufferSpace): member in Session
|
| /dports/devel/mutagen/mutagen-0.11.8/vendor/github.com/pion/webrtc/v2/ |
| H A D | peerconnection.go | 999 func (pc *PeerConnection) startReceiver(incoming incomingTrack, receiver *RTPReceiver) { func
1106 go pc.startReceiver(incoming, t.Receiver)
1120 go pc.startReceiver(incoming, t.Receiver)
1150 go pc.startReceiver(incoming, t.Receiver)
|
| /dports/graphics/dcmtk/dcmtk-DCMTK-3.6.6/dcmpstat/include/dcmtk/dcmpstat/ |
| H A D | dviface.h | 737 OFCondition startReceiver();
|
| /dports/security/snowflake-tor/snowflake-ead5a960d7fa19dc890ccbfc0765c5ab6629eaa9/vendor/github.com/pion/webrtc/v3/ |
| H A D | peerconnection.go | 1150 func (pc *PeerConnection) startReceiver(incoming trackDetails, receiver *RTPReceiver) { func
1248 pc.startReceiver(incomingTrack, t.Receiver())
1267 pc.startReceiver(incoming, t.Receiver())
1361 pc.startReceiver(incoming, t.Receiver())
|