comparison Framework/HttpQueries/DetectTransferPlugin.cpp @ 10:c9e28e31262e

new option: MaxHttpRetries
author Sebastien Jodogne <s.jodogne@gmail.com>
date Mon, 04 Mar 2019 15:26:49 +0100
parents 7e207ade2f1a
children b06103a50c95
comparison
equal deleted inserted replaced
9:7e207ade2f1a 10:c9e28e31262e
49 size_t size) 49 size_t size)
50 { 50 {
51 Json::Reader reader; 51 Json::Reader reader;
52 Json::Value value; 52 Json::Value value;
53 53
54 bool enabled = false;
55
54 if (reader.parse(reinterpret_cast<const char*>(answer), 56 if (reader.parse(reinterpret_cast<const char*>(answer),
55 reinterpret_cast<const char*>(answer) + size, value) && 57 reinterpret_cast<const char*>(answer) + size, value) &&
56 value.type() == Json::arrayValue) 58 value.type() == Json::arrayValue)
57 { 59 {
60 // Loop over the plugins that are enabled on the remote peer
58 for (Json::Value::ArrayIndex i = 0; i < value.size(); i++) 61 for (Json::Value::ArrayIndex i = 0; i < value.size(); i++)
59 { 62 {
60 if (value[i].type() == Json::stringValue && 63 if (value[i].type() == Json::stringValue &&
61 value[i].asString() == PLUGIN_NAME) 64 value[i].asString() == PLUGIN_NAME)
62 { 65 {
63 result_[peer_] = true; 66 result_[peer_] = true;
67 enabled = true;
64 } 68 }
65 } 69 }
70 }
71
72 if (enabled)
73 {
74 LOG(INFO) << "Peer \"" << peer_ << "\" has the transfers accelerator plugin enabled";
75 }
76 else
77 {
78 LOG(WARNING) << "Peer \"" << peer_ << "\" does *not* have the transfers accelerator plugin enabled";
66 } 79 }
67 } 80 }
68 81
69 82
70 void DetectTransferPlugin::Apply(Result& result, 83 void DetectTransferPlugin::Apply(Result& result,