bbs/vbbs
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Capture SocketException when server terminated normally.

Browse Source
This commit is contained in:
Deon George 2018-12-07 14:22:47 +11:00
parent aa4bafc391
commit 67b2382c84
1 changed files with 17 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
app/Console/Commands/Server.php
View File

@ -8,12 +8,14 @@
namespace App\Console\Commands; namespace App\Console\Commands;
use App\Classes\Frame;
use Illuminate\Console\Command; use Illuminate\Console\Command;
use Illuminate\Database\Eloquent\ModelNotFoundException; use Illuminate\Database\Eloquent\ModelNotFoundException;
use Illuminate\Support\Facades\Log; use Illuminate\Support\Facades\Log;
use Sock\{SocketClient,SocketServer,SocketException}; use Sock\{SocketClient,SocketServer,SocketException};
use App\Classes\Frame as FrameClass;
use App\Models\Frame as FrameModel;
class Server extends Command class Server extends Command
{ {
// Size of Bottom Line Pollution // Size of Bottom Line Pollution
@ -70,7 +72,16 @@ class Server extends Command
$server = new SocketServer(config('app.port'),config('app.bind')); $server = new SocketServer(config('app.port'),config('app.bind'));
$server->init(); $server->init();
$server->setConnectionHandler([$this,'onConnect']); $server->setConnectionHandler([$this,'onConnect']);
$server->listen();
try {
$server->listen();
} catch (SocketException $e) {
if ($e->getMessage() == 'Can\'t accept connections: "Success"')
Log::debug('Server Terminated.');
else
Log::emergency('Uncaught Message: '.$e->getMessage());
}
} }
/** /**
@ -364,7 +375,7 @@ class Server extends Command
$page['frame'] = $pagedata['route1']; $page['frame'] = $pagedata['route1'];
$page['index'] = 'a'; $page['index'] = 'a';
} elseif (\App\Models\Frame::where('frame',$fo->frame())->where('index',$fo->index_next())->exists()) { } elseif (FrameModel::where('frame',$fo->frame())->where('index',$fo->index_next())->exists()) {
$action = ACTION_GOTO; $action = ACTION_GOTO;
$page['frame'] = array_get($current,'page.frame'); $page['frame'] = array_get($current,'page.frame');
$page['index'] = chr(1 + ord($page['index'])); $page['index'] = chr(1 + ord($page['index']));
@ -402,7 +413,7 @@ class Server extends Command
$page['frame'] = $pagedata['route2']; $page['frame'] = $pagedata['route2'];
$page['index'] = 'a'; $page['index'] = 'a';
} elseif (\App\Models\Frame::where('frame',$fo->frame())->where('index',$fo->index_next())->exists()) { } elseif (FrameModel::where('frame',$fo->frame())->where('index',$fo->index_next())->exists()) {
$action = ACTION_GOTO; $action = ACTION_GOTO;
$page['frame'] = $fo->frame(); $page['frame'] = $fo->frame();
$page['index'] = $fo->index_next(); $page['index'] = $fo->index_next();
@ -625,8 +636,8 @@ class Server extends Command
try { try {
$fo = $timewarpalt $fo = $timewarpalt
? new \App\Classes\Frame(\App\Models\Frame::findOrFail($timewarpalt)) ? new FrameClass(FrameModel::findOrFail($timewarpalt))
: (new \App\Models\Frame)->fetch($page['frame'],$page['index']); : (new FrameModel)->fetch($page['frame'],$page['index']);
} catch (ModelNotFoundException $e) { } catch (ModelNotFoundException $e) {
$this->sendBaseline($client,ERR_PAGE); $this->sendBaseline($client,ERR_PAGE);