X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Fyaz-pdu-assoc-thread.cpp;h=e13297ebc48a06ab33ba37655daeaf50b01f20a0;hb=bed85d2160500f57db63f4ab9d5533e0225cce15;hp=23b930805cdd1f183c0c20c4a6b312190afa9f60;hpb=594ba02c8c039a6570451da08e3461f22a7d0d11;p=yazpp-moved-to-github.git diff --git a/src/yaz-pdu-assoc-thread.cpp b/src/yaz-pdu-assoc-thread.cpp index 23b9308..e13297e 100644 --- a/src/yaz-pdu-assoc-thread.cpp +++ b/src/yaz-pdu-assoc-thread.cpp @@ -1,10 +1,11 @@ -/* - * Copyright (c) 1998-2004, Index Data. +/* This file is part of the yazpp toolkit. + * Copyright (C) 1998-2012 Index Data and Mike Taylor * See the file LICENSE for details. - * - * $Id: yaz-pdu-assoc-thread.cpp,v 1.13 2005-10-10 15:59:43 adam Exp $ */ +#if HAVE_CONFIG_H +#include +#endif #ifdef WIN32 #define USE_THREADS 1 #endif @@ -30,8 +31,8 @@ #include #include -#include -#include +#include +#include using namespace yazpp_1; @@ -82,6 +83,14 @@ void PDU_AssocThread::childNotify(COMSTACK cs) /// Clone PDU Observer new_observable->m_PDU_Observer = m_PDU_Observer->sessionNotify(new_observable, cs_fileno(cs)); + + if (!new_observable->m_PDU_Observer) + { + new_observable->shutdown(); + delete new_observable; + delete socket_observable; + return; + } worker *w = new worker; w->m_assoc = new_observable; @@ -109,6 +118,7 @@ void PDU_AssocThread::childNotify(COMSTACK cs) /* * Local variables: * c-basic-offset: 4 + * c-file-style: "Stroustrup" * indent-tabs-mode: nil * End: * vim: shiftwidth=4 tabstop=8 expandtab