/dports/devel/msbuild/msbuild-0.06/src/Build/BackEnd/BuildManager/ |
H A D | LegacyThreadingData.cs | 93 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 D | MesosClusterScheduler.scala | 170 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 D | StandaloneRestSubmitSuite.scala | 105 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 D | SubmitRestProtocolSuite.scala | 147 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 D | RestSubmissionClient.scala | 117 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 D | StandaloneRestServer.scala | 73 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 D | SubmitRestProtocolResponse.scala | 39 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 D | RestSubmissionServer.scala | 217 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 D | Google_ModeratorService.php | 1477 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 D | SdkResolverService.cs | 79 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 D | CachingSdkResolverService.cs | 22 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 D | SdkResolverCachingWrapper.cs | 34 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 D | SdkResolverRequest.cs | 29 …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 D | OutOfProcNodeSdkResolverService.cs | 64 …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 D | MainNodeSdkResolverService.cs | 62 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 D | ISdkResolverService.cs | 25 void ClearCache(int submissionId); in ClearCache() argument 37 …SdkResult ResolveSdk(int submissionId, SdkReference sdk, LoggingContext loggingContext, ElementLoc… in ResolveSdk() argument
|
H A D | HostedSdkResolverServiceBase.cs | 31 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 D | AnswerMapper.php | 43 * @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 D | MesosDriverDescription.scala | 45 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 D | MesosRestServer.scala | 111 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 D | BuildEventContext.cs | 94 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 D | MuxLogger.cs | 194 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 D | SdkResolverService_Tests.cs | 130 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 D | MockSdkResolverService.cs | 14 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 D | MesosClusterSchedulerSuite.scala | 71 assert(queuedDrivers(0).submissionId == response.submissionId) 72 assert(queuedDrivers(1).submissionId == response2.submissionId) 82 val killResponse = scheduler.killDriver(response.submissionId)
|