Compare commits
3 Commits
14c505c15b
...
c2516a2b54
Author | SHA1 | Date | |
---|---|---|---|
c2516a2b54 | |||
171392cf40 | |||
64d37741a5 |
@ -128,10 +128,10 @@ class Receive extends Base
|
||||
// If packet is greater than a size, lets queue it
|
||||
if ($this->queue || ($this->receiving->size > config('fido.queue_size',0))) {
|
||||
Log::info(sprintf('%s:- Packet [%s] will be sent to the queue for processing because its [%d] size, or queue forced',self::LOGKEY,$this->receiving->full_name,$this->receiving->size));
|
||||
PacketProcess::dispatch($this->receiving,$this->ao,$rcvd_time);
|
||||
PacketProcess::dispatch($this->receiving,$this->ao->withoutRelations(),$rcvd_time);
|
||||
|
||||
} else
|
||||
PacketProcess::dispatchSync($this->receiving,$this->ao,$rcvd_time);
|
||||
PacketProcess::dispatchSync($this->receiving,$this->ao->withoutRelations(),$rcvd_time);
|
||||
|
||||
} catch (\Exception $e) {
|
||||
Log::error(sprintf('%s:! Got error dispatching packet [%s] (%d:%s-%s).',self::LOGKEY,$this->receiving->full_name,$e->getLine(),$e->getFile(),$e->getMessage()));
|
||||
|
@ -92,7 +92,7 @@ class Node
|
||||
|
||||
// Return how long our session has been connected
|
||||
case 'session_time':
|
||||
return sprintf("%d",Carbon::now()->diffInSeconds($this->start_time));
|
||||
return sprintf("%d",$this->start_time->diffInSeconds(Carbon::now()));
|
||||
|
||||
case 'system':
|
||||
case 'sysop':
|
||||
|
@ -132,7 +132,7 @@ class PacketProcess implements ShouldQueue
|
||||
} else {
|
||||
// If we want to keep the packet, we could do that logic here
|
||||
if (config('fido.packet_keep')) {
|
||||
$dir = sprintf('%s/%s',config('fido.dir'),Carbon::now()->format('Ymd'));
|
||||
$dir = sprintf('%s/%d/%d/%d',config('fido.dir'),($x=Carbon::now())->format('Y'),$x->format('m'),$x->format('d'));
|
||||
Log::debug(sprintf('%s:- Moving processed packet [%s] to [%s]',self::LOGKEY,$this->file->rel_name,$dir));
|
||||
|
||||
try {
|
||||
|
Loading…
Reference in New Issue
Block a user