This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
(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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
(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,\ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[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) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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); | |
^~~~~~~~~ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 = [ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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, |
NewerOlder