jkimmel
/
vx46
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: jkimmel:be06681ca7c45cb4760d36bea719ab8127ea550d
Branches Tags
jkimmel:master
...
compare: jkimmel:e749e9ab47d1de46b0e8aed5b98fbd2a81e0a1ef
Branches Tags
jkimmel:master

2 Commits
be06681ca7 ... e749e9ab47

Author SHA1 Message Date
Johannes Kimmel e749e9ab47 disable high queue usage, since it hurts small queues 2023-08-23 23:17:09 +02:00
Johannes Kimmel d404fb8147 retry sending remaining message instead of exiting 2023-08-23 23:15:57 +02:00
1 changed files with 16 additions and 14 deletions
Show Stats Expand all files Collapse all files

30
main.go
View File

@ -66,7 +66,7 @@ func (vx *vx46) forward46() error {
for {
n, err := vx.pc4.ReadBatch(msgs4[:], 0)
if n > vx.buffers*3/4 {
log.Printf("forward46: %d in", n)
//log.Printf("forward46: %d in", n)
}
if err != nil {
return err
@ -75,12 +75,13 @@ func (vx *vx46) forward46() error {
if err != nil {
return err
}
outn, err := vx.pc6.WriteBatch(msgs6[:n], 0)
if err != nil {
return err
}
if outn != n {
return fmt.Errorf("Dropped messages. Sent %d of %d.", outn, n)
queue := msgs6[:n]
for len(queue) > 0 {
outn, err := vx.pc6.WriteBatch(queue, 0)
if err != nil {
return err
}
queue = queue[outn:]
}
}
}
@ -125,7 +126,7 @@ func (vx *vx46) forward64() error {
for {
n, err := vx.pc6.ReadBatch(msgs6[:], 0)
if n > vx.buffers*3/4 {
log.Printf("forward64: %d in", n)
//log.Printf("forward64: %d in", n)
}
if err != nil {
return err
@ -134,12 +135,13 @@ func (vx *vx46) forward64() error {
if err != nil {
return err
}
outn, err := vx.pc4.WriteBatch(msgs4[:n], 0)
if err != nil {
return err
}
if outn != n {
return fmt.Errorf("Dropped messages. Sent %d of %d.", outn, n)
queue := msgs4[:n]
for len(queue) > 0 {
outn, err := vx.pc4.WriteBatch(queue, 0)
if err != nil {
return err
}
queue = queue[outn:]
}
}
}