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

retry sending remaining message instead of exiting

This commit is contained in:
Johannes Kimmel 2023-08-23 23:15:57 +02:00
parent be06681ca7
commit d404fb8147
1 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
main.go
View File

@ -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:]
}
}
}
@ -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:]
}
}
}