Aren/haiku
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

implemented SO_LINGER support in TCP

Browse Source 
git-svn-id: file:///srv/svn/repos/haiku/haiku/trunk@20540 a95241bf-73f2-0310-859d-f6bbb57e9c96
This commit is contained in:
Hugo Santos 2007-04-03 17:35:56 +00:00
parent 71bca39bbe
commit 0c88e5eea3
1 changed files with 24 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/add-ons/kernel/network/protocols/tcp/TCPEndpoint.cpp
View File

@ -1,10 +1,11 @@
/*
* Copyright 2006, Haiku, Inc. All Rights Reserved.
* Copyright 2006-2007, Haiku, Inc. All Rights Reserved.
* Distributed under the terms of the MIT License.
*
* Authors:
* Andrew Galante, haiku.galante@gmail.com
* Axel Dörfler, axeld@pinc-software.de
* Hugo Santos, hugosantos@gmail.com
*/
@ -177,6 +178,28 @@ TCPEndpoint::Close()
}
TRACE("Close(): Entering state %d", fState);
if (socket->options & SO_LINGER) {
TRACE("Close(): Lingering for %i secs", socket->linger);
bigtime_t maximum = system_time() + socket->linger * 1000000LL;
while (fSendQueue.Used() > 0) {
lock.Unlock();
status = acquire_sem_etc(fSendLock, 1, B_CAN_INTERRUPT
| B_ABSOLUTE_TIMEOUT, maximum);
if (status == B_TIMED_OUT) {
TRACE("Close(): Lingering made me wait, but not all data was sent.");
return B_OK;
} else if (status < B_OK)
return status;
lock.Lock();
}
TRACE("Close(): Waited for all data to be sent with success");
}
// TODO: do i need to wait until fState returns to CLOSED?
return B_OK;
}