/* This is just the same as stream_open() except that it uses the default
* JSONRPC ports if none is specified. */
int
/* This is just the same as stream_open() except that it uses the default
* JSONRPC ports if none is specified. */
int
}
/* This is just the same as pstream_open() except that it uses the default
* JSONRPC ports if none is specified. */
int
}
/* This is just the same as pstream_open() except that it uses the default
* JSONRPC ports if none is specified. */
int
- if (error
- || (reply->type == JSONRPC_REPLY
- && json_equal(id, reply->id))) {
+ if (error) {
+ break;
+ }
+ if ((reply->type == JSONRPC_REPLY || reply->type == JSONRPC_ERROR)
+ && json_equal(id, reply->id)) {
if (!pstream_verify_name(name)) {
reconnect_set_passive(s->reconnect, true, time_msec());
}
if (!pstream_verify_name(name)) {
reconnect_set_passive(s->reconnect, true, time_msec());
}