This commit is contained in:
2021-04-27 16:42:44 +08:00
parent ae5864e947
commit c856c0f449
2 changed files with 397 additions and 394 deletions
+2 -1
View File
@@ -15,6 +15,7 @@ use PDO;
use PDOStatement;
use Snowflake\Abstracts\Component;
use Snowflake\Core\Json;
use Swoole\Coroutine;
/**
* Class Command
@@ -174,7 +175,7 @@ class Command extends Component
if (!($query = $connect->query($this->sql))) {
return $this->addError($connect->errorInfo()[2] ?? '数据库异常, 请稍后再试.');
}
defer(function () use ($query) {
Coroutine::defer(function () use ($query) {
$query->closeCursor();
});
if ($type === static::FETCH_COLUMN) {
+7 -5
View File
@@ -3,6 +3,7 @@
namespace HttpServer;
use Exception;
use HttpServer\Abstracts\HttpService;
use HttpServer\Events\OnClose;
use HttpServer\Events\OnConnect;
@@ -10,16 +11,13 @@ use HttpServer\Events\OnPacket;
use HttpServer\Events\OnReceive;
use HttpServer\Events\OnRequest;
use HttpServer\Service\Http;
use HttpServer\Service\Receive;
use HttpServer\Service\Packet;
use HttpServer\Service\Receive;
use HttpServer\Service\Websocket;
use Exception;
use ReflectionException;
use Snowflake\Abstracts\Config;
use Snowflake\Error\LoggerProcess;
use Snowflake\Event;
use Snowflake\Exception\ConfigException;
use Snowflake\Exception\NotFindClassException;
use Snowflake\Process\Biomonitoring;
use Snowflake\Snowflake;
use Swoole\Coroutine;
@@ -115,7 +113,11 @@ class Server extends HttpService
return 'ok';
}
Runtime::enableCoroutine(true, SWOOLE_HOOK_ALL ^ SWOOLE_HOOK_BLOCKING_FUNCTION);
Runtime::enableCoroutine(true, SWOOLE_HOOK_TCP |
SWOOLE_HOOK_UNIX | SWOOLE_HOOK_UDP | SWOOLE_HOOK_UDG |
SWOOLE_HOOK_SSL | SWOOLE_HOOK_TLS | SWOOLE_HOOK_SLEEP |
SWOOLE_HOOK_STREAM_FUNCTION | SWOOLE_HOOK_PROC
);
Coroutine::set(['enable_deadlock_check' => false]);