Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Rewrite with compression support#163

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to ourterms of service andprivacy statement. We’ll occasionally send you account related emails.

Already on GitHub?Sign in to your account

Merged
nhooyr merged 56 commits intomasterfromcompress
Feb 16, 2020
Merged
Show file tree
Hide file tree
Changes from1 commit
Commits
Show all changes
56 commits
Select commitHold shift + click to select a range
8604dee
Increase TestWASM timeout
nhooyrOct 15, 2019
e55ac18
Document compression API
nhooyrOct 14, 2019
e142e08
Improve compression docs
nhooyrNov 12, 2019
53c1aea
Implement compression extension negotiation
nhooyrNov 12, 2019
2cf6c28
Implement compression writer and reader pooling
nhooyrNov 12, 2019
a01afea
Support x-webkit-deflate-frame extension for Safari
nhooyrNov 12, 2019
531d4fa
Improve general compression API and write docs
nhooyrNov 12, 2019
d0a8049
Rewrite core
nhooyrNov 19, 2019
dd107dd
Update CI
nhooyrNov 28, 2019
6c6b8e9
Cleanup wspb and wsjson
nhooyrNov 28, 2019
6b782a3
Run make fmt
nhooyrNov 28, 2019
989ba2f
Change websocket to WebSocket in docs/errors
nhooyrNov 28, 2019
9f15963
Simplify dial.go
nhooyrNov 28, 2019
120911b
Remove use of math/rand.Init
nhooyrNov 28, 2019
7ad1514
Update README.md comparison
nhooyrNov 29, 2019
746140b
Further improve README
nhooyrNov 29, 2019
43cb01e
Refactor read.go/write.go
nhooyrNov 29, 2019
e8dfe27
Make CI pass
nhooyrNov 29, 2019
f6137f3
Add minor improvements
nhooyrDec 6, 2019
6f6fa43
Refactor autobahn
nhooyrDec 31, 2019
8c87970
Add slidingWindowReader
nhooyrJan 4, 2020
aaf4b45
Up test coverage of accept.go to 100%
nhooyrJan 26, 2020
6b76536
Up dial coverage to 100%
nhooyrJan 30, 2020
0f115ed
Add Go 1.12 support
nhooyrJan 31, 2020
b6b56b7
Both modes seem to work :)
nhooyrFeb 5, 2020
9e32354
Fix randString method in tests
nhooyrFeb 6, 2020
78da35e
Get test with multiple messages working
nhooyrFeb 7, 2020
d092686
Autobahn tests fully pass :)
nhooyrFeb 8, 2020
6975801
Fix race in tests
nhooyrFeb 9, 2020
bbaf469
Fix test step
nhooyrFeb 9, 2020
faadcc9
Simplify tests
nhooyrFeb 9, 2020
3f2589f
Remove quite a bit of slog
nhooyrFeb 9, 2020
b53f306
Get Wasm tests working
nhooyrFeb 9, 2020
69ff675
More tests and fixes
nhooyrFeb 9, 2020
085e671
Get coverage to 85%
nhooyrFeb 9, 2020
51769b3
Add wspb test
nhooyrFeb 9, 2020
670be05
Merge in handshake improvements from master
nhooyrFeb 9, 2020
988b8f2
Merge remote-tracking branch 'origin/master' into compress
nhooyrFeb 9, 2020
3a526d8
Fix bug in closeHandshake
nhooyrFeb 9, 2020
999b812
Fix race in msgReader
nhooyrFeb 9, 2020
4b84d25
Fix a race with c.closed
nhooyrFeb 9, 2020
85f249d
Up timeouts
nhooyrFeb 9, 2020
6b38ebb
Test fixes
nhooyrFeb 9, 2020
6770421
Fix goroutine leak from deadlock when closing
nhooyrFeb 12, 2020
c752365
Make flateThreshold work
nhooyrFeb 12, 2020
0ea9466
Cleanup writeMu and flateThreshold
nhooyrFeb 12, 2020
b33d48c
Minor cleanup
nhooyrFeb 12, 2020
9c5bfab
Simplifications of conn_test.go
nhooyrFeb 13, 2020
3673c2c
Use basic test assertions
nhooyrFeb 13, 2020
c5b0a00
Fix badPing test duration
nhooyrFeb 13, 2020
1c7c14e
Pool sliding windows
nhooyrFeb 13, 2020
503b469
Simplify sliding window API
nhooyrFeb 13, 2020
dff4af3
Add conn benchmark
nhooyrFeb 13, 2020
2377cca
Switch to klauspost/compress
nhooyrFeb 15, 2020
d57b253
Report how efficient compression is in BenchmarkConn
nhooyrFeb 16, 2020
1bc100d
Update docs and random little issues
nhooyrFeb 16, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
PrevPrevious commit
NextNext commit
Fix a race with c.closed
  • Loading branch information
@nhooyr
nhooyr committedFeb 9, 2020
commit4b84d25251ad9be731c0452f93cad4e48a893d6b
2 changes: 1 addition & 1 deletionconn_notjs.go
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -127,9 +127,9 @@ func (c *Conn) close(err error) {
if c.isClosed() {
return
}
c.setCloseErrLocked(err)
close(c.closed)
runtime.SetFinalizer(c, nil)
c.setCloseErrLocked(err)

// Have to close after c.closed is closed to ensure any goroutine that wakes up
// from the connection being closed also sees that c.closed is closed and returns
Expand Down
12 changes: 6 additions & 6 deletionsconn_test.go
View file
Open in desktop
Original file line numberDiff line numberDiff line change
Expand Up@@ -55,7 +55,7 @@ func TestConn(t *testing.T) {
defer c2.Close(websocket.StatusInternalError, "")
defer c1.Close(websocket.StatusInternalError, "")

ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
defer cancel()

echoLoopErr := xsync.Go(func() error {
Expand DownExpand Up@@ -142,7 +142,7 @@ func TestConn(t *testing.T) {
defer c1.Close(websocket.StatusInternalError, "")
defer c2.Close(websocket.StatusInternalError, "")

ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
defer cancel()

c2.CloseRead(ctx)
Expand DownExpand Up@@ -242,7 +242,7 @@ func TestConn(t *testing.T) {
defer c2.Close(websocket.StatusInternalError, "")
defer c1.Close(websocket.StatusInternalError, "")

ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
defer cancel()

n1 := websocket.NetConn(ctx, c1, websocket.MessageBinary)
Expand DownExpand Up@@ -298,7 +298,7 @@ func TestConn(t *testing.T) {
defer c2.Close(websocket.StatusInternalError, "")
defer c1.Close(websocket.StatusInternalError, "")

ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
defer cancel()

n1 := websocket.NetConn(ctx, c1, websocket.MessageBinary)
Expand DownExpand Up@@ -333,7 +333,7 @@ func TestConn(t *testing.T) {
defer c2.Close(websocket.StatusInternalError, "")
defer c1.Close(websocket.StatusInternalError, "")

ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
defer cancel()

echoLoopErr := xsync.Go(func() error {
Expand DownExpand Up@@ -381,7 +381,7 @@ func TestConn(t *testing.T) {
defer c2.Close(websocket.StatusInternalError, "")
defer c1.Close(websocket.StatusInternalError, "")

ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
defer cancel()

echoLoopErr := xsync.Go(func() error {
Expand Down
[8]ページ先頭
©2009-2025 Movatter.jp