rename sendPingReq into sendPingReqs

esatterwhite · Nov 30, 2015 · 372d6c7 · 372d6c7
1 parent 4b23332
commit 372d6c7
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 10 deletions.
diff --git a/lib/gossip/index.js b/lib/gossip/index.js
@@ -21,7 +21,7 @@
 
 var metrics = require('metrics');
 var sendPing = require('./ping-sender.js');
-var sendPingReq = require('./ping-req-sender.js');
+var sendPingReqs = require('./ping-req-sender.js');
 
 function Gossip(options) {
     this.ringpop = options.ringpop;
@@ -179,7 +179,7 @@ Gossip.prototype.tick = function tick(callback) {
         // the response), though it does delay the protocol period
         // unnecessarily. We may want to bypass the ping-req here
         // if the member's status is faulty.
-        sendPingReq({
+        sendPingReqs({
             ringpop: self.ringpop,
             unreachableMember: member,
             pingReqSize: self.ringpop.pingReqSize

diff --git a/lib/gossip/ping-req-sender.js b/lib/gossip/ping-req-sender.js
@@ -118,7 +118,7 @@ PingReqSender.prototype.onPingReq = function (err, res) {
     this.callback();
 };
 
-module.exports = function sendPingReq(opts, callback) {
+module.exports = function sendPingReqs(opts, callback) {
     var ringpop = opts.ringpop;
     var gossipLogger = ringpop.loggerFactory.getLogger('gossip');
     var unreachableMember = opts.unreachableMember;

diff --git a/test/integration/gossip_test.js b/test/integration/gossip_test.js
@@ -19,7 +19,7 @@
 // THE SOFTWARE.
 'use strict';
 
-var sendPingReq = require('../../lib/gossip/ping-req-sender.js');
+var sendPingReqs = require('../../lib/gossip/ping-req-sender.js');
 var testRingpopCluster = require('../lib/test-ringpop-cluster.js');
 
 // Avoid depending upon mutation of member and find
@@ -64,7 +64,7 @@ testRingpopCluster({
     var ringpop = cluster[0];
     var unreachableMember = ringpop.membership.findMemberByAddress(cluster[1].hostPort);
 
-    sendPingReq({
+    sendPingReqs({
         ringpop: cluster[0],
         unreachableMember: unreachableMember,
         pingReqSize: 3
@@ -89,7 +89,7 @@ testRingpopCluster({
         findMemberByAddress(cluster[1].hostPort);
     var pingReqSize = 3;
 
-    sendPingReq({
+    sendPingReqs({
         ringpop: cluster[0],
         unreachableMember: unreachableMember,
         pingReqSize: pingReqSize
@@ -117,7 +117,7 @@ testRingpopCluster({
         var unreachableMember = ringpop.membership.findMemberByAddress(badRingpop.hostPort);
         var pingReqSize = 3;
 
-        sendPingReq({
+        sendPingReqs({
             ringpop: ringpop,
             unreachableMember: unreachableMember,
             pingReqSize: pingReqSize
@@ -142,7 +142,7 @@ testRingpopCluster({
     var unreachableMember = ringpop.membership.findMemberByAddress(ringpop2Addr);
     var pingReqSize = 3;
 
-    sendPingReq({
+    sendPingReqs({
         ringpop: ringpop,
         unreachableMember: unreachableMember,
         pingReqSize: pingReqSize
@@ -170,7 +170,7 @@ testRingpopCluster({
     var unreachableMember = ringpop.membership.findMemberByAddress(badRingpop.hostPort);
     var pingReqSize = 3;
 
-    sendPingReq({
+    sendPingReqs({
         ringpop: ringpop,
         unreachableMember: unreachableMember,
         pingReqSize: pingReqSize
@@ -200,7 +200,7 @@ testRingpopCluster({
         }
     });
 
-    sendPingReq({
+    sendPingReqs({
         ringpop: ringpop,
         unreachableMember: unreachableMember,
         pingReqSize: pingReqSize