std::string host, int timeout_sec)
: Z_Assoc(PDU_Observable),
m_socket_manager(socket_manager), m_PDU_Observable(PDU_Observable),
std::string host, int timeout_sec)
: Z_Assoc(PDU_Observable),
m_socket_manager(socket_manager), m_PDU_Observable(PDU_Observable),
- m_package(0), m_in_use(true), m_waiting(false),
+ m_package(0), m_in_use(true), m_waiting(false),
m_destroyed(false), m_connected(false), m_has_closed(false),
m_queue_len(1),
m_time_elapsed(0), m_time_max(timeout_sec), m_time_connect_max(10),
m_destroyed(false), m_connected(false), m_has_closed(false),
m_queue_len(1),
m_time_elapsed(0), m_time_max(timeout_sec), m_time_connect_max(10),
m_package->response() = odr.create_close(apdu, Z_Close_peerAbort, 0);
m_package->session().close();
}
m_package->response() = odr.create_close(apdu, Z_Close_peerAbort, 0);
m_package->session().close();
}
// should really check for nsd->which.. But union has two members
// containing almost same data
const char *v2Addinfo = nsd->u.v2Addinfo;
// should really check for nsd->which.. But union has two members
// containing almost same data
const char *v2Addinfo = nsd->u.v2Addinfo;
if (unit->which == Z_OtherInfo_externallyDefinedInfo &&
unit->information.externallyDefinedInfo &&
unit->information.externallyDefinedInfo->which ==
if (unit->which == Z_OtherInfo_externallyDefinedInfo &&
unit->information.externallyDefinedInfo &&
unit->information.externallyDefinedInfo->which ==
{
// only one thread messes with the clients list at a time
boost::mutex::scoped_lock lock(m_mutex);
std::map<mp::Session,yf::Z3950Client::Assoc *>::iterator it;
{
// only one thread messes with the clients list at a time
boost::mutex::scoped_lock lock(m_mutex);
std::map<mp::Session,yf::Z3950Client::Assoc *>::iterator it;
apdu,
YAZ_BIB1_INIT_NEGOTIATION_OPTION_REQUIRED,
"z3950_client: No vhost given");
apdu,
YAZ_BIB1_INIT_NEGOTIATION_OPTION_REQUIRED,
"z3950_client: No vhost given");
}
}
yaz_log(YLOG_LOG, "Found %d/%d connections for %s", number, max_sockets,
}
}
yaz_log(YLOG_LOG, "Found %d/%d connections for %s", number, max_sockets,
package.response() = odr.create_initResponse(
apdu, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, "max sessions");
package.session().close();
package.response() = odr.create_initResponse(
apdu, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, "max sessions");
package.session().close();
package.response() = odr.create_initResponse(
apdu, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, "max sessions");
package.session().close();
package.response() = odr.create_initResponse(
apdu, YAZ_BIB1_TEMPORARY_SYSTEM_ERROR, "max sessions");
package.session().close();
yazpp_1::SocketManager *sm = new yazpp_1::SocketManager;
yazpp_1::PDU_Assoc *pdu_as = new yazpp_1::PDU_Assoc(sm);
yf::Z3950Client::Assoc *as = new yf::Z3950Client::Assoc(sm, pdu_as,
yazpp_1::SocketManager *sm = new yazpp_1::SocketManager;
yazpp_1::PDU_Assoc *pdu_as = new yazpp_1::PDU_Assoc(sm);
yf::Z3950Client::Assoc *as = new yf::Z3950Client::Assoc(sm, pdu_as,
package.request() = odr.create_close(
0, Z_Close_finished, "z3950_client");
c->m_package = 0; // don't inspect response
package.request() = odr.create_close(
0, Z_Close_finished, "z3950_client");
c->m_package = 0; // don't inspect response
{
boost::mutex::scoped_lock lock(m_mutex);
std::map<mp::Session,yf::Z3950Client::Assoc *>::iterator it;
{
boost::mutex::scoped_lock lock(m_mutex);
std::map<mp::Session,yf::Z3950Client::Assoc *>::iterator it;