| /dports/net-mgmt/pmacct/pmacct-1.7.5/src/sfprobe_plugin/ |
| H A D | sflow_receiver.c | 39 struct sockaddr_in *sa4 = (struct sockaddr_in *) &receiver->receiver; in sfl_receiver_init()
42 memset(receiver, 0, sizeof(*receiver)); in sfl_receiver_init()
57 receiver->sampleCollector.datap = receiver->sampleCollector.data; in sfl_receiver_init()
75 sfl_agent_resetReceiver(receiver->agent, receiver); in reset()
77 sfl_receiver_init(receiver, receiver->agent); in reset()
92 reset(receiver); in sfl_receiver_set_sFlowRcvrOwner()
128 addr_to_sa((struct sockaddr *) &receiver->receiver, &ha, (u_int16_t)receiver->sFlowRcvrPort); in sfl_receiver_set_sFlowRcvrAddress()
156 if(--receiver->sFlowRcvrTimeout == 0) reset(receiver); in sfl_receiver_tick()
818 if(receiver->agent->sendFn) (*receiver->agent->sendFn)(receiver->agent->magic, in sendSample()
829 (struct sockaddr *)&receiver->receiver, in sendSample()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chromeos/services/secure_channel/ |
| H A D | ble_weave_packet_receiver_unittest.cc | 64 receiver->ReceivePacket(p0); in TEST_F()
76 receiver->ReceivePacket(p1); in TEST_F()
87 receiver->ReceivePacket(p2); in TEST_F()
99 receiver->ReceivePacket(p3); in TEST_F()
110 receiver->ReceivePacket(p4); in TEST_F()
142 receiver->ReceivePacket(p0); in TEST_F()
155 receiver->ReceivePacket(p1); in TEST_F()
166 receiver->ReceivePacket(p2); in TEST_F()
176 receiver->ReceivePacket(p3); in TEST_F()
192 receiver->ReceivePacket(p0); in TEST_F()
[all …]
|
| /dports/devel/cutter/cutter-1.2.6/test/lib/ |
| H A D | cuttest-event-receiver.c | 313 if (receiver->start_tests) { in dispose()
390 receiver->n_start_runs++; in start_run()
402 receiver->ready_test_suites = in ready_test_suite()
424 receiver->ready_test_cases = g_list_append(receiver->ready_test_cases, info); in ready_test_case()
433 receiver->start_test_cases = in start_test_case()
469 receiver->start_tests = g_list_append(receiver->start_tests, info); in start_test()
494 receiver->pass_assertions = g_list_append(receiver->pass_assertions, info); in pass_assertion()
507 receiver->failure_tests = g_list_append(receiver->failure_tests, info); in failure_test()
532 receiver->complete_tests = g_list_append(receiver->complete_tests, info); in complete_test()
577 receiver->complete_runs = g_list_append(receiver->complete_runs, in complete_run()
[all …]
|
| /dports/www/nginx-full/nginx-sflow-module-543c72a/ |
| H A D | ngx_http_sflow_api.c | 708 memset(receiver, 0, sizeof(*receiver)); in sfl_receiver_init()
730 sfl_agent_resetReceiver(receiver->agent, receiver); in resetReceiver()
732 sfl_receiver_init(receiver, receiver->agent); in resetReceiver()
786 if(receiver->sampleCollector.numSamples > 0) sendSample(receiver); in sfl_receiver_tick()
790 if(--receiver->sFlowRcvrTimeout == 0) resetReceiver(receiver); in sfl_receiver_tick()
1043 …receiver->sampleCollector.pktlen = (byte_t *)receiver->sampleCollector.datap - (byte_t *)receiver-… in sfl_receiver_writeFlowSample()
1125 …receiver->sampleCollector.pktlen = (byte_t *)receiver->sampleCollector.datap - (byte_t *)receiver-… in sfl_receiver_writeEncodedFlowSample()
1271 …receiver->sampleCollector.pktlen = (byte_t *)receiver->sampleCollector.datap - (byte_t *)receiver-… in sfl_receiver_writeCountersSample()
1296 receiver->sampleCollector.datap = receiver->sampleCollector.data; in sendSample()
1300 putNet32(receiver, ++receiver->sampleCollector.packetSeqNo); in sendSample()
[all …]
|
| /dports/x11-toolkits/kf5-kconfigwidgets/kconfigwidgets-5.89.0/autotests/ |
| H A D | kstandardactiontest.cpp | 56 Receiver receiver; in testCreateNewStyle() local
58 QVERIFY(!receiver.triggered); in testCreateNewStyle()
60 QVERIFY(receiver.triggered); in testCreateNewStyle()
90 &receiver, in testCreateNewStyle()
94 &receiver); in testCreateNewStyle()
110 Receiver receiver; in testCreateOldStyle() local
112 QVERIFY(!receiver.triggered); in testCreateOldStyle()
114 QVERIFY(receiver.triggered); in testCreateOldStyle()
117 receiver.triggered = false; in testCreateOldStyle()
119 QVERIFY(!receiver.triggered); in testCreateOldStyle()
[all …]
|
| /dports/devel/grpc/grpc-1.42.0/test/core/transport/binder/ |
| H A D | transport_stream_receiver_test.cc | 186 t0.Complete(receiver); in TEST_F()
192 t0.Complete(receiver); in TEST_F()
200 t1.Complete(receiver); in TEST_F()
201 t0.Complete(receiver); in TEST_F()
212 t1.Complete(receiver); in TEST_F()
213 t0.Complete(receiver); in TEST_F()
221 t1.Complete(receiver); in TEST_F()
224 t0.Complete(receiver); in TEST_F()
226 t2.Complete(receiver); in TEST_F()
237 t0.Complete(receiver); in TEST_F()
[all …]
|
| /dports/devel/py-louie/Louie-2.0/louie/ |
| H A D | dispatcher.py | 131 receiver = saferef.safe_ref(receiver, on_delete=_remove_receiver)
204 receiver = saferef.safe_ref(receiver)
258 receiver = receiver()
340 original = receiver
342 receiver = plugin.wrap_receiver(receiver)
362 original = receiver
364 receiver = plugin.wrap_receiver(receiver)
384 original = receiver
386 receiver = plugin.wrap_receiver(receiver)
433 receiver = plugin.wrap_receiver(receiver)
[all …]
|
| /dports/x11-toolkits/py-wxPython40/wxPython-4.0.7/wx/py/ |
| H A D | dispatcher.py | 47 receiver = safeRef(receiver)
74 receivers.append(receiver)
84 receiver = safeRef(receiver)
139 for receiver in receivers:
143 receiver = receiver()
151 def _call(receiver, **kwds): argument
155 (hasattr(receiver.__call__, '__func__') or hasattr(receiver.__call__, '__code__')):
158 receiver = receiver.__call__
165 fc = receiver.__code__
176 return receiver(**kwds)
[all …]
|
| /dports/science/afni/afni-AFNI_21.3.16/src/ |
| H A D | afni_receive.c | 125 if( im3d->vinfo->receiver[ir] == NULL ) break ; in AFNI_receive_init()
132 im3d->vinfo->receiver = AFREALL( im3d->vinfo->receiver, AFNI_receiver *, ir+1 ); in AFNI_receive_init()
137 im3d->vinfo->receiver[ir]->receiver_func = cb ; in AFNI_receive_init()
143 im3d->vinfo->receiver[ir]->receiver_funcname = in AFNI_receive_init()
167 if( im3d->vinfo->receiver[ir] != NULL ){ in AFNI_receive_destroy()
181 free( im3d->vinfo->receiver[ir] ) ; in AFNI_receive_destroy()
182 im3d->vinfo->receiver[ir] = NULL ; in AFNI_receive_destroy()
363 im3d->vinfo->receiver[key] = NULL ; in AFNI_receive_control()
388 if( im3d->vinfo->receiver != NULL ){ in AFNI_toggle_drawing()
391 if( im3d->vinfo->receiver[ir] != NULL && in AFNI_toggle_drawing()
[all …]
|
| /dports/lang/rust/rustc-1.58.1-src/src/test/mir-opt/ |
| H A D | receiver_ptr_mutability.main.mir_map.0.mir | 12 … let _2: (); // in scope 0 at $DIR/receiver-ptr-mutability.rs:15:5: 15:12
13 … let mut _3: *const Test; // in scope 0 at $DIR/receiver-ptr-mutability.rs:15:5: 15:12
14 let mut _4: *mut Test; // in scope 0 at $DIR/receiver-ptr-mutability.rs:15:5: 15:8
31 StorageLive(_1); // scope 0 at $DIR/receiver-ptr-mutability.rs:14:9: 14:12
34 // + span: $DIR/receiver-ptr-mutability.rs:14:26: 14:44
39 FakeRead(ForLet(None), _1); // scope 0 at $DIR/receiver-ptr-mutability.rs:14:9: 14:12
43 StorageLive(_4); // scope 1 at $DIR/receiver-ptr-mutability.rs:15:5: 15:8
44 _4 = _1; // scope 1 at $DIR/receiver-ptr-mutability.rs:15:5: 15:8
46 StorageDead(_4); // scope 1 at $DIR/receiver-ptr-mutability.rs:15:7: 15:8
49 // + span: $DIR/receiver-ptr-mutability.rs:15:9: 15:10
[all …]
|
| /dports/comms/scrcpy/scrcpy-1.9/app/src/ |
| H A D | receiver.c | 12 receiver_init(struct receiver *receiver, socket_t control_socket) { in receiver_init() argument
21 receiver_destroy(struct receiver *receiver) { in receiver_destroy() argument
22 SDL_DestroyMutex(receiver->mutex); in receiver_destroy()
26 process_msg(struct receiver *receiver, struct device_msg *msg) { in process_msg() argument
36 process_msgs(struct receiver *receiver, const unsigned char *buf, size_t len) { in process_msgs() argument
48 process_msg(receiver, &msg); in process_msgs()
61 struct receiver *receiver = data; in run_receiver() local
92 receiver_start(struct receiver *receiver) { in receiver_start() argument
95 receiver->thread = SDL_CreateThread(run_receiver, "receiver", receiver); in receiver_start()
96 if (!receiver->thread) { in receiver_start()
[all …]
|
| /dports/editors/kile/kile-09ee4ef0417165b93da82c1fc057b9e1713a0c05/src/ |
| H A D | kilestdactions.cpp | 28 void setupStdTags(KileInfo *ki, const QObject* receiver, KActionCollection *actionCollection, QWidg… in setupStdTags() argument
218 void setupBibTags(const QObject *receiver, KActionCollection *actionCollection, KActionMenu * menu) in setupBibTags() argument
352 void setupMathTags(const QObject *receiver, KActionCollection *actionCollection) in setupMathTags() argument
354 …(void) new KileAction::Tag(i18n("\\mathrm{}"), QString(), QKeySequence(), receiver, SLOT(insertTag… in setupMathTags()
355 …(void) new KileAction::Tag(i18n("\\mathit{}"), QString(), QKeySequence(), receiver, SLOT(insertTag… in setupMathTags()
356 …(void) new KileAction::Tag(i18n("\\mathbf{}"), QString(), QKeySequence(), receiver, SLOT(insertTag… in setupMathTags()
357 …(void) new KileAction::Tag(i18n("\\mathsf{}"), QString(), QKeySequence(), receiver, SLOT(insertTag… in setupMathTags()
442 …(void) new KileAction::Tag(i18n("bigl - \\bigl"), i18n("bigl"), QKeySequence(), receiver, SLOT(ins… in setupMathTags()
443 …(void) new KileAction::Tag(i18n("Bigl - \\Bigl"), i18n("Bigl"), QKeySequence(), receiver, SLOT(ins… in setupMathTags()
447 …(void) new KileAction::Tag(i18n("bigr - \\bigr"), i18n("bigr"), QKeySequence(), receiver, SLOT(ins… in setupMathTags()
[all …]
|
| /dports/devel/entt/entt-3.8.1/test/entt/signal/ |
| H A D | dispatcher.cpp | 11 struct receiver { struct
23 receiver receiver; in TEST() argument
29 dispatcher.sink<an_event>().connect<&receiver::receive>(receiver); in TEST()
33 ASSERT_EQ(receiver.cnt, 1); in TEST()
38 ASSERT_EQ(receiver.cnt, 1); in TEST()
55 receiver.reset(); in TEST()
59 dispatcher.sink<an_event>().disconnect<&receiver::receive>(receiver); in TEST()
70 receiver receiver; in TEST() local
73 dispatcher.sink<an_event>().connect<&receiver::receive>(receiver); in TEST()
88 receiver receiver; in TEST() local
[all …]
|
| /dports/devel/py-pydispatcher/PyDispatcher-2.0.5/pydispatch/ |
| H A D | dispatcher.py | 130 receiver = saferef.safeRef(receiver, onDelete=_removeReceiver)
149 receiverID = id(receiver)
166 receivers.append(receiver)
200 if weak: receiver = saferef.safeRef(receiver)
218 receiver,
259 receiver = receiver()
263 yield receiver
285 for receiver in set:
334 receiver,
353 receiver,
[all …]
|
| /dports/net-im/farstream/farstream-0.2.9/gst/fsrtpconference/ |
| H A D | tfrc.c | 555 return receiver; in tfrc_receiver_new()
566 return receiver; in tfrc_receiver_new_sp()
799 receiver->sender_rtt, receiver->max_receive_rate); in calculate_loss_event_rate()
802 receiver->first_loss_interval, receiver->sender_rtt, in calculate_loss_event_rate()
996 receiver->feedback_timer_expiry = now + receiver->sender_rtt; in tfrc_receiver_feedback_timer_expired()
1021 receiver->prev_received_bytes = receiver->received_bytes; in tfrc_receiver_send_feedback()
1022 receiver->prev_received_packets = receiver->received_packets; in tfrc_receiver_send_feedback()
1027 receiver->prev_received_bytes += receiver->received_bytes; in tfrc_receiver_send_feedback()
1042 receiver->receive_rate > receiver->max_receive_rate) in tfrc_receiver_send_feedback()
1044 receiver->max_receive_rate = receiver->receive_rate; in tfrc_receiver_send_feedback()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/chrome/utility/ |
| H A D | services.cc | 118 receiver) { in RunLanguageDetectionService()
120 std::move(receiver)); in RunLanguageDetectionService()
125 receiver) { in RunQRCodeGeneratorService()
127 std::move(receiver)); in RunQRCodeGeneratorService()
132 receiver) { in RunMachineLearningService()
134 std::move(receiver)); in RunMachineLearningService()
157 receiver) { in RunProxyResolver()
159 std::move(receiver)); in RunProxyResolver()
176 std::move(receiver)); in RunSpeechRecognitionService()
232 std::move(receiver)); in RunPrintBackendService()
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | service_test.go | 72 receiver *testStatusChangeReceiver member
78 ts := &testService{receiver: receiver}
79 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
193 receiver *testStatusChangeReceiver member
199 ts := &testCompositeService{receiver: receiver}
200 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
267 parent.receiver.VerifyNoStatusChanges(t)
290 parent.receiver.VerifyNoStatusChanges(t)
433 child2.receiver.VerifyNoStatusChanges(t)
434 parent.receiver.VerifyNoStatusChanges(t)
[all …]
|
| /dports/net/drive/drive-0.4.0/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | service_test.go | 72 receiver *testStatusChangeReceiver member
78 ts := &testService{receiver: receiver}
79 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
193 receiver *testStatusChangeReceiver member
199 ts := &testCompositeService{receiver: receiver}
200 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
267 parent.receiver.VerifyNoStatusChanges(t)
290 parent.receiver.VerifyNoStatusChanges(t)
433 child2.receiver.VerifyNoStatusChanges(t)
434 parent.receiver.VerifyNoStatusChanges(t)
[all …]
|
| /dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | service_test.go | 72 receiver *testStatusChangeReceiver member
78 ts := &testService{receiver: receiver}
79 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
193 receiver *testStatusChangeReceiver member
199 ts := &testCompositeService{receiver: receiver}
200 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
267 parent.receiver.VerifyNoStatusChanges(t)
290 parent.receiver.VerifyNoStatusChanges(t)
426 child2.receiver.VerifyNoStatusChanges(t)
427 parent.receiver.VerifyNoStatusChanges(t)
[all …]
|
| /dports/net/rclone/rclone-1.57.0/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | service_test.go | 72 receiver *testStatusChangeReceiver member
78 ts := &testService{receiver: receiver}
79 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
193 receiver *testStatusChangeReceiver member
199 ts := &testCompositeService{receiver: receiver}
200 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
267 parent.receiver.VerifyNoStatusChanges(t)
290 parent.receiver.VerifyNoStatusChanges(t)
433 child2.receiver.VerifyNoStatusChanges(t)
434 parent.receiver.VerifyNoStatusChanges(t)
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | service_test.go | 72 receiver *testStatusChangeReceiver member
78 ts := &testService{receiver: receiver}
79 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
193 receiver *testStatusChangeReceiver member
199 ts := &testCompositeService{receiver: receiver}
200 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
267 parent.receiver.VerifyNoStatusChanges(t)
290 parent.receiver.VerifyNoStatusChanges(t)
433 child2.receiver.VerifyNoStatusChanges(t)
434 parent.receiver.VerifyNoStatusChanges(t)
[all …]
|
| /dports/www/gohugo/hugo-0.91.2/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | service_test.go | 72 receiver *testStatusChangeReceiver member
78 ts := &testService{receiver: receiver}
79 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
193 receiver *testStatusChangeReceiver member
199 ts := &testCompositeService{receiver: receiver}
200 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
267 parent.receiver.VerifyNoStatusChanges(t)
290 parent.receiver.VerifyNoStatusChanges(t)
433 child2.receiver.VerifyNoStatusChanges(t)
434 parent.receiver.VerifyNoStatusChanges(t)
[all …]
|
| /dports/www/gitlab-pages/gitlab-pages-f8512edbec4ec83b426c8ca2dda467de424685e4/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | service_test.go | 72 receiver *testStatusChangeReceiver member
78 ts := &testService{receiver: receiver}
79 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
193 receiver *testStatusChangeReceiver member
199 ts := &testCompositeService{receiver: receiver}
200 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
267 parent.receiver.VerifyNoStatusChanges(t)
290 parent.receiver.VerifyNoStatusChanges(t)
433 child2.receiver.VerifyNoStatusChanges(t)
434 parent.receiver.VerifyNoStatusChanges(t)
[all …]
|
| /dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | service_test.go | 72 receiver *testStatusChangeReceiver
78 ts := &testService{receiver: receiver}
79 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
193 receiver *testStatusChangeReceiver
199 ts := &testCompositeService{receiver: receiver}
200 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
267 parent.receiver.VerifyNoStatusChanges(t)
290 parent.receiver.VerifyNoStatusChanges(t)
426 child2.receiver.VerifyNoStatusChanges(t)
427 parent.receiver.VerifyNoStatusChanges(t)
[all …]
|
| /dports/sysutils/restic/restic-0.12.1/vendor/cloud.google.com/go/pubsublite/internal/wire/ |
| H A D | service_test.go | 72 receiver *testStatusChangeReceiver member
78 ts := &testService{receiver: receiver}
79 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
193 receiver *testStatusChangeReceiver member
199 ts := &testCompositeService{receiver: receiver}
200 ts.AddStatusChangeReceiver(receiver.Handle(), receiver.OnStatusChange)
267 parent.receiver.VerifyNoStatusChanges(t)
290 parent.receiver.VerifyNoStatusChanges(t)
426 child2.receiver.VerifyNoStatusChanges(t)
427 parent.receiver.VerifyNoStatusChanges(t)
[all …]
|