| | |
|---|
| | |
|
|---|
| | | void OnUpdate()
|
|---|
| | | {
|
|---|
| | | while (mainProtocolQueue.Count > 0)
|
|---|
| | | lock (this)
|
|---|
| | | {
|
|---|
| | | PackageRegedit.Distribute(mainProtocolQueue.Dequeue());
|
|---|
| | | while (mainProtocolQueue.Count > 0)
|
|---|
| | | {
|
|---|
| | | var package = mainProtocolQueue.Dequeue();
|
|---|
| | | if (package != null)
|
|---|
| | | {
|
|---|
| | | PackageRegedit.Distribute(package);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | while (crossSeverProtocolQueue.Count > 0)
|
|---|
| | | {
|
|---|
| | | var package = crossSeverProtocolQueue.Dequeue();
|
|---|
| | | if (package!=null)
|
|---|
| | | {
|
|---|
| | | PackageRegedit.Distribute(package);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | while (crossSeverProtocolQueue.Count > 0)
|
|---|
| | | {
|
|---|
| | | PackageRegedit.Distribute(crossSeverProtocolQueue.Dequeue());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public enum NetState
|
|---|
