github/ttrpc
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

channel_test: update oversize message test.

Browse Source 
Co-authored-by: Alessio Cantillo <cantillo.trd@gmail.com>
Co-authored-by: Qian Zhang <cosmoer@qq.com>
Signed-off-by: Krisztian Litkey <krisztian.litkey@intel.com>
This commit is contained in:
Krisztian Litkey 2024-08-21 14:20:27 +03:00
parent de273bf751
commit d8c00dfec3
No known key found for this signature in database
GPG Key ID: 637F2939D50AF85D
1 changed files with 7 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
channel_test.go
View File

@ -89,21 +89,19 @@ func TestReadWriteMessage(t *testing.T) {
func TestMessageOversize(t *testing.T) { func TestMessageOversize(t *testing.T) {
var ( var (
w, r = net.Pipe() w, _ = net.Pipe()
wch, rch = newChannel(w), newChannel(r) wch = newChannel(w)
msg = bytes.Repeat([]byte("a message of massive length"), 512<<10) msg = bytes.Repeat([]byte("a message of massive length"), 512<<10)
errs = make(chan error, 1) errs = make(chan error, 1)
) )
go func() { go func() {
if err := wch.send(1, 1, 0, msg); err != nil { errs <- wch.send(1, 1, 0, msg)
errs <- err
}
}() }()
_, _, err := rch.recv() err := <-errs
if err == nil { if err == nil {
t.Fatalf("error expected reading with small buffer") t.Fatalf("sending oversized message expected to fail")
} }
status, ok := status.FromError(err) status, ok := status.FromError(err)
@ -114,12 +112,4 @@ func TestMessageOversize(t *testing.T) {
if status.Code() != codes.ResourceExhausted { if status.Code() != codes.ResourceExhausted {
t.Fatalf("expected grpc status code: %v != %v", status.Code(), codes.ResourceExhausted) t.Fatalf("expected grpc status code: %v != %v", status.Code(), codes.ResourceExhausted)
} }
select {
case err := <-errs:
if err != nil {
t.Fatal(err)
}
default:
}
} }