| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/deploy/rest/ |
| H A D | StandaloneRestSubmitSuite.scala | 78 val submitResponse = getSubmitResponse(response) constant
79 assert(submitResponse.action === Utils.getFormattedClassName(submitResponse))
83 assert(submitResponse.success)
97 assert(submitResponse.action === Utils.getFormattedClassName(submitResponse))
101 assert(submitResponse.success)
138 assert(submitResponse.success)
139 assert(submitResponse.submissionId != null)
141 val submissionId = submitResponse.submissionId
154 assert(submitResponse.success)
155 assert(submitResponse.submissionId != null)
[all …]
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/deploy/rest/ |
| H A D | StandaloneRestServer.scala | 179 val submitResponse = new CreateSubmissionResponse constant
180 submitResponse.serverSparkVersion = sparkVersion
181 submitResponse.message = response.message
182 submitResponse.success = response.success
183 submitResponse.submissionId = response.driverId.orNull
187 submitResponse.unknownFields = unknownFields
189 submitResponse
|
| H A D | RestSubmissionClient.scala | 318 submitResponse: CreateSubmissionResponse): Unit = {
319 if (submitResponse.success) {
320 val submissionId = submitResponse.submissionId
329 val failMessage = Option(submitResponse.message).map { ": " + _ }.getOrElse("")
|
| /dports/dns/powerdns/pdns-4.5.2/pdns/ |
| H A D | responsestats.hh | 34 void submitResponse(DNSPacket& p, bool udpOrTCP, bool last = true) const;
35 void submitResponse(uint16_t qtype, uint16_t respsize, bool udpOrTCP) const;
36 void submitResponse(uint16_t qtype, uint16_t respsize, uint8_t rcode, bool udpOrTCP) const;
|
| H A D | responsestats.cc | 40 void ResponseStats::submitResponse(uint16_t qtype, uint16_t respsize, uint8_t rcode, bool udpOrTCP)… in submitResponse() function in ResponseStats
43 submitResponse(qtype, respsize, udpOrTCP); in submitResponse()
46 void ResponseStats::submitResponse(uint16_t qtype, uint16_t respsize, bool udpOrTCP) const in submitResponse() function in ResponseStats
|
| H A D | responsestats-auth.cc | 10 void ResponseStats::submitResponse(DNSPacket &p, bool udpOrTCP, bool last) const { in submitResponse() function in ResponseStats
63 submitResponse(p.qtype.getCode(), buf.length(), p.d.rcode, udpOrTCP); in submitResponse()
|
| H A D | nameserver.cc | 218 g_rs.submitResponse(p, true); in send()
|
| H A D | tcpreceiver.cc | 174 g_rs.submitResponse(*p, false, last); in sendPacket()
|
| /dports/www/grafana8/grafana-8.3.6/pkg/services/live/runstream/ |
| H A D | manager.go | 333 …sr.responseCh <- submitResponse{Result: submitResult{StreamExists: true, CloseNotify: streamCtx.Cl…
353 sr.responseCh <- submitResponse{Result: submitResult{StreamExists: false, CloseNotify: closeCh}}
381 responseCh chan submitResponse
392 type submitResponse struct { struct
419 responseCh: make(chan submitResponse, 1),
|
| /dports/devel/qtcreator/qt-creator-opensource-src-5.0.3/src/plugins/perforce/ |
| H A D | perforceplugin.cpp | 1610 const PerforceResponse submitResponse = runP4Cmd(m_settings.topLevelSymLinkTarget(), submitArgs, in submitEditorAboutToClose() local
1613 if (submitResponse.error) { in submitEditorAboutToClose()
1614 VcsOutputWindow::appendError(tr("p4 submit failed: %1").arg(submitResponse.message)); in submitEditorAboutToClose()
1617 VcsOutputWindow::append(submitResponse.stdOut); in submitEditorAboutToClose()
1618 …if (submitResponse.stdOut.contains(QLatin1String("Out of date files must be resolved or reverted)"… in submitEditorAboutToClose()
|
| /dports/textproc/zorba/zorba-2.7.0/test/zperf/src/ |
| H A D | start.xq | 414 " - submitResponse")
|