From: Matteo Nastasi (mop) <nastasi@alternativeoutput.it>
Date: Mon, 14 Apr 2014 11:25:17 +0000 (+0200)
Subject: non blocking test added
X-Git-Tag: v4.14.0~10
X-Git-Url: http://mop.ddnsfree.com/gitweb/?a=commitdiff_plain;h=5886386f05c5a37d8091e14934eb42b8a5c22063;p=brisk.git
non blocking test added
---
diff --git a/test/nonblocking.php b/test/nonblocking.php
new file mode 100755
index 0000000..4125c86
--- /dev/null
+++ b/test/nonblocking.php
@@ -0,0 +1,148 @@
+#!/usr/bin/php
+<?php
+/*
+ * brisk - test/nonblocking.php
+ *
+ * Copyright (C) 2014 Matteo Nastasi
+ * mailto: nastasi@alternativeoutput.it
+ * matteo.nastasi@milug.org
+ * web: http://www.alternativeoutput.it
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABLILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * General Public License for more details. You should have received a
+ * copy of the GNU General Public License along with this program; if
+ * not, write to the Free Software Foundation, Inc, 59 Temple Place -
+ * Suite 330, Boston, MA 02111-1307, USA.
+ *
+ */
+
+$blocking_mode = 0; // 0 is non-blocking
+
+function cmd_serialize($attrs)
+{
+ $ret = "";
+
+ $sep = "";
+ foreach ($attrs as $key => $value) {
+ $ret .= $sep . $key . '=' . urlencode($value);
+ $sep = "&";
+ }
+ return $ret;
+}
+
+function cmd_deserialize($cmd)
+{
+ $ret = array();
+ $a = explode('&', $cmd);
+ $i = 0;
+ while ($i < count($a)) {
+ $b = split('=', $a[$i]);
+ $ret[urldecode($b[0])] = urldecode($b[1]);
+ $i++;
+ }
+
+ return $ret;
+}
+
+
+function sock_mgmt($sock)
+{
+ $buf_all = "";
+ $output = "bib bob bub beb";
+
+ $st = 1;
+ while(1) {
+ if ($st == 1) {
+ printf("\n LOOP SOCK BEGIN\n");
+ $buf = fread($sock, 4096);
+ if ($buf == FALSE) {
+ printf(" BUF == FALSE\n");
+ }
+ if ($buf === FALSE) {
+ printf(" BUF === FALSE\n");
+ }
+ if (!($buf == FALSE) && !($buf === FALSE)) {
+ if (strlen($buf) > 0) {
+ printf(" REC: [%s]\n", $buf);
+ $buf_all .= $buf;
+ if (substr(trim($buf_all), -13) == "&the_end=true") {
+ $st = 2;
+ $ct = 0;
+ }
+ }
+ else {
+ printf(" LEN(BUF) == 0\n");
+ }
+ }
+ else {
+ printf(" FEOF RETURN %d\n", feof($sock));
+ if (feof($sock)) {
+ fclose($sock);
+ return(TRUE);
+ }
+ }
+ }
+ else if ($st == 2) {
+ fwrite($sock, substr($output, $ct, 9), 9);
+ fflush($sock);
+ $ct += 9;
+ }
+ usleep(500000);
+ }
+}
+
+function main()
+{
+ GLOBAL $blocking_mode;
+
+ // $cmd1 = array ("pippo" => "pl'&uto", "minnie" => 'mic"=key', "the_end" => "true" );
+ $cmd1 = array ("cmd" => "userauth", "login" => 'mop', 'private' => 'it_must_be_correct',
+ 'the_end' => 'true' );
+
+ $ret1 = cmd_serialize($cmd1);
+ $ret2 = cmd_deserialize($ret1);
+
+ print_r($cmd1);
+ printf("SER: %s\n", $ret1);
+ printf("DESER\n");
+ print_r($ret2);
+
+ $file_socket = "/tmp/brisk.sock";
+ $unix_socket = "unix://$file_socket";
+
+ if (file_exists($file_socket)) {
+ unlink($file_socket);
+ }
+
+ $old_umask = umask(0);
+ if (($list = stream_socket_server($unix_socket, $err, $errs)) === FALSE) {
+ return (FALSE);
+ }
+ umask($old_umask);
+ printf("Blocking mode (listen): %d\n", $blocking_mode);
+ stream_set_blocking($list, $blocking_mode); // Set the stream to non-blocking
+
+ while(1) {
+ printf("\nLOOP BEGIN\n");
+ if (($new_unix = stream_socket_accept($list)) == FALSE) {
+ printf("SOCKET_ACCEPT FAILED\n");
+ usleep(500000);
+ continue;
+ }
+ else {
+ stream_set_blocking($new_unix, $blocking_mode); // Set the stream to non-blocking
+ sock_mgmt($new_unix);
+ }
+ usleep(500000);
+ }
+}
+
+main();
+?>
\ No newline at end of file