114 lines
3.2 KiB
C
114 lines
3.2 KiB
C
|
/* $Xorg: xtwatch.c,v 1.4 2001/02/09 02:06:01 xorgcvs Exp $ */
|
|||
|
/******************************************************************************
|
|||
|
|
|||
|
Copyright 1993, 1998 The Open Group
|
|||
|
|
|||
|
Permission to use, copy, modify, distribute, and sell this software and its
|
|||
|
documentation for any purpose is hereby granted without fee, provided that
|
|||
|
the above copyright notice appear in all copies and that both that
|
|||
|
copyright notice and this permission notice appear in supporting
|
|||
|
documentation.
|
|||
|
|
|||
|
The above copyright notice and this permission notice shall be included in
|
|||
|
all copies or substantial portions of the Software.
|
|||
|
|
|||
|
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|||
|
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|||
|
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|||
|
OPEN GROUP BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
|
|||
|
AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
|||
|
CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
|
|||
|
|
|||
|
Except as contained in this notice, the name of The Open Group shall not be
|
|||
|
used in advertising or otherwise to promote the sale, use or other dealings
|
|||
|
in this Software without prior written authorization from The Open Group.
|
|||
|
******************************************************************************/
|
|||
|
/* $XFree86: xc/programs/xsm/xtwatch.c,v 1.4 2001/01/17 23:46:31 dawes Exp $ */
|
|||
|
|
|||
|
#include <X11/ICE/ICElib.h>
|
|||
|
#include <X11/Intrinsic.h>
|
|||
|
#include "xsm.h"
|
|||
|
#include "xtwatch.h"
|
|||
|
|
|||
|
static void _XtIceWatchProc(IceConn ice_conn, IcePointer client_data,
|
|||
|
Bool opening, IcePointer *watch_data );
|
|||
|
static void _XtProcessIceMsgProc(XtPointer client_data, int *source,
|
|||
|
XtInputId *id);
|
|||
|
|
|||
|
|
|||
|
Status
|
|||
|
InitWatchProcs(XtAppContext appContext)
|
|||
|
{
|
|||
|
|
|||
|
return (IceAddConnectionWatch (_XtIceWatchProc, (IcePointer) appContext));
|
|||
|
}
|
|||
|
|
|||
|
|
|||
|
static void
|
|||
|
_XtIceWatchProc(IceConn ice_conn, IcePointer client_data, Bool opening,
|
|||
|
IcePointer *watch_data)
|
|||
|
{
|
|||
|
if (opening)
|
|||
|
{
|
|||
|
XtAppContext appContext = (XtAppContext) client_data;
|
|||
|
|
|||
|
*watch_data = (IcePointer) XtAppAddInput (
|
|||
|
appContext,
|
|||
|
IceConnectionNumber (ice_conn),
|
|||
|
(XtPointer) XtInputReadMask,
|
|||
|
_XtProcessIceMsgProc,
|
|||
|
(XtPointer) ice_conn);
|
|||
|
}
|
|||
|
else
|
|||
|
{
|
|||
|
XtRemoveInput ((XtInputId) *watch_data);
|
|||
|
}
|
|||
|
}
|
|||
|
|
|||
|
|
|||
|
static void
|
|||
|
_XtProcessIceMsgProc(XtPointer client_data, int *source, XtInputId *id)
|
|||
|
{
|
|||
|
IceConn ice_conn = (IceConn) client_data;
|
|||
|
IceProcessMessagesStatus status;
|
|||
|
|
|||
|
status = IceProcessMessages (ice_conn, NULL, NULL);
|
|||
|
|
|||
|
if (status == IceProcessMessagesIOError)
|
|||
|
{
|
|||
|
List *cl;
|
|||
|
int found = 0;
|
|||
|
|
|||
|
if (verbose)
|
|||
|
{
|
|||
|
printf ("IO error on connection (fd = %d)\n",
|
|||
|
IceConnectionNumber (ice_conn));
|
|||
|
printf ("\n");
|
|||
|
}
|
|||
|
|
|||
|
for (cl = ListFirst (RunningList); cl; cl = ListNext (cl))
|
|||
|
{
|
|||
|
ClientRec *client = (ClientRec *) cl->thing;
|
|||
|
|
|||
|
if (client->ice_conn == ice_conn)
|
|||
|
{
|
|||
|
CloseDownClient (client);
|
|||
|
found = 1;
|
|||
|
break;
|
|||
|
}
|
|||
|
}
|
|||
|
|
|||
|
if (!found)
|
|||
|
{
|
|||
|
/*
|
|||
|
* The client must have disconnected before it was added
|
|||
|
* to the session manager's running list (i.e. before the
|
|||
|
* NewClientProc callback was invoked).
|
|||
|
*/
|
|||
|
|
|||
|
IceSetShutdownNegotiation (ice_conn, False);
|
|||
|
IceCloseConnection (ice_conn);
|
|||
|
}
|
|||
|
}
|
|||
|
}
|