Created
September 24, 2024 00:54
-
-
Save schmichael/f9691ca8e8d1c0b0c49f5b14abadeea8 to your computer and use it in GitHub Desktop.
Fork of https://gist.github.com/slingamn/1dafab6141e03d27a3f51bcbbcdb9972 that adds a read closer
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package main | |
import ( | |
"bufio" | |
"bytes" | |
"fmt" | |
"log" | |
"net" | |
"strings" | |
"time" | |
"github.com/hashicorp/yamux" | |
) | |
const address = "127.0.0.1:7000" | |
func acceptLoop(listener net.Listener, connChan chan net.Conn) { | |
for { | |
conn, err := listener.Accept() | |
if err != nil { | |
close(connChan) | |
return | |
} | |
connChan <- conn | |
} | |
} | |
func yamuxAcceptLoop(session *yamux.Session) { | |
for { | |
sConn, err := session.Accept() | |
log.Printf("accepted") | |
if err != nil { | |
log.Fatal(err) | |
} | |
go yamuxServe(sConn) | |
} | |
} | |
func yamuxServe(conn net.Conn) { | |
defer conn.Close() | |
r := bufio.NewReader(conn) | |
for { | |
line, err := r.ReadString('\n') | |
if err != nil { | |
log.Printf("server error reading from stream: %v", err) | |
return | |
} | |
line = strings.TrimSpace(line) | |
log.Printf("server received message: `%s`", line) | |
if line == "5" { | |
log.Printf("terminating server side") | |
return | |
} | |
} | |
} | |
func main() { | |
// set up a yamux.Server and yamux.Client connected over loopback TCP: | |
listener, err := net.Listen("tcp", address) | |
if err != nil { | |
log.Fatal(err) | |
} | |
connChan := make(chan net.Conn, 1) | |
go acceptLoop(listener, connChan) | |
clientConn, err := net.Dial("tcp", address) | |
if err != nil { | |
log.Fatal(err) | |
} | |
serverConn, ok := <-connChan | |
if !ok { | |
log.Fatal("could not obtain server connection") | |
} | |
serverSession, err := yamux.Server(serverConn, nil) | |
if err != nil { | |
log.Fatal(err) | |
} | |
clientSession, err := yamux.Client(clientConn, nil) | |
if err != nil { | |
log.Fatal(err) | |
} | |
// run server side (accept some messages, then close the stream): | |
go yamuxAcceptLoop(serverSession) | |
// run client side: send some messages | |
cStream, err := clientSession.Open() | |
if err != nil { | |
log.Fatal(err) | |
} | |
go func() { | |
_, err = cStream.Read([]byte{}) | |
if err != nil { | |
log.Printf("Client.Stream.Read failed: %v", err) | |
cStream.Close() | |
} | |
}() | |
for i := 0; i < 10; i++ { | |
// compose a message to send: | |
// "4 [many spaces to exhaust send window] \n" | |
var message bytes.Buffer | |
fmt.Fprintf(&message, "%d", i) | |
for j := 0; j < 100000; j++ { | |
fmt.Fprintf(&message, " ") | |
} | |
fmt.Fprintf(&message, "\n") | |
log.Printf("writing %d", i) | |
_, err := cStream.Write(message.Bytes()) | |
log.Printf("wrote %d with error %v", i, err) | |
time.Sleep(100 * time.Millisecond) | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment