defer os.RemoveAll(spool)
nodeOur, err := NewNodeGenerate()
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
ctx := Ctx{
Spool: spool,
Self: nodeOur,
+ SelfId: nodeOur.Id,
Neigh: make(map[NodeId]*Node),
Alias: make(map[string]*NodeId),
LogPath: filepath.Join(spool, "log.log"),
}
our, err := NewNodeGenerate()
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
privates[recipient] = our
ctx.Neigh[*our.Id] = our.Their()
[]byte{123},
1<<15,
); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
}
for _, recipient := range recipients {
if len(dirFiles(rxPath)) == 0 {
continue
}
- ctx.Toss(ctx.Self.Id, DefaultNiceMail-1, false)
+ ctx.Toss(ctx.Self.Id, DefaultNiceMail-1, false, false)
if len(dirFiles(rxPath)) == 0 {
return false
}
ctx.Neigh[*nodeOur.Id].Sendmail = []string{"/bin/sh", "-c", "false"}
- ctx.Toss(ctx.Self.Id, DefaultNiceMail, false)
+ ctx.Toss(ctx.Self.Id, DefaultNiceMail, false, false)
if len(dirFiles(rxPath)) == 0 {
return false
}
"/bin/sh", "-c",
fmt.Sprintf("cat >> %s", filepath.Join(spool, "mbox")),
}
- ctx.Toss(ctx.Self.Id, DefaultNiceMail, false)
+ ctx.Toss(ctx.Self.Id, DefaultNiceMail, false, false)
if len(dirFiles(rxPath)) != 0 {
return false
}
defer os.RemoveAll(spool)
nodeOur, err := NewNodeGenerate()
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
ctx := Ctx{
Spool: spool,
Self: nodeOur,
+ SelfId: nodeOur.Id,
Neigh: make(map[NodeId]*Node),
Alias: make(map[string]*NodeId),
LogPath: filepath.Join(spool, "log.log"),
fileName,
1<<15,
); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
}
rxPath := filepath.Join(spool, ctx.Self.Id.String(), string(TRx))
os.Rename(filepath.Join(spool, ctx.Self.Id.String(), string(TTx)), rxPath)
- ctx.Toss(ctx.Self.Id, DefaultNiceFile, false)
+ ctx.Toss(ctx.Self.Id, DefaultNiceFile, false, false)
if len(dirFiles(rxPath)) == 0 {
return false
}
ctx.Neigh[*nodeOur.Id].Incoming = &incomingPath
- ctx.Toss(ctx.Self.Id, DefaultNiceFile, false)
+ ctx.Toss(ctx.Self.Id, DefaultNiceFile, false, false)
if len(dirFiles(rxPath)) != 0 {
return false
}
defer os.RemoveAll(spool)
nodeOur, err := NewNodeGenerate()
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
ctx := Ctx{
Spool: spool,
Self: nodeOur,
+ SelfId: nodeOur.Id,
Neigh: make(map[NodeId]*Node),
Alias: make(map[string]*NodeId),
LogPath: filepath.Join(spool, "log.log"),
[]byte("doesnotmatter"),
os.FileMode(0600),
); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
incomingPath := filepath.Join(spool, "incoming")
for i := 0; i < files; i++ {
"samefile",
1<<15,
); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
}
rxPath := filepath.Join(spool, ctx.Self.Id.String(), string(TRx))
os.Rename(filepath.Join(spool, ctx.Self.Id.String(), string(TTx)), rxPath)
ctx.Neigh[*nodeOur.Id].Incoming = &incomingPath
- ctx.Toss(ctx.Self.Id, DefaultNiceFile, false)
+ ctx.Toss(ctx.Self.Id, DefaultNiceFile, false, false)
expected := make(map[string]struct{})
expected["samefile"] = struct{}{}
for i := 0; i < files-1; i++ {
defer os.RemoveAll(spool)
nodeOur, err := NewNodeGenerate()
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
ctx := Ctx{
Spool: spool,
Self: nodeOur,
+ SelfId: nodeOur.Id,
Neigh: make(map[NodeId]*Node),
Alias: make(map[string]*NodeId),
LogPath: filepath.Join(spool, "log.log"),
fileName,
1<<15,
); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
}
rxPath := filepath.Join(spool, ctx.Self.Id.String(), string(TRx))
txPath := filepath.Join(spool, ctx.Self.Id.String(), string(TTx))
os.Rename(txPath, rxPath)
os.MkdirAll(txPath, os.FileMode(0700))
- ctx.Toss(ctx.Self.Id, DefaultNiceFreq, false)
+ ctx.Toss(ctx.Self.Id, DefaultNiceFreq, false, false)
if len(dirFiles(txPath)) != 0 || len(dirFiles(rxPath)) == 0 {
return false
}
ctx.Neigh[*nodeOur.Id].Freq = &spool
- ctx.Toss(ctx.Self.Id, DefaultNiceFreq, false)
+ ctx.Toss(ctx.Self.Id, DefaultNiceFreq, false, false)
if len(dirFiles(txPath)) != 0 || len(dirFiles(rxPath)) == 0 {
return false
}
panic(err)
}
}
- ctx.Toss(ctx.Self.Id, DefaultNiceFreq, false)
+ ctx.Toss(ctx.Self.Id, DefaultNiceFreq, false, false)
if len(dirFiles(txPath)) == 0 || len(dirFiles(rxPath)) != 0 {
return false
}
var buf bytes.Buffer
_, _, err := PktEncRead(ctx.Self, ctx.Neigh, job.Fd, &buf)
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
var pkt Pkt
if _, err = xdr.Unmarshal(&buf, &pkt); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
dst := string(pkt.Path[:int(pkt.PathLen)])
if bytes.Compare(buf.Bytes(), files[dst]) != 0 {
defer os.RemoveAll(spool)
nodeOur, err := NewNodeGenerate()
if err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
ctx := Ctx{
Spool: spool,
Self: nodeOur,
+ SelfId: nodeOur.Id,
Neigh: make(map[NodeId]*Node),
Alias: make(map[string]*NodeId),
LogPath: filepath.Join(spool, "log.log"),
bytes.NewReader(data),
&dst,
); err != nil {
- panic(err)
+ t.Error(err)
+ return false
}
checksum := blake2b.Sum256(dst.Bytes())
if err := ioutil.WriteFile(
panic(err)
}
}
- ctx.Toss(ctx.Self.Id, 123, false)
+ ctx.Toss(ctx.Self.Id, 123, false, false)
if len(dirFiles(rxPath)) != 0 {
return false
}