Fixes #1531

lib/http2.js

@@ -929,7 +929,7 @@ Agent.prototype.addRequest = function(req, host, port) {
 };
 Agent.prototype.createSocket = function(name, host, port) {
   var self = this;
-  var s = self.createConnection(port, host);
+  var s = self.createConnection(port, host, self.options);
   if (!self.sockets[name]) {
     self.sockets[name] = [];
   }
@@ -1027,7 +1027,11 @@ function ClientRequest(options, cb) {
   if (self.socketPath) {
     self._last = true;
     self.shouldKeepAlive = false;
+    if (options.createConnection) {
+      self.onSocket(options.createConnection(self.socketPath));
+    } else {
       self.onSocket(net.createConnection(self.socketPath));
+    }
   } else if (self.agent) {
     // If there is an agent we should default to Connection:keep-alive.
     self._last = false;
@@ -1037,8 +1041,12 @@ function ClientRequest(options, cb) {
     // No agent, default to Connection:close.
     self._last = true;
     self.shouldKeepAlive = false;
+    if (options.createConnection) {
+      self.onSocket(options.createConnection(options.port, options.host, options));
+    } else {
       self.onSocket(net.createConnection(options.port, options.host));
     }
+  }
 
   self._deferToConnect(null, null, function () {
     self._flush();

lib/https2.js

@@ -51,12 +51,14 @@ exports.createServer = function(opts, requestListener) {
 
 // HTTPS agents.
 
+function createConnection(port, host, options) {
+  return tls.connect(port, host, options);
+};
+
 function Agent(options) {
   http.Agent.call(this, options);
-  this.createConnection = function(port, host) {
+  this.createConnection = createConnection;
-    return tls.connect(port, host, options);
 };
-}
 inherits(Agent, http.Agent);
 Agent.prototype.defaultPort = 443;
 
@@ -69,6 +71,7 @@ exports.request = function(options, cb) {
   if (options.agent === undefined) {
     options.agent = globalAgent;
   }
+  options.createConnection = createConnection;
   options.defaultPort = options.defaultPort || 443;
   return http.request(options, cb);
 };