Fix reconnect test failure.
This commit is contained in:
@@ -25,6 +25,7 @@ typedef struct {
|
|||||||
void on_connect(void *passthrough) {
|
void on_connect(void *passthrough) {
|
||||||
test_state *state = passthrough;
|
test_state *state = passthrough;
|
||||||
assert(!pthread_mutex_lock(&state->lock));
|
assert(!pthread_mutex_lock(&state->lock));
|
||||||
|
state->disconnect_fired = false;
|
||||||
state->connect_fired = true;
|
state->connect_fired = true;
|
||||||
assert(!pthread_cond_signal(&state->cond));
|
assert(!pthread_cond_signal(&state->cond));
|
||||||
assert(!pthread_mutex_unlock(&state->lock));
|
assert(!pthread_mutex_unlock(&state->lock));
|
||||||
@@ -33,6 +34,7 @@ void on_connect(void *passthrough) {
|
|||||||
void on_disconnect(void *passthrough) {
|
void on_disconnect(void *passthrough) {
|
||||||
test_state *state = passthrough;
|
test_state *state = passthrough;
|
||||||
assert(!pthread_mutex_lock(&state->lock));
|
assert(!pthread_mutex_lock(&state->lock));
|
||||||
|
state->connect_fired = false;
|
||||||
state->disconnect_fired = true;
|
state->disconnect_fired = true;
|
||||||
assert(!pthread_cond_signal(&state->cond));
|
assert(!pthread_cond_signal(&state->cond));
|
||||||
assert(!pthread_mutex_unlock(&state->lock));
|
assert(!pthread_mutex_unlock(&state->lock));
|
||||||
|
|||||||
Reference in New Issue
Block a user