123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197 |
- using System.Collections.Generic;
- using UnityEditor.PackageManager.Requests;
- using UnityEditor.PackageManager;
- using System;
- namespace Unity.RenderStreaming.Editor {
- internal class RequestJobManager
- {
- [UnityEditor.InitializeOnLoadMethod]
- static void OnLoad() {
- UnityEditor.EditorApplication.update+=UpdateRequestJobs;
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- public static void CreateListRequest(bool offlineMode, bool includeIndirectIndependencies,
- Action<Request<PackageCollection>> onSuccess, Action<Request<PackageCollection>> onFail)
- {
- m_pendingListRequests.Enqueue(new ListRequestInfo(offlineMode, includeIndirectIndependencies, onSuccess, onFail));
- }
-
-
-
-
-
-
-
-
- public static void CreateAddRequest(string packageName,
- Action<Request<PackageInfo>> onSuccess, Action<Request<PackageInfo>> onFail)
- {
- m_pendingAddRequests.Enqueue(new AddRequestInfo(packageName, onSuccess, onFail));
- }
-
-
-
-
-
-
-
- public static void CreateRemoveRequest(string packageName, Action onSuccess, Action onFail)
- {
- m_pendingRemoveRequests.Enqueue(new RemoveRequestInfo(packageName, onSuccess, onFail));
- }
-
-
-
-
-
-
-
-
-
-
-
- public static void CreateSearchRequest(string packageName, bool offlineMode,
- Action<Request<PackageInfo[]>> onSuccess, Action<Request<PackageInfo[]>> onFail)
- {
- m_pendingSearchRequests.Enqueue(new SearchRequestInfo(packageName, offlineMode, onSuccess, onFail));
- }
-
-
-
-
-
-
-
-
-
-
- public static void CreateSearchAllRequest(bool offlineMode,
- Action<Request<PackageInfo[]>> onSuccess, Action<Request<PackageInfo[]>> onFail)
- {
- m_pendingSearchAllRequests.Enqueue(new SearchAllRequestInfo(offlineMode, onSuccess, onFail));
- }
-
- static void UpdateRequestJobs()
- {
- {
- var enumerator = m_pendingListRequests.GetEnumerator();
- while (enumerator.MoveNext()) {
- ListRequestInfo info = enumerator.Current;
- ListRequest listReq = Client.List(info.OfflineMode, info.IncludeIndirectIndependencies);
- m_requestJobs.Add(new RequestJob<PackageCollection>(listReq,info.OnSuccessAction,info.OnFailAction));
- }
- m_pendingListRequests.Clear();
- }
- {
- var enumerator = m_pendingAddRequests.GetEnumerator();
- while (enumerator.MoveNext()) {
- AddRequestInfo info = enumerator.Current;
- AddRequest addReq = Client.Add(info.PackageName);
- m_requestJobs.Add(new RequestJob<PackageInfo>(addReq,info.OnSuccessAction,info.OnFailAction));
- }
- m_pendingAddRequests.Clear();
- }
- {
- var enumerator = m_pendingRemoveRequests.GetEnumerator();
- while (enumerator.MoveNext()) {
- RemoveRequestInfo info = enumerator.Current;
- RemoveRequest removeReq = Client.Remove(info.PackageName);
- m_requestJobs.Add(new RequestJob(removeReq,info.OnSuccessAction,info.OnFailAction));
- }
- m_pendingRemoveRequests.Clear();
- }
- {
- var enumerator = m_pendingSearchRequests.GetEnumerator();
- while (enumerator.MoveNext()) {
- SearchRequestInfo info = enumerator.Current;
- SearchRequest searchReq = Client.Search(info.PackageName, info.OfflineMode);
- m_requestJobs.Add(new RequestJob<PackageInfo[]>(searchReq,info.OnSuccessAction,info.OnFailAction));
- }
- m_pendingSearchRequests.Clear();
- }
- {
- var enumerator = m_pendingSearchAllRequests.GetEnumerator();
- while (enumerator.MoveNext()) {
- SearchAllRequestInfo info = enumerator.Current;
- SearchRequest searchReq = Client.SearchAll(info.OfflineMode);
- m_requestJobs.Add(new RequestJob<PackageInfo[]>(searchReq,info.OnSuccessAction,info.OnFailAction));
- }
- m_pendingSearchAllRequests.Clear();
- }
- {
- var enumerator = m_requestJobs.GetEnumerator();
- while (enumerator.MoveNext()) {
- StatusCode code = enumerator.Current.Update();
- if (StatusCode.Failure == code || StatusCode.Success == code) {
- m_jobsToDelete.Add(enumerator.Current);
- }
- }
- }
-
- {
- var enumerator = m_jobsToDelete.GetEnumerator();
- while (enumerator.MoveNext()) {
- m_requestJobs.Remove(enumerator.Current);
- }
- m_jobsToDelete.Clear();
- }
- }
- static Queue<ListRequestInfo> m_pendingListRequests = new Queue<ListRequestInfo>();
- static Queue<AddRequestInfo> m_pendingAddRequests = new Queue<AddRequestInfo>();
- static Queue<RemoveRequestInfo> m_pendingRemoveRequests = new Queue<RemoveRequestInfo>();
- static Queue<SearchRequestInfo> m_pendingSearchRequests = new Queue<SearchRequestInfo>();
- static Queue<SearchAllRequestInfo> m_pendingSearchAllRequests = new Queue<SearchAllRequestInfo>();
- static System.Collections.Generic.HashSet<IRequestJob> m_requestJobs = new HashSet<IRequestJob>();
- static System.Collections.Generic.List<IRequestJob> m_jobsToDelete = new List<IRequestJob>();
- }
- }
|