- $id = $user_cur->id_get();
- $user_a[$id]->enable($new_socket, $get['sess']);
- printf("s2u: ci passo %d\n", intval($new_socket));
- $s2u[intval($new_socket)] = $id;
-
- fwrite($new_socket, $rndstr);
- fflush($new_socket);
- }
- else {
- printf("Too many opened users\n");
- fclose($new_socket);
+
+
+
+ if (0 == 1) {
+ /* TODO: here stuff to decide if it is old or new user */
+ if (($user_cur = user_get_sess($user_a, $get['sess'])) != FALSE) {
+ /* close the previous socket */
+ unset($s2u[intval($user_cur->sock_get())]);
+ unset($socks[intval($user_cur->sock_get())]);
+ fclose($user_cur->sock_get());
+ /* assign the new socket */
+ $user_cur->sock_set($new_socket);
+ $id = $user_cur->id_get();
+ $s2u[intval($new_socket)] = $id;
+ $socks[intval($new_socket)] = $new_socket;
+ fwrite($new_socket, $rndstr);
+ fflush($new_socket);
+ }
+ else if (($user_cur = user_get_free($user_a)) != FALSE) {
+ stream_set_blocking($new_socket, $blocking_mode); // Set the stream to non-blocking
+ $socks[intval($new_socket)] = $new_socket;
+
+ $id = $user_cur->id_get();
+ $user_a[$id]->enable($new_socket, $get['sess']);
+ printf("s2u: ci passo %d\n", intval($new_socket));
+ $s2u[intval($new_socket)] = $id;
+
+ fwrite($new_socket, $rndstr);
+ fflush($new_socket);
+ }
+ else {
+ printf("Too many opened users\n");
+ fclose($new_socket);
+ }