add websocket client stress test, passed and update the vendors (this…

… commit fixes the #1178 and #1173)

_examples/websocket/go-client-stress-test/client/main.go

@@ -0,0 +1,85 @@
+package main
+
+import (
+	"bufio"
+	"fmt"
+	"math/rand"
+	"os"
+	"sync"
+	"time"
+
+	"github.com/kataras/iris/websocket"
+)
+
+var (
+	url = "ws://localhost:8080/socket"
+	f   *os.File
+)
+
+const totalClients = 1200
+
+func main() {
+	var err error
+	f, err = os.Open("./test.data")
+	if err != nil {
+		panic(err)
+	}
+	defer f.Close()
+
+	wg := new(sync.WaitGroup)
+	for i := 0; i < totalClients/2; i++ {
+		wg.Add(1)
+		go connect(wg, 5*time.Second)
+	}
+
+	for i := 0; i < totalClients/2; i++ {
+		wg.Add(1)
+		waitTime := time.Duration(rand.Intn(10)) * time.Millisecond
+		time.Sleep(waitTime)
+		go connect(wg, 10*time.Second+waitTime)
+	}
+
+	wg.Wait()
+	fmt.Println("ALL OK.")
+	time.Sleep(5 * time.Second)
+}
+
+func connect(wg *sync.WaitGroup, alive time.Duration) {
+
+	c, err := websocket.Dial(url, websocket.ConnectionConfig{})
+	if err != nil {
+		panic(err)
+	}
+
+	c.OnError(func(err error) {
+		fmt.Printf("error: %v", err)
+	})
+
+	disconnected := false
+	c.OnDisconnect(func() {
+		fmt.Printf("I am disconnected after [%s].\n", alive)
+		disconnected = true
+	})
+
+	c.On("chat", func(message string) {
+		fmt.Printf("\n%s\n", message)
+	})
+
+	go func() {
+		time.Sleep(alive)
+		if err := c.Disconnect(); err != nil {
+			panic(err)
+		}
+
+		wg.Done()
+	}()
+
+	scanner := bufio.NewScanner(f)
+	for !disconnected {
+		if !scanner.Scan() || scanner.Err() != nil {
+			break
+		}
+
+		c.Emit("chat", scanner.Text())
+	}
+}

_examples/websocket/go-client-stress-test/client/test.data

@@ -0,0 +1,19 @@
+Σκουπίζει τη τι αρματωσιά ευρυδίκης κι αποδεχθεί αν εχτύπεσεν. Οι το ζητούσε δεκτικό αφήσουν μπράτσο βλ απ. Φυγή τι έτσι εκ πλάι αυτή θεός ας αδάμ. Αποβαίνει να τι βλ κατάγεται γεγονότος. Μπουφάν ξάπλωσε σχέσεις βλ ας να να. Υποδηλώσει τα τι κι σιδερένιων εξελικτική ως συγκράτησε παιγνιώδης. Προφανώς μου μία σύγχρονο ιστορίας. 
+
+Νερά ψηλά λύπη αφτί ας ψυχή τι λόγω. Του φίλ διά γεφυρώνει ανίχνευση διεύρυνση. Όλο μήπως τομέα πρώτο στους δις νόημα εάν του. Παιδείας ομορφιάς καλύτερα ας με. Παραγωγή προθέαση σε κουλιζάρ παραπάνω υπ. Πώς δικούς στήθος πόντου πως θέατρο θέληση σίδερο. Σιδερένια διηγήσεων ναι δύο επέμβασης καθ ώρα ιδιαίτερα βεβαιώνει θεωρείται. Βλ νερο τη να ύλης μτφρ τέλη. Ας ρόλων τη χώρων υπ αφορά είδος είπεν. 
+
+Ου πάρκαρε παιδικό μάλιστα ιι. Σκοτωθεί απαγωγής ανάλυσης άνθρωποι ιι τραγικού οι. Αναπνοή επέλεξα πομπούς εφ δράσεις να. Νε υλικό ας ως ευρήκ νόρμα ου. Ιι εμάζεψα δεύτερη αλλαγές ατ τα σύζευξη επίπεδο. Συγγραφέα νεότερους κατέγραψε ζωή διά υφολογική. Που απέσ νου στον άρα είδη σούκ νικά ήρωά. Το κανένα τι ιι γωνίας να δεσμός. 
+
+Ροή ρευστότητα στο έλα παραμυθιού διαδικασία ειδυλλιακή. Ελλάδας σύμβαση δε με πομπούς εμφανής. Ατ ως εποχή τρόπο εβγάλ αυτές πεδίο γωνία. Των άνθρωπος μπανιέρα ροζ υφίστατο φίλ. Εδώ ροζ πήρε τύπο πια μην δική. Έζησαν μάλλον ως με δε τρόπου. Παράλληλη από αδιόρατης επισκίασε άρα rites ναι. Πολιτισμού του ειδολογική νέο συνάντησης στα ταυτότητας δημοσίευση. 
+
+Παραλλαγές τόζλουτζας κι ατ συγγραφέας παρωδώντας συνείδησης να. Συν χρειάζεται εξελικτική συνιστώσες αναβόσβησε παιγνιώδης έξω εμφανίζουν. Περίτεχνο κοινωνίας ρου του ηθελημένα την σύγχρονων ζώγ. Συν στα υποτίθεται εις ανακάλυψης νέο κατασκευές. Τεκμήρια επίλογοι περίοδος σου εξω στα αγγελίες ποικίλες. Γι παραμένει συμβάντος ακολούθως δε κι να υπόστρωμα. Τη θάρρος θεϊκού να μικρές αηδίες σοφίας πρέπει. Γιατί ευρήκ σοφία αίσια και όνομά για επικό την. Έστειλεν οι σύνδρομο αληθινής κι με εξυπνάδα υπέδειξε αδειάσει. 
+
+Πω δε φοβηθώ ας σε μιχάλη ακουσε όμορφα εφόδιο. Ελέγχοντας διαχείριση όλα αναπαράγει συν στα εάν. Κεί τραγουδιών μαθητεύσει την επισημάνει οικολογικά παραμυθικό ζέη στο. Λαϊκού ατότες εξω μια την ακούμε. Δεδομένου ας τα αγαπημένο παρουσίας διαθέσεων αν. Αντίστροφα ρεαλιστικό περιπέτεια διαδικασία άρα ατο ημερολόγια. 
+
+Άντλησης νεόφερτο μοναδικό εκ ιι δυναμική μηνύματα. Συγγραφική προ έξω την περιπέτεια εγχειρίδια μαθητεύσει εκφέρονται. Εάν δεν μαρί άρα ήχοι ατο κόρη. Εν ας επομένως κινήματα άνθρωποι. Ου δάσος τι υπ γιατί πόνος όποια αυτός. Δεύτερη δέχεται το χρονικά αχιλλέα μη. Τα απαγωγή ου ακριβώς θηλάσει. Οι παραγωγή τα παιγνίδι απ παιδικών τρομάξει. 
+
+Ιστορικά ανθρώπου οπλιστεί εκκίνηση στα μερ χάσματος αργότερα. Κοινωνία επιδίωξη κοιμάται πια πειστική διά πιο απ΄. Εκ οι εύκολα γονείς σύζυγο κι πολλοί με φυσερά. Εκ τα μέτωπο το κύματα δηλαδή όμορφα φανερό πράγμα. Νωρίτερα ομορφιάς διαμέσου ζώγ ανέδειξε υπό πρόσμιξη. Επιδιώκει τις όλη μια βεβαιώνει μελετηθεί μία. Παρατηρεί υιοθετούν ροή ανθρώπινη τον επέστρεψε κατασκευή πια. 
+
+Αναπνοή επί νυχτικά εις σηκώνει τράβηξε γερανού χάλκενα. Αν αδειάσει ποικίλες νε δυναμικό. Όπως δύο αυτό ένα δέβα αυτο από νέοι πάλι. Έως υποβάλλουν αποτέλεσμα εξω σην συγχρονική μεσημεριού. Όλα νέο νου εναντίον σκέπαζαν τον διδάσκει σπουδαίο. Ακόμη πι ως έργου σοφοί δε τα. Σώματος απόλυτα εν τέτοιες διάφορα ατ πι τι. Ως ατ κοινού έμαθες πλάκες. Τα τη συνοχή έκρυβε οποίος σταθεί παίκτη. 
+
+Με σύγχρονης βρίσκεται αποτέλεσε πα τα ελληνικής. Ανακοίνωσή τις στο ουσιαστικό πολλαπλούς τις φιλολογική σου. Φιλολογική να κι κι μορφολογία μυθοπλασία πω. Τυχόν βαθιά ου λόγια έχουν να. Μικρούς έχοντας με χαμένης τη μη. Μοντέλα συνήθως επί θεωρίες χρονικά όλα χάλκενα. Διήγημα θεωρίας ατ βαγγέλη βλ νε αρ ευτελής μαγείας. 

_examples/websocket/go-client-stress-test/server/main.go

@@ -0,0 +1,64 @@
+package main
+
+import (
+	"fmt"
+	"os"
+	"sync/atomic"
+	"time"
+
+	"github.com/kataras/iris"
+	"github.com/kataras/iris/websocket"
+)
+
+const totalClients = 1200
+
+func main() {
+	app := iris.New()
+
+	// websocket.Config{PingPeriod: ((60 * time.Second) * 9) / 10}
+	ws := websocket.New(websocket.Config{})
+	ws.OnConnection(handleConnection)
+	app.Get("/socket", ws.Handler())
+
+	go func() {
+		t := time.NewTicker(2 * time.Second)
+		for {
+			<-t.C
+
+			conns := ws.GetConnections()
+			for _, conn := range conns {
+				// fmt.Println(conn.ID())
+				// Do nothing.
+				_ = conn
+			}
+
+			if atomic.LoadUint64(&count) == totalClients {
+				fmt.Println("ALL CLIENTS DISCONNECTED SUCCESSFULLY.")
+				t.Stop()
+				os.Exit(0)
+				return
+			}
+		}
+	}()
+
+	app.Run(iris.Addr(":8080"))
+}
+
+func handleConnection(c websocket.Connection) {
+	c.OnError(func(err error) { handleErr(c, err) })
+	c.OnDisconnect(func() { handleDisconnect(c) })
+	c.On("chat", func(message string) {
+		c.To(websocket.Broadcast).Emit("chat", c.ID()+": "+message)
+	})
+}
+
+var count uint64
+
+func handleDisconnect(c websocket.Connection) {
+	atomic.AddUint64(&count, 1)
+	fmt.Printf("client [%s] disconnected!\n", c.ID())
+}
+
+func handleErr(c websocket.Connection, err error) {
+	fmt.Printf("client [%s] errored: %v\n", c.ID(), err)
+}

_examples/websocket/go-client/client/main.go

@@ -21,6 +21,7 @@ $ go run main.go
 >> hi!
 */
 func main() {
+	// `websocket.DialContext` is also available.
 	c, err := websocket.Dial(url, websocket.ConnectionConfig{})
 	if err != nil {
 		panic(err)

websocket/config.go

@@ -15,16 +15,15 @@ const (
 	DefaultWebsocketWriteTimeout = 0
 	// DefaultWebsocketReadTimeout 0, no timeout
 	DefaultWebsocketReadTimeout = 0
-	// DefaultWebsocketPongTimeout 60 * time.Second
-	DefaultWebsocketPongTimeout = 60 * time.Second
-	// DefaultWebsocketPingPeriod (DefaultPongTimeout * 9) / 10
-	DefaultWebsocketPingPeriod = (DefaultWebsocketPongTimeout * 9) / 10
-	// DefaultWebsocketMaxMessageSize 1024
-	DefaultWebsocketMaxMessageSize = 1024
-	// DefaultWebsocketReadBufferSize 4096
-	DefaultWebsocketReadBufferSize = 4096
-	// DefaultWebsocketWriterBufferSize 4096
-	DefaultWebsocketWriterBufferSize = 4096
+	// DefaultWebsocketPingPeriod is 0 but
+	// could be 10 * time.Second.
+	DefaultWebsocketPingPeriod = 0
+	// DefaultWebsocketMaxMessageSize 0
+	DefaultWebsocketMaxMessageSize = 0
+	// DefaultWebsocketReadBufferSize 0
+	DefaultWebsocketReadBufferSize = 0
+	// DefaultWebsocketWriterBufferSize 0
+	DefaultWebsocketWriterBufferSize = 0
 	// DefaultEvtMessageKey is the default prefix of the underline websocket events
 	// that are being established under the hoods.
 	//
@@ -76,11 +75,9 @@ type Config struct {
 	// 0 means no timeout.
 	// Default value is 0
 	ReadTimeout time.Duration
-	// PongTimeout allowed to read the next pong message from the connection.
-	// Default value is 60 * time.Second
-	PongTimeout time.Duration
-	// PingPeriod send ping messages to the connection within this period. Must be less than PongTimeout.
-	// Default value is 60 *time.Second
+	// PingPeriod send ping messages to the connection repeatedly after this period.
+	// The value should be close to the ReadTimeout to avoid issues.
+	// Default value is 0.
 	PingPeriod time.Duration
 	// MaxMessageSize max message size allowed from connection.
 	// Default value is 1024
@@ -89,12 +86,13 @@ type Config struct {
 	// compatible if you wanna use the Connection's EmitMessage to send a custom binary data to the client, like a native server-client communication.
 	// Default value is false
 	BinaryMessages bool
-	// ReadBufferSize is the buffer size for the connection reader.
-	// Default value is 4096
-	ReadBufferSize int
-	// WriteBufferSize is the buffer size for the connection writer.
-	// Default value is 4096
-	WriteBufferSize int
+	// ReadBufferSize and WriteBufferSize specify I/O buffer sizes. If a buffer
+	// size is zero, then buffers allocated by the HTTP server are used. The
+	// I/O buffer sizes do not limit the size of the messages that can be sent
+	// or received.
+	//
+	// Default value is 0.
+	ReadBufferSize, WriteBufferSize int
 	// EnableCompression specify if the server should attempt to negotiate per
 	// message compression (RFC 7692). Setting this value to true does not
 	// guarantee that compression will be supported. Currently only "no context
@@ -121,10 +119,6 @@ func (c Config) Validate() Config {
 		c.ReadTimeout = DefaultWebsocketReadTimeout
 	}
 
-	if c.PongTimeout < 0 {
-		c.PongTimeout = DefaultWebsocketPongTimeout
-	}
-
 	if c.PingPeriod <= 0 {
 		c.PingPeriod = DefaultWebsocketPingPeriod
 	}