rxRate, txRate int,
onlineDeadline, maxOnlineTime uint,
listOnly bool,
- onlyPkts map[[32]byte]bool) (isGood bool) {
+ onlyPkts map[[32]byte]bool,
+) (isGood bool) {
for _, addr := range addrs {
sds := SDS{"node": node.Id, "addr": addr}
ctx.LogD("call", sds, "dialing")
nonce []byte,
doEncrypt bool,
r io.Reader,
- w io.Writer) (int, error) {
+ w io.Writer,
+) (int, error) {
var blkCtr uint64
ciphCtr := nonce[len(nonce)-8:]
buf := make([]byte, EncBlkSize+aead.Overhead())
nice uint8,
size, padSize int64,
data io.Reader,
- out io.Writer) error {
+ out io.Writer,
+) error {
pubEph, prvEph, err := box.GenerateKey(rand.Reader)
if err != nil {
return err
our *NodeOur,
nodes map[NodeId]*Node,
data io.Reader,
- out io.Writer) (*Node, int64, error) {
+ out io.Writer,
+) (*Node, int64, error) {
var pktEnc PktEnc
_, err := xdr.Unmarshal(data, &pktEnc)
if err != nil {
func (ctx *Ctx) Toss(
nodeId *NodeId,
nice uint8,
- dryRun, doSeen, noFile, noFreq, noExec, noTrns bool) bool {
+ dryRun, doSeen, noFile, noFreq, noExec, noTrns bool,
+) bool {
isBad := false
for job := range ctx.Jobs(nodeId, TRx) {
pktName := filepath.Base(job.Fd.Name())
pkt *Pkt,
nice uint8,
size, minSize int64,
- src io.Reader) (*Node, error) {
+ src io.Reader,
+) (*Node, error) {
tmp, err := ctx.NewTmpFileWHash()
if err != nil {
return nil, err
nice uint8,
srcPath, dstPath string,
minSize int64,
- chunkSize int64) error {
+ chunkSize int64,
+) error {
if dstPath == "" {
if srcPath == "-" {
return errors.New("Must provide destination filename")
handle string,
args []string,
body []byte,
- minSize int64) error {
+ minSize int64,
+) error {
path := make([][]byte, 0, 1+len(args))
path = append(path, []byte(handle))
for _, arg := range args {