mirror of
https://github.com/gnustep/libs-gsweb.git
synced 2025-02-24 04:01:16 +00:00
57ca07a26d
Compilation is OK but this version hasn't been tested
* GSWeb.framework/GSWFileUpload.m: Added Traces
corrected bug when uploading string type data.
* GSWExtensionsGSW.framework/GSWFileUploadFormComponent.m:
handle nil fileInfo retrieving, added isDeleteEnabled
* GSWExtensionsGSW.framework/GSWFileUploadFormComponent.gswc/GSWFileUploadFormComponent.html/.gswd:
added isDeleteEnabled condition
* GSWAdaptors/commun/GSWConfig.c/.h: added adaptorTemplatesPath handle (per application and global)
* GSWAdaptors/commun/GSWApp.h/.c: added pszAdaptorTemplatesPath
* GSWAdaptors/commun/GSWHTTPResponse.c added parameter to GSWTemplate_* calls
* GSWAdaptors/commun/GSWAppRequest.c added parameter to GSWTemplate_* calls
* GSWAdaptors/commun/GSWTemplates.h/.c: added GSWApp* parameter
o handle per application Templates
* GSWeb.framework/GSWResourcesManager.m: traces
* GSWeb.framework/GSWApplication.m:
o change trace level from "low" to "application"
o added filterLanguages: method
* GSWeb.framework/GSWContext.m: added filterLanguages: call in _languages
* GSWeb.framework/GSWAssociations.m: traces
* GSWeb.framework/GSWSession.m: Added Traces
* GSWeb.framework/GSWUtils.m: Added warning
* GSWeb.framework/GSWRequest.m: Added Traces
* GSWeb.framework/GSWWOCompatibility.h/.m: added WOImageButton
* GSWeb.framework/GSWPopUpButton.m: Added Traces
* GSWeb.framework/GSWResponse.m: fix stringByEscapingHTMLString:
o stringByEscapingHTMLAttributeValue:
o stringByConvertingToHTMLEntities:
o stringByConvertingToHTML:
* GSWeb.framework/NSObject+IVarAccess+PerformSel.m: added EOF access type
git-svn-id: svn+ssh://svn.gna.org/svn/gnustep/libs/gsweb/trunk@11266 72102866-910b-0410-8b05-ffd578937521
657 lines
21 KiB
Objective-C
657 lines
21 KiB
Objective-C
/* GSWDefaultAdaptor.m - GSWeb: Class GSWDefaultAdaptor
|
|
Copyright (C) 1999 Free Software Foundation, Inc.
|
|
|
|
Written by: Manuel Guesdon <mguesdon@sbuilders.com>
|
|
Date: Jan 1999
|
|
|
|
This file is part of the GNUstep Web Library.
|
|
|
|
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.
|
|
*/
|
|
|
|
static char rcsId[] = "$Id$";
|
|
|
|
#include <GSWeb/GSWeb.h>
|
|
|
|
//====================================================================
|
|
@implementation GSWDefaultAdaptor
|
|
|
|
-(id)initWithName:(NSString*)name_
|
|
arguments:(NSDictionary*)arguments_
|
|
{
|
|
NSDebugMLog(@"Init");
|
|
if ((self=[super initWithName:name_
|
|
arguments:arguments_]))
|
|
{
|
|
fileHandle=nil;
|
|
threads=[NSMutableArray new];
|
|
waitingThreads=[NSMutableArray new];
|
|
selfLock=[NSLock new];
|
|
port=[[arguments_ objectForKey:GSWOPT_Port[GSWebNamingConv]] intValue];
|
|
NSDebugMLLog(@"info",@"port=%d",port);
|
|
ASSIGN(host,[arguments_ objectForKey:GSWOPT_Host[GSWebNamingConv]]);
|
|
// [self setInstance:_instance];
|
|
queueSize=[[arguments_ objectForKey:GSWOPT_ListenQueueSize[GSWebNamingConv]] intValue];
|
|
workerThreadCount=[[arguments_ objectForKey:GSWOPT_WorkerThreadCount[GSWebNamingConv]] intValue];
|
|
isMultiThreadEnabled=[[arguments_ objectForKey:GSWOPT_MultiThreadEnabled] boolValue];
|
|
};
|
|
LOGObjectFnStop();
|
|
return self;
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
-(void)dealloc
|
|
{
|
|
GSWLogC("Dealloc GSWDefaultAdaptor");
|
|
//TODO? DESTROY(listenPortObject);
|
|
GSWLogC("Dealloc GSWDefaultAdaptor: host");
|
|
DESTROY(host);
|
|
GSWLogC("Dealloc GSWDefaultAdaptor: fileHandle");
|
|
DESTROY(fileHandle);
|
|
GSWLogC("Dealloc GSWDefaultAdaptor: threads");
|
|
DESTROY(threads);
|
|
GSWLogC("Dealloc GSWDefaultAdaptor: waitingThreads");
|
|
DESTROY(waitingThreads);
|
|
GSWLogC("Dealloc GSWDefaultAdaptor: selfLock");
|
|
DESTROY(selfLock);
|
|
GSWLogC("Dealloc GSWDefaultAdaptor Super");
|
|
[super dealloc];
|
|
GSWLogC("End Dealloc GSWDefaultAdaptor");
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
-(void)registerForEvents
|
|
{
|
|
NSDebugMLog(@"START registerForEvents - ThreadID=%p",(void*)objc_thread_id());
|
|
NSAssert(!fileHandle,@"fileHandle already exists");
|
|
NSDebugMLLog(@"info",@"registerForEvents port=%d",port);
|
|
NSDebugMLLog(@"info",@"registerForEvents host=%@",host);
|
|
if (!host)
|
|
{
|
|
ASSIGN(host,[[NSHost currentHost] name]);
|
|
};
|
|
fileHandle=[[NSFileHandle fileHandleAsServerAtAddress:host
|
|
service:[NSString stringWithFormat:@"%d",port]
|
|
protocol:@"tcp"] retain];
|
|
NSDebugMLLog(@"info",@"fileHandle=%p\n",(void*)fileHandle);
|
|
[[NSNotificationCenter defaultCenter] addObserver:self
|
|
selector: @selector(announceNewConnection:)
|
|
name: NSFileHandleConnectionAcceptedNotification
|
|
object:fileHandle];
|
|
/* [NotificationDispatcher addObserver:self
|
|
selector: @selector(announceNewConnection:)
|
|
name: NSFileHandleConnectionAcceptedNotification
|
|
object:fileHandle];
|
|
*/
|
|
[fileHandle acceptConnectionInBackgroundAndNotify];
|
|
NSDebugMLog(@"ThreadID=%p - B readInProgress=%d",(void*)objc_thread_id(),(int)[fileHandle readInProgress]);
|
|
printf("ThreadID=%p - B readInProgress=%d\n",(void*)objc_thread_id(),(int)[fileHandle readInProgress]);
|
|
[GSWApplication statusLogWithFormat:@"ThreadID %p: Waiting for connections.",(void*)objc_thread_id()];
|
|
NSDebugMLog(@"STOP registerForEvents");
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
-(void)unregisterForEvents
|
|
{
|
|
printf("ThreadID=%p - unregisterForEvents\n",(void*)objc_thread_id());
|
|
[[NSNotificationCenter defaultCenter] removeObserver:self
|
|
name: NSFileHandleConnectionAcceptedNotification
|
|
object:fileHandle];
|
|
/* [NotificationDispatcher removeObserver:self
|
|
name: NSFileHandleConnectionAcceptedNotification
|
|
object:fileHandle];
|
|
*/
|
|
DESTROY(fileHandle);
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
-(void)logWithFormat:(NSString*)_format,...
|
|
{
|
|
LOGObjectFnNotImplemented(); //TODOFN
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
+(void)logWithFormat:(NSString*)_format,...
|
|
{
|
|
LOGClassFnNotImplemented(); //TODOFN
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
-(void)runOnce
|
|
{
|
|
//call doesBusyRunOnce
|
|
LOGObjectFnNotImplemented(); //TODOFN
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
-(BOOL)doesBusyRunOnce
|
|
{
|
|
//call _runOnce
|
|
LOGObjectFnNotImplemented(); //TODOFN
|
|
return NO;
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
-(BOOL)dispatchesRequestsConcurrently
|
|
{
|
|
return YES;
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
-(int)port
|
|
{
|
|
return port;
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
-(NSString*)host
|
|
{
|
|
return host;
|
|
};
|
|
|
|
|
|
//--------------------------------------------------------------------
|
|
-(void)setWorkerThreadCount:(id)workerThreadCount_
|
|
{
|
|
if ([self tryLock])
|
|
{
|
|
NS_DURING
|
|
{
|
|
workerThreadCount=[workerThreadCount_ intValue];
|
|
if (workerThreadCount<1)
|
|
workerThreadCount=1;
|
|
}
|
|
NS_HANDLER
|
|
{
|
|
LOGException(@"%@ (%@)",
|
|
localException,
|
|
[localException reason]);
|
|
}
|
|
NS_ENDHANDLER;
|
|
[self unlock];
|
|
}
|
|
else
|
|
{
|
|
//TODO
|
|
};
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
-(id)workerThreadCount
|
|
{
|
|
return [NSNumber numberWithInt:workerThreadCount];
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
-(BOOL)isMultiThreadEnabled
|
|
{
|
|
return isMultiThreadEnabled;
|
|
};
|
|
//--------------------------------------------------------------------
|
|
-(void)setListenQueueSize:(id)listenQueueSize_
|
|
{
|
|
if ([self tryLock])
|
|
{
|
|
NS_DURING
|
|
{
|
|
queueSize=[listenQueueSize_ intValue];
|
|
if (queueSize<1)
|
|
queueSize=1;
|
|
}
|
|
NS_HANDLER
|
|
{
|
|
LOGException(@"%@ (%@)",
|
|
localException,
|
|
[localException reason]);
|
|
}
|
|
NS_ENDHANDLER;
|
|
[self unlock];
|
|
}
|
|
else
|
|
{
|
|
//TODO
|
|
};
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
//NDFN
|
|
-(id)announceNewConnection:(id)notification
|
|
{
|
|
GSWDefaultAdaptorThread* _newThread=nil;
|
|
NSFileHandle* _listenHandle=nil;
|
|
NSFileHandle* inStream = nil;
|
|
NSCalendarDate* requestDate=nil;
|
|
NSString* requestDateString=nil;
|
|
LOGObjectFnStart();
|
|
_listenHandle=[notification object];
|
|
requestDate=[NSCalendarDate calendarDate];
|
|
requestDateString=[NSString stringWithFormat:@"ThreadID=%p: New Request %@",(void*)objc_thread_id(),requestDate];
|
|
[GSWApplication statusLogWithFormat:@"%@",requestDateString];
|
|
NSDebugMLLog(@"info",@"_listenHandle=%p",(void*)_listenHandle);
|
|
inStream = [[notification userInfo]objectForKey:@"NSFileHandleNotificationFileHandleItem"];
|
|
printf("ThreadID=%p announceNewConnection notification=%@ socketAddress=%@ [notification userInfo]=%p\n",
|
|
(void*)objc_thread_id(),
|
|
notification,
|
|
[inStream socketAddress],
|
|
[notification userInfo]);
|
|
NSDebugMLLog(@"info",@"notification userInfo=%@\n",
|
|
[notification userInfo]);
|
|
NSDebugMLog(@"ThreadID=%p - A1 readInProgress=%d",
|
|
(void*)objc_thread_id(),
|
|
(int)[fileHandle readInProgress]);
|
|
printf("ThreadID=%p - A1 readInProgress=%d\n",
|
|
(void*)objc_thread_id(),
|
|
(int)[fileHandle readInProgress]);
|
|
printf("NEW CONN APP selfLockn=%d selfLock_thread_id=%p globalLockn=%d globalLock_thread_id=%p threads count=%d waitingThreads count=%d blocked=%d\n",
|
|
(int)([GSWApplication application]->selfLockn),
|
|
(void*)([GSWApplication application]->selfLock_thread_id),
|
|
(int)([GSWApplication application]->globalLockn),
|
|
(void*)([GSWApplication application]->globalLock_thread_id),
|
|
[threads count],
|
|
[waitingThreads count],
|
|
blocked);
|
|
printf("[waitingThreads count]=%d queueSize=%d",[waitingThreads count],queueSize);
|
|
if ([waitingThreads count]>=queueSize)
|
|
{
|
|
//remove expired thread
|
|
if ([self tryLock])
|
|
{
|
|
NSDebugMLog0(@"locked !");
|
|
NS_DURING
|
|
{
|
|
int i=0;
|
|
GSWDefaultAdaptorThread* thread=nil;
|
|
for(i=0;i<[waitingThreads count];)
|
|
{
|
|
thread=[waitingThreads objectAtIndex:i];
|
|
if ([thread isExpired])
|
|
{
|
|
// [GSWDefaultAdaptorThread sendRetryLasterResponseToStream:[thread stream]];
|
|
[waitingThreads removeObjectAtIndex:i];
|
|
}
|
|
else
|
|
i++;
|
|
};
|
|
}
|
|
NS_HANDLER
|
|
{
|
|
LOGException(@"%@ (%@)",
|
|
localException,[localException reason]);
|
|
//TODO
|
|
[self unlock];
|
|
[localException raise];
|
|
}
|
|
NS_ENDHANDLER;
|
|
[self unlock];
|
|
};
|
|
};
|
|
if ([waitingThreads count]>=queueSize)
|
|
{
|
|
printf("DESTROY the connection: too many conn - ThreadID=%p - A1 readInProgress=%d\n",(void*)objc_thread_id(),(int)[fileHandle readInProgress]);
|
|
[GSWDefaultAdaptorThread sendRetryLasterResponseToStream:inStream];
|
|
//[inStream closeFile];
|
|
}
|
|
else
|
|
{
|
|
//release done after lock !
|
|
_newThread=[[GSWDefaultAdaptorThread alloc] initWithApp:[GSWApplication application]
|
|
withAdaptor:self
|
|
withStream:inStream];
|
|
if (_newThread)
|
|
{
|
|
NSDebugMLog0(@"_newThread !");
|
|
if ([self tryLock])
|
|
{
|
|
NSDebugMLog0(@"locked !");
|
|
NS_DURING
|
|
{
|
|
NSDebugMLLog(@"low",
|
|
@"[waitingThreads count]=%d [threads count]=%d",
|
|
[waitingThreads count],
|
|
[threads count]);
|
|
if ([threads count]<workerThreadCount)
|
|
{
|
|
[threads addObject:_newThread];
|
|
NSDebugMLLog(@"trace",@"isMultiThreadEnabled=%d",isMultiThreadEnabled);
|
|
if (isMultiThreadEnabled)
|
|
{
|
|
requestDate=[NSCalendarDate calendarDate];
|
|
requestDateString=[NSString stringWithFormat:@"ThreadID=%p : Lauch Thread (Multi) %@",
|
|
(void*)objc_thread_id(),
|
|
requestDate];
|
|
[GSWApplication statusLogWithFormat:@"%@",requestDateString];
|
|
NSDebugMLLog(@"info",
|
|
@"ThreadID=%p : Lauch Thread (Multi) %p",
|
|
(void*)objc_thread_id(),
|
|
(void*)_newThread);
|
|
[NSThread detachNewThreadSelector:@selector(run:)
|
|
toTarget:_newThread
|
|
withObject:nil];
|
|
DESTROY(_newThread);
|
|
}
|
|
else
|
|
{
|
|
//Runit after
|
|
/*
|
|
[GSWApplication statusLogWithFormat:@"Lauch Thread (Mono)"];
|
|
NSDebugMLLog(@"info",
|
|
@"Lauch Thread (Mono) %p",
|
|
(void*)_newThread);
|
|
[_newThread run:nil];
|
|
*/
|
|
};
|
|
}
|
|
else
|
|
{
|
|
[GSWApplication statusLogWithFormat:@"Set Thread to wait"];
|
|
NSDebugMLLog(@"info",
|
|
@"Set Thread to wait %p",
|
|
(void*)_newThread);
|
|
[waitingThreads addObject:_newThread];
|
|
DESTROY(_newThread);
|
|
};
|
|
}
|
|
NS_HANDLER
|
|
{
|
|
LOGException(@"%@ (%@)",
|
|
localException,[localException reason]);
|
|
//TODO
|
|
[self unlock];
|
|
[localException raise];
|
|
}
|
|
NS_ENDHANDLER;
|
|
[self unlock];
|
|
}
|
|
else
|
|
{
|
|
DESTROY(_newThread);
|
|
};
|
|
};
|
|
if (!isMultiThreadEnabled && _newThread)
|
|
{
|
|
requestDate=[NSCalendarDate calendarDate];
|
|
requestDateString=[NSString stringWithFormat:@"Lauch Thread (Mono) %@",requestDate];
|
|
[GSWApplication statusLogWithFormat:@"%@",requestDateString];
|
|
NSDebugMLLog(@"info",
|
|
@"%@ %p",
|
|
requestDateString,
|
|
(void*)_newThread);
|
|
[_newThread run:nil];
|
|
DESTROY(_newThread);
|
|
requestDate=[NSCalendarDate calendarDate];
|
|
requestDateString=[NSString stringWithFormat:@"Stop Thread (Mono) %@",requestDate];
|
|
[GSWApplication statusLogWithFormat:@"%@",requestDateString];
|
|
NSDebugMLLog0(@"info",
|
|
requestDateString);
|
|
};
|
|
};
|
|
NSDebugMLLog(@"trace",@"Try Lock");
|
|
if ([self tryLock])
|
|
{
|
|
BOOL accept=YES;//NEW[waitingThreads count]<queueSize;
|
|
NSDebugMLLog(@"trace",@"Accept=%d",accept);
|
|
NS_DURING
|
|
{
|
|
if (accept)
|
|
{
|
|
[_listenHandle acceptConnectionInBackgroundAndNotify];
|
|
blocked=NO;
|
|
printf("ACCEPT ThreadID=%p A2 readInProgress=%d\n",(void*)objc_thread_id(),(int)[fileHandle readInProgress]);
|
|
}
|
|
else
|
|
printf("NOT ACCEPT ThreadID=%p A2 readInProgress=%d\n",(void*)objc_thread_id(),(int)[fileHandle readInProgress]);
|
|
|
|
NSDebugMLog(@"ThreadID=%p A2 readInProgress=%d",(void*)objc_thread_id(),(int)[fileHandle readInProgress]);
|
|
printf("ThreadID=%p A2 readInProgress=%d\n",(void*)objc_thread_id(),(int)[fileHandle readInProgress]);
|
|
}
|
|
NS_HANDLER
|
|
{
|
|
LOGException(@"%@ (%@)",
|
|
localException,[localException reason]);
|
|
//TODO
|
|
blocked=!accept;
|
|
[self unlock];
|
|
[localException raise];
|
|
}
|
|
NS_ENDHANDLER;
|
|
blocked=!accept;
|
|
printf("blocked=%d",blocked);
|
|
[self unlock];
|
|
};
|
|
NSDebugMLLog(@"trace",@"end announceNewConnection");
|
|
printf("END NEWCONN APP selfLockn=%d selfLock_thread_id=%p globalLockn=%d globalLock_thread_id=%p threads count=%d waitingThreads count=%d blocked=%d acceptOK\n",
|
|
(int)([GSWApplication application]->selfLockn),
|
|
(void*)([GSWApplication application]->selfLock_thread_id),
|
|
(int)([GSWApplication application]->globalLockn),
|
|
(void*)([GSWApplication application]->globalLock_thread_id),
|
|
[threads count],
|
|
[waitingThreads count],
|
|
blocked);
|
|
LOGObjectFnStop();
|
|
return self;
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
-(void)adaptorThreadExited:(GSWDefaultAdaptorThread*)adaptorThread_
|
|
{
|
|
LOGObjectFnStart();
|
|
// NSDebugMLLog(@"trace",@"adaptorThreadExited");
|
|
printf("adaptorThreadExited\n");
|
|
printf("EXIT APP selfLockn=%d selfLock_thread_id=%p globalLockn=%d globalLock_thread_id=%p threads count=%d waitingThreads count=%d blocked=%d\n",
|
|
(int)([GSWApplication application]->selfLockn),
|
|
(void*)([GSWApplication application]->selfLock_thread_id),
|
|
(int)([GSWApplication application]->globalLockn),
|
|
(void*)([GSWApplication application]->globalLock_thread_id),
|
|
[threads count],
|
|
[waitingThreads count],
|
|
blocked);
|
|
|
|
if ([self tryLock])
|
|
{
|
|
NSAutoreleasePool* pool=nil;
|
|
#ifndef NDEBUG
|
|
pool=[NSAutoreleasePool new];
|
|
NSDebugMLLog(@"low",
|
|
@"remove thread %p",
|
|
(void*)adaptorThread_);
|
|
DESTROY(pool);
|
|
#endif
|
|
NS_DURING
|
|
{
|
|
[adaptorThread_ retain];
|
|
[adaptorThread_ autorelease];
|
|
[threads removeObject:adaptorThread_];
|
|
}
|
|
NS_HANDLER
|
|
{
|
|
pool=[NSAutoreleasePool new];
|
|
LOGException(@"%@ (%@)",
|
|
localException,
|
|
[localException reason]);
|
|
DESTROY(pool);
|
|
//TODO
|
|
// [self unlock];
|
|
// [localException raise];
|
|
}
|
|
NS_ENDHANDLER;
|
|
#ifndef NDEBUG
|
|
pool=[NSAutoreleasePool new];
|
|
NSDebugMLLog(@"low",
|
|
@"[waitingThreads count]=%d [threads count]=%d",
|
|
[waitingThreads count],
|
|
[threads count]);
|
|
DESTROY(pool);
|
|
#endif
|
|
if ([threads count]==0)
|
|
{
|
|
BOOL _isApplicationRequestHandlingLocked=[[GSWApplication application] isRequestHandlingLocked];
|
|
if (_isApplicationRequestHandlingLocked)
|
|
{
|
|
pool=[NSAutoreleasePool new];
|
|
LOGSeriousError0(@"Application RequestHandling is LOCKED !!!");
|
|
NSAssert(NO,@"Application RequestHandling is LOCKED !!!");//TODO-NOW
|
|
[[GSWApplication application] terminate];
|
|
DESTROY(pool);
|
|
};
|
|
};
|
|
if ([waitingThreads count]>0 && [threads count]<workerThreadCount)
|
|
{
|
|
NS_DURING
|
|
{
|
|
GSWDefaultAdaptorThread* _thread=nil;
|
|
while(!_thread && [waitingThreads count]>0)
|
|
{
|
|
_thread=[waitingThreads objectAtIndex:0];
|
|
if ([_thread isExpired])
|
|
{
|
|
// [GSWDefaultAdaptorThread sendRetryLasterResponseToStream:[_thread stream]];
|
|
_thread=nil;
|
|
}
|
|
else
|
|
[threads addObject:_thread];
|
|
[waitingThreads removeObjectAtIndex:0];
|
|
};
|
|
if (_thread)
|
|
{
|
|
#ifndef NDEBUG
|
|
pool=[NSAutoreleasePool new];
|
|
[GSWApplication statusLogWithFormat:@"Lauch waiting Thread"];
|
|
NSDebugMLLog(@"info",
|
|
@"Lauch waiting Thread %p",
|
|
(void*)_thread);
|
|
DESTROY(pool);
|
|
#endif
|
|
if (isMultiThreadEnabled)
|
|
[NSThread detachNewThreadSelector:@selector(run:)
|
|
toTarget:_thread
|
|
withObject:nil];
|
|
else
|
|
[_thread run:nil];
|
|
};
|
|
}
|
|
NS_HANDLER
|
|
{
|
|
pool=[NSAutoreleasePool new];
|
|
LOGException(@"%@ (%@)",
|
|
localException,
|
|
[localException reason]);
|
|
DESTROY(pool);
|
|
//TODO
|
|
// [self unlock];
|
|
// [localException raise];
|
|
}
|
|
NS_ENDHANDLER;
|
|
};
|
|
|
|
NS_DURING
|
|
{
|
|
BOOL accept=[waitingThreads count]<queueSize;
|
|
if (blocked && accept)
|
|
{
|
|
printf("ACCEPT AGAIN ThreadID=%p A2 readInProgress=%d\n",(void*)objc_thread_id(),(int)[fileHandle readInProgress]);
|
|
[fileHandle acceptConnectionInBackgroundAndNotify];
|
|
blocked=NO;
|
|
};
|
|
}
|
|
NS_HANDLER
|
|
{
|
|
pool=[NSAutoreleasePool new];
|
|
LOGException(@"%@ (%@)",
|
|
localException,
|
|
[localException reason]);
|
|
DESTROY(pool);
|
|
//TODO
|
|
// [self unlock];
|
|
// [localException raise];
|
|
}
|
|
NS_ENDHANDLER;
|
|
|
|
[self unlock];
|
|
};
|
|
//TODO remove
|
|
printf("END EXIT APP selfLockn=%d selfLock_thread_id=%p globalLockn=%d globalLock_thread_id=%p threads count=%d waitingThreads count=%d blocked=%d\n",
|
|
(int)([GSWApplication application]->selfLockn),
|
|
(void*)([GSWApplication application]->selfLock_thread_id),
|
|
(int)([GSWApplication application]->globalLockn),
|
|
(void*)([GSWApplication application]->globalLock_thread_id),
|
|
[threads count],
|
|
[waitingThreads count],
|
|
blocked);
|
|
// (int)(((UnixFileHandle*)fileHandle)->acceptOK));
|
|
NSDebugMLog(@"ThreadID=%p B2 readInProgress=%d",(void*)objc_thread_id(),(int)[fileHandle readInProgress]);
|
|
printf("ThreadID=%p B2 readInProgress=%d\n",(void*)objc_thread_id(),(int)[fileHandle readInProgress]);
|
|
LOGObjectFnStop();
|
|
};
|
|
|
|
-(NSFileHandle*)fileHandle
|
|
{
|
|
return fileHandle;
|
|
};
|
|
//--------------------------------------------------------------------
|
|
//NDFN
|
|
-(id)announceBrokenConnection:(id)notification
|
|
{
|
|
LOGObjectFnNotImplemented(); //TODOFN
|
|
NSDebugMLLog(@"trace",@"announceBrokenConnection");
|
|
// [self shutDownConnectionWithSocket:[in_port _port_socket]];
|
|
return self;
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
// lock
|
|
-(BOOL)tryLock
|
|
{
|
|
BOOL _locked=NO;
|
|
LOGObjectFnStart();
|
|
printf("self=%p ThreadID=%p TRYLOCK\n",self,(void*)objc_thread_id());
|
|
_locked=[selfLock tmptryLockBeforeDate:[NSDate dateWithTimeIntervalSinceNow:90]];
|
|
printf("self=%p ThreadID=%p TRYLOCK LOCKED ?\n",self,(void*)objc_thread_id());
|
|
LOGObjectFnStop();
|
|
return _locked;
|
|
};
|
|
|
|
//--------------------------------------------------------------------
|
|
// unlock
|
|
-(void)unlock
|
|
{
|
|
LOGObjectFnStart();
|
|
printf("self=%p ThreadID=%p UNLOCK\n",self,(void*)objc_thread_id());
|
|
[selfLock tmpunlock];
|
|
printf("self=%p ThreadID=%p UNLOCK UNLOCKED ?\n",self,(void*)objc_thread_id());
|
|
LOGObjectFnStop();
|
|
};
|
|
|
|
@end
|
|
|
|
|
|
//====================================================================
|
|
@implementation GSWDefaultAdaptor (GSWDefaultAdaptorA)
|
|
-(void)stop
|
|
{
|
|
LOGObjectFnNotImplemented(); //TODOFN
|
|
};
|
|
|
|
-(void)run
|
|
{
|
|
LOGObjectFnNotImplemented(); //TODOFN
|
|
};
|
|
|
|
-(void)_runOnce
|
|
{
|
|
LOGObjectFnNotImplemented(); //TODOFN
|
|
};
|
|
|
|
@end
|
|
|