Skip to content

Instantly share code, notes, and snippets.

View bowrocker's full-sized avatar

Jon Anderson bowrocker

  • Fastly
  • Massachusetts
View GitHub Profile
(base) joyentmac12398:manta-rebalancer jonran$ sudo RUST_BACKTRACE=1 cargo test job --no-fail-fast -- --test-threads=1
Finished test [unoptimized + debuginfo] target(s) in 0.69s
Running target/debug/deps/rebalancer_agent-22956bc1022123e6
running 0 tests
test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 6 filtered out
Running target/debug/deps/manager-4d9e50a4a6fb89e1
(base) joyentmac12398:manta-rebalancer jonran$ sudo make test
Password:
RUST_LOG=remora=trace cargo test agenttests
Finished test [unoptimized + debuginfo] target(s) in 1.02s
Running target/debug/deps/rebalancer_agent-22956bc1022123e6
running 6 tests
{"msg":"listening","v":0,"name":"rebalancer","level":30,"time":"2020-06-18T13:23:07.793676-04:00","hostname":"joyentmac12398.local","pid":75329,"build-id":"0.1.0","address":"127.0.0.1:8878"}
{"msg":"rebalancer[ThreadId(22):tokio-runtime-worker-3]: Received assignment a6d94808-f8d0-443d-b80d-cdabb682016f.","v":0,"name":"rebalancer","level":30,"time":"2020-06-18T13:23:07.804909-04:00","hostname":"joyentmac12398.local","pid":75329,"build-id":"0.1.0"}
{"msg":"rebalancer[ThreadId(22):tokio-runtime-worker-3]: Received assignment: RwLock {\n data: Assignment {\n uuid: \"a6d94808-f8d0-443d-b80d-cdabb682016f\",\n stats: AgentAssignmentStats {\n state: Scheduled,\n failed: 0,\n complete: 0,\n total: 1,\
[root@headnode (jonran-dc) /var/tmp]# manta-oneach -s nameservice "echo stat | nc localhost 2181"
=== Output from 09e0c9f9-e833-4796-9e69-0e977172c226 on headnode (nameservice):
Zookeeper version: 3.4.12--1, built on 01/29/2020 08:44 GMT
Clients:
/10.77.77.254:43242[1](queued=1,recved=12,sent=12)
/10.77.77.252:49882[1](queued=1,recved=12,sent=12)
/10.77.77.223:48441[1](queued=1,recved=8,sent=11)
/10.77.77.225:42004[1](queued=1,recved=38,sent=38)
/10.77.77.253:51016[1](queued=1,recved=12,sent=12)
/127.0.0.1:37002[1](queued=1,recved=126,sent=135)
[root@headnode (jonran-dc) /var/tmp]# manta-oneach -s nameservice "echo stat | nc localhost 2181"
=== Output from 645c1bdc-00b3-4140-9031-04bb56d9b71c on headnode (nameservice):
Zookeeper version: 3.4.12--1, built on 01/29/2020 08:44 GMT
Clients:
/127.0.0.1:52413[1](queued=1,recved=21,sent=23)
/10.77.77.183:63826[1](queued=0,recved=82,sent=82)
/0:0:0:0:0:0:0:1:43132[0](queued=0,recved=1,sent=0)
/10.77.77.183:41399[1](queued=0,recved=9,sent=9)
Latency min/avg/max: 0/0/55
g++ '-DNODE_GYP_MODULE_NAME=DTraceProviderBindings' '-DUSING_UV_SHARED=1' '-DUSING_V8_SHARED=1' '-DV8_DEPRECATION_WARNINGS=1' '-D_LARGEFILE_SOURCE' '-D_FILE_OFFSET_BITS=64' '-DBUILDING_NODE_EXTENSION' -I/home/jonran/.cache/node-gyp/8.17.0/include/node -I/home/jonran/.cache/node-gyp/8.17.0/src -I/home/jonran/.cache/node-gyp/8.17.0/deps/openssl/config -I/home/jonran/.cache/node-gyp/8.17.0/deps/openssl/openssl/include -I/home/jonran/.cache/node-gyp/8.17.0/deps/uv/include -I/home/jonran/.cache/node-gyp/8.17.0/deps/zlib -I/home/jonran/.cache/node-gyp/8.17.0/deps/v8/include -I../libusdt -fPIC -Wall -Wextra -Wno-unused-parameter -m64 -pthreads -O3 -fno-omit-frame-pointer -fno-rtti -fno-exceptions -std=gnu++0x -MMD -MF ./Release/.deps/Release/obj.target/DTraceProviderBindings/dtrace_provider.o.d.raw -c -o Release/obj.target/DTraceProviderBindings/dtrace_provider.o ../dtrace_provider.cc
In file included from ../dtrace_provider.cc:1:0:
../dtrace_provider.h:69:48: error: 'Arguments' in namespace 'v8' does not name
In file included from ../dtrace_provider.cc:1:0:
../dtrace_provider.h:69:48: error: 'Arguments' in namespace 'v8' does not name a type
static v8::Handle<v8::Value> New(const v8::Arguments& args);
^~~~~~~~~
../dtrace_provider.h:70:49: error: 'Arguments' in namespace 'v8' does not name a type
static v8::Handle<v8::Value> Fire(const v8::Arguments& args);
^~~~~~~~~
../dtrace_provider.h:87:48: error: 'Arguments' in namespace 'v8' does not name a type
static v8::Handle<v8::Value> New(const v8::Arguments& args);
^~~~~~~~~
INFO: Running "/usr/bin/zonename" ...
Jan 10 21:13:28.173 DEBG starting decoherence task, interval 300 seconds, build-id: 0.1.0
Jan 10 21:13:28.174 DEBG starting connection health task, interval 30 seconds, build-id: 0.1.0
Jan 10 21:13:28.174 INFO resolvers specified: ["10.77.77.109:53"], build-id: 0.1.0
Jan 10 21:13:28.177 DEBG srv_response: DnsResponse([Message { header: Header { id: 58065, message_type: Response, op_code: Query, authoritative: false, truncation: false, recursion_desired: true, recursion_available: false, authentic_data: false, checking_disabled: false, response_code: 0, query_count: 1, answer_count: 1, name_server_count: 0, additional_count: 2 }, queries: [Query { name: Name { is_fqdn: true, labels: [_buckets-mdplacement, _tcp, buckets-mdplacement, jonran-region, joyent, us] }, query_type: SRV, query_class: IN }], answers: [Record { name_labels: Name { is_fqdn: true, labels: [_buckets-mdplacement, _tcp, buckets-mdplacement, jonran-region, joyent, us] }, rr_type: SRV, dns_class: IN, ttl: 60
4 0.00000 172.27.2.26 -> d30cf424-4d2c-4635-91b0-f921856bf758.buckets-mdplacement.nightly.joyent.us TCP D=2020 S=43196 Push Ack=1519538546 Seq=2189156358 Len=117 Win=32806 Options=<nop,nop,tstamp 58549570 58549527>
0: 90b8 d0a9 4c16 90b8 d054 b412 0800 4500 ....L....T....E.
16: 00a9 003c 4000 4006 dda9 ac1b 021a ac1b ...<@.@.........
32: 0219 a8bc 07e4 827b e006 5a92 5172 8018 .......{..Z.Qr..
48: 8026 656e 0000 0101 080a 037d 6542 037d .&en.......}eB.}
64: 6517 0101 0100 0000 0000 00a4 6b00 0000 e...........k...
80: 667b 226d 223a 7b22 7574 7322 3a31 3537 f{"m":{"uts":157
96: 3830 3838 3630 3330 3630 3832 362c 226e 8088603060826,"n
112: 616d 6522 3a22 6765 7476 6e6f 6465 7322 ame":"getvnodes"
diff --git a/Cargo.toml b/Cargo.toml
index ef85636..fa66e0d 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -1,6 +1,6 @@
[package]
name = "cueball"
-version = "0.3.0"
+version = "0.2.0"
authors = [
fn check_pool_connections<C>(
protected_data: ProtectedData<C>,
rebalance_check: RebalanceCheck,
log: Logger,
) where
C: Connection,
{
let mut connection_data = protected_data.connection_data_lock();
debug!(
log,