anacrolix

package s3storage

import (
	"bytes"
	"crypto/sha1"
	"encoding/hex"
	"errors"
	"fmt"
	"io"
	"log"

anacrolix

#!/bin/bash

set -eu

export IPFS_GATEWAY="${IPFS_GATEWAY:-http://127.0.0.1:8080}"

CACHE_DIR="$(go env GOPATH)/pkg/mod/cache"

basepath() {
    echo "${1##${CACHE_DIR}/download/}"

anacrolix

Keybase proof

I hereby claim:

• I am anacrolix on github.
• I am anacrolix (https://keybase.io/anacrolix) on keybase.
• I have a public key ASAJKwn773yfndSRr376At4mjuwp4QspnAeQlMimAhVXogo

To claim this, I am signing this object:

anacrolix

# this would be called before adding a connection to the connection manager
# (presumably we just completed dial or accept routines to completion)
def before_adding_conn():
  if numconns < highwater:
    return
  # amortize the cost of evicting conns, drop connection count to the low water mark
  for numconns > lowwater:
    if not optimistic_evict():
      force_eviction()

anacrolix

zenground0 [2:07 PM]
The first one is whether a libp2p host will advertise its (pid, multiaddr) mapping in a networks' DHT after constructing the node with a `libp2p.Routing(makeDHT)` option.
Right now this is all we do in the filecoin network and we don't seem to be advertising id,addr records in the dht.
Wondering if we're missing an obvious `provideRouteToMe` call or something like that

anacrolix [2:11 PM]
I’ll have to check, but a typical DHT will routinely reestablish its own presence to nearby peers, and announce itself during bootstraps.
In the context of libp2p, that should include the peer ID and routing information like multiaddrs

zenground0 [2:12 PM]

anacrolix

Prune local tags that don't exist on remote

All "naked" version tags from gx are now prefixed with gx/. The old ones should be removed from local checkouts to avoid repushing. This command removes local tags that don't exist on the remote.

git fetch --prune <remote> '+refs/tags/*:refs/tags/*'

Travis turd template

This template does CI for both gx and go-mod:

anacrolix

dial queue completely ignores backoff errors. dial errors end query in first alpha value connect attempts:

> find_providers QmW1UQYrsBotoorzgBcQ3HVj5RzZUzB6g1vQwnNfUuCVdN 10
14:03:32.639 DEBUG        dht: not connected. dialing. query.go:244
14:03:32.639 DEBUG        dht: not connected. dialing. query.go:244
14:03:32.639 DEBUG        dht: not connected. dialing. query.go:244
14:03:32.675 DEBUG        dht: error connecting: dial backoff query.go:252
14:03:32.675 DEBUG        dht: error connecting: dial backoff query.go:252
14:03:32.675 DEBUG        dht: discarding dialled peer because of error: dial backoff dial_queue.go:325
14:03:32.675 DEBUG        dht: discarding dialled peer because of error: dial backoff dial_queue.go:325

anacrolix

Backlog:

• Run static analysis tools on some repos, like unconvert, staticcheck etc.
• Read about Vuvuzela: https://discuss.libp2p.io/t/vuvuzela-scalable-private-messaging-resistant-to-traffic-analysis/53
• Read and comment on logging: https://docs.google.com/document/d/1aD3vPTTKEiRYhluLrqUpfHG4Q8eqBnnWl0MZKIzkIbE/edit#

Blocked:

• "Functional"/func gauges with OC through Prometheus: census-instrumentation/opencensus-go#1080
• Can't view libp2p sync meeting video: libp2p/team-mgmt#31 (comment)

Now:

anacrolix

macro_rules! handle {
    ($value:expr, $err:ident,$onerr:expr) => {
        match $value {
            Ok(ok) => ok,
            Err($err) => $onerr,
        }
    };
}

anacrolix

        let result = handle!(result, err, {
            error!("error receiving messages: {}", err);
            continue;
        });
        trace!("got message result");
        for msg in result.messages.unwrap_or_default() {
            let body = msg.body.unwrap();
            let _delete = sqs
                .delete_message(rusoto_sqs::DeleteMessageRequest {
                    queue_url: queue_url.to_owned(),