Home
last modified time | relevance | path

Searched refs:submissionId (Results 1 – 25 of 73) sorted by relevance

123

/dports/devel/msbuild/msbuild-0.06/src/Build/BackEnd/BuildManager/
H A DLegacyThreadingData.cs93 internal void RegisterSubmissionForLegacyThread(int submissionId) in RegisterSubmissionForLegacyThread() argument
97 …ngEventsById.ContainsKey(submissionId), "Submission {0} should not already be registered with Lega… in RegisterSubmissionForLegacyThread()
111 internal void UnregisterSubmissionForLegacyThread(int submissionId) in UnregisterSubmissionForLegacyThread() argument
115 …ventsById.ContainsKey(submissionId), "Submission {0} should have been previously registered with L… in UnregisterSubmissionForLegacyThread()
117 if (_legacyThreadingEventsById.ContainsKey(submissionId)) in UnregisterSubmissionForLegacyThread()
119 _legacyThreadingEventsById.Remove(submissionId); in UnregisterSubmissionForLegacyThread()
128 internal WaitHandle GetStartRequestBuilderMainThreadEventForSubmission(int submissionId) in GetStartRequestBuilderMainThreadEventForSubmission() argument
134 _legacyThreadingEventsById.TryGetValue(submissionId, out legacyThreadingEvents); in GetStartRequestBuilderMainThreadEventForSubmission()
146 internal Task GetLegacyThreadInactiveTask(int submissionId) in GetLegacyThreadInactiveTask() argument
173 int submissionId = instance.RequestEntry.Request.SubmissionId; in SignalLegacyThreadStart()
[all …]
/dports/devel/spark/spark-2.1.1/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/
H A DMesosClusterScheduler.scala170 c.submissionId = desc.submissionId
185 k.submissionId = submissionId
203 } else if (finishedDrivers.exists(_.driverDescription.submissionId.equals(submissionId))) {
221 s.submissionId = submissionId
223 if (queuedDrivers.exists(_.submissionId.equals(submissionId))) {
234 .find(d => d.driverDescription.submissionId.equals(submissionId)).get.mesosTaskStatus
236 } else if (pendingRetryDrivers.exists(_.submissionId.equals(submissionId))) {
237 val status = pendingRetryDrivers.find(_.submissionId.equals(submissionId))
255 queuedDrivers.find(_.submissionId.equals(submissionId))
259 .orElse(finishedDrivers.find(_.driverDescription.submissionId.equals(submissionId))
[all …]
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/deploy/rest/
H A DStandaloneRestSubmitSuite.scala105 val submissionId = "my-lyft-driver" constant
113 assert(killResponse.submissionId === submissionId)
118 val submissionId = "my-uber-driver" constant
127 assert(statusResponse.submissionId === submissionId)
139 assert(submitResponse.submissionId != null)
141 val submissionId = submitResponse.submissionId constant
145 assert(killResponse.submissionId === submissionId)
157 val submissionId = submitResponse.submissionId constant
161 assert(statusResponse.submissionId === submissionId)
611 val k = super.handleKill(submissionId)
[all …]
H A DSubmitRestProtocolSuite.scala147 message.submissionId = "driver_123"
155 assert(newMessage.submissionId === "driver_123")
163 message.submissionId = "driver_123"
171 assert(newMessage.submissionId === "driver_123")
179 message.submissionId = "driver_123"
191 assert(newMessage.submissionId === "driver_123")
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/deploy/rest/
H A DRestSubmissionClient.scala117 val url = getKillUrl(m, submissionId)
141 submissionId: String,
149 val url = getStatusUrl(m, submissionId)
283 private def getKillUrl(master: String, submissionId: String): URL = {
285 new URL(s"$baseUrl/kill/$submissionId")
291 new URL(s"$baseUrl/status/$submissionId")
320 val submissionId = submitResponse.submissionId constant
321 if (submissionId != null) {
323 pollSubmissionStatus(submissionId)
338 private def pollSubmissionStatus(submissionId: String): Unit = {
[all …]
H A DStandaloneRestServer.scala73 protected def handleKill(submissionId: String): KillSubmissionResponse = {
75 DeployMessages.RequestKillDriver(submissionId))
79 k.submissionId = submissionId
91 protected def handleStatus(submissionId: String): SubmissionStatusResponse = {
93 DeployMessages.RequestDriverStatus(submissionId))
97 d.submissionId = submissionId
183 submitResponse.submissionId = response.driverId.orNull
H A DSubmitRestProtocolResponse.scala39 var submissionId: String = null variable
50 var submissionId: String = null variable
53 assertFieldIsSet(submissionId, "submissionId")
62 var submissionId: String = null variable
69 assertFieldIsSet(submissionId, "submissionId")
H A DRestSubmissionServer.scala217 val submissionId = parseSubmissionId(request.getPathInfo) constant
218 val responseMessage = submissionId.map(handleKill).getOrElse {
225 protected def handleKill(submissionId: String): KillSubmissionResponse
240 val submissionId = parseSubmissionId(request.getPathInfo) constant
241 val responseMessage = submissionId.map(handleStatus).getOrElse {
248 protected def handleStatus(submissionId: String): SubmissionStatusResponse
/dports/www/groupoffice/groupoffice-6.4.231-php-71/modules/googledrive/google-api-php-client/src/contrib/
H A DGoogle_ModeratorService.php1477 public $submissionId; variable in Google_SubmissionId
1485 $this->submissionId = $submissionId;
1488 return $this->submissionId;
1514 public $submissionId; variable in Google_SubmissionParentSubmissionId
1522 $this->submissionId = $submissionId;
1525 return $this->submissionId;
1575 public $submissionId; variable in Google_TagId
1589 $this->submissionId = $submissionId;
1592 return $this->submissionId;
1855 public $submissionId; variable in Google_VoteId
[all …]
/dports/devel/msbuild/msbuild-0.06/src/Build/BackEnd/Components/SdkResolution/
H A DSdkResolverService.cs79 public virtual void ClearCache(int submissionId) in ClearCache() argument
81 _resolverStateBySubmission.TryRemove(submissionId, out _); in ClearCache()
85 …public virtual SdkResult ResolveSdk(int submissionId, SdkReference sdk, LoggingContext loggingCont… in ResolveSdk() argument
104 State = GetResolverState(submissionId, sdkResolver) in ResolveSdk()
132 SetResolverState(submissionId, sdkResolver, context.State); in ResolveSdk()
202 private object GetResolverState(int submissionId, SdkResolver resolver) in GetResolverState() argument
205 if (submissionId != BuildEventContext.InvalidSubmissionId) in GetResolverState()
209 if (_resolverStateBySubmission.TryGetValue(submissionId, out resolverState)) in GetResolverState()
236 private void SetResolverState(int submissionId, SdkResolver resolver, object state) in SetResolverState() argument
239 if (submissionId != BuildEventContext.InvalidSubmissionId) in SetResolverState()
[all …]
H A DCachingSdkResolverService.cs22 public override void ClearCache(int submissionId) in ClearCache() argument
24 base.ClearCache(submissionId); in ClearCache()
26 _cache.TryRemove(submissionId, out _); in ClearCache()
29 …public override SdkResult ResolveSdk(int submissionId, SdkReference sdk, LoggingContext loggingCon… in ResolveSdk() argument
35 …result = base.ResolveSdk(submissionId, sdk, loggingContext, sdkReferenceLocation, solutionPath, pr… in ResolveSdk()
40 …ConcurrentDictionary<string, SdkResult> cached = _cache.GetOrAdd(submissionId, new ConcurrentDicti… in ResolveSdk()
49 …key => base.ResolveSdk(submissionId, sdk, loggingContext, sdkReferenceLocation, solutionPath, proj… in ResolveSdk()
H A DSdkResolverCachingWrapper.cs34 public void ClearCache(int submissionId) in ClearCache() argument
36 _wrappedService.ClearCache(submissionId); in ClearCache()
38 _cache.TryRemove(submissionId, out _); in ClearCache()
41 …public SdkResult ResolveSdk(int submissionId, SdkReference sdk, LoggingContext loggingContext, Ele… in ResolveSdk() argument
47 …result = _wrappedService.ResolveSdk(submissionId, sdk, loggingContext, sdkReferenceLocation, solut… in ResolveSdk()
52 …ConcurrentDictionary<string, SdkResult> cached = _cache.GetOrAdd(submissionId, new ConcurrentDicti… in ResolveSdk()
61 …key => _wrappedService.ResolveSdk(submissionId, sdk, loggingContext, sdkReferenceLocation, solutio… in ResolveSdk()
H A DSdkResolverRequest.cs29 …private SdkResolverRequest(int submissionId, string name, string version, string minimumVersion, B… in SdkResolverRequest() argument
32 _submissionId = submissionId; in SdkResolverRequest()
61 …public static SdkResolverRequest Create(int submissionId, SdkReference sdkReference, BuildEventCon… in Create() argument
63 …return new SdkResolverRequest(submissionId, sdkReference.Name, sdkReference.Version, sdkReference.… in Create()
H A DOutOfProcNodeSdkResolverService.cs64 …public override SdkResult ResolveSdk(int submissionId, SdkReference sdk, LoggingContext loggingCon… in ResolveSdk() argument
71 …var result = RequestSdkPathFromMainNode(submissionId, sdk, loggingContext, sdkReferenceLocation, s… in ResolveSdk()
106 …private SdkResult RequestSdkPathFromMainNode(int submissionId, SdkReference sdk, LoggingContext lo… in RequestSdkPathFromMainNode() argument
112 …INodePacket packet = SdkResolverRequest.Create(submissionId, sdk, loggingContext.BuildEventContext… in RequestSdkPathFromMainNode()
H A DMainNodeSdkResolverService.cs62 public override void ClearCache(int submissionId) in ClearCache() argument
64 _cachedSdkResolver.ClearCache(submissionId); in ClearCache()
79 …public override SdkResult ResolveSdk(int submissionId, SdkReference sdk, LoggingContext loggingCon… in ResolveSdk() argument
86 …return _cachedSdkResolver.ResolveSdk(submissionId, sdk, loggingContext, sdkReferenceLocation, solu… in ResolveSdk()
H A DISdkResolverService.cs25 void ClearCache(int submissionId); in ClearCache() argument
37 …SdkResult ResolveSdk(int submissionId, SdkReference sdk, LoggingContext loggingContext, ElementLoc… in ResolveSdk() argument
H A DHostedSdkResolverServiceBase.cs31 public virtual void ClearCache(int submissionId) in ClearCache() argument
46 …public abstract SdkResult ResolveSdk(int submissionId, SdkReference sdk, LoggingContext loggingCon… in ResolveSdk() argument
/dports/www/nextcloud-forms/forms/lib/Db/
H A DAnswerMapper.php43 * @param int $submissionId
48 public function findBySubmission(int $submissionId): array { argument
54 …$qb->expr()->eq('submission_id', $qb->createNamedParameter($submissionId, IQueryBuilder::PARAM_INT…
61 * @param int $submissionId
63 public function deleteBySubmission(int $submissionId): void { argument
68 …$qb->expr()->eq('submission_id', $qb->createNamedParameter($submissionId, IQueryBuilder::PARAM_INT…
/dports/devel/spark/spark-2.1.1/mesos/src/main/scala/org/apache/spark/deploy/mesos/
H A DMesosDriverDescription.scala45 val submissionId: String, constant
61 submissionId: String = submissionId,
66 submissionId, submissionDate, retryState)
/dports/devel/spark/spark-2.1.1/mesos/src/main/scala/org/apache/spark/deploy/rest/mesos/
H A DMesosRestServer.scala111 val submissionId = newDriverId(submitDate) constant
115 command, request.sparkProperties, submissionId, submitDate)
142 protected override def handleKill(submissionId: String): KillSubmissionResponse = {
143 val k = scheduler.killDriver(submissionId)
151 protected override def handleStatus(submissionId: String): SubmissionStatusResponse = {
152 val d = scheduler.getDriverStatus(submissionId)
/dports/devel/msbuild/msbuild-0.06/src/Framework/
H A DBuildEventContext.cs94 int submissionId, in BuildEventContext() argument
101 …:this(submissionId, nodeId, InvalidEvaluationId, projectInstanceId, projectContextId, targetId, ta… in BuildEventContext()
110 int submissionId, in BuildEventContext() argument
119 _submissionId = submissionId; in BuildEventContext()
/dports/devel/msbuild/msbuild-0.06/src/Utilities/
H A DMuxLogger.cs194 public void RegisterLogger(int submissionId, ILogger logger) in RegisterLogger() argument
206 if (_submissionProjectsInProgress.ContainsKey(submissionId)) in RegisterLogger()
215 if (!_submissionRecords.TryGetValue(submissionId, out record)) in RegisterLogger()
217 …record = new SubmissionRecord(submissionId, _eventSourceForBuild, _buildStartedEvent, _maxNodeCoun… in RegisterLogger()
218 _submissionRecords.Add(submissionId, record); in RegisterLogger()
228 public bool UnregisterLoggers(int submissionId) in UnregisterLoggers() argument
233 if (!_submissionRecords.TryGetValue(submissionId, out record)) in UnregisterLoggers()
238 _submissionRecords.Remove(submissionId); in UnregisterLoggers()
456 …internal SubmissionRecord(int submissionId, IEventSource buildEventSource, BuildStartedEventArgs b… in SubmissionRecord() argument
464 _submissionId = submissionId; in SubmissionRecord()
/dports/devel/msbuild/msbuild-0.06/src/Build.UnitTests/BackEnd/
H A DSdkResolverService_Tests.cs130 const int submissionId = 5; in AssertResolverHasStatePreserved()
137 …SdkResolverService.Instance.ResolveSdk(submissionId, sdk, _loggingContext, new MockElementLocation… in AssertResolverHasStatePreserved()
140 …SdkResolverService.Instance.ResolveSdk(submissionId, sdk, _loggingContext, new MockElementLocation… in AssertResolverHasStatePreserved()
146 const int submissionId = BuildEventContext.InvalidSubmissionId; in AssertResolverStateNotPreserved()
153 …SdkResolverService.Instance.ResolveSdk(submissionId, sdk, _loggingContext, new MockElementLocation… in AssertResolverStateNotPreserved()
156 …SdkResolverService.Instance.ResolveSdk(submissionId, sdk, _loggingContext, new MockElementLocation… in AssertResolverStateNotPreserved()
H A DMockSdkResolverService.cs14 public void ClearCache(int submissionId) in ClearCache() argument
18 …public Build.BackEnd.SdkResolution.SdkResult ResolveSdk(int submissionId, SdkReference sdk, Loggin… in ResolveSdk() argument
/dports/devel/spark/spark-2.1.1/mesos/src/test/scala/org/apache/spark/scheduler/cluster/mesos/
H A DMesosClusterSchedulerSuite.scala71 assert(queuedDrivers(0).submissionId == response.submissionId)
72 assert(queuedDrivers(1).submissionId == response2.submissionId)
82 val killResponse = scheduler.killDriver(response.submissionId)

123