Browse Source

Cleanup

git-svn-id: http://subversion.jackaudio.org/jack/jack2/trunk/jackmp@1355 0c269be4-1314-0410-8aa9-9f06e86f4224
tags/0.62
sletz 19 years ago
parent
commit
2f75c8e768
2 changed files with 21 additions and 54 deletions
  1. +17
    -18
      windows/JackWinNamedPipe.cpp
  2. +4
    -36
      windows/JackWinThread.cpp

+ 17
- 18
windows/JackWinNamedPipe.cpp View File

@@ -96,12 +96,12 @@ int JackWinNamedPipeClient::Connect(const char* dir, const char* name, int which


int JackWinNamedPipeClient::Close() int JackWinNamedPipeClient::Close()
{ {
if (fNamedPipe != INVALID_HANDLE_VALUE) {
CloseHandle(fNamedPipe);
fNamedPipe = INVALID_HANDLE_VALUE;
return 0;
if (fNamedPipe != INVALID_HANDLE_VALUE) {
CloseHandle(fNamedPipe);
fNamedPipe = INVALID_HANDLE_VALUE;
return 0;
} else { } else {
return -1;
return -1;
} }
} }


@@ -111,7 +111,6 @@ void JackWinNamedPipeClient::SetReadTimeOut(long sec)
void JackWinNamedPipeClient::SetWriteTimeOut(long sec) void JackWinNamedPipeClient::SetWriteTimeOut(long sec)
{} {}



JackWinAsyncNamedPipeClient::JackWinAsyncNamedPipeClient() JackWinAsyncNamedPipeClient::JackWinAsyncNamedPipeClient()
: JackWinNamedPipeClient(), fIOState(kIdle), fPendingIO(false) : JackWinNamedPipeClient(), fIOState(kIdle), fPendingIO(false)
{ {
@@ -281,8 +280,8 @@ bool JackWinNamedPipeServer::Accept()


JackWinNamedPipeClient* JackWinNamedPipeServer::AcceptClient() JackWinNamedPipeClient* JackWinNamedPipeServer::AcceptClient()
{ {
if (ConnectNamedPipe(fNamedPipe, NULL)) {
JackWinNamedPipeClient* client = new JackWinNamedPipeClient(fNamedPipe);
if (ConnectNamedPipe(fNamedPipe, NULL)) {
JackWinNamedPipeClient* client = new JackWinNamedPipeClient(fNamedPipe);
// Init the pipe to the default value // Init the pipe to the default value
fNamedPipe = INVALID_HANDLE_VALUE; fNamedPipe = INVALID_HANDLE_VALUE;
} else { } else {
@@ -300,16 +299,16 @@ JackWinNamedPipeClient* JackWinNamedPipeServer::AcceptClient()
} }


int JackWinNamedPipeServer::Close() int JackWinNamedPipeServer::Close()
{
JackLog("JackWinNamedPipeServer::Close\n");
if (fNamedPipe != INVALID_HANDLE_VALUE) {
DisconnectNamedPipe(fNamedPipe);
CloseHandle(fNamedPipe);
fNamedPipe = INVALID_HANDLE_VALUE;
return 0;
} else {
return -1;
{
JackLog("JackWinNamedPipeServer::Close\n");
if (fNamedPipe != INVALID_HANDLE_VALUE) {
DisconnectNamedPipe(fNamedPipe);
CloseHandle(fNamedPipe);
fNamedPipe = INVALID_HANDLE_VALUE;
return 0;
} else {
return -1;
} }
} }




+ 4
- 36
windows/JackWinThread.cpp View File

@@ -87,7 +87,7 @@ int JackWinThread::Start()
} }
} }


int JackWinThread::StartImp(pthread_t* thread, int priority, int realtime, ThreadCallback start_routine, void* arg)
int JackWinThread::StartImp(pthread_t* thread, int priority, int realtime, ThreadCallback start_routine, void* arg)
{ {
DWORD id; DWORD id;


@@ -206,29 +206,12 @@ int JackWinThread::Stop()


int JackWinThread::AcquireRealTime() int JackWinThread::AcquireRealTime()
{ {
/*
JackLog("JackWinThread::AcquireRealTime\n");

if (fThread) {
if (!SetThreadPriority(fThread, THREAD_PRIORITY_TIME_CRITICAL)) {
jack_error("Cannot set thread priority = %d", GetLastError());
return -1;
}
JackLog("JackWinThread::AcquireRealTime OK\n");
return 0;
} else {
return -1;
}
*/
return (fThread) ? AcquireRealTimeImp(fThread, fPriority) : -1; return (fThread) ? AcquireRealTimeImp(fThread, fPriority) : -1;
} }


int JackWinThread::AcquireRealTime(int priority) int JackWinThread::AcquireRealTime(int priority)
{ {
//JackLog("JackWinThread::AcquireRealTime priority = %ld\n", priority);
//return AcquireRealTime();
fPriority = priority;
fPriority = priority;
return AcquireRealTime(); return AcquireRealTime();
} }


@@ -244,21 +227,6 @@ int JackWinThread::AcquireRealTimeImp(pthread_t thread, int priority)
return -1; return -1;
} }
} }

/*
int JackWinThread::DropRealTime()
{
if (fThread) {
if (!SetThreadPriority(fThread, THREAD_PRIORITY_NORMAL)) {
jack_error("Cannot set thread priority = %d", GetLastError());
return -1;
}
return 0;
} else {
return -1;
}
}
*/
int JackWinThread::DropRealTime() int JackWinThread::DropRealTime()
{ {
return DropRealTimeImp(fThread); return DropRealTimeImp(fThread);
@@ -270,8 +238,8 @@ int JackWinThread::DropRealTimeImp(pthread_t thread)
return 0; return 0;
} else { } else {
jack_error("Cannot set thread priority = %d", GetLastError()); jack_error("Cannot set thread priority = %d", GetLastError());
return -1;
}
return -1;
}
} }


pthread_t JackWinThread::GetThreadID() pthread_t JackWinThread::GetThreadID()


Loading…
Cancel
Save