php: stress test client

src/php/tests/interop/interop_client.php

@@ -388,48 +388,46 @@ function timeoutOnSleepingServer($stub)
              'Call status was not DEADLINE_EXCEEDED');
 }
 
-$args = getopt('', ['server_host:', 'server_port:', 'test_case:',
+function interop_main($args)
-                    'use_tls::', 'use_test_ca::',
+{
-                    'server_host_override:', 'oauth_scope:',
+    if (!array_key_exists('server_host', $args)) {
-                    'default_service_account:', ]);
-if (!array_key_exists('server_host', $args)) {
         throw new Exception('Missing argument: --server_host is required');
-}
+    }
-if (!array_key_exists('server_port', $args)) {
+    if (!array_key_exists('server_port', $args)) {
         throw new Exception('Missing argument: --server_port is required');
-}
+    }
-if (!array_key_exists('test_case', $args)) {
+    if (!array_key_exists('test_case', $args)) {
         throw new Exception('Missing argument: --test_case is required');
-}
+    }
 
-if ($args['server_port'] == 443) {
+    if ($args['server_port'] == 443) {
         $server_address = $args['server_host'];
-} else {
+    } else {
         $server_address = $args['server_host'].':'.$args['server_port'];
-}
+    }
 
-$test_case = $args['test_case'];
+    $test_case = $args['test_case'];
 
-$host_override = 'foo.test.google.fr';
+    $host_override = 'foo.test.google.fr';
-if (array_key_exists('server_host_override', $args)) {
+    if (array_key_exists('server_host_override', $args)) {
         $host_override = $args['server_host_override'];
-}
+    }
 
-$use_tls = false;
+    $use_tls = false;
-if (array_key_exists('use_tls', $args) &&
+    if (array_key_exists('use_tls', $args) &&
         $args['use_tls'] != 'false') {
         $use_tls = true;
-}
+    }
 
-$use_test_ca = false;
+    $use_test_ca = false;
-if (array_key_exists('use_test_ca', $args) &&
+    if (array_key_exists('use_test_ca', $args) &&
         $args['use_test_ca'] != 'false') {
         $use_test_ca = true;
-}
+    }
 
-$opts = [];
+    $opts = [];
 
-if ($use_tls) {
+    if ($use_tls) {
         if ($use_test_ca) {
             $ssl_credentials = Grpc\ChannelCredentials::createSsl(
                 file_get_contents(dirname(__FILE__).'/../data/ca.pem'));
@@ -438,11 +436,11 @@ if ($use_tls) {
         }
         $opts['credentials'] = $ssl_credentials;
         $opts['grpc.ssl_target_name_override'] = $host_override;
-} else {
+    } else {
         $opts['credentials'] = Grpc\ChannelCredentials::createInsecure();
-}
+    }
 
-if (in_array($test_case, ['service_account_creds',
+    if (in_array($test_case, ['service_account_creds',
                               'compute_engine_creds', 'jwt_token_creds', ])) {
         if ($test_case == 'jwt_token_creds') {
             $auth_credentials = ApplicationDefaultCredentials::getCredentials();
@@ -452,9 +450,9 @@ if (in_array($test_case, ['service_account_creds',
             );
         }
         $opts['update_metadata'] = $auth_credentials->getUpdateMetadataFunc();
-}
+    }
 
-if ($test_case == 'oauth2_auth_token') {
+    if ($test_case == 'oauth2_auth_token') {
         $auth_credentials = ApplicationDefaultCredentials::getCredentials(
             $args['oauth_scope']
         );
@@ -472,14 +470,14 @@ if ($test_case == 'oauth2_auth_token') {
                 return $metadata_copy;
             };
         $opts['update_metadata'] = $update_metadata;
-}
+    }
 
-$stub = new grpc\testing\TestServiceClient($server_address, $opts);
+    $stub = new grpc\testing\TestServiceClient($server_address, $opts);
 
-echo "Connecting to $server_address\n";
+    echo "Connecting to $server_address\n";
-echo "Running test case $test_case\n";
+    echo "Running test case $test_case\n";
 
-switch ($test_case) {
+    switch ($test_case) {
         case 'empty_unary':
             emptyUnary($stub);
             break;
@@ -525,4 +523,13 @@ switch ($test_case) {
         default:
             echo "Unsupported test case $test_case\n";
             exit(1);
+    }
+}
+
+if (isset($_SERVER['PHP_SELF']) && preg_match('/interop_client/', $_SERVER['PHP_SELF'])) {
+    $args = getopt('', ['server_host:', 'server_port:', 'test_case:',
+                        'use_tls::', 'use_test_ca::',
+                        'server_host_override:', 'oauth_scope:',
+                        'default_service_account:', ]);
+    interop_main($args);
 }

src/php/tests/interop/metrics_client.php

@@ -0,0 +1,17 @@
+<?php
+
+$args = getopt('', ['metric_server_address:', 'total_only::']);
+$parts = explode(':', $args['metric_server_address']);
+$server_host = $parts[0];
+$server_port = (count($parts) == 2) ? $parts[1] : '';
+
+$socket = socket_create(AF_INET, SOCK_STREAM, 0);
+if (@!socket_connect($socket, $server_host, $server_port)) {
+  echo "Cannot connect to merics server...\n";
+  exit(1);
+}
+socket_write($socket, 'qps');
+while ($out = socket_read($socket, 1024)) {
+  echo "$out\n";
+}
+socket_close($socket);

src/php/tests/interop/stress_client.php

@@ -0,0 +1,83 @@
+<?php
+
+include_once('interop_client.php');
+
+function stress_main($args) {
+  mt_srand();
+  set_time_limit(0);
+
+  // open socket to listen as metrics server
+  $socket = socket_create(AF_INET, SOCK_STREAM, 0);
+  socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
+  if (@!socket_bind($socket, 'localhost', $args['metrics_port'])) {
+    echo "Cannot create socket for metrics server...\n";
+    exit(1);
+  }
+  socket_listen($socket);
+  socket_set_nonblock($socket);
+
+  $start_time = microtime(true);
+  $count = 0;
+  $deadline = $args['test_duration_secs'] ?
+              ($start_time + $args['test_duration_secs']) : false;
+  $num_test_cases = count($args['test_cases']);
+
+  while (true) {
+    $current_time = microtime(true);
+    if ($deadline && $current_time > $deadline) {
+      break;
+    }
+    if ($client_connection = socket_accept($socket)) {
+      // there is an incoming request, respond with qps metrics
+      $input = socket_read($client_connection, 1024);
+      $qps = round($count / ($current_time - $start_time));
+      socket_write($client_connection, "qps: $qps");
+      socket_close($client_connection);
+    } else {
+      // do actual work, run one interop test case
+      $args['test_case'] =
+          $args['test_cases'][mt_rand(0, $num_test_cases - 1)];
+      @interop_main($args);
+      $count++;
+    }
+  }
+  socket_close($socket);
+  echo "Number of interop tests run in $args[test_duration_secs] seconds: $count.\n";
+}
+
+// process command line arguments
+$raw_args = getopt('',
+  ['server_addresses::',
+   'test_cases:',
+   'metrics_port::',
+   'test_duration_secs::',
+   'num_channels_per_server::',
+   'num_stubs_per_channel::']);
+
+$args = [];
+
+if (empty($raw_args['server_addresses'])) {
+  $args['server_host'] = 'localhost';
+  $args['server_port'] = '8080';
+} else {
+  $parts = explode(':', $raw_args['server_addresses']);
+  $args['server_host'] = $parts[0];
+  $args['server_port'] = (count($parts) == 2) ? $parts[1] : '';
+}
+
+$args['metrics_port'] = empty($raw_args['metrics_port']) ?
+  '8081' : $args['metrics_port'];
+
+$args['test_duration_secs'] = empty($raw_args['test_duration_secs']) ||
+  $raw_args['test_duration_secs'] == -1 ?
+  false : $raw_args['test_duration_secs'];
+
+$test_cases = [];
+$test_case_strs = explode(',', $raw_args['test_cases']);
+foreach ($test_case_strs as $test_case_str) {
+  $parts = explode(':', $test_case_str);
+  $test_cases = array_merge($test_cases, array_fill(0, $parts[1], $parts[0]));
+}
+$args['test_cases'] = $test_cases;
+
+stress_main($args);