Compare commits

...

3 Commits

Author SHA1 Message Date
世界
b40f642fa4
Bump version 2025-08-21 09:43:47 +08:00
世界
22782ca6fc
Fix outbound start 2025-08-21 09:41:31 +08:00
世界
1468d83895
Make realityClientConnWrapper replaceable 2025-08-20 16:26:27 +08:00
4 changed files with 21 additions and 9 deletions

View File

@ -56,6 +56,14 @@ func (m *Manager) Start(stage adapter.StartStage) error {
m.started = true
m.stage = stage
if stage == adapter.StartStateStart {
if m.defaultTag != "" && m.defaultOutbound == nil {
defaultEndpoint, loaded := m.endpoint.Get(m.defaultTag)
if !loaded {
m.access.Unlock()
return E.New("default outbound not found: ", m.defaultTag)
}
m.defaultOutbound = defaultEndpoint
}
if m.defaultOutbound == nil {
directOutbound, err := m.defaultOutboundFallback()
if err != nil {
@ -66,14 +74,6 @@ func (m *Manager) Start(stage adapter.StartStage) error {
m.outboundByTag[directOutbound.Tag()] = directOutbound
m.defaultOutbound = directOutbound
}
if m.defaultTag != "" && m.defaultOutbound == nil {
defaultEndpoint, loaded := m.endpoint.Get(m.defaultTag)
if !loaded {
m.access.Unlock()
return E.New("default outbound not found: ", m.defaultTag)
}
m.defaultOutbound = defaultEndpoint
}
outbounds := m.outbounds
m.access.Unlock()
return m.startOutbounds(append(outbounds, common.Map(m.endpoint.Endpoints(), func(it adapter.Endpoint) adapter.Outbound { return it })...))

@ -1 +1 @@
Subproject commit 597c18482f6edc44e0c94b7cc849dd03b2121c45
Subproject commit 24b26130071bd96c660deeecc4931a3e31339681

View File

@ -307,3 +307,11 @@ func (c *realityClientConnWrapper) Upstream() any {
func (c *realityClientConnWrapper) CloseWrite() error {
return c.Close()
}
func (c *realityClientConnWrapper) ReaderReplaceable() bool {
return true
}
func (c *realityClientConnWrapper) WriterReplaceable() bool {
return true
}

View File

@ -2,6 +2,10 @@
icon: material/alert-decagram
---
#### 1.12.3
* Fixes and improvements
#### 1.12.2
* Fixes and improvements