modelcontextprotocol/go-sdk
Watch
1
0
Fork
You've already forked go-sdk
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

examples/server/distributed: address comment in #380

Browse source 
I failed to push my branch before merging #380. Address one minor
comment from that PR.
This commit is contained in:
Robert Findley 2025-09-03 11:34:39 -04:00 • committed by GitHub
commit c76d991f05
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
examples/server/distributed/main.go
View file

@ -80,7 +80,6 @@ func parent() {
var wg sync.WaitGroup var wg sync.WaitGroup
childURLs := make([]*url.URL, len(ports)) childURLs := make([]*url.URL, len(ports))
for i, port := range ports { for i, port := range ports {
wg.Add(1)
childURL := fmt.Sprintf("http://localhost:%s", port) childURL := fmt.Sprintf("http://localhost:%s", port)
childURLs[i], err = url.Parse(childURL) childURLs[i], err = url.Parse(childURL)
if err != nil { if err != nil {
@ -89,6 +88,8 @@ func parent() {
cmd := exec.CommandContext(ctx, exe, os.Args[1:]...) cmd := exec.CommandContext(ctx, exe, os.Args[1:]...)
cmd.Env = append(os.Environ(), fmt.Sprintf("%s=%s", childPortVar, port)) cmd.Env = append(os.Environ(), fmt.Sprintf("%s=%s", childPortVar, port))
cmd.Stderr = os.Stderr cmd.Stderr = os.Stderr
wg.Add(1)
go func() { go func() {
defer wg.Done() defer wg.Done()
log.Printf("starting child %d at %s", i, childURL) log.Printf("starting child %d at %s", i, childURL)