stkn/node-pcsclite
Archived
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Revert "src: handle last event before exiting status threads"

Browse Source 
This reverts commit 3800c39291.
This commit is contained in:
Santiago Gimeno
2015-09-26 16:13:46 +02:00
parent 99391039b7
commit 4650a529f7
2 changed files with 26 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
src/cardreader.cpp
View File

@@ -333,7 +333,17 @@ void CardReader::HandleReaderStatusChange(uv_async_t *handle, int status) {
AsyncResult* ar = async_baton->async_result;
if ((ar->result == SCARD_S_SUCCESS) || (ar->result == (LONG)SCARD_E_NO_READERS_AVAILABLE)) {
if (ar->do_exit) {
uv_close(reinterpret_cast<uv_handle_t*>(&async_baton->async), CloseCallback); // necessary otherwise UV will block
/* Emit end event */
Local<Value> argv[1] = {
Nan::New("_end").ToLocalChecked(), // event name
};
Nan::MakeCallback(async_baton->reader->handle(), "emit", 1, argv);
} else {
if (ar->result == SCARD_S_SUCCESS) {
const unsigned argc = 3;
Local<Value> argv[argc] = {
Nan::Undefined(), // argument
@@ -349,17 +359,6 @@ void CardReader::HandleReaderStatusChange(uv_async_t *handle, int status) {
Local<Value> argv[argc] = { err };
Nan::Callback(Nan::New(async_baton->callback)).Call(argc, argv);
}
// Do exit, after throwing last events
if (ar->do_exit) {
uv_close(reinterpret_cast<uv_handle_t*>(&async_baton->async), CloseCallback); // necessary otherwise UV will block
/* Emit end event */
Local<Value> argv[1] = {
Nan::New("_end").ToLocalChecked(), // event name
};
Nan::MakeCallback(async_baton->reader->handle(), "emit", 1, argv);
}
if (reader->m_status_thread) {
@@ -393,21 +392,20 @@ void CardReader::HandlerFunction(void* arg) {
if (!keep_watching) {
reader->m_state = 2;
async_baton->async_result->do_exit = true;
}
uv_mutex_unlock(&reader->m_mutex);
async_baton->async_result->result = result;
async_baton->async_result->status = card_reader_state.dwEventState;
memcpy(async_baton->async_result->atr, card_reader_state.rgbAtr, card_reader_state.cbAtr);
async_baton->async_result->atrlen = card_reader_state.cbAtr;
uv_mutex_unlock(&reader->m_mutex);
uv_async_send(&async_baton->async);
card_reader_state.dwCurrentState = card_reader_state.dwEventState;
}
// Exit flag set in keepwatching and handled in following uv_async_send
async_baton->async_result->do_exit = true;
uv_async_send(&async_baton->async);
}
void CardReader::DoConnect(uv_work_t* req) {

11
src/pcsclite.cpp
View File

@@ -124,6 +124,11 @@ void PCSCLite::HandleReaderStatusChange(uv_async_t *handle, int status) {
AsyncBaton* async_baton = static_cast<AsyncBaton*>(handle->data);
AsyncResult* ar = async_baton->async_result;
if (ar->do_exit) {
uv_close(reinterpret_cast<uv_handle_t*>(&async_baton->async), CloseCallback); // necessary otherwise UV will block
return;
}
if ((ar->result == SCARD_S_SUCCESS) || (ar->result == (LONG)SCARD_E_NO_READERS_AVAILABLE)) {
const unsigned argc = 2;
Local<Value> argv[argc] = {
@@ -140,12 +145,6 @@ void PCSCLite::HandleReaderStatusChange(uv_async_t *handle, int status) {
Nan::Callback(Nan::New(async_baton->callback)).Call(argc, argv);
}
// Do exit, after throwing last events
if (ar->do_exit) {
uv_close(reinterpret_cast<uv_handle_t*>(&async_baton->async), CloseCallback); // necessary otherwise UV will block
return;
}
/* reset AsyncResult */
delete [] ar->readers_name;
ar->readers_name = NULL;