| /dports/net/concourse-fly/concourse-6.7.1/fly/eventstream/ |
| H A D | render_test.go | 26 receivedEvents chan<- atc.Event
38 receivedEvents = events
56 receivedEvents <- event.Log{
80 receivedEvents <- event.Error{
124 receivedEvents <- event.StartTask{
153 receivedEvents <- event.FinishTask{
164 receivedEvents <- event.Status{
192 receivedEvents <- event.Status{
219 receivedEvents <- event.Status{
246 receivedEvents <- event.Status{
[all …]
|
| /dports/misc/concourse/concourse-6.7.2/fly/eventstream/ |
| H A D | render_test.go | 26 receivedEvents chan<- atc.Event
38 receivedEvents = events
56 receivedEvents <- event.Log{
80 receivedEvents <- event.Error{
124 receivedEvents <- event.StartTask{
153 receivedEvents <- event.FinishTask{
164 receivedEvents <- event.Status{
192 receivedEvents <- event.Status{
219 receivedEvents <- event.Status{
246 receivedEvents <- event.Status{
[all …]
|
| /dports/net-mgmt/bosun/bosun-0.9.0-preview/vendor/github.com/google/cadvisor/events/ |
| H A D | handler_test.go | 166 receivedEvents, err := myEventHolder.GetEvents(myRequest)
168 checkNumberOfEvents(t, 1, len(receivedEvents))
169 ensureProperEventReturned(t, fakeEvent2, receivedEvents[0])
181 receivedEvents, err := myEventHolder.GetEvents(myRequest)
184 checkNumberOfEvents(t, 1, len(receivedEvents))
185 ensureProperEventReturned(t, fakeEvent2, receivedEvents[0])
194 receivedEvents, err := myEventHolder.GetEvents(myRequest)
196 checkNumberOfEvents(t, 0, len(receivedEvents))
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/pkg/volume/util/recyclerclient/ |
| H A D | recycler_client_test.go | 172 if len(client.receivedEvents) <= i {
176 receivedEvent := client.receivedEvents[i]
184 for i := len(test.expectedEvents); i < len(client.receivedEvents); i++ {
185 …xpected event received: %s, %q", test.name, client.receivedEvents[i].eventtype, client.receivedEve…
193 receivedEvents []mockEvent member
233 c.receivedEvents = append(c.receivedEvents, mockEvent{eventtype, message})
|
| /dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/server/ |
| H A D | sessionID_test.go | 271 receivedEvents := make(map[string]int)
273 receivedEvents[<-duplicateSessionIDEvents] += 1
276 if receivedEvents[stoppingEvent] < 1 {
280 if receivedEvents[abortingEvent] < 1 {
|
| /dports/net/ooni-mini/probe-engine-0.23.0/vendor/github.com/ooni/psiphon/oopsi/github.com/Psiphon-Labs/psiphon-tunnel-core/psiphon/server/ |
| H A D | sessionID_test.go | 271 receivedEvents := make(map[string]int)
273 receivedEvents[<-duplicateSessionIDEvents] += 1
276 if receivedEvents[stoppingEvent] < 1 {
280 if receivedEvents[abortingEvent] < 1 {
|
| /dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.platform.text/org.eclipse.text.tests/projection/org/eclipse/text/tests/ |
| H A D | ProjectionDocumentTest.java | 1653 final List<DocumentEvent> receivedEvents= new ArrayList<>(); in test22() local
1660 receivedEvents.add(event); in test22()
1666 DocumentEvent[] actual= new DocumentEvent[receivedEvents.size()]; in test22()
1667 receivedEvents.toArray(actual); in test22()
1684 final List<DocumentEvent> receivedEvents= new ArrayList<>(); in test23() local
1691 receivedEvents.add(event); in test23()
1704 DocumentEvent[] actual= new DocumentEvent[receivedEvents.size()]; in test23()
1705 receivedEvents.toArray(actual); in test23()
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/ndb/test/ndbapi/ |
| H A D | testBasic.cpp | 2604 Vector<EventInfo>& receivedEvents, in collectEvents() argument
2632 g_err << "# " << receivedEvents.size() in collectEvents()
2696 receivedEvents.push_back(ei); in collectEvents()
2711 int verifyEvents(const Vector<EventInfo>& receivedEvents, in verifyEvents() argument
2720 g_err << "Received total of " << receivedEvents.size() << " events" << endl; in verifyEvents()
2729 for (Uint32 e=0; e < receivedEvents.size(); e++) in verifyEvents()
2731 EventInfo ei = receivedEvents[e]; in verifyEvents()
2991 Vector<EventInfo> receivedEvents; in runRefreshTuple() local
2993 int rc = collectEvents(ndb, calc, tab, receivedEvents, idCol, updateCol, in runRefreshTuple()
2998 rc = verifyEvents(receivedEvents, in runRefreshTuple()
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/ndb/test/ndbapi/ |
| H A D | testBasic.cpp | 2604 Vector<EventInfo>& receivedEvents, in collectEvents() argument
2632 g_err << "# " << receivedEvents.size() in collectEvents()
2696 receivedEvents.push_back(ei); in collectEvents()
2711 int verifyEvents(const Vector<EventInfo>& receivedEvents, in verifyEvents() argument
2720 g_err << "Received total of " << receivedEvents.size() << " events" << endl; in verifyEvents()
2729 for (Uint32 e=0; e < receivedEvents.size(); e++) in verifyEvents()
2731 EventInfo ei = receivedEvents[e]; in verifyEvents()
2991 Vector<EventInfo> receivedEvents; in runRefreshTuple() local
2993 int rc = collectEvents(ndb, calc, tab, receivedEvents, idCol, updateCol, in runRefreshTuple()
2998 rc = verifyEvents(receivedEvents, in runRefreshTuple()
|
| /dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/storage/ndb/test/ndbapi/ |
| H A D | testBasic.cpp | 2604 Vector<EventInfo>& receivedEvents, in collectEvents() argument
2632 g_err << "# " << receivedEvents.size() in collectEvents()
2696 receivedEvents.push_back(ei); in collectEvents()
2711 int verifyEvents(const Vector<EventInfo>& receivedEvents, in verifyEvents() argument
2720 g_err << "Received total of " << receivedEvents.size() << " events" << endl; in verifyEvents()
2729 for (Uint32 e=0; e < receivedEvents.size(); e++) in verifyEvents()
2731 EventInfo ei = receivedEvents[e]; in verifyEvents()
2991 Vector<EventInfo> receivedEvents; in runRefreshTuple() local
2993 int rc = collectEvents(ndb, calc, tab, receivedEvents, idCol, updateCol, in runRefreshTuple()
2998 rc = verifyEvents(receivedEvents, in runRefreshTuple()
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/ndb/test/ndbapi/ |
| H A D | testBasic.cpp | 2604 Vector<EventInfo>& receivedEvents, in collectEvents() argument
2632 g_err << "# " << receivedEvents.size() in collectEvents()
2696 receivedEvents.push_back(ei); in collectEvents()
2711 int verifyEvents(const Vector<EventInfo>& receivedEvents, in verifyEvents() argument
2720 g_err << "Received total of " << receivedEvents.size() << " events" << endl; in verifyEvents()
2729 for (Uint32 e=0; e < receivedEvents.size(); e++) in verifyEvents()
2731 EventInfo ei = receivedEvents[e]; in verifyEvents()
2991 Vector<EventInfo> receivedEvents; in runRefreshTuple() local
2993 int rc = collectEvents(ndb, calc, tab, receivedEvents, idCol, updateCol, in runRefreshTuple()
2998 rc = verifyEvents(receivedEvents, in runRefreshTuple()
|
| /dports/databases/mysql56-client/mysql-5.6.51/storage/ndb/test/ndbapi/ |
| H A D | testBasic.cpp | 2604 Vector<EventInfo>& receivedEvents, in collectEvents() argument
2632 g_err << "# " << receivedEvents.size() in collectEvents()
2696 receivedEvents.push_back(ei); in collectEvents()
2711 int verifyEvents(const Vector<EventInfo>& receivedEvents, in verifyEvents() argument
2720 g_err << "Received total of " << receivedEvents.size() << " events" << endl; in verifyEvents()
2729 for (Uint32 e=0; e < receivedEvents.size(); e++) in verifyEvents()
2731 EventInfo ei = receivedEvents[e]; in verifyEvents()
2991 Vector<EventInfo> receivedEvents; in runRefreshTuple() local
2993 int rc = collectEvents(ndb, calc, tab, receivedEvents, idCol, updateCol, in runRefreshTuple()
2998 rc = verifyEvents(receivedEvents, in runRefreshTuple()
|
| /dports/databases/xtrabackup/percona-xtrabackup-2.4.21/storage/ndb/test/ndbapi/ |
| H A D | testBasic.cpp | 2770 Vector<EventInfo>& receivedEvents, in collectEvents() argument
2820 g_err << "# " << receivedEvents.size() in collectEvents()
2884 receivedEvents.push_back(ei); in collectEvents()
2893 int verifyEvents(const Vector<EventInfo>& receivedEvents, in verifyEvents() argument
2902 g_err << "Received total of " << receivedEvents.size() << " events" << endl; in verifyEvents()
2911 for (Uint32 e=0; e < receivedEvents.size(); e++) in verifyEvents()
2913 EventInfo ei = receivedEvents[e]; in verifyEvents()
3173 Vector<EventInfo> receivedEvents; in runRefreshTuple() local
3175 int rc = collectEvents(ndb, calc, tab, receivedEvents, idCol, updateCol, in runRefreshTuple()
3180 rc = verifyEvents(receivedEvents, in runRefreshTuple()
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/ndb/test/ndbapi/ |
| H A D | testBasic.cpp | 2770 Vector<EventInfo>& receivedEvents, in collectEvents() argument
2820 g_err << "# " << receivedEvents.size() in collectEvents()
2884 receivedEvents.push_back(ei); in collectEvents()
2893 int verifyEvents(const Vector<EventInfo>& receivedEvents, in verifyEvents() argument
2902 g_err << "Received total of " << receivedEvents.size() << " events" << endl; in verifyEvents()
2911 for (Uint32 e=0; e < receivedEvents.size(); e++) in verifyEvents()
2913 EventInfo ei = receivedEvents[e]; in verifyEvents()
3173 Vector<EventInfo> receivedEvents; in runRefreshTuple() local
3175 int rc = collectEvents(ndb, calc, tab, receivedEvents, idCol, updateCol, in runRefreshTuple()
3180 rc = verifyEvents(receivedEvents, in runRefreshTuple()
|
| /dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/storage/ndb/test/ndbapi/ |
| H A D | testBasic.cpp | 2770 Vector<EventInfo>& receivedEvents, in collectEvents() argument
2820 g_err << "# " << receivedEvents.size() in collectEvents()
2884 receivedEvents.push_back(ei); in collectEvents()
2893 int verifyEvents(const Vector<EventInfo>& receivedEvents, in verifyEvents() argument
2902 g_err << "Received total of " << receivedEvents.size() << " events" << endl; in verifyEvents()
2911 for (Uint32 e=0; e < receivedEvents.size(); e++) in verifyEvents()
2913 EventInfo ei = receivedEvents[e]; in verifyEvents()
3173 Vector<EventInfo> receivedEvents; in runRefreshTuple() local
3175 int rc = collectEvents(ndb, calc, tab, receivedEvents, idCol, updateCol, in runRefreshTuple()
3180 rc = verifyEvents(receivedEvents, in runRefreshTuple()
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/test/ndbapi/ |
| H A D | testBasic.cpp | 2770 Vector<EventInfo>& receivedEvents, in collectEvents() argument
2820 g_err << "# " << receivedEvents.size() in collectEvents()
2884 receivedEvents.push_back(ei); in collectEvents()
2893 int verifyEvents(const Vector<EventInfo>& receivedEvents, in verifyEvents() argument
2902 g_err << "Received total of " << receivedEvents.size() << " events" << endl; in verifyEvents()
2911 for (Uint32 e=0; e < receivedEvents.size(); e++) in verifyEvents()
2913 EventInfo ei = receivedEvents[e]; in verifyEvents()
3173 Vector<EventInfo> receivedEvents; in runRefreshTuple() local
3175 int rc = collectEvents(ndb, calc, tab, receivedEvents, idCol, updateCol, in runRefreshTuple()
3180 rc = verifyEvents(receivedEvents, in runRefreshTuple()
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/ndb/test/ndbapi/ |
| H A D | testBasic.cpp | 2770 Vector<EventInfo>& receivedEvents, in collectEvents() argument
2820 g_err << "# " << receivedEvents.size() in collectEvents()
2884 receivedEvents.push_back(ei); in collectEvents()
2893 int verifyEvents(const Vector<EventInfo>& receivedEvents, in verifyEvents() argument
2902 g_err << "Received total of " << receivedEvents.size() << " events" << endl; in verifyEvents()
2911 for (Uint32 e=0; e < receivedEvents.size(); e++) in verifyEvents()
2913 EventInfo ei = receivedEvents[e]; in verifyEvents()
3173 Vector<EventInfo> receivedEvents; in runRefreshTuple() local
3175 int rc = collectEvents(ndb, calc, tab, receivedEvents, idCol, updateCol, in runRefreshTuple()
3180 rc = verifyEvents(receivedEvents, in runRefreshTuple()
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/hotspot/jtreg/vmTestbase/nsk/share/jdi/ |
| H A D | JDIEventsDebugger.java | 315 List<Event> receivedEvents = allReceivedEvents.get(eventClass); in checkEvents() local
318 for (Iterator<Event> allReceivedEventsIterator = receivedEvents.iterator(); in checkEvents()
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/hotspot/jtreg/vmTestbase/nsk/share/jdi/ |
| H A D | JDIEventsDebugger.java | 315 List<Event> receivedEvents = allReceivedEvents.get(eventClass); in checkEvents() local
318 for (Iterator<Event> allReceivedEventsIterator = receivedEvents.iterator(); in checkEvents()
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/hotspot/jtreg/vmTestbase/nsk/share/jdi/ |
| H A D | JDIEventsDebugger.java | 315 List<Event> receivedEvents = allReceivedEvents.get(eventClass); in checkEvents() local
318 for (Iterator<Event> allReceivedEventsIterator = receivedEvents.iterator(); in checkEvents()
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/hotspot/jtreg/vmTestbase/nsk/share/jdi/ |
| H A D | JDIEventsDebugger.java | 315 List<Event> receivedEvents = allReceivedEvents.get(eventClass); in checkEvents() local
318 for (Iterator<Event> allReceivedEventsIterator = receivedEvents.iterator(); in checkEvents()
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/hotspot/jtreg/vmTestbase/nsk/share/jdi/ |
| H A D | JDIEventsDebugger.java | 315 List<Event> receivedEvents = allReceivedEvents.get(eventClass); in checkEvents() local
318 for (Iterator<Event> allReceivedEventsIterator = receivedEvents.iterator(); in checkEvents()
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/hotspot/jtreg/vmTestbase/nsk/share/jdi/ |
| H A D | JDIEventsDebugger.java | 315 List<Event> receivedEvents = allReceivedEvents.get(eventClass); in checkEvents() local
318 for (Iterator<Event> allReceivedEventsIterator = receivedEvents.iterator(); in checkEvents()
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/hotspot/jtreg/vmTestbase/nsk/share/jdi/ |
| H A D | JDIEventsDebugger.java | 315 List<Event> receivedEvents = allReceivedEvents.get(eventClass); in checkEvents() local
318 for (Iterator<Event> allReceivedEventsIterator = receivedEvents.iterator(); in checkEvents()
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/hotspot/jtreg/vmTestbase/nsk/share/jdi/ |
| H A D | JDIEventsDebugger.java | 315 List<Event> receivedEvents = allReceivedEvents.get(eventClass); in checkEvents() local
318 for (Iterator<Event> allReceivedEventsIterator = receivedEvents.iterator(); in checkEvents()
|