mirror of
https://github.com/gnustep/libs-gsweb.git
synced 2025-02-20 18:32:29 +00:00
o added
git-svn-id: svn+ssh://svn.gna.org/svn/gnustep/libs/gsweb/trunk@18155 72102866-910b-0410-8b05-ffd578937521
This commit is contained in:
Manuel Guesdon
parent
0b99f48dc4
commit
a1972df795
2 changed files with 318 additions and 0 deletions
79
GSWeb.framework/GSWLifebeatThread.h
Normal file
79
GSWeb.framework/GSWLifebeatThread.h
Normal file
|
|
@ -0,0 +1,79 @@
|
|||
/** GSWLifebeatThread.m - <title>GSWeb: Class GSWLifebeatThread</title>
|
||||
|
||||
Copyright (C) 2003 Free Software Foundation, Inc.
|
||||
|
||||
Written by: Manuel Guesdon <mguesdon@orange-concept.com>
|
||||
Date: Jul 2003
|
||||
|
||||
$Revision$
|
||||
$Date$
|
||||
$Id$
|
||||
|
||||
This file is part of the GNUstep Web Library.
|
||||
|
||||
<license>
|
||||
This library is free software; you can redistribute it and/or
|
||||
modify it under the terms of the GNU Library General Public
|
||||
License as published by the Free Software Foundation; either
|
||||
version 2 of the License, or (at your option) any later version.
|
||||
|
||||
This library is distributed in the hope that it will be useful,
|
||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
Library General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU Library General Public
|
||||
License along with this library; if not, write to the Free
|
||||
Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
|
||||
</license>
|
||||
**/
|
||||
|
||||
#ifndef _GSWLifebeatThread_h__
|
||||
#define _GSWLifebeatThread_h__
|
||||
|
||||
|
||||
//==============================================================================
|
||||
@interface GSWLifebeatThread: NSObject
|
||||
{
|
||||
NSAutoreleasePool* _pool;
|
||||
NSDate* _creationDate;
|
||||
GSWApplication* _application;
|
||||
NSString* _applicationName;
|
||||
int _applicationPort;
|
||||
NSString* _applicationHost;
|
||||
NSString* _lifebeatHost;
|
||||
int _lifebeatPort;
|
||||
NSTimeInterval _interval;
|
||||
NSString* _baseURL;
|
||||
NSDictionary* _messages;
|
||||
int _requestNamingConv;//GSWNAMES_INDEX or WONAMES_INDEX
|
||||
}
|
||||
|
||||
+(GSWLifebeatThread*)lifebeatThreadWithApplication:(GSWApplication*)application
|
||||
name:(NSString*)name
|
||||
host:(NSString*)host
|
||||
port:(int)port
|
||||
lifebeatHost:(NSString*)lifebeatHost
|
||||
lifebeatPort:(int)lifebeatPort
|
||||
interval:(NSTimeInterval)interval;
|
||||
-(id)initWithApplication:(GSWApplication*)application
|
||||
name:(NSString*)name
|
||||
host:(NSString*)host
|
||||
port:(int)port
|
||||
lifebeatHost:(NSString*)lifebeatHost
|
||||
lifebeatPort:(int)lifebeatPort
|
||||
interval:(NSTimeInterval)interval;
|
||||
|
||||
|
||||
-(void)run:(id)nothing;
|
||||
|
||||
-(NSAutoreleasePool*)pool;
|
||||
-(void)setPool:(NSAutoreleasePool*)pool
|
||||
destroyLast:(BOOL)destroy;
|
||||
|
||||
-(void)threadExited;
|
||||
+(id)threadExited:(NSNotification*)notif;
|
||||
|
||||
@end
|
||||
|
||||
#endif
|
||||
239
GSWeb.framework/GSWLifebeatThread.m
Normal file
239
GSWeb.framework/GSWLifebeatThread.m
Normal file
|
|
@ -0,0 +1,239 @@
|
|||
/** GSWLifebeatThread.m - <title>GSWeb: Class GSWLifebeatThread</title>
|
||||
|
||||
Copyright (C) 2003 Free Software Foundation, Inc.
|
||||
|
||||
Written by: Manuel Guesdon <mguesdon@orange-concept.com>
|
||||
Date: Jul 2003
|
||||
|
||||
$Revision$
|
||||
$Date$
|
||||
$Id$
|
||||
|
||||
<abstract></abstract>
|
||||
|
||||
This file is part of the GNUstep Web Library.
|
||||
|
||||
<license>
|
||||
This library is free software; you can redistribute it and/or
|
||||
modify it under the terms of the GNU Library General Public
|
||||
License as published by the Free Software Foundation; either
|
||||
version 2 of the License, or (at your option) any later version.
|
||||
|
||||
This library is distributed in the hope that it will be useful,
|
||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||
Library General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU Library General Public
|
||||
License along with this library; if not, write to the Free
|
||||
Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
|
||||
</license>
|
||||
**/
|
||||
|
||||
#include "config.h"
|
||||
|
||||
RCS_ID("$Id$")
|
||||
|
||||
#include <unistd.h>
|
||||
#include "GSWeb.h"
|
||||
#include "GSWLifebeatThread.h"
|
||||
|
||||
//====================================================================
|
||||
@implementation GSWLifebeatThread
|
||||
|
||||
+(GSWLifebeatThread*)lifebeatThreadWithApplication:(GSWApplication*)application
|
||||
name:(NSString*)name
|
||||
host:(NSString*)host
|
||||
port:(int)port
|
||||
lifebeatHost:(NSString*)lifebeatHost
|
||||
lifebeatPort:(int)lifebeatPort
|
||||
interval:(NSTimeInterval)interval
|
||||
{
|
||||
return [[[self alloc]initWithApplication:application
|
||||
name:name
|
||||
host:host
|
||||
port:port
|
||||
lifebeatHost:lifebeatHost
|
||||
lifebeatPort:lifebeatPort
|
||||
interval:interval]autorelease];
|
||||
};
|
||||
|
||||
//--------------------------------------------------------------------
|
||||
-(id)init
|
||||
{
|
||||
if ((self=[super init]))
|
||||
{
|
||||
ASSIGN(_creationDate,[NSDate date]);
|
||||
_requestNamingConv=GSWebNamingConv;//GSWNAMES_INDEX or WONAMES_INDEX
|
||||
};
|
||||
return self;
|
||||
};
|
||||
|
||||
//--------------------------------------------------------------------
|
||||
-(id)initWithApplication:(GSWApplication*)application
|
||||
name:(NSString*)name
|
||||
host:(NSString*)host
|
||||
port:(int)port
|
||||
lifebeatHost:(NSString*)lifebeatHost
|
||||
lifebeatPort:(int)lifebeatPort
|
||||
interval:(NSTimeInterval)interval
|
||||
{
|
||||
if ((self=[self init]))
|
||||
{
|
||||
_application=application; //don't retain
|
||||
ASSIGN(_applicationName,name);
|
||||
ASSIGN(_applicationHost,host);
|
||||
_applicationPort=port;
|
||||
ASSIGN(_lifebeatHost,lifebeatHost);
|
||||
_lifebeatPort=lifebeatPort;
|
||||
_interval=interval;
|
||||
|
||||
ASSIGN(_baseURL,([NSString stringWithFormat:@"http://%@:%d/GSWeb/gswtaskd.gswa/lb/applicationName=%@&applicationHost=%@&applicationPort=%d&",
|
||||
_lifebeatHost,
|
||||
lifebeatPort,
|
||||
_applicationName,
|
||||
_applicationHost,
|
||||
_applicationPort]));
|
||||
ASSIGN(_messages,([NSDictionary dictionaryWithObjectsAndKeys:
|
||||
[NSString stringWithFormat:@"%@message=hasStarted",_baseURL],
|
||||
@"hasStarted",
|
||||
|
||||
[NSString stringWithFormat:@"%@message=lifebeat",_baseURL],
|
||||
@"lifebeat",
|
||||
|
||||
[NSString stringWithFormat:@"%@message=willStop",_baseURL],
|
||||
@"willStop",
|
||||
|
||||
[NSString stringWithFormat:@"%@message=willCrash",_baseURL],
|
||||
@"willCrash",
|
||||
|
||||
nil]));
|
||||
};
|
||||
return self;
|
||||
};
|
||||
|
||||
//--------------------------------------------------------------------
|
||||
-(void)dealloc
|
||||
{
|
||||
GSWLogMemC("dealloc GSWLifebeatThread");
|
||||
DESTROY(_creationDate);
|
||||
DESTROY(_applicationName);
|
||||
DESTROY(_applicationHost);
|
||||
DESTROY(_lifebeatHost);
|
||||
DESTROY(_baseURL);
|
||||
DESTROY(_messages);
|
||||
GSWLogMemC("release pool");
|
||||
// DESTROY(_pool);
|
||||
GSWLogMemC("super dealloc");
|
||||
[super dealloc];
|
||||
GSWLogMemC("dealloc GSWLifebeatThread end");
|
||||
};
|
||||
|
||||
//--------------------------------------------------------------------
|
||||
-(NSAutoreleasePool*)pool
|
||||
{
|
||||
return _pool;
|
||||
};
|
||||
|
||||
//--------------------------------------------------------------------
|
||||
-(void)setPool:(NSAutoreleasePool*)pool
|
||||
destroyLast:(BOOL)destroy
|
||||
{
|
||||
if (destroy)
|
||||
{
|
||||
GSWLogMemC("dealloc pool\n");
|
||||
GSWLogMemCF("Destroy NSAutoreleasePool: %p. ThreadID=%p",_pool,(void*)objc_thread_id());
|
||||
DESTROY(_pool);
|
||||
GSWLogMemC("end dealloc pool\n");
|
||||
};
|
||||
_pool=pool;
|
||||
};
|
||||
|
||||
//--------------------------------------------------------------------
|
||||
-(void)sendMessage:(NSString*)message
|
||||
{
|
||||
NSURL* url=[NSURL URLWithString:message];
|
||||
NSData* data=[url resourceDataUsingCache:NO];
|
||||
NSDebugMLog(@"MESSAGE data=%@",data);//TODO handle it !
|
||||
};
|
||||
|
||||
//--------------------------------------------------------------------
|
||||
-(void)run:(id)nothing
|
||||
{
|
||||
_pool=[NSAutoreleasePool new];
|
||||
|
||||
[self sendMessage:[_messages objectForKey:@"hasStarted"]];
|
||||
NSTimeIntervalSleep(_interval);
|
||||
while(YES)
|
||||
{
|
||||
//TODO
|
||||
|
||||
// [self sendMessage:[_messages objectForKey:@"lifebeat"]];
|
||||
NSTimeIntervalSleep(_interval);
|
||||
};
|
||||
|
||||
|
||||
/*
|
||||
LOGObjectFnStop();
|
||||
#ifdef DEBUG
|
||||
[GSWApplication statusLogWithFormat:@"threadWillExit START"];
|
||||
#endif
|
||||
[_application threadWillExit];
|
||||
#ifdef DEBUG
|
||||
[GSWApplication statusLogWithFormat:@"threadWillExit STOP"];
|
||||
#endif
|
||||
if (_isMultiThread)
|
||||
{
|
||||
NSAssert([NSThread isMultiThreaded],@"No MultiThread !");
|
||||
[NSThread exit]; //???
|
||||
}
|
||||
else
|
||||
[self threadExited];
|
||||
#ifdef DEBUG
|
||||
[GSWApplication statusLogWithFormat:@"run STOP"];
|
||||
#endif
|
||||
*/
|
||||
};
|
||||
|
||||
//--------------------------------------------------------------------
|
||||
-(void)threadExited
|
||||
{
|
||||
// LOGObjectFnStart();
|
||||
// NSDebugMLLog0(@"trace",@"GSWLifebeatThread: threadExited method");
|
||||
// NSDebugMLLog(@"low",@"[_defaultAdaptorThread retainCount=%d",
|
||||
// (int)[self retainCount]);
|
||||
GSWLogMemCF("Will Destroy NSAutoreleasePool: %p",_pool);
|
||||
[self setPool:nil
|
||||
destroyLast:YES];
|
||||
// LOGObjectFnStop();
|
||||
GSWLogDeepC("threadExited\n");
|
||||
};
|
||||
/*
|
||||
//TODO
|
||||
//--------------------------------------------------------------------
|
||||
+(id)threadExited:(NSNotification*)notif
|
||||
{
|
||||
NSThread* thread=nil;
|
||||
NSMutableDictionary* threadDict=nil;
|
||||
GSWLifebeatThread* adaptorThread=nil;
|
||||
GSWLogDeepC("Start threadExited:");
|
||||
NSAssert([NSThread isMultiThreaded],@"No MultiThread !");
|
||||
NSDebugMLLog(@"low",@"notif=%@",notif);
|
||||
thread=[notif object];
|
||||
NSDebugMLLog(@"low",@"thread=%@",thread);
|
||||
threadDict = [thread threadDictionary];
|
||||
NSDebugMLLog(@"low",@"threadDict=%@",threadDict);
|
||||
adaptorThread=[threadDict objectForKey:GSWThreadKey_LifebeatThread];
|
||||
NSDebugMLLog(@"low",@"adaptorThread=%@",adaptorThread);
|
||||
[threadDict removeObjectForKey:GSWThreadKey_LifebeatThread];
|
||||
[[NSNotificationCenter defaultCenter] removeObserver:self
|
||||
name:NSThreadExiting//NSThreadWillExitNotification
|
||||
object:thread];
|
||||
[adaptorThread threadExited];
|
||||
GSWLogDeepC("Stop threadExited:");
|
||||
GSWLogDeepC("threadExited really exit");
|
||||
return nil; //??
|
||||
};
|
||||
*/
|
||||
|
||||
@end
|
||||
Loading…
Reference in a new issue