cpconnectionmanager.cs

来自「zwave 无线通讯协议 PC controller 控制器源码」· CS 代码 · 共 989 行 · 第 1/4 页

            {
               if(_S.GetAction("ConnectionComplete")==null)
               {
                   return(false);
               }
               else
               {
                   return(true);
               }
            }
        }
        public bool HasAction_GetCurrentConnectionIDs
        {
            get
            {
               if(_S.GetAction("GetCurrentConnectionIDs")==null)
               {
                   return(false);
               }
               else
               {
                   return(true);
               }
            }
        }
        public bool HasAction_GetCurrentConnectionInfo
        {
            get
            {
               if(_S.GetAction("GetCurrentConnectionInfo")==null)
               {
                   return(false);
               }
               else
               {
                   return(true);
               }
            }
        }
        public bool HasAction_GetProtocolInfo
        {
            get
            {
               if(_S.GetAction("GetProtocolInfo")==null)
               {
                   return(false);
               }
               else
               {
                   return(true);
               }
            }
        }
        public bool HasAction_PrepareForConnection
        {
            get
            {
               if(_S.GetAction("PrepareForConnection")==null)
               {
                   return(false);
               }
               else
               {
                   return(true);
               }
            }
        }
        public void Sync_ConnectionComplete(System.Int32 ConnectionID)
        {
           UPnPArgument[] args = new UPnPArgument[1];
           args[0] = new UPnPArgument("ConnectionID", ConnectionID);
            _S.InvokeSync("ConnectionComplete", args);
            ConnectionID = (System.Int32) args[0].DataValue;
            return;
        }
        public void ConnectionComplete(System.Int32 ConnectionID)
        {
            ConnectionComplete(ConnectionID, null, null);
        }
        public void ConnectionComplete(System.Int32 ConnectionID, object _Tag, Delegate_OnResult_ConnectionComplete _Callback)
        {
           UPnPArgument[] args = new UPnPArgument[1];
           args[0] = new UPnPArgument("ConnectionID", ConnectionID);
           _S.InvokeAsync("ConnectionComplete", args, new object[2]{_Tag,_Callback},new UPnPService.UPnPServiceInvokeHandler(Sink_ConnectionComplete), new UPnPService.UPnPServiceInvokeErrorHandler(Error_Sink_ConnectionComplete));
        }
        private void Sink_ConnectionComplete(UPnPService sender, string MethodName, UPnPArgument[] Args, object RetVal, object _Tag)
        {
            object[] StateInfo = (object[])_Tag;
            if(StateInfo[1]!=null)
            {
                ((Delegate_OnResult_ConnectionComplete)StateInfo[1])(this, (System.Int32 )Args[0].DataValue, null, StateInfo[0]);
            }
            else
            {
                OnResult_ConnectionComplete_Event.Fire(this, (System.Int32 )Args[0].DataValue, null, StateInfo[0]);
            }
        }
        private void Error_Sink_ConnectionComplete(UPnPService sender, string MethodName, UPnPArgument[] Args, UPnPInvokeException e, object _Tag)
        {
            object[] StateInfo = (object[])_Tag;
            if(StateInfo[1]!=null)
            {
                ((Delegate_OnResult_ConnectionComplete)StateInfo[1])(this, (System.Int32 )Args[0].DataValue, e, StateInfo[0]);
            }
            else
            {
                OnResult_ConnectionComplete_Event.Fire(this, (System.Int32 )Args[0].DataValue, e, StateInfo[0]);
            }
        }
        public void Sync_GetCurrentConnectionIDs(out System.String ConnectionIDs)
        {
           UPnPArgument[] args = new UPnPArgument[1];
           args[0] = new UPnPArgument("ConnectionIDs", "");
            _S.InvokeSync("GetCurrentConnectionIDs", args);
            ConnectionIDs = (System.String) args[0].DataValue;
            return;
        }
        public void GetCurrentConnectionIDs()
        {
            GetCurrentConnectionIDs(null, null);
        }
        public void GetCurrentConnectionIDs(object _Tag, Delegate_OnResult_GetCurrentConnectionIDs _Callback)
        {
           UPnPArgument[] args = new UPnPArgument[1];
           args[0] = new UPnPArgument("ConnectionIDs", "");
           _S.InvokeAsync("GetCurrentConnectionIDs", args, new object[2]{_Tag,_Callback},new UPnPService.UPnPServiceInvokeHandler(Sink_GetCurrentConnectionIDs), new UPnPService.UPnPServiceInvokeErrorHandler(Error_Sink_GetCurrentConnectionIDs));
         }
        private void Sink_GetCurrentConnectionIDs(UPnPService sender, string MethodName, UPnPArgument[] Args, object RetVal, object _Tag)
        {
            object[] StateInfo = (object[])_Tag;
            if(StateInfo[1]!=null)
            {
                ((Delegate_OnResult_GetCurrentConnectionIDs)StateInfo[1])(this, (System.String )Args[0].DataValue, null, StateInfo[0]);
            }
            else
            {
                OnResult_GetCurrentConnectionIDs_Event.Fire(this, (System.String )Args[0].DataValue, null, StateInfo[0]);
            }
        }
        private void Error_Sink_GetCurrentConnectionIDs(UPnPService sender, string MethodName, UPnPArgument[] Args, UPnPInvokeException e, object _Tag)
        {
            object[] StateInfo = (object[])_Tag;
            if(StateInfo[1]!=null)
            {
                ((Delegate_OnResult_GetCurrentConnectionIDs)StateInfo[1])(this, (System.String)UPnPService.CreateObjectInstance(typeof(System.String),null), e, StateInfo[0]);
            }
            else
            {
                OnResult_GetCurrentConnectionIDs_Event.Fire(this, (System.String)UPnPService.CreateObjectInstance(typeof(System.String),null), e, StateInfo[0]);
            }
        }
        public void Sync_GetCurrentConnectionInfo(System.Int32 ConnectionID, out System.Int32 RcsID, out System.Int32 AVTransportID, out System.String ProtocolInfo, out System.String PeerConnectionManager, out System.Int32 PeerConnectionID, out Enum_A_ARG_TYPE_Direction Direction, out Enum_A_ARG_TYPE_ConnectionStatus Status)
        {
           UPnPArgument[] args = new UPnPArgument[8];
           args[0] = new UPnPArgument("ConnectionID", ConnectionID);
           args[1] = new UPnPArgument("RcsID", "");
           args[2] = new UPnPArgument("AVTransportID", "");
           args[3] = new UPnPArgument("ProtocolInfo", "");
           args[4] = new UPnPArgument("PeerConnectionManager", "");
           args[5] = new UPnPArgument("PeerConnectionID", "");
           args[6] = new UPnPArgument("Direction", "");
           args[7] = new UPnPArgument("Status", "");
            _S.InvokeSync("GetCurrentConnectionInfo", args);
            for(int i=0;i<args.Length;++i)
            {
                switch(args[i].Name)
                {
                    case "Direction":
                        switch((string)args[i].DataValue)
                        {
                            case "Input":
                                args[i].DataValue = Enum_A_ARG_TYPE_Direction.INPUT;
                                break;
                            case "Output":
                                args[i].DataValue = Enum_A_ARG_TYPE_Direction.OUTPUT;
                                break;
                            default:
                               SetUnspecifiedValue("Enum_A_ARG_TYPE_Direction", (string)args[i].DataValue);
                               args[i].DataValue = Enum_A_ARG_TYPE_Direction._UNSPECIFIED_;
                               break;
                        }
                        break;
                    case "Status":
                        switch((string)args[i].DataValue)
                        {
                            case "OK":
                                args[i].DataValue = Enum_A_ARG_TYPE_ConnectionStatus.OK;
                                break;
                            case "ContentFormatMismatch":
                                args[i].DataValue = Enum_A_ARG_TYPE_ConnectionStatus.CONTENTFORMATMISMATCH;
                                break;
                            case "InsufficientBandwidth":
                                args[i].DataValue = Enum_A_ARG_TYPE_ConnectionStatus.INSUFFICIENTBANDWIDTH;
                                break;
                            case "UnreliableChannel":
                                args[i].DataValue = Enum_A_ARG_TYPE_ConnectionStatus.UNRELIABLECHANNEL;
                                break;
                            case "Unknown":
                                args[i].DataValue = Enum_A_ARG_TYPE_ConnectionStatus.UNKNOWN;
                                break;
                            default:
                               SetUnspecifiedValue("Enum_A_ARG_TYPE_ConnectionStatus", (string)args[i].DataValue);
                               args[i].DataValue = Enum_A_ARG_TYPE_ConnectionStatus._UNSPECIFIED_;
                               break;
                        }
                        break;
                }
            }
            ConnectionID = (System.Int32) args[0].DataValue;
            RcsID = (System.Int32) args[1].DataValue;
            AVTransportID = (System.Int32) args[2].DataValue;
            ProtocolInfo = (System.String) args[3].DataValue;
            PeerConnectionManager = (System.String) args[4].DataValue;
            PeerConnectionID = (System.Int32) args[5].DataValue;
            Direction = (Enum_A_ARG_TYPE_Direction) args[6].DataValue;
            Status = (Enum_A_ARG_TYPE_ConnectionStatus) args[7].DataValue;
            return;
        }
        public void GetCurrentConnectionInfo(System.Int32 ConnectionID)
        {
            GetCurrentConnectionInfo(ConnectionID, null, null);
        }
        public void GetCurrentConnectionInfo(System.Int32 ConnectionID, object _Tag, Delegate_OnResult_GetCurrentConnectionInfo _Callback)
        {
           UPnPArgument[] args = new UPnPArgument[8];
           args[0] = new UPnPArgument("ConnectionID", ConnectionID);
           args[1] = new UPnPArgument("RcsID", "");
           args[2] = new UPnPArgument("AVTransportID", "");
           args[3] = new UPnPArgument("ProtocolInfo", "");
           args[4] = new UPnPArgument("PeerConnectionManager", "");
           args[5] = new UPnPArgument("PeerConnectionID", "");
           args[6] = new UPnPArgument("Direction", "");
           args[7] = new UPnPArgument("Status", "");
           _S.InvokeAsync("GetCurrentConnectionInfo", args, new object[2]{_Tag,_Callback},new UPnPService.UPnPServiceInvokeHandler(Sink_GetCurrentConnectionInfo), new UPnPService.UPnPServiceInvokeErrorHandler(Error_Sink_GetCurrentConnectionInfo));
        }
        private void Sink_GetCurrentConnectionInfo(UPnPService sender, string MethodName, UPnPArgument[] Args, object RetVal, object _Tag)
        {
            for(int i=0;i<Args.Length;++i)
            {
                switch(Args[i].Name)
                {
                    case "Direction":
                        switch((string)Args[i].DataValue)
                        {
                            case "Input":
                                Args[i].DataValue = Enum_A_ARG_TYPE_Direction.INPUT;
                                break;
                            case "Output":