Skip to content

Commit

Permalink
core, refactor: not lock the object before calling the synchronizatio…
Browse files Browse the repository at this point in the history 
…n method.
  • Loading branch information
@xicilion
xicilion committed May 24, 2023
1 parent 7d78fbc commit f2ac34a
Show file tree
Hide file tree
Showing 34 changed files with 150 additions and 128 deletions.
10 changes: 5 additions & 5 deletions fibjs/include/ifs/BufferedStream.h
View file
Expand Up @@ -122,7 +122,7 @@ inline void BufferedStream_base::s_readText(const v8::FunctionCallbackInfo<v8::V
{
exlib::string vr;

METHOD_INSTANCE(BufferedStream_base);
ASYNC_METHOD_INSTANCE(BufferedStream_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -141,7 +141,7 @@ inline void BufferedStream_base::s_readLine(const v8::FunctionCallbackInfo<v8::V
{
exlib::string vr;

METHOD_INSTANCE(BufferedStream_base);
ASYNC_METHOD_INSTANCE(BufferedStream_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 0);
Expand Down Expand Up @@ -176,7 +176,7 @@ inline void BufferedStream_base::s_readUntil(const v8::FunctionCallbackInfo<v8::
{
exlib::string vr;

METHOD_INSTANCE(BufferedStream_base);
ASYNC_METHOD_INSTANCE(BufferedStream_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(2, 1);
Expand All @@ -194,7 +194,7 @@ inline void BufferedStream_base::s_readUntil(const v8::FunctionCallbackInfo<v8::

inline void BufferedStream_base::s_writeText(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(BufferedStream_base);
ASYNC_METHOD_INSTANCE(BufferedStream_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -211,7 +211,7 @@ inline void BufferedStream_base::s_writeText(const v8::FunctionCallbackInfo<v8::

inline void BufferedStream_base::s_writeLine(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(BufferedStream_base);
ASYNC_METHOD_INSTANCE(BufferedStream_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand Down
2 changes: 1 addition & 1 deletion fibjs/include/ifs/ChildProcess.h
View file
Expand Up @@ -131,7 +131,7 @@ inline void ChildProcess_base::s_join(const v8::FunctionCallbackInfo<v8::Value>&
{
int32_t vr;

METHOD_INSTANCE(ChildProcess_base);
ASYNC_METHOD_INSTANCE(ChildProcess_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(0, 0);
Expand Down
4 changes: 2 additions & 2 deletions fibjs/include/ifs/Cipher.h
View file
Expand Up @@ -189,7 +189,7 @@ inline void Cipher_base::s_encrypt(const v8::FunctionCallbackInfo<v8::Value>& ar
{
obj_ptr<Buffer_base> vr;

METHOD_INSTANCE(Cipher_base);
ASYNC_METHOD_INSTANCE(Cipher_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -208,7 +208,7 @@ inline void Cipher_base::s_decrypt(const v8::FunctionCallbackInfo<v8::Value>& ar
{
obj_ptr<Buffer_base> vr;

METHOD_INSTANCE(Cipher_base);
ASYNC_METHOD_INSTANCE(Cipher_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand Down
30 changes: 15 additions & 15 deletions fibjs/include/ifs/DbConnection.h
View file
Expand Up @@ -157,7 +157,7 @@ inline void DbConnection_base::s_get_type(v8::Local<v8::Name> property, const v8

inline void DbConnection_base::s_close(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(0, 0);
Expand All @@ -172,7 +172,7 @@ inline void DbConnection_base::s_close(const v8::FunctionCallbackInfo<v8::Value>

inline void DbConnection_base::s_use(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -189,7 +189,7 @@ inline void DbConnection_base::s_use(const v8::FunctionCallbackInfo<v8::Value>&

inline void DbConnection_base::s_begin(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 0);
Expand All @@ -206,7 +206,7 @@ inline void DbConnection_base::s_begin(const v8::FunctionCallbackInfo<v8::Value>

inline void DbConnection_base::s_commit(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 0);
Expand All @@ -223,7 +223,7 @@ inline void DbConnection_base::s_commit(const v8::FunctionCallbackInfo<v8::Value

inline void DbConnection_base::s_rollback(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 0);
Expand Down Expand Up @@ -265,7 +265,7 @@ inline void DbConnection_base::s_execute(const v8::FunctionCallbackInfo<v8::Valu
{
obj_ptr<NArray> vr;

METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -292,7 +292,7 @@ inline void DbConnection_base::s_execute(const v8::FunctionCallbackInfo<v8::Valu

inline void DbConnection_base::s_createTable(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -309,7 +309,7 @@ inline void DbConnection_base::s_createTable(const v8::FunctionCallbackInfo<v8::

inline void DbConnection_base::s_dropTable(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -326,7 +326,7 @@ inline void DbConnection_base::s_dropTable(const v8::FunctionCallbackInfo<v8::Va

inline void DbConnection_base::s_createIndex(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -343,7 +343,7 @@ inline void DbConnection_base::s_createIndex(const v8::FunctionCallbackInfo<v8::

inline void DbConnection_base::s_dropIndex(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -362,7 +362,7 @@ inline void DbConnection_base::s_insert(const v8::FunctionCallbackInfo<v8::Value
{
double vr;

METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -381,7 +381,7 @@ inline void DbConnection_base::s_find(const v8::FunctionCallbackInfo<v8::Value>&
{
obj_ptr<NArray> vr;

METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -400,7 +400,7 @@ inline void DbConnection_base::s_count(const v8::FunctionCallbackInfo<v8::Value>
{
int32_t vr;

METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -419,7 +419,7 @@ inline void DbConnection_base::s_update(const v8::FunctionCallbackInfo<v8::Value
{
int32_t vr;

METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand All @@ -438,7 +438,7 @@ inline void DbConnection_base::s_remove(const v8::FunctionCallbackInfo<v8::Value
{
int32_t vr;

METHOD_INSTANCE(DbConnection_base);
ASYNC_METHOD_INSTANCE(DbConnection_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand Down
4 changes: 2 additions & 2 deletions fibjs/include/ifs/DgramSocket.h
View file
Expand Up @@ -102,7 +102,7 @@ inline ClassInfo& DgramSocket_base::class_info()

inline void DgramSocket_base::s_bind(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(DgramSocket_base);
ASYNC_METHOD_INSTANCE(DgramSocket_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(2, 0);
Expand Down Expand Up @@ -131,7 +131,7 @@ inline void DgramSocket_base::s_send(const v8::FunctionCallbackInfo<v8::Value>&
{
int32_t vr;

METHOD_INSTANCE(DgramSocket_base);
ASYNC_METHOD_INSTANCE(DgramSocket_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(3, 2);
Expand Down
4 changes: 2 additions & 2 deletions fibjs/include/ifs/Digest.h
View file
Expand Up @@ -116,7 +116,7 @@ inline void Digest_base::s_sign(const v8::FunctionCallbackInfo<v8::Value>& args)
{
obj_ptr<Buffer_base> vr;

METHOD_INSTANCE(Digest_base);
ASYNC_METHOD_INSTANCE(Digest_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(2, 1);
Expand All @@ -136,7 +136,7 @@ inline void Digest_base::s_verify(const v8::FunctionCallbackInfo<v8::Value>& arg
{
bool vr;

METHOD_INSTANCE(Digest_base);
ASYNC_METHOD_INSTANCE(Digest_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(3, 2);
Expand Down
2 changes: 1 addition & 1 deletion fibjs/include/ifs/ECKey.h
View file
Expand Up @@ -144,7 +144,7 @@ inline void ECKey_base::s_computeSecret(const v8::FunctionCallbackInfo<v8::Value
{
obj_ptr<Buffer_base> vr;

METHOD_INSTANCE(ECKey_base);
ASYNC_METHOD_INSTANCE(ECKey_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand Down
2 changes: 1 addition & 1 deletion fibjs/include/ifs/Ed25519Key.h
View file
Expand Up @@ -64,7 +64,7 @@ inline void Ed25519Key_base::s_toX25519(const v8::FunctionCallbackInfo<v8::Value
{
obj_ptr<ECKey_base> vr;

METHOD_INSTANCE(Ed25519Key_base);
ASYNC_METHOD_INSTANCE(Ed25519Key_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(0, 0);
Expand Down
2 changes: 1 addition & 1 deletion fibjs/include/ifs/File.h
View file
Expand Up @@ -95,7 +95,7 @@ inline void File_base::s_get_fd(v8::Local<v8::Name> property, const v8::Property

inline void File_base::s_chmod(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(File_base);
ASYNC_METHOD_INSTANCE(File_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand Down
2 changes: 1 addition & 1 deletion fibjs/include/ifs/Handler.h
View file
Expand Up @@ -101,7 +101,7 @@ inline void Handler_base::s_invoke(const v8::FunctionCallbackInfo<v8::Value>& ar
{
obj_ptr<Handler_base> vr;

METHOD_INSTANCE(Handler_base);
ASYNC_METHOD_INSTANCE(Handler_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand Down
2 changes: 1 addition & 1 deletion fibjs/include/ifs/HeapSnapshot.h
View file
Expand Up @@ -113,7 +113,7 @@ inline void HeapSnapshot_base::s_getNodeById(const v8::FunctionCallbackInfo<v8::

inline void HeapSnapshot_base::s_save(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(HeapSnapshot_base);
ASYNC_METHOD_INSTANCE(HeapSnapshot_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand Down
14 changes: 7 additions & 7 deletions fibjs/include/ifs/HttpClient.h
View file
Expand Up @@ -474,7 +474,7 @@ inline void HttpClient_base::s_request(const v8::FunctionCallbackInfo<v8::Value>
{
obj_ptr<HttpResponse_base> vr;

METHOD_INSTANCE(HttpClient_base);
ASYNC_METHOD_INSTANCE(HttpClient_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(2, 2);
Expand Down Expand Up @@ -535,7 +535,7 @@ inline void HttpClient_base::s_get(const v8::FunctionCallbackInfo<v8::Value>& ar
{
obj_ptr<HttpResponse_base> vr;

METHOD_INSTANCE(HttpClient_base);
ASYNC_METHOD_INSTANCE(HttpClient_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(2, 1);
Expand All @@ -555,7 +555,7 @@ inline void HttpClient_base::s_post(const v8::FunctionCallbackInfo<v8::Value>& a
{
obj_ptr<HttpResponse_base> vr;

METHOD_INSTANCE(HttpClient_base);
ASYNC_METHOD_INSTANCE(HttpClient_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(2, 1);
Expand All @@ -575,7 +575,7 @@ inline void HttpClient_base::s_del(const v8::FunctionCallbackInfo<v8::Value>& ar
{
obj_ptr<HttpResponse_base> vr;

METHOD_INSTANCE(HttpClient_base);
ASYNC_METHOD_INSTANCE(HttpClient_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(2, 1);
Expand All @@ -595,7 +595,7 @@ inline void HttpClient_base::s_put(const v8::FunctionCallbackInfo<v8::Value>& ar
{
obj_ptr<HttpResponse_base> vr;

METHOD_INSTANCE(HttpClient_base);
ASYNC_METHOD_INSTANCE(HttpClient_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(2, 1);
Expand All @@ -615,7 +615,7 @@ inline void HttpClient_base::s_patch(const v8::FunctionCallbackInfo<v8::Value>&
{
obj_ptr<HttpResponse_base> vr;

METHOD_INSTANCE(HttpClient_base);
ASYNC_METHOD_INSTANCE(HttpClient_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(2, 1);
Expand All @@ -635,7 +635,7 @@ inline void HttpClient_base::s_head(const v8::FunctionCallbackInfo<v8::Value>& a
{
obj_ptr<HttpResponse_base> vr;

METHOD_INSTANCE(HttpClient_base);
ASYNC_METHOD_INSTANCE(HttpClient_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(2, 1);
Expand Down
2 changes: 1 addition & 1 deletion fibjs/include/ifs/HttpResponse.h
View file
Expand Up @@ -242,7 +242,7 @@ inline void HttpResponse_base::s_redirect(const v8::FunctionCallbackInfo<v8::Val

inline void HttpResponse_base::s_sendHeader(const v8::FunctionCallbackInfo<v8::Value>& args)
{
METHOD_INSTANCE(HttpResponse_base);
ASYNC_METHOD_INSTANCE(HttpResponse_base);
METHOD_ENTER();

ASYNC_METHOD_OVER(1, 1);
Expand Down

0 comments on commit f2ac34a

Please sign in to comment.