Documentation ¶
Overview ¶
Copyright (c) 2019 Sippy Software, Inc. All rights reserved.
All rights reserved.
Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met:
1. Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer.
2. Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the following disclaimer in the documentation and/or other materials provided with the distribution.
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
Copyright (c) 2003-2005 Maxim Sobolev. All rights reserved. Copyright (c) 2006-2020 Sippy Software, Inc. All rights reserved.
All rights reserved.
Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met:
1. Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer.
2. Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the following disclaimer in the documentation and/or other materials provided with the distribution.
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
Index ¶
- Constants
- Variables
- func NewAsyncReciever(userv *UdpServer, logger sippy_log.ErrorLogger) *asyncReceiver
- func NewAsyncResolver(userv *UdpServer, logger sippy_log.ErrorLogger) *asyncResolver
- func NewAsyncSender(userv *UdpServer, n int) *asyncSender
- func NewClientTransactionObj(req sippy_types.SipRequest, tid *sippy_header.TID, userv sippy_net.Transport, ...) (*clientTransaction, error)
- func NewDefaultSipTransportFactory(config sippy_conf.Config) *defaultSipTransportFactory
- func NewLocal4Remote(config sippy_conf.Config, handleIncoming sippy_net.DataPacketReceiver) (*local4remote, error)
- func NewMsgBody(content, mtype string) *msgBody
- func NewRtpProxyClient(opts *rtpProxyClientOpts) sippy_types.RtpProxyClient
- func NewRtpProxyClientOpts(spath string, bind_address *sippy_net.HostPort, config sippy_conf.Config, ...) (*rtpProxyClientOpts, error)
- func NewServerTransaction(req sippy_types.SipRequest, checksum string, tid *sippy_header.TID, ...) (sippy_types.ServerTransaction, error)
- func NewSipMsg(rtime *sippy_time.MonoTime, config sippy_conf.Config) *sipMsg
- func NewSipRequest(method string, ruri *sippy_header.SipURL, sipver string, ...) (*sipRequest, error)
- func NewSipResponse(scode int, reason, sipver string, from *sippy_header.SipFrom, ...) *sipResponse
- func NewSipTransactionManager(config sippy_conf.Config, call_map sippy_types.CallMap) (*sipTransactionManager, error)
- func NewStatefulProxy(sip_tm sippy_types.SipTransactionManager, destination *sippy_net.HostPort, ...) *statefulProxy
- func NewUacStateRinging(ua sippy_types.UA, config sippy_conf.Config) sippy_types.UaState
- func NewUdpServerOpts(laddress *sippy_net.HostPort, data_callback sippy_net.DataPacketReceiver) *udpServerOpts
- func ParseSdpBody(body string) (*sdpBody, error)
- func ParseSipHeader(s string) ([]sippy_header.SipHeader, error)
- func ParseSipMsg(_buf []byte, rtime *sippy_time.MonoTime, config sippy_conf.Config) (*sipMsg, error)
- func ParseSipRequest(buf []byte, rtime *sippy_time.MonoTime, config sippy_conf.Config) (*sipRequest, error)
- func ParseSipResponse(buf []byte, rtime *sippy_time.MonoTime, config sippy_conf.Config) (*sipResponse, error)
- type CCEventConnect
- type CCEventDisconnect
- type CCEventFail
- func (*CCEventFail) GetBody() sippy_types.MsgBody
- func (s *CCEventFail) GetExtraHeaders() []sippy_header.SipHeader
- func (s *CCEventFail) GetScode() int
- func (s *CCEventFail) GetScodeReason() string
- func (s *CCEventFail) SetScode(scode int)
- func (s *CCEventFail) SetScodeReason(reason string)
- func (s *CCEventFail) SetWarning(text string)
- func (s *CCEventFail) String() string
- type CCEventGeneric
- func (s *CCEventGeneric) AppendExtraHeader(eh sippy_header.SipHeader)
- func (s *CCEventGeneric) GetExtraHeaders() []sippy_header.SipHeader
- func (s *CCEventGeneric) GetMaxForwards() *sippy_header.SipMaxForwards
- func (s *CCEventGeneric) GetOrigin() string
- func (s *CCEventGeneric) GetReason() *sippy_header.SipReason
- func (s *CCEventGeneric) GetRtime() *sippy_time.MonoTime
- func (s *CCEventGeneric) GetSeq() int64
- func (s *CCEventGeneric) SetMaxForwards(max_forwards *sippy_header.SipMaxForwards)
- func (s *CCEventGeneric) SetReason(sip_reason *sippy_header.SipReason)
- type CCEventInfo
- type CCEventPreConnect
- type CCEventRedirect
- func (*CCEventRedirect) GetBody() sippy_types.MsgBody
- func (s *CCEventRedirect) GetContacts() []*sippy_header.SipContact
- func (s *CCEventRedirect) GetRedirectURL() *sippy_header.SipAddress
- func (s *CCEventRedirect) GetRedirectURLs() []*sippy_header.SipAddress
- func (s *CCEventRedirect) SortAddresses()
- func (s *CCEventRedirect) String() string
- type CCEventRing
- type CCEventTry
- func (s *CCEventTry) GetBody() sippy_types.MsgBody
- func (s *CCEventTry) GetCLD() string
- func (s *CCEventTry) GetCLI() string
- func (s *CCEventTry) GetCallerName() string
- func (s *CCEventTry) GetSipAuthorizationBody() *sippy_header.SipAuthorizationBody
- func (s *CCEventTry) GetSipAuthorizationHF() sippy_header.SipAuthorizationHeader
- func (s *CCEventTry) GetSipCallId() *sippy_header.SipCallId
- func (s *CCEventTry) SetRoutes(routes []*sippy_header.SipRoute)
- func (s *CCEventTry) String() string
- type CCEventUpdate
- type ESipParseException
- type RtpProxyCmd
- type Rtp_proxy_client_base
- func (s *Rtp_proxy_client_base) Address() net.Addr
- func (s *Rtp_proxy_client_base) GetActiveSessions() int64
- func (s *Rtp_proxy_client_base) GetActiveStreams() int64
- func (s *Rtp_proxy_client_base) GetOpts() sippy_types.RtpProxyClientOpts
- func (s *Rtp_proxy_client_base) GetPReceived() int64
- func (s *Rtp_proxy_client_base) GetPTransmitted() int64
- func (s *Rtp_proxy_client_base) GetProxyAddress() string
- func (s *Rtp_proxy_client_base) GetRtpcDelay() float64
- func (s *Rtp_proxy_client_base) GetSessionsCreated() int64
- func (s *Rtp_proxy_client_base) GoOffline()
- func (s *Rtp_proxy_client_base) GoOnline()
- func (s *Rtp_proxy_client_base) IsLocal() bool
- func (s *Rtp_proxy_client_base) IsOnline() bool
- func (s *Rtp_proxy_client_base) IsShutDown() bool
- func (s *Rtp_proxy_client_base) Reconnect(addr net.Addr, bind_addr *sippy_net.HostPort)
- func (s *Rtp_proxy_client_base) SBindSupported() bool
- func (s *Rtp_proxy_client_base) SendCommand(cmd string, cb func(string))
- func (s *Rtp_proxy_client_base) Shutdown()
- func (s *Rtp_proxy_client_base) Start() error
- func (s *Rtp_proxy_client_base) TNotSupported() bool
- func (s *Rtp_proxy_client_base) UpdateActive(...)
- func (s *Rtp_proxy_client_base) WdntSupported() bool
- type Rtp_proxy_client_stream
- type Rtp_proxy_client_udp
- type Rtp_proxy_session
- func (s *Rtp_proxy_session) CallerSessionExists() bool
- func (s *Rtp_proxy_session) Delete()
- func (s *Rtp_proxy_session) GetProxyAddress() (string, error)
- func (s *Rtp_proxy_session) IsLocal() (bool, error)
- func (s *Rtp_proxy_session) OnCalleeSdpChange(sdp_body sippy_types.MsgBody, result_callback func(sippy_types.MsgBody)) error
- func (s *Rtp_proxy_session) OnCallerSdpChange(sdp_body sippy_types.MsgBody, result_callback func(sippy_types.MsgBody)) error
- func (s *Rtp_proxy_session) PlayCaller(prompt_name string, times int, result_callback func(string), index int)
- func (s *Rtp_proxy_session) SBindSupported() (bool, error)
- func (s *Rtp_proxy_session) SetAfterCallerSdpChange(cb func(sippy_types.RtpProxyUpdateResult))
- func (s *Rtp_proxy_session) SetCalleeLaddress(addr string)
- func (s *Rtp_proxy_session) SetCalleeRaddress(addr *sippy_net.HostPort)
- func (s *Rtp_proxy_session) SetCallerLaddress(addr string)
- func (s *Rtp_proxy_session) SetCallerRaddress(addr *sippy_net.HostPort)
- func (s *Rtp_proxy_session) SetInsertNortpp(v bool)
- func (s *Rtp_proxy_session) StartRecording(rname string, result_callback func(string), index int)
- func (s *Rtp_proxy_session) StopPlayCaller(result_callback func(string), index int)
- func (s *Rtp_proxy_session) TNotSupported() (bool, error)
- type RtppStats
- type SdpSession
- type Timeout
- func NewInactiveTimeout(callback func(), cb_lock sync.Locker, _timeout time.Duration, nticks int, ...) *Timeout
- func StartTimeout(callback func(), cb_lock sync.Locker, _timeout time.Duration, nticks int, ...) *Timeout
- func StartTimeoutWithSpread(callback func(), cb_lock sync.Locker, _timeout time.Duration, nticks int, ...) *Timeout
- type Ua
- func (s *Ua) BeforeRequestSent(sippy_types.SipRequest)
- func (s *Ua) BeforeResponseSent(sippy_types.SipResponse)
- func (s *Ua) BeginClientTransaction(req sippy_types.SipRequest, tr sippy_types.ClientTransaction)
- func (s *Ua) BeginNewClientTransaction(req sippy_types.SipRequest, resp_receiver sippy_types.ResponseReceiver)
- func (s *Ua) CancelCreditTimer()
- func (s *Ua) CancelExpireTimer()
- func (s *Ua) CancelNoProgressTimer()
- func (s *Ua) CancelNoReplyTimer()
- func (s *Ua) ChangeState(newstate sippy_types.UaState, cb func())
- func (s *Ua) Cleanup()
- func (s *Ua) Config() sippy_conf.Config
- func (s *Ua) ConnCb(rtime *sippy_time.MonoTime, origin string)
- func (s *Ua) DelayedRemoteSdpUpdate(event sippy_types.CCEvent, remote_sdp_body sippy_types.MsgBody)
- func (s *Ua) DiscCb(rtime *sippy_time.MonoTime, origin string, scode int, ...)
- func (s *Ua) Disconnect(rtime *sippy_time.MonoTime, origin string)
- func (s *Ua) EmitEvent(event sippy_types.CCEvent)
- func (s *Ua) Enqueue(event sippy_types.CCEvent)
- func (s *Ua) FailCb(rtime *sippy_time.MonoTime, origin string, scode int)
- func (s *Ua) GenRequest(method string, body sippy_types.MsgBody, challenge sippy_types.Challenge, ...) (sippy_types.SipRequest, error)
- func (s *Ua) GetAcct(disconnect_ts *sippy_time.MonoTime) (duration time.Duration, delay time.Duration, connected bool, disconnected bool)
- func (s *Ua) GetCLD() string
- func (s *Ua) GetCLI() string
- func (s *Ua) GetCallId() *sippy_header.SipCallId
- func (s *Ua) GetClientTransaction() sippy_types.ClientTransaction
- func (s *Ua) GetConnCb() sippy_types.OnConnectListener
- func (s *Ua) GetConnectTs() *sippy_time.MonoTime
- func (s *Ua) GetController() sippy_types.CallController
- func (s *Ua) GetDeadCb() sippy_types.OnDeadListener
- func (s *Ua) GetDiscCb() sippy_types.OnDisconnectListener
- func (s *Ua) GetDisconnectTs() *sippy_time.MonoTime
- func (s *Ua) GetDlgHeaders() []sippy_header.SipHeader
- func (s *Ua) GetExMtime() *sippy_time.MonoTime
- func (s *Ua) GetExpireTime() time.Duration
- func (s *Ua) GetExtraHeaders() []sippy_header.SipHeader
- func (s *Ua) GetFailCb() sippy_types.OnFailureListener
- func (s *Ua) GetGoDeadTimeout() time.Duration
- func (s *Ua) GetKaInterval() time.Duration
- func (s *Ua) GetLContact() *sippy_header.SipContact
- func (s *Ua) GetLContacts() []*sippy_header.SipContact
- func (s *Ua) GetLSDP() sippy_types.MsgBody
- func (s *Ua) GetLTag() string
- func (s *Ua) GetLUri() *sippy_header.SipFrom
- func (s *Ua) GetLastScode() int
- func (s *Ua) GetLateMedia() bool
- func (s *Ua) GetLocalUA() *sippy_header.SipUserAgent
- func (s *Ua) GetNoProgressTime() time.Duration
- func (s *Ua) GetNoReplyTime() time.Duration
- func (s *Ua) GetNpMtime() *sippy_time.MonoTime
- func (s *Ua) GetNrMtime() *sippy_time.MonoTime
- func (s *Ua) GetOnLocalSdpChange() sippy_types.OnLocalSdpChange
- func (s *Ua) GetOnRemoteSdpChange() sippy_types.OnRemoteSdpChange
- func (s *Ua) GetOrigin() string
- func (s *Ua) GetOutboundProxy() *sippy_net.HostPort
- func (s *Ua) GetP100Ts() *sippy_time.MonoTime
- func (s *Ua) GetP1xxTs() *sippy_time.MonoTime
- func (s *Ua) GetPassAuth() bool
- func (s *Ua) GetPassword() string
- func (s *Ua) GetPendingTr() sippy_types.ClientTransaction
- func (s *Ua) GetRAddr() *sippy_net.HostPort
- func (s *Ua) GetRAddr0() *sippy_net.HostPort
- func (s *Ua) GetRSDP() sippy_types.MsgBody
- func (s *Ua) GetRTarget() *sippy_header.SipURL
- func (s *Ua) GetRUri() *sippy_header.SipTo
- func (s *Ua) GetRemoteUA() string
- func (s *Ua) GetSessionLock() sync.Locker
- func (s *Ua) GetSetupTs() *sippy_time.MonoTime
- func (s *Ua) GetSourceAddress() *sippy_net.HostPort
- func (s *Ua) GetState() sippy_types.UaStateID
- func (s *Ua) GetStateName() string
- func (s *Ua) GetUasLossEmul() int
- func (s *Ua) GetUasResp() sippy_types.SipResponse
- func (s *Ua) GetUsername() string
- func (s *Ua) HasNoProgressTimer() bool
- func (s *Ua) HasNoReplyTimer() bool
- func (s *Ua) HasOnLocalSdpChange() bool
- func (s *Ua) HasOnRemoteSdpChange() bool
- func (s *Ua) IsYours(req sippy_types.SipRequest, br0k3n_to bool) bool
- func (s *Ua) OnDead()
- func (s *Ua) OnEarlyUasDisconnect(ev sippy_types.CCEvent) (int, string)
- func (s *Ua) OnLocalSdpChange(body sippy_types.MsgBody, cb func(sippy_types.MsgBody)) error
- func (s *Ua) OnReinvite(req sippy_types.SipRequest, event_update sippy_types.CCEvent)
- func (s *Ua) OnRemoteSdpChange(body sippy_types.MsgBody, f func(x sippy_types.MsgBody)) error
- func (s *Ua) OnUacSetupComplete()
- func (s *Ua) OnUnregister()
- func (s *Ua) PassAuth() bool
- func (s *Ua) PrRel() bool
- func (s *Ua) PrepTr(req sippy_types.SipRequest, eh []sippy_header.SipHeader) (sippy_types.ClientTransaction, error)
- func (s *Ua) RecvACK(req sippy_types.SipRequest)
- func (s *Ua) RecvEvent(event sippy_types.CCEvent)
- func (s *Ua) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s *Ua) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) *sippy_types.UaContext
- func (s *Ua) RecvResponse(resp sippy_types.SipResponse, tr sippy_types.ClientTransaction)
- func (s *Ua) RegConsumer(consumer sippy_types.UA, call_id string)
- func (s *Ua) ResetCreditTime(rtime *sippy_time.MonoTime, new_credit_times map[int64]*sippy_time.MonoTime)
- func (s *Ua) ResetOnLocalSdpChange()
- func (s *Ua) ResetOnRemoteSdpChange()
- func (s *Ua) RingCb(rtime *sippy_time.MonoTime, origin string, scode int)
- func (s *Ua) SendUasResponse(t sippy_types.ServerTransaction, scode int, reason string, ...)
- func (s *Ua) SetAuth(auth sippy_header.SipHeader)
- func (s *Ua) SetBranch(branch string)
- func (s *Ua) SetCallId(call_id *sippy_header.SipCallId)
- func (s *Ua) SetClientTransaction(tr sippy_types.ClientTransaction)
- func (s *Ua) SetConnCb(conn_cb sippy_types.OnConnectListener)
- func (s *Ua) SetConnectTs(connect_ts *sippy_time.MonoTime)
- func (s *Ua) SetCreditTime(credit_time time.Duration)
- func (s *Ua) SetDeadCb(dead_cb sippy_types.OnDeadListener)
- func (s *Ua) SetDiscCb(disc_cb sippy_types.OnDisconnectListener)
- func (s *Ua) SetDisconnectTs(ts *sippy_time.MonoTime)
- func (s *Ua) SetDlgHeaders(hdrs []sippy_header.SipHeader)
- func (s *Ua) SetExMtime(t *sippy_time.MonoTime)
- func (s *Ua) SetExpireStartsOnSetup(v bool)
- func (s *Ua) SetExpireTime(expire_time time.Duration)
- func (s *Ua) SetExtraHeaders(extra_headers []sippy_header.SipHeader)
- func (s *Ua) SetFailCb(fail_cb sippy_types.OnFailureListener)
- func (s *Ua) SetKaInterval(ka time.Duration)
- func (s *Ua) SetLCSeq(cseq int)
- func (s *Ua) SetLContact(contact *sippy_header.SipContact)
- func (s *Ua) SetLSDP(msg sippy_types.MsgBody)
- func (s *Ua) SetLUri(from *sippy_header.SipFrom)
- func (s *Ua) SetLastScode(scode int)
- func (s *Ua) SetLateMedia(late_media bool)
- func (s *Ua) SetLocalUA(ua *sippy_header.SipUserAgent)
- func (s *Ua) SetNoProgressTime(no_progress_time time.Duration)
- func (s *Ua) SetNoReplyTime(no_reply_time time.Duration)
- func (s *Ua) SetNpMtime(t *sippy_time.MonoTime)
- func (s *Ua) SetNrMtime(t *sippy_time.MonoTime)
- func (s *Ua) SetOnLocalSdpChange(on_local_sdp_change sippy_types.OnLocalSdpChange)
- func (s *Ua) SetOnRemoteSdpChange(on_remote_sdp_change sippy_types.OnRemoteSdpChange)
- func (s *Ua) SetOnUacSetupComplete(fn func())
- func (s *Ua) SetOrigin(origin string)
- func (s *Ua) SetOutboundProxy(outbound_proxy *sippy_net.HostPort)
- func (s *Ua) SetP100Ts(ts *sippy_time.MonoTime)
- func (s *Ua) SetP1xxTs(ts *sippy_time.MonoTime)
- func (s *Ua) SetPassword(passwd string)
- func (s *Ua) SetPendingTr(tr sippy_types.ClientTransaction)
- func (s *Ua) SetRAddr(addr *sippy_net.HostPort)
- func (s *Ua) SetRAddr0(addr *sippy_net.HostPort)
- func (s *Ua) SetRSDP(sdp sippy_types.MsgBody)
- func (s *Ua) SetRTarget(url *sippy_header.SipURL)
- func (s *Ua) SetRUri(ruri *sippy_header.SipTo)
- func (s *Ua) SetRoutes(routes []*sippy_header.SipRoute)
- func (s *Ua) SetSetupTs(ts *sippy_time.MonoTime)
- func (s *Ua) SetSourceAddress(addr *sippy_net.HostPort)
- func (s *Ua) SetUasResp(resp sippy_types.SipResponse)
- func (s *Ua) SetUsername(username string)
- func (s *Ua) ShouldUseRefer() bool
- func (s *Ua) StartCreditTimer(rtime *sippy_time.MonoTime)
- func (s *Ua) StartExpireTimer(start *sippy_time.MonoTime)
- func (s *Ua) StartNoProgressTimer()
- func (s *Ua) StartNoReplyTimer()
- func (s *Ua) String() string
- func (s *Ua) UasLossEmul() int
- func (s *Ua) UpdateRouting(resp sippy_types.SipResponse, update_rtarget bool, reverse_routes bool)
- type UaStateConnected
- func (s *UaStateConnected) ID() sippy_types.UaStateID
- func (s UaStateConnected) IsConnected() bool
- func (s *UaStateConnected) OnActivation()
- func (s *UaStateConnected) OnDeactivate()
- func (UaStateConnected) RecvACK(sippy_types.SipRequest)
- func (s UaStateConnected) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s *UaStateConnected) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UaStateConnected) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s *UaStateConnected) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s UaStateConnected) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UaStateConnected) String() string
- type UaStateDead
- func (s *UaStateDead) ID() sippy_types.UaStateID
- func (s UaStateDead) IsConnected() bool
- func (s *UaStateDead) OnActivation()
- func (UaStateDead) OnDeactivate()
- func (UaStateDead) RecvACK(sippy_types.SipRequest)
- func (s UaStateDead) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s UaStateDead) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UaStateDead) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s UaStateDead) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s UaStateDead) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UaStateDead) String() string
- type UaStateDisconnected
- func (s *UaStateDisconnected) ID() sippy_types.UaStateID
- func (s UaStateDisconnected) IsConnected() bool
- func (s *UaStateDisconnected) OnActivation()
- func (UaStateDisconnected) OnDeactivate()
- func (UaStateDisconnected) RecvACK(sippy_types.SipRequest)
- func (s UaStateDisconnected) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s UaStateDisconnected) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UaStateDisconnected) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s *UaStateDisconnected) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s UaStateDisconnected) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UaStateDisconnected) String() string
- type UaStateFailed
- func (s *UaStateFailed) ID() sippy_types.UaStateID
- func (s UaStateFailed) IsConnected() bool
- func (s *UaStateFailed) OnActivation()
- func (UaStateFailed) OnDeactivate()
- func (UaStateFailed) RecvACK(sippy_types.SipRequest)
- func (s UaStateFailed) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s UaStateFailed) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UaStateFailed) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s UaStateFailed) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s UaStateFailed) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UaStateFailed) String() string
- type UacStateCancelling
- func (s *UacStateCancelling) ID() sippy_types.UaStateID
- func (s UacStateCancelling) IsConnected() bool
- func (s *UacStateCancelling) OnActivation()
- func (UacStateCancelling) OnDeactivate()
- func (UacStateCancelling) RecvACK(sippy_types.SipRequest)
- func (s UacStateCancelling) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s UacStateCancelling) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UacStateCancelling) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s UacStateCancelling) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s *UacStateCancelling) RecvResponse(resp sippy_types.SipResponse, tr sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UacStateCancelling) String() string
- type UacStateIdle
- func (s *UacStateIdle) ID() sippy_types.UaStateID
- func (s UacStateIdle) IsConnected() bool
- func (UacStateIdle) OnActivation()
- func (UacStateIdle) OnDeactivate()
- func (UacStateIdle) RecvACK(sippy_types.SipRequest)
- func (s UacStateIdle) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s *UacStateIdle) RecvEvent(_event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UacStateIdle) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s UacStateIdle) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s UacStateIdle) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UacStateIdle) String() string
- type UacStateRinging
- func (s *UacStateRinging) ID() sippy_types.UaStateID
- func (s UacStateRinging) IsConnected() bool
- func (UacStateRinging) OnActivation()
- func (UacStateRinging) OnDeactivate()
- func (UacStateRinging) RecvACK(sippy_types.SipRequest)
- func (s UacStateRinging) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s *UacStateRinging) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UacStateRinging) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s UacStateRinging) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s *UacStateRinging) RecvResponse(resp sippy_types.SipResponse, tr sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UacStateRinging) String() string
- type UacStateTrying
- func (s *UacStateTrying) ID() sippy_types.UaStateID
- func (s UacStateTrying) IsConnected() bool
- func (UacStateTrying) OnActivation()
- func (UacStateTrying) OnDeactivate()
- func (UacStateTrying) RecvACK(sippy_types.SipRequest)
- func (s UacStateTrying) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s *UacStateTrying) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UacStateTrying) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s UacStateTrying) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s *UacStateTrying) RecvResponse(resp sippy_types.SipResponse, tr sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UacStateTrying) String() string
- type UacStateUpdating
- func (s *UacStateUpdating) ID() sippy_types.UaStateID
- func (s UacStateUpdating) IsConnected() bool
- func (UacStateUpdating) OnActivation()
- func (UacStateUpdating) OnDeactivate()
- func (UacStateUpdating) RecvACK(sippy_types.SipRequest)
- func (s UacStateUpdating) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s *UacStateUpdating) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UacStateUpdating) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s *UacStateUpdating) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s *UacStateUpdating) RecvResponse(resp sippy_types.SipResponse, tr sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UacStateUpdating) String() string
- type UasStateIdle
- func (s *UasStateIdle) ID() sippy_types.UaStateID
- func (s UasStateIdle) IsConnected() bool
- func (UasStateIdle) OnActivation()
- func (UasStateIdle) OnDeactivate()
- func (UasStateIdle) RecvACK(sippy_types.SipRequest)
- func (s UasStateIdle) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s UasStateIdle) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UasStateIdle) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s *UasStateIdle) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s UasStateIdle) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UasStateIdle) String() string
- type UasStatePreConnect
- func (s *UasStatePreConnect) ID() sippy_types.UaStateID
- func (s UasStatePreConnect) IsConnected() bool
- func (UasStatePreConnect) OnActivation()
- func (s *UasStatePreConnect) OnDeactivate()
- func (s *UasStatePreConnect) RecvACK(req sippy_types.SipRequest)
- func (s UasStatePreConnect) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s *UasStatePreConnect) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UasStatePreConnect) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s *UasStatePreConnect) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s UasStatePreConnect) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UasStatePreConnect) String() string
- type UasStateRinging
- func (s *UasStateRinging) ID() sippy_types.UaStateID
- func (s UasStateRinging) IsConnected() bool
- func (UasStateRinging) OnActivation()
- func (UasStateRinging) OnDeactivate()
- func (UasStateRinging) RecvACK(sippy_types.SipRequest)
- func (s *UasStateRinging) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s *UasStateRinging) RecvEvent(_event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UasStateRinging) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s *UasStateRinging) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s UasStateRinging) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UasStateRinging) String() string
- type UasStateRingingRel
- func (s UasStateRingingRel) IsConnected() bool
- func (UasStateRingingRel) OnActivation()
- func (UasStateRingingRel) OnDeactivate()
- func (UasStateRingingRel) RecvACK(sippy_types.SipRequest)
- func (s *UasStateRingingRel) RecvEvent(_event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s *UasStateRingingRel) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s UasStateRingingRel) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
- type UasStateTrying
- func (s *UasStateTrying) ID() sippy_types.UaStateID
- func (s UasStateTrying) IsConnected() bool
- func (UasStateTrying) OnActivation()
- func (UasStateTrying) OnDeactivate()
- func (UasStateTrying) RecvACK(sippy_types.SipRequest)
- func (s *UasStateTrying) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
- func (s *UasStateTrying) RecvEvent(_event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UasStateTrying) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s UasStateTrying) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s UasStateTrying) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UasStateTrying) String() string
- type UasStateUpdating
- func (s *UasStateUpdating) ID() sippy_types.UaStateID
- func (s UasStateUpdating) IsConnected() bool
- func (UasStateUpdating) OnActivation()
- func (UasStateUpdating) OnDeactivate()
- func (UasStateUpdating) RecvACK(sippy_types.SipRequest)
- func (s *UasStateUpdating) RecvCancel(rtime *sippy_time.MonoTime, inreq sippy_types.SipRequest)
- func (s *UasStateUpdating) RecvEvent(_event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
- func (s UasStateUpdating) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
- func (s *UasStateUpdating) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
- func (s UasStateUpdating) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
- func (s *UasStateUpdating) String() string
- type UdpServer
- type UpdateLookupOpts
Constants ¶
const ( TRYING = sip_transaction_state(iota) RINGING COMPLETED CONFIRMED TERMINATED UACK )
Variables ¶
Functions ¶
func NewAsyncReciever ¶
func NewAsyncReciever(userv *UdpServer, logger sippy_log.ErrorLogger) *asyncReceiver
func NewAsyncResolver ¶
func NewAsyncResolver(userv *UdpServer, logger sippy_log.ErrorLogger) *asyncResolver
func NewAsyncSender ¶
func NewClientTransactionObj ¶
func NewClientTransactionObj(req sippy_types.SipRequest, tid *sippy_header.TID, userv sippy_net.Transport, data []byte, sip_tm *sipTransactionManager, resp_receiver sippy_types.ResponseReceiver, session_lock sync.Locker, address *sippy_net.HostPort, eh []sippy_header.SipHeader, req_out_cb func(sippy_types.SipRequest)) (*clientTransaction, error)
func NewDefaultSipTransportFactory ¶
func NewDefaultSipTransportFactory(config sippy_conf.Config) *defaultSipTransportFactory
func NewLocal4Remote ¶
func NewLocal4Remote(config sippy_conf.Config, handleIncoming sippy_net.DataPacketReceiver) (*local4remote, error)
func NewMsgBody ¶
func NewMsgBody(content, mtype string) *msgBody
func NewRtpProxyClient ¶
func NewRtpProxyClient(opts *rtpProxyClientOpts) sippy_types.RtpProxyClient
func NewRtpProxyClientOpts ¶
func NewServerTransaction ¶
func NewSipRequest ¶
func NewSipRequest(method string, ruri *sippy_header.SipURL, sipver string, to *sippy_header.SipTo, from *sippy_header.SipFrom, via *sippy_header.SipVia, cseq int, callid *sippy_header.SipCallId, maxforwards *sippy_header.SipMaxForwards, body sippy_types.MsgBody, contact *sippy_header.SipContact, routes []*sippy_header.SipRoute, target *sippy_net.HostPort, user_agent *sippy_header.SipUserAgent, expires *sippy_header.SipExpires, config sippy_conf.Config) (*sipRequest, error)
func NewSipResponse ¶
func NewSipResponse(scode int, reason, sipver string, from *sippy_header.SipFrom, callid *sippy_header.SipCallId, vias []*sippy_header.SipVia, to *sippy_header.SipTo, cseq *sippy_header.SipCSeq, rrs []*sippy_header.SipRecordRoute, body sippy_types.MsgBody, server *sippy_header.SipServer, config sippy_conf.Config) *sipResponse
func NewSipTransactionManager ¶
func NewSipTransactionManager(config sippy_conf.Config, call_map sippy_types.CallMap) (*sipTransactionManager, error)
func NewStatefulProxy ¶
func NewStatefulProxy(sip_tm sippy_types.SipTransactionManager, destination *sippy_net.HostPort, config sippy_conf.Config) *statefulProxy
func NewUacStateRinging ¶
func NewUacStateRinging(ua sippy_types.UA, config sippy_conf.Config) sippy_types.UaState
func NewUdpServerOpts ¶
func NewUdpServerOpts(laddress *sippy_net.HostPort, data_callback sippy_net.DataPacketReceiver) *udpServerOpts
func ParseSdpBody ¶
func ParseSipHeader ¶
func ParseSipMsg ¶
func ParseSipRequest ¶
func ParseSipResponse ¶
Types ¶
type CCEventConnect ¶
type CCEventConnect struct { CCEventGeneric // contains filtered or unexported fields }
func NewCCEventConnect ¶
func NewCCEventConnect(scode int, scode_reason string, msg_body sippy_types.MsgBody, rtime *sippy_time.MonoTime, origin string, extra_headers ...sippy_header.SipHeader) *CCEventConnect
func (*CCEventConnect) GetBody ¶
func (s *CCEventConnect) GetBody() sippy_types.MsgBody
func (*CCEventConnect) String ¶
func (s *CCEventConnect) String() string
type CCEventDisconnect ¶
type CCEventDisconnect struct { CCEventGeneric // contains filtered or unexported fields }
func NewCCEventDisconnect ¶
func NewCCEventDisconnect(also *sippy_header.SipAddress, rtime *sippy_time.MonoTime, origin string, extra_headers ...sippy_header.SipHeader) *CCEventDisconnect
func (*CCEventDisconnect) GetBody ¶
func (*CCEventDisconnect) GetBody() sippy_types.MsgBody
func (*CCEventDisconnect) GetRedirectURL ¶
func (s *CCEventDisconnect) GetRedirectURL() *sippy_header.SipAddress
func (*CCEventDisconnect) String ¶
func (s *CCEventDisconnect) String() string
type CCEventFail ¶
type CCEventFail struct { CCEventGeneric // contains filtered or unexported fields }
func NewCCEventFail ¶
func NewCCEventFail(scode int, scode_reason string, rtime *sippy_time.MonoTime, origin string, extra_headers ...sippy_header.SipHeader) *CCEventFail
func (*CCEventFail) GetBody ¶
func (*CCEventFail) GetBody() sippy_types.MsgBody
func (*CCEventFail) GetExtraHeaders ¶
func (s *CCEventFail) GetExtraHeaders() []sippy_header.SipHeader
func (*CCEventFail) GetScode ¶
func (s *CCEventFail) GetScode() int
func (*CCEventFail) GetScodeReason ¶
func (s *CCEventFail) GetScodeReason() string
func (*CCEventFail) SetScode ¶
func (s *CCEventFail) SetScode(scode int)
func (*CCEventFail) SetScodeReason ¶
func (s *CCEventFail) SetScodeReason(reason string)
func (*CCEventFail) SetWarning ¶
func (s *CCEventFail) SetWarning(text string)
func (*CCEventFail) String ¶
func (s *CCEventFail) String() string
type CCEventGeneric ¶
type CCEventGeneric struct {
// contains filtered or unexported fields
}
func (*CCEventGeneric) AppendExtraHeader ¶
func (s *CCEventGeneric) AppendExtraHeader(eh sippy_header.SipHeader)
func (*CCEventGeneric) GetExtraHeaders ¶
func (s *CCEventGeneric) GetExtraHeaders() []sippy_header.SipHeader
func (*CCEventGeneric) GetMaxForwards ¶
func (s *CCEventGeneric) GetMaxForwards() *sippy_header.SipMaxForwards
func (*CCEventGeneric) GetOrigin ¶
func (s *CCEventGeneric) GetOrigin() string
func (*CCEventGeneric) GetReason ¶
func (s *CCEventGeneric) GetReason() *sippy_header.SipReason
func (*CCEventGeneric) GetRtime ¶
func (s *CCEventGeneric) GetRtime() *sippy_time.MonoTime
func (*CCEventGeneric) GetSeq ¶
func (s *CCEventGeneric) GetSeq() int64
func (*CCEventGeneric) SetMaxForwards ¶
func (s *CCEventGeneric) SetMaxForwards(max_forwards *sippy_header.SipMaxForwards)
func (*CCEventGeneric) SetReason ¶
func (s *CCEventGeneric) SetReason(sip_reason *sippy_header.SipReason)
type CCEventInfo ¶
type CCEventInfo struct { CCEventGeneric // contains filtered or unexported fields }
func NewCCEventInfo ¶
func NewCCEventInfo(rtime *sippy_time.MonoTime, origin string, msg_body sippy_types.MsgBody, extra_headers ...sippy_header.SipHeader) *CCEventInfo
func (*CCEventInfo) GetBody ¶
func (s *CCEventInfo) GetBody() sippy_types.MsgBody
func (*CCEventInfo) String ¶
func (s *CCEventInfo) String() string
type CCEventPreConnect ¶
type CCEventPreConnect struct { CCEventGeneric // contains filtered or unexported fields }
func NewCCEventPreConnect ¶
func NewCCEventPreConnect(scode int, scode_reason string, body sippy_types.MsgBody, rtime *sippy_time.MonoTime, origin string) *CCEventPreConnect
func (*CCEventPreConnect) GetBody ¶
func (s *CCEventPreConnect) GetBody() sippy_types.MsgBody
func (*CCEventPreConnect) GetScode ¶
func (s *CCEventPreConnect) GetScode() int
func (*CCEventPreConnect) GetScodeReason ¶
func (s *CCEventPreConnect) GetScodeReason() string
func (*CCEventPreConnect) String ¶
func (s *CCEventPreConnect) String() string
type CCEventRedirect ¶
type CCEventRedirect struct { CCEventGeneric // contains filtered or unexported fields }
func NewCCEventRedirect ¶
func NewCCEventRedirect(scode int, scode_reason string, body sippy_types.MsgBody, addrs []*sippy_header.SipAddress, rtime *sippy_time.MonoTime, origin string, extra_headers ...sippy_header.SipHeader) *CCEventRedirect
func (*CCEventRedirect) GetBody ¶
func (*CCEventRedirect) GetBody() sippy_types.MsgBody
func (*CCEventRedirect) GetContacts ¶
func (s *CCEventRedirect) GetContacts() []*sippy_header.SipContact
func (*CCEventRedirect) GetRedirectURL ¶
func (s *CCEventRedirect) GetRedirectURL() *sippy_header.SipAddress
func (*CCEventRedirect) GetRedirectURLs ¶
func (s *CCEventRedirect) GetRedirectURLs() []*sippy_header.SipAddress
func (*CCEventRedirect) SortAddresses ¶
func (s *CCEventRedirect) SortAddresses()
func (*CCEventRedirect) String ¶
func (s *CCEventRedirect) String() string
type CCEventRing ¶
type CCEventRing struct { CCEventGeneric // contains filtered or unexported fields }
func NewCCEventRing ¶
func NewCCEventRing(scode int, scode_reason string, body sippy_types.MsgBody, rtime *sippy_time.MonoTime, origin string) *CCEventRing
func (*CCEventRing) GetBody ¶
func (s *CCEventRing) GetBody() sippy_types.MsgBody
func (*CCEventRing) GetScode ¶
func (s *CCEventRing) GetScode() int
func (*CCEventRing) SetScode ¶
func (s *CCEventRing) SetScode(scode int)
func (*CCEventRing) SetScodeReason ¶
func (s *CCEventRing) SetScodeReason(scode_reason string)
func (*CCEventRing) String ¶
func (s *CCEventRing) String() string
type CCEventTry ¶
type CCEventTry struct { CCEventGeneric // contains filtered or unexported fields }
func NewCCEventTry ¶
func (*CCEventTry) GetBody ¶
func (s *CCEventTry) GetBody() sippy_types.MsgBody
func (*CCEventTry) GetCLD ¶
func (s *CCEventTry) GetCLD() string
func (*CCEventTry) GetCLI ¶
func (s *CCEventTry) GetCLI() string
func (*CCEventTry) GetCallerName ¶
func (s *CCEventTry) GetCallerName() string
func (*CCEventTry) GetSipAuthorizationBody ¶
func (s *CCEventTry) GetSipAuthorizationBody() *sippy_header.SipAuthorizationBody
func (*CCEventTry) GetSipAuthorizationHF ¶
func (s *CCEventTry) GetSipAuthorizationHF() sippy_header.SipAuthorizationHeader
func (*CCEventTry) GetSipCallId ¶
func (s *CCEventTry) GetSipCallId() *sippy_header.SipCallId
func (*CCEventTry) SetRoutes ¶
func (s *CCEventTry) SetRoutes(routes []*sippy_header.SipRoute)
func (*CCEventTry) String ¶
func (s *CCEventTry) String() string
type CCEventUpdate ¶
type CCEventUpdate struct { CCEventGeneric // contains filtered or unexported fields }
func NewCCEventUpdate ¶
func NewCCEventUpdate(rtime *sippy_time.MonoTime, origin string, reason *sippy_header.SipReason, max_forwards *sippy_header.SipMaxForwards, msg_body sippy_types.MsgBody) *CCEventUpdate
func (*CCEventUpdate) GetBody ¶
func (s *CCEventUpdate) GetBody() sippy_types.MsgBody
func (*CCEventUpdate) String ¶
func (s *CCEventUpdate) String() string
type ESipParseException ¶
type ESipParseException struct {
// contains filtered or unexported fields
}
func (*ESipParseException) Error ¶
func (s *ESipParseException) Error() string
type RtpProxyCmd ¶
type RtpProxyCmd struct { Type byte ULOpts *UpdateLookupOpts CommandOpts string CallId string Args string Nretr int }
func NewRtpProxyCmd ¶
func NewRtpProxyCmd(cmd string) (*RtpProxyCmd, error)
func (*RtpProxyCmd) String ¶
func (rpc *RtpProxyCmd) String() string
type Rtp_proxy_client_base ¶
type Rtp_proxy_client_base struct {
// contains filtered or unexported fields
}
func NewRtp_proxy_client_base ¶
func NewRtp_proxy_client_base(heir sippy_types.RtpProxyClient, opts *rtpProxyClientOpts) *Rtp_proxy_client_base
func (*Rtp_proxy_client_base) Address ¶
func (s *Rtp_proxy_client_base) Address() net.Addr
func (*Rtp_proxy_client_base) GetActiveSessions ¶
func (s *Rtp_proxy_client_base) GetActiveSessions() int64
func (*Rtp_proxy_client_base) GetActiveStreams ¶
func (s *Rtp_proxy_client_base) GetActiveStreams() int64
func (*Rtp_proxy_client_base) GetOpts ¶
func (s *Rtp_proxy_client_base) GetOpts() sippy_types.RtpProxyClientOpts
func (*Rtp_proxy_client_base) GetPReceived ¶
func (s *Rtp_proxy_client_base) GetPReceived() int64
func (*Rtp_proxy_client_base) GetPTransmitted ¶
func (s *Rtp_proxy_client_base) GetPTransmitted() int64
func (*Rtp_proxy_client_base) GetProxyAddress ¶
func (s *Rtp_proxy_client_base) GetProxyAddress() string
func (*Rtp_proxy_client_base) GetRtpcDelay ¶
func (s *Rtp_proxy_client_base) GetRtpcDelay() float64
func (*Rtp_proxy_client_base) GetSessionsCreated ¶
func (s *Rtp_proxy_client_base) GetSessionsCreated() int64
func (*Rtp_proxy_client_base) GoOffline ¶
func (s *Rtp_proxy_client_base) GoOffline()
func (*Rtp_proxy_client_base) GoOnline ¶
func (s *Rtp_proxy_client_base) GoOnline()
func (*Rtp_proxy_client_base) IsLocal ¶
func (s *Rtp_proxy_client_base) IsLocal() bool
func (*Rtp_proxy_client_base) IsOnline ¶
func (s *Rtp_proxy_client_base) IsOnline() bool
func (*Rtp_proxy_client_base) IsShutDown ¶
func (s *Rtp_proxy_client_base) IsShutDown() bool
func (*Rtp_proxy_client_base) Reconnect ¶
func (s *Rtp_proxy_client_base) Reconnect(addr net.Addr, bind_addr *sippy_net.HostPort)
func (*Rtp_proxy_client_base) SBindSupported ¶
func (s *Rtp_proxy_client_base) SBindSupported() bool
func (*Rtp_proxy_client_base) SendCommand ¶
func (s *Rtp_proxy_client_base) SendCommand(cmd string, cb func(string))
func (*Rtp_proxy_client_base) Shutdown ¶
func (s *Rtp_proxy_client_base) Shutdown()
func (*Rtp_proxy_client_base) Start ¶
func (s *Rtp_proxy_client_base) Start() error
func (*Rtp_proxy_client_base) TNotSupported ¶
func (s *Rtp_proxy_client_base) TNotSupported() bool
func (*Rtp_proxy_client_base) UpdateActive ¶
func (s *Rtp_proxy_client_base) UpdateActive(active_sessions, sessions_created, active_streams, preceived, ptransmitted int64)
func (*Rtp_proxy_client_base) WdntSupported ¶
func (s *Rtp_proxy_client_base) WdntSupported() bool
type Rtp_proxy_client_stream ¶
type Rtp_proxy_client_stream struct {
// contains filtered or unexported fields
}
type Rtp_proxy_client_udp ¶
type Rtp_proxy_client_udp struct {
// contains filtered or unexported fields
}
type Rtp_proxy_session ¶
type Rtp_proxy_session struct {
// contains filtered or unexported fields
}
func NewRtp_proxy_session ¶
func NewRtp_proxy_session(config sippy_conf.Config, rtp_proxy_clients []sippy_types.RtpProxyClient, call_id, from_tag, to_tag, notify_socket, notify_tag string, session_lock sync.Locker) (*Rtp_proxy_session, error)
func (*Rtp_proxy_session) CallerSessionExists ¶
func (s *Rtp_proxy_session) CallerSessionExists() bool
func (*Rtp_proxy_session) Delete ¶
func (s *Rtp_proxy_session) Delete()
func (*Rtp_proxy_session) GetProxyAddress ¶
func (s *Rtp_proxy_session) GetProxyAddress() (string, error)
func (*Rtp_proxy_session) IsLocal ¶
func (s *Rtp_proxy_session) IsLocal() (bool, error)
func (*Rtp_proxy_session) OnCalleeSdpChange ¶
func (s *Rtp_proxy_session) OnCalleeSdpChange(sdp_body sippy_types.MsgBody, result_callback func(sippy_types.MsgBody)) error
func (*Rtp_proxy_session) OnCallerSdpChange ¶
func (s *Rtp_proxy_session) OnCallerSdpChange(sdp_body sippy_types.MsgBody, result_callback func(sippy_types.MsgBody)) error
func (*Rtp_proxy_session) PlayCaller ¶
func (s *Rtp_proxy_session) PlayCaller(prompt_name string, times int, result_callback func(string), index int)
def version(s, result_callback):
s.send_command("V", s.version_result, result_callback)
def version_result(s, result, result_callback):
result_callback(result)
func (*Rtp_proxy_session) SBindSupported ¶
func (s *Rtp_proxy_session) SBindSupported() (bool, error)
func (*Rtp_proxy_session) SetAfterCallerSdpChange ¶
func (s *Rtp_proxy_session) SetAfterCallerSdpChange(cb func(sippy_types.RtpProxyUpdateResult))
func (*Rtp_proxy_session) SetCalleeLaddress ¶
func (s *Rtp_proxy_session) SetCalleeLaddress(addr string)
func (*Rtp_proxy_session) SetCalleeRaddress ¶
func (s *Rtp_proxy_session) SetCalleeRaddress(addr *sippy_net.HostPort)
func (*Rtp_proxy_session) SetCallerLaddress ¶
func (s *Rtp_proxy_session) SetCallerLaddress(addr string)
func (*Rtp_proxy_session) SetCallerRaddress ¶
func (s *Rtp_proxy_session) SetCallerRaddress(addr *sippy_net.HostPort)
func (*Rtp_proxy_session) SetInsertNortpp ¶
func (s *Rtp_proxy_session) SetInsertNortpp(v bool)
func (*Rtp_proxy_session) StartRecording ¶
func (s *Rtp_proxy_session) StartRecording(rname string, result_callback func(string), index int)
func (*Rtp_proxy_session) StopPlayCaller ¶
func (s *Rtp_proxy_session) StopPlayCaller(result_callback func(string), index int)
func (*Rtp_proxy_session) TNotSupported ¶
func (s *Rtp_proxy_session) TNotSupported() (bool, error)
type RtppStats ¶
type RtppStats struct { Verbose bool // contains filtered or unexported fields }
func NewRtppStats ¶
func (*RtppStats) ParseAndAdd ¶
def __iadd__(s, other):
for sname in s.all_names: aname = s.spookyPrefix + sname s.__dict__[aname] += other.__dict__[aname] return s
type SdpSession ¶
type SdpSession struct {
// contains filtered or unexported fields
}
func NewSdpSession ¶
func NewSdpSession() *SdpSession
func (*SdpSession) FixupVersion ¶
func (s *SdpSession) FixupVersion(body sippy_types.MsgBody) error
type Timeout ¶
type Timeout struct {
// contains filtered or unexported fields
}
func NewInactiveTimeout ¶
func StartTimeout ¶
func StartTimeoutWithSpread ¶
func (*Timeout) SpreadRuns ¶
type Ua ¶
type Ua struct {
// contains filtered or unexported fields
}
func (*Ua) BeforeRequestSent ¶
func (s *Ua) BeforeRequestSent(sippy_types.SipRequest)
func (*Ua) BeforeResponseSent ¶
func (s *Ua) BeforeResponseSent(sippy_types.SipResponse)
func (*Ua) BeginClientTransaction ¶
func (s *Ua) BeginClientTransaction(req sippy_types.SipRequest, tr sippy_types.ClientTransaction)
func (*Ua) BeginNewClientTransaction ¶
func (s *Ua) BeginNewClientTransaction(req sippy_types.SipRequest, resp_receiver sippy_types.ResponseReceiver)
func (*Ua) CancelCreditTimer ¶
func (s *Ua) CancelCreditTimer()
func (*Ua) CancelExpireTimer ¶
func (s *Ua) CancelExpireTimer()
func (*Ua) CancelNoProgressTimer ¶
func (s *Ua) CancelNoProgressTimer()
func (*Ua) CancelNoReplyTimer ¶
func (s *Ua) CancelNoReplyTimer()
func (*Ua) ChangeState ¶
func (s *Ua) ChangeState(newstate sippy_types.UaState, cb func())
func (*Ua) DelayedRemoteSdpUpdate ¶
func (s *Ua) DelayedRemoteSdpUpdate(event sippy_types.CCEvent, remote_sdp_body sippy_types.MsgBody)
func (*Ua) Disconnect ¶
func (*Ua) GenRequest ¶
func (*Ua) GetClientTransaction ¶
func (s *Ua) GetClientTransaction() sippy_types.ClientTransaction
func (*Ua) GetConnectTs ¶
func (s *Ua) GetConnectTs() *sippy_time.MonoTime
func (*Ua) GetController ¶
func (s *Ua) GetController() sippy_types.CallController
func (*Ua) GetDisconnectTs ¶
func (s *Ua) GetDisconnectTs() *sippy_time.MonoTime
func (*Ua) GetDlgHeaders ¶
func (s *Ua) GetDlgHeaders() []sippy_header.SipHeader
func (*Ua) GetExMtime ¶
func (s *Ua) GetExMtime() *sippy_time.MonoTime
func (*Ua) GetExpireTime ¶
func (*Ua) GetExtraHeaders ¶
func (s *Ua) GetExtraHeaders() []sippy_header.SipHeader
func (*Ua) GetGoDeadTimeout ¶
func (*Ua) GetKaInterval ¶
func (*Ua) GetLContact ¶
func (s *Ua) GetLContact() *sippy_header.SipContact
func (*Ua) GetLContacts ¶
func (s *Ua) GetLContacts() []*sippy_header.SipContact
func (*Ua) GetLastScode ¶
func (*Ua) GetLateMedia ¶
func (*Ua) GetLocalUA ¶
func (s *Ua) GetLocalUA() *sippy_header.SipUserAgent
func (*Ua) GetNoProgressTime ¶
func (*Ua) GetNoReplyTime ¶
func (*Ua) GetNpMtime ¶
func (s *Ua) GetNpMtime() *sippy_time.MonoTime
func (*Ua) GetNrMtime ¶
func (s *Ua) GetNrMtime() *sippy_time.MonoTime
func (*Ua) GetOnLocalSdpChange ¶
func (s *Ua) GetOnLocalSdpChange() sippy_types.OnLocalSdpChange
func (*Ua) GetOnRemoteSdpChange ¶
func (s *Ua) GetOnRemoteSdpChange() sippy_types.OnRemoteSdpChange
func (*Ua) GetOutboundProxy ¶
func (s *Ua) GetOutboundProxy() *sippy_net.HostPort
func (*Ua) GetPassAuth ¶
func (*Ua) GetPassword ¶
func (*Ua) GetPendingTr ¶
func (s *Ua) GetPendingTr() sippy_types.ClientTransaction
func (*Ua) GetRTarget ¶
func (s *Ua) GetRTarget() *sippy_header.SipURL
func (*Ua) GetRemoteUA ¶
func (*Ua) GetSessionLock ¶
func (*Ua) GetSetupTs ¶
func (s *Ua) GetSetupTs() *sippy_time.MonoTime
func (*Ua) GetSourceAddress ¶
func (s *Ua) GetSourceAddress() *sippy_net.HostPort
func (*Ua) GetStateName ¶
func (*Ua) GetUasLossEmul ¶
func (*Ua) GetUasResp ¶
func (s *Ua) GetUasResp() sippy_types.SipResponse
func (*Ua) GetUsername ¶
func (*Ua) HasNoProgressTimer ¶
func (*Ua) HasNoReplyTimer ¶
func (*Ua) HasOnLocalSdpChange ¶
func (*Ua) HasOnRemoteSdpChange ¶
func (*Ua) OnEarlyUasDisconnect ¶
func (*Ua) OnLocalSdpChange ¶
func (*Ua) OnReinvite ¶
func (s *Ua) OnReinvite(req sippy_types.SipRequest, event_update sippy_types.CCEvent)
func (*Ua) OnRemoteSdpChange ¶
func (*Ua) OnUacSetupComplete ¶
func (s *Ua) OnUacSetupComplete()
func (*Ua) OnUnregister ¶
func (s *Ua) OnUnregister()
func (*Ua) RecvPRACK ¶
func (s *Ua) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (*Ua) RecvRequest ¶
func (s *Ua) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) *sippy_types.UaContext
func (*Ua) RecvResponse ¶
func (s *Ua) RecvResponse(resp sippy_types.SipResponse, tr sippy_types.ClientTransaction)
func (*Ua) RegConsumer ¶
func (*Ua) ResetCreditTime ¶
func (*Ua) ResetOnLocalSdpChange ¶
func (s *Ua) ResetOnLocalSdpChange()
func (*Ua) ResetOnRemoteSdpChange ¶
func (s *Ua) ResetOnRemoteSdpChange()
func (*Ua) SendUasResponse ¶
func (*Ua) SetClientTransaction ¶
func (s *Ua) SetClientTransaction(tr sippy_types.ClientTransaction)
func (*Ua) SetConnectTs ¶
func (s *Ua) SetConnectTs(connect_ts *sippy_time.MonoTime)
func (*Ua) SetCreditTime ¶
func (*Ua) SetDisconnectTs ¶
func (s *Ua) SetDisconnectTs(ts *sippy_time.MonoTime)
func (*Ua) SetDlgHeaders ¶
func (s *Ua) SetDlgHeaders(hdrs []sippy_header.SipHeader)
func (*Ua) SetExMtime ¶
func (s *Ua) SetExMtime(t *sippy_time.MonoTime)
func (*Ua) SetExpireStartsOnSetup ¶
func (*Ua) SetExpireTime ¶
func (*Ua) SetExtraHeaders ¶
func (s *Ua) SetExtraHeaders(extra_headers []sippy_header.SipHeader)
func (*Ua) SetKaInterval ¶
func (*Ua) SetLContact ¶
func (s *Ua) SetLContact(contact *sippy_header.SipContact)
func (*Ua) SetLastScode ¶
func (*Ua) SetLateMedia ¶
func (*Ua) SetLocalUA ¶
func (s *Ua) SetLocalUA(ua *sippy_header.SipUserAgent)
func (*Ua) SetNoProgressTime ¶
func (*Ua) SetNoReplyTime ¶
func (*Ua) SetNpMtime ¶
func (s *Ua) SetNpMtime(t *sippy_time.MonoTime)
func (*Ua) SetNrMtime ¶
func (s *Ua) SetNrMtime(t *sippy_time.MonoTime)
func (*Ua) SetOnLocalSdpChange ¶
func (s *Ua) SetOnLocalSdpChange(on_local_sdp_change sippy_types.OnLocalSdpChange)
func (*Ua) SetOnRemoteSdpChange ¶
func (s *Ua) SetOnRemoteSdpChange(on_remote_sdp_change sippy_types.OnRemoteSdpChange)
func (*Ua) SetOnUacSetupComplete ¶
func (s *Ua) SetOnUacSetupComplete(fn func())
func (*Ua) SetOutboundProxy ¶
func (s *Ua) SetOutboundProxy(outbound_proxy *sippy_net.HostPort)
func (*Ua) SetPassword ¶
func (*Ua) SetPendingTr ¶
func (s *Ua) SetPendingTr(tr sippy_types.ClientTransaction)
func (*Ua) SetRTarget ¶
func (s *Ua) SetRTarget(url *sippy_header.SipURL)
func (*Ua) SetSetupTs ¶
func (s *Ua) SetSetupTs(ts *sippy_time.MonoTime)
func (*Ua) SetSourceAddress ¶
func (s *Ua) SetSourceAddress(addr *sippy_net.HostPort)
func (*Ua) SetUasResp ¶
func (s *Ua) SetUasResp(resp sippy_types.SipResponse)
func (*Ua) SetUsername ¶
func (*Ua) ShouldUseRefer ¶
func (*Ua) StartCreditTimer ¶
func (s *Ua) StartCreditTimer(rtime *sippy_time.MonoTime)
func (*Ua) StartExpireTimer ¶
func (s *Ua) StartExpireTimer(start *sippy_time.MonoTime)
func (*Ua) StartNoProgressTimer ¶
func (s *Ua) StartNoProgressTimer()
func (*Ua) StartNoReplyTimer ¶
func (s *Ua) StartNoReplyTimer()
func (*Ua) UasLossEmul ¶
func (*Ua) UpdateRouting ¶
type UaStateConnected ¶
type UaStateConnected struct {
// contains filtered or unexported fields
}
func NewUaStateConnected ¶
func NewUaStateConnected(ua sippy_types.UA, config sippy_conf.Config) *UaStateConnected
func (*UaStateConnected) ID ¶
func (s *UaStateConnected) ID() sippy_types.UaStateID
func (UaStateConnected) IsConnected ¶
func (s UaStateConnected) IsConnected() bool
func (*UaStateConnected) OnActivation ¶
func (s *UaStateConnected) OnActivation()
func (*UaStateConnected) OnDeactivate ¶
func (s *UaStateConnected) OnDeactivate()
func (UaStateConnected) RecvCancel ¶
func (s UaStateConnected) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (*UaStateConnected) RecvEvent ¶
func (s *UaStateConnected) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UaStateConnected) RecvPRACK ¶
func (s UaStateConnected) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (*UaStateConnected) RecvRequest ¶
func (s *UaStateConnected) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (UaStateConnected) RecvResponse ¶
func (s UaStateConnected) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UaStateConnected) String ¶
func (s *UaStateConnected) String() string
type UaStateDead ¶
type UaStateDead struct {
// contains filtered or unexported fields
}
func NewUaStateDead ¶
func NewUaStateDead(ua sippy_types.UA, config sippy_conf.Config) *UaStateDead
func (*UaStateDead) ID ¶
func (s *UaStateDead) ID() sippy_types.UaStateID
func (UaStateDead) IsConnected ¶
func (s UaStateDead) IsConnected() bool
func (*UaStateDead) OnActivation ¶
func (s *UaStateDead) OnActivation()
func (UaStateDead) OnDeactivate ¶
func (UaStateDead) OnDeactivate()
func (UaStateDead) RecvCancel ¶
func (s UaStateDead) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (UaStateDead) RecvEvent ¶
func (s UaStateDead) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UaStateDead) RecvPRACK ¶
func (s UaStateDead) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (UaStateDead) RecvRequest ¶
func (s UaStateDead) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (UaStateDead) RecvResponse ¶
func (s UaStateDead) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UaStateDead) String ¶
func (s *UaStateDead) String() string
type UaStateDisconnected ¶
type UaStateDisconnected struct {
// contains filtered or unexported fields
}
func NewUaStateDisconnected ¶
func NewUaStateDisconnected(ua sippy_types.UA, config sippy_conf.Config) *UaStateDisconnected
func (*UaStateDisconnected) ID ¶
func (s *UaStateDisconnected) ID() sippy_types.UaStateID
func (UaStateDisconnected) IsConnected ¶
func (s UaStateDisconnected) IsConnected() bool
func (*UaStateDisconnected) OnActivation ¶
func (s *UaStateDisconnected) OnActivation()
func (UaStateDisconnected) OnDeactivate ¶
func (UaStateDisconnected) OnDeactivate()
func (UaStateDisconnected) RecvCancel ¶
func (s UaStateDisconnected) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (UaStateDisconnected) RecvEvent ¶
func (s UaStateDisconnected) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UaStateDisconnected) RecvPRACK ¶
func (s UaStateDisconnected) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (*UaStateDisconnected) RecvRequest ¶
func (s *UaStateDisconnected) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (UaStateDisconnected) RecvResponse ¶
func (s UaStateDisconnected) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UaStateDisconnected) String ¶
func (s *UaStateDisconnected) String() string
type UaStateFailed ¶
type UaStateFailed struct {
// contains filtered or unexported fields
}
func NewUaStateFailed ¶
func NewUaStateFailed(ua sippy_types.UA, config sippy_conf.Config) *UaStateFailed
func (*UaStateFailed) ID ¶
func (s *UaStateFailed) ID() sippy_types.UaStateID
func (UaStateFailed) IsConnected ¶
func (s UaStateFailed) IsConnected() bool
func (*UaStateFailed) OnActivation ¶
func (s *UaStateFailed) OnActivation()
func (UaStateFailed) OnDeactivate ¶
func (UaStateFailed) OnDeactivate()
func (UaStateFailed) RecvCancel ¶
func (s UaStateFailed) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (UaStateFailed) RecvEvent ¶
func (s UaStateFailed) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UaStateFailed) RecvPRACK ¶
func (s UaStateFailed) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (UaStateFailed) RecvRequest ¶
func (s UaStateFailed) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (UaStateFailed) RecvResponse ¶
func (s UaStateFailed) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UaStateFailed) String ¶
func (s *UaStateFailed) String() string
type UacStateCancelling ¶
type UacStateCancelling struct {
// contains filtered or unexported fields
}
func NewUacStateCancelling ¶
func NewUacStateCancelling(ua sippy_types.UA, config sippy_conf.Config) *UacStateCancelling
func (*UacStateCancelling) ID ¶
func (s *UacStateCancelling) ID() sippy_types.UaStateID
func (UacStateCancelling) IsConnected ¶
func (s UacStateCancelling) IsConnected() bool
func (*UacStateCancelling) OnActivation ¶
func (s *UacStateCancelling) OnActivation()
func (UacStateCancelling) OnDeactivate ¶
func (UacStateCancelling) OnDeactivate()
func (UacStateCancelling) RecvCancel ¶
func (s UacStateCancelling) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (UacStateCancelling) RecvEvent ¶
func (s UacStateCancelling) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UacStateCancelling) RecvPRACK ¶
func (s UacStateCancelling) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (UacStateCancelling) RecvRequest ¶
func (s UacStateCancelling) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (*UacStateCancelling) RecvResponse ¶
func (s *UacStateCancelling) RecvResponse(resp sippy_types.SipResponse, tr sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UacStateCancelling) String ¶
func (s *UacStateCancelling) String() string
type UacStateIdle ¶
type UacStateIdle struct {
// contains filtered or unexported fields
}
func NewUacStateIdle ¶
func NewUacStateIdle(ua sippy_types.UA, config sippy_conf.Config) *UacStateIdle
func (*UacStateIdle) ID ¶
func (s *UacStateIdle) ID() sippy_types.UaStateID
func (UacStateIdle) IsConnected ¶
func (s UacStateIdle) IsConnected() bool
func (UacStateIdle) OnActivation ¶
func (UacStateIdle) OnActivation()
func (UacStateIdle) OnDeactivate ¶
func (UacStateIdle) OnDeactivate()
func (UacStateIdle) RecvCancel ¶
func (s UacStateIdle) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (*UacStateIdle) RecvEvent ¶
func (s *UacStateIdle) RecvEvent(_event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UacStateIdle) RecvPRACK ¶
func (s UacStateIdle) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (UacStateIdle) RecvRequest ¶
func (s UacStateIdle) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (UacStateIdle) RecvResponse ¶
func (s UacStateIdle) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UacStateIdle) String ¶
func (s *UacStateIdle) String() string
type UacStateRinging ¶
type UacStateRinging struct {
// contains filtered or unexported fields
}
func (*UacStateRinging) ID ¶
func (s *UacStateRinging) ID() sippy_types.UaStateID
func (UacStateRinging) IsConnected ¶
func (s UacStateRinging) IsConnected() bool
func (UacStateRinging) OnActivation ¶
func (UacStateRinging) OnActivation()
func (UacStateRinging) OnDeactivate ¶
func (UacStateRinging) OnDeactivate()
func (UacStateRinging) RecvCancel ¶
func (s UacStateRinging) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (*UacStateRinging) RecvEvent ¶
func (s *UacStateRinging) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UacStateRinging) RecvPRACK ¶
func (s UacStateRinging) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (UacStateRinging) RecvRequest ¶
func (s UacStateRinging) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (*UacStateRinging) RecvResponse ¶
func (s *UacStateRinging) RecvResponse(resp sippy_types.SipResponse, tr sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UacStateRinging) String ¶
func (s *UacStateRinging) String() string
type UacStateTrying ¶
type UacStateTrying struct {
// contains filtered or unexported fields
}
func NewUacStateTrying ¶
func NewUacStateTrying(ua sippy_types.UA, config sippy_conf.Config) *UacStateTrying
func (*UacStateTrying) ID ¶
func (s *UacStateTrying) ID() sippy_types.UaStateID
func (UacStateTrying) IsConnected ¶
func (s UacStateTrying) IsConnected() bool
func (UacStateTrying) OnActivation ¶
func (UacStateTrying) OnActivation()
func (UacStateTrying) OnDeactivate ¶
func (UacStateTrying) OnDeactivate()
func (UacStateTrying) RecvCancel ¶
func (s UacStateTrying) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (*UacStateTrying) RecvEvent ¶
func (s *UacStateTrying) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UacStateTrying) RecvPRACK ¶
func (s UacStateTrying) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (UacStateTrying) RecvRequest ¶
func (s UacStateTrying) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (*UacStateTrying) RecvResponse ¶
func (s *UacStateTrying) RecvResponse(resp sippy_types.SipResponse, tr sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UacStateTrying) String ¶
func (s *UacStateTrying) String() string
type UacStateUpdating ¶
type UacStateUpdating struct {
// contains filtered or unexported fields
}
func NewUacStateUpdating ¶
func NewUacStateUpdating(ua sippy_types.UA, config sippy_conf.Config) *UacStateUpdating
func (*UacStateUpdating) ID ¶
func (s *UacStateUpdating) ID() sippy_types.UaStateID
func (UacStateUpdating) IsConnected ¶
func (s UacStateUpdating) IsConnected() bool
func (UacStateUpdating) OnActivation ¶
func (UacStateUpdating) OnActivation()
func (UacStateUpdating) OnDeactivate ¶
func (UacStateUpdating) OnDeactivate()
func (UacStateUpdating) RecvCancel ¶
func (s UacStateUpdating) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (*UacStateUpdating) RecvEvent ¶
func (s *UacStateUpdating) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UacStateUpdating) RecvPRACK ¶
func (s UacStateUpdating) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (*UacStateUpdating) RecvRequest ¶
func (s *UacStateUpdating) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (*UacStateUpdating) RecvResponse ¶
func (s *UacStateUpdating) RecvResponse(resp sippy_types.SipResponse, tr sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UacStateUpdating) String ¶
func (s *UacStateUpdating) String() string
type UasStateIdle ¶
type UasStateIdle struct {
// contains filtered or unexported fields
}
func NewUasStateIdle ¶
func NewUasStateIdle(ua sippy_types.UA, config sippy_conf.Config) *UasStateIdle
func (*UasStateIdle) ID ¶
func (s *UasStateIdle) ID() sippy_types.UaStateID
func (UasStateIdle) IsConnected ¶
func (s UasStateIdle) IsConnected() bool
func (UasStateIdle) OnActivation ¶
func (UasStateIdle) OnActivation()
func (UasStateIdle) OnDeactivate ¶
func (UasStateIdle) OnDeactivate()
func (UasStateIdle) RecvCancel ¶
func (s UasStateIdle) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (UasStateIdle) RecvEvent ¶
func (s UasStateIdle) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UasStateIdle) RecvPRACK ¶
func (s UasStateIdle) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (*UasStateIdle) RecvRequest ¶
func (s *UasStateIdle) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (UasStateIdle) RecvResponse ¶
func (s UasStateIdle) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UasStateIdle) String ¶
func (s *UasStateIdle) String() string
type UasStatePreConnect ¶
type UasStatePreConnect struct {
// contains filtered or unexported fields
}
func NewUasStatePreConnect ¶
func NewUasStatePreConnect(ua sippy_types.UA, config sippy_conf.Config, confirm_connect bool) *UasStatePreConnect
func (*UasStatePreConnect) ID ¶
func (s *UasStatePreConnect) ID() sippy_types.UaStateID
func (UasStatePreConnect) IsConnected ¶
func (s UasStatePreConnect) IsConnected() bool
func (UasStatePreConnect) OnActivation ¶
func (UasStatePreConnect) OnActivation()
func (*UasStatePreConnect) OnDeactivate ¶
func (s *UasStatePreConnect) OnDeactivate()
func (*UasStatePreConnect) RecvACK ¶
func (s *UasStatePreConnect) RecvACK(req sippy_types.SipRequest)
func (UasStatePreConnect) RecvCancel ¶
func (s UasStatePreConnect) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (*UasStatePreConnect) RecvEvent ¶
func (s *UasStatePreConnect) RecvEvent(event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UasStatePreConnect) RecvPRACK ¶
func (s UasStatePreConnect) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (*UasStatePreConnect) RecvRequest ¶
func (s *UasStatePreConnect) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (UasStatePreConnect) RecvResponse ¶
func (s UasStatePreConnect) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UasStatePreConnect) String ¶
func (s *UasStatePreConnect) String() string
type UasStateRinging ¶
type UasStateRinging struct {
// contains filtered or unexported fields
}
func NewUasStateRinging ¶
func NewUasStateRinging(ua sippy_types.UA, config sippy_conf.Config) *UasStateRinging
func (*UasStateRinging) ID ¶
func (s *UasStateRinging) ID() sippy_types.UaStateID
func (UasStateRinging) IsConnected ¶
func (s UasStateRinging) IsConnected() bool
func (UasStateRinging) OnActivation ¶
func (UasStateRinging) OnActivation()
func (UasStateRinging) OnDeactivate ¶
func (UasStateRinging) OnDeactivate()
func (*UasStateRinging) RecvCancel ¶
func (s *UasStateRinging) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (*UasStateRinging) RecvEvent ¶
func (s *UasStateRinging) RecvEvent(_event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UasStateRinging) RecvPRACK ¶
func (s UasStateRinging) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (*UasStateRinging) RecvRequest ¶
func (s *UasStateRinging) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (UasStateRinging) RecvResponse ¶
func (s UasStateRinging) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UasStateRinging) String ¶
func (s *UasStateRinging) String() string
type UasStateRingingRel ¶
type UasStateRingingRel struct { *UasStateRinging // contains filtered or unexported fields }
func NewUasStateRingingRel ¶
func NewUasStateRingingRel(ua sippy_types.UA, config sippy_conf.Config) *UasStateRingingRel
func (UasStateRingingRel) IsConnected ¶
func (s UasStateRingingRel) IsConnected() bool
func (UasStateRingingRel) OnActivation ¶
func (UasStateRingingRel) OnActivation()
func (UasStateRingingRel) OnDeactivate ¶
func (UasStateRingingRel) OnDeactivate()
func (*UasStateRingingRel) RecvEvent ¶
func (s *UasStateRingingRel) RecvEvent(_event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (*UasStateRingingRel) RecvPRACK ¶
func (s *UasStateRingingRel) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (UasStateRingingRel) RecvResponse ¶
func (s UasStateRingingRel) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
type UasStateTrying ¶
type UasStateTrying struct {
// contains filtered or unexported fields
}
func NewUasStateTrying ¶
func NewUasStateTrying(ua sippy_types.UA, config sippy_conf.Config) *UasStateTrying
func (*UasStateTrying) ID ¶
func (s *UasStateTrying) ID() sippy_types.UaStateID
func (UasStateTrying) IsConnected ¶
func (s UasStateTrying) IsConnected() bool
func (UasStateTrying) OnActivation ¶
func (UasStateTrying) OnActivation()
func (UasStateTrying) OnDeactivate ¶
func (UasStateTrying) OnDeactivate()
func (*UasStateTrying) RecvCancel ¶
func (s *UasStateTrying) RecvCancel(rtime *sippy_time.MonoTime, req sippy_types.SipRequest)
func (*UasStateTrying) RecvEvent ¶
func (s *UasStateTrying) RecvEvent(_event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UasStateTrying) RecvPRACK ¶
func (s UasStateTrying) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (UasStateTrying) RecvRequest ¶
func (s UasStateTrying) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (UasStateTrying) RecvResponse ¶
func (s UasStateTrying) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UasStateTrying) String ¶
func (s *UasStateTrying) String() string
type UasStateUpdating ¶
type UasStateUpdating struct {
// contains filtered or unexported fields
}
func NewUasStateUpdating ¶
func NewUasStateUpdating(ua sippy_types.UA, config sippy_conf.Config) *UasStateUpdating
func (*UasStateUpdating) ID ¶
func (s *UasStateUpdating) ID() sippy_types.UaStateID
func (UasStateUpdating) IsConnected ¶
func (s UasStateUpdating) IsConnected() bool
func (UasStateUpdating) OnActivation ¶
func (UasStateUpdating) OnActivation()
func (UasStateUpdating) OnDeactivate ¶
func (UasStateUpdating) OnDeactivate()
func (*UasStateUpdating) RecvCancel ¶
func (s *UasStateUpdating) RecvCancel(rtime *sippy_time.MonoTime, inreq sippy_types.SipRequest)
func (*UasStateUpdating) RecvEvent ¶
func (s *UasStateUpdating) RecvEvent(_event sippy_types.CCEvent) (sippy_types.UaState, func(), error)
func (UasStateUpdating) RecvPRACK ¶
func (s UasStateUpdating) RecvPRACK(req sippy_types.SipRequest, resp sippy_types.SipResponse)
func (*UasStateUpdating) RecvRequest ¶
func (s *UasStateUpdating) RecvRequest(req sippy_types.SipRequest, t sippy_types.ServerTransaction) (sippy_types.UaState, func())
func (UasStateUpdating) RecvResponse ¶
func (s UasStateUpdating) RecvResponse(resp sippy_types.SipResponse, t sippy_types.ClientTransaction) (sippy_types.UaState, func())
func (*UasStateUpdating) String ¶
func (s *UasStateUpdating) String() string
type UdpServer ¶
type UdpServer struct {
// contains filtered or unexported fields
}
func NewUdpServer ¶
func (*UdpServer) GetLAddress ¶
func (s *UdpServer) GetLAddress() *sippy_net.HostPort
func (*UdpServer) SendToWithCb ¶
type UpdateLookupOpts ¶
type UpdateLookupOpts struct { DestinationIP string LocalIP string Codecs []string OtherParams string RemoteIP string RemotePort string FromTag string ToTag string NotifySocket string NotifyTag string }
func NewUpdateLookupOpts ¶
func NewUpdateLookupOpts(s, args string) (*UpdateLookupOpts, error)
Source Files ¶
- base_transaction.go
- cc_event_redirect.go
- cc_events.go
- client_transaction.go
- default_sip_transport.go
- esip_parse_exception.go
- keepalive_controller.go
- local4remote.go
- msg_body.go
- redirect_controller.go
- rtp_proxy_client.go
- rtp_proxy_client_opts.go
- rtp_proxy_client_stream.go
- rtp_proxy_client_udp.go
- rtp_proxy_cmd.go
- rtp_proxy_session.go
- rtpps_side.go
- sdp_body.go
- sdp_session.go
- server_transaction.go
- sip_header.go
- sip_msg.go
- sip_request.go
- sip_response.go
- sip_transaction_manager.go
- stateful_proxy.go
- timeout.go
- ua.go
- ua_state_connected.go
- ua_state_dead.go
- ua_state_disconnected.go
- ua_state_failed.go
- ua_state_generic.go
- uac_state_cancelling.go
- uac_state_idle.go
- uac_state_ringing.go
- uac_state_trying.go
- uac_state_updating.go
- uas_state_idle.go
- uas_state_preconnect.go
- uas_state_ringing.go
- uas_state_ringing_rel.go
- uas_state_trying.go
- uas_state_updating.go
- udp_server.go
Directories ¶
Path | Synopsis |
---|---|
Package sippy_container Copyright (c) 2015 Andrii Pylypenko.
|
Package sippy_container Copyright (c) 2015 Andrii Pylypenko. |
Package sippy_header Copyright (c) 2015 Andrii Pylypenko.
|
Package sippy_header Copyright (c) 2015 Andrii Pylypenko. |