Compare commits
2 Commits
be06681ca7
...
e749e9ab47
Author | SHA1 | Date |
---|---|---|
Johannes Kimmel | e749e9ab47 | |
Johannes Kimmel | d404fb8147 |
30
main.go
30
main.go
|
@ -66,7 +66,7 @@ func (vx *vx46) forward46() error {
|
||||||
for {
|
for {
|
||||||
n, err := vx.pc4.ReadBatch(msgs4[:], 0)
|
n, err := vx.pc4.ReadBatch(msgs4[:], 0)
|
||||||
if n > vx.buffers*3/4 {
|
if n > vx.buffers*3/4 {
|
||||||
log.Printf("forward46: %d in", n)
|
//log.Printf("forward46: %d in", n)
|
||||||
}
|
}
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
@ -75,12 +75,13 @@ func (vx *vx46) forward46() error {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
outn, err := vx.pc6.WriteBatch(msgs6[:n], 0)
|
queue := msgs6[:n]
|
||||||
if err != nil {
|
for len(queue) > 0 {
|
||||||
return err
|
outn, err := vx.pc6.WriteBatch(queue, 0)
|
||||||
}
|
if err != nil {
|
||||||
if outn != n {
|
return err
|
||||||
return fmt.Errorf("Dropped messages. Sent %d of %d.", outn, n)
|
}
|
||||||
|
queue = queue[outn:]
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -125,7 +126,7 @@ func (vx *vx46) forward64() error {
|
||||||
for {
|
for {
|
||||||
n, err := vx.pc6.ReadBatch(msgs6[:], 0)
|
n, err := vx.pc6.ReadBatch(msgs6[:], 0)
|
||||||
if n > vx.buffers*3/4 {
|
if n > vx.buffers*3/4 {
|
||||||
log.Printf("forward64: %d in", n)
|
//log.Printf("forward64: %d in", n)
|
||||||
}
|
}
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
@ -134,12 +135,13 @@ func (vx *vx46) forward64() error {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
outn, err := vx.pc4.WriteBatch(msgs4[:n], 0)
|
queue := msgs4[:n]
|
||||||
if err != nil {
|
for len(queue) > 0 {
|
||||||
return err
|
outn, err := vx.pc4.WriteBatch(queue, 0)
|
||||||
}
|
if err != nil {
|
||||||
if outn != n {
|
return err
|
||||||
return fmt.Errorf("Dropped messages. Sent %d of %d.", outn, n)
|
}
|
||||||
|
queue = queue[outn:]
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue