From owner-freebsd-threads@FreeBSD.ORG Thu May 25 15:58:39 2006 Return-Path: X-Original-To: freebsd-threads@freebsd.org Delivered-To: freebsd-threads@freebsd.org Received: from mx1.FreeBSD.org (mx1.freebsd.org [216.136.204.125]) by hub.freebsd.org (Postfix) with ESMTP id 1D04516A434 for ; Thu, 25 May 2006 15:58:39 +0000 (UTC) (envelope-from lists@intricatesoftware.com) Received: from mta6.srv.hcvlny.cv.net (mta6.srv.hcvlny.cv.net [167.206.4.201]) by mx1.FreeBSD.org (Postfix) with ESMTP id C668443D46 for ; Thu, 25 May 2006 15:58:38 +0000 (GMT) (envelope-from lists@intricatesoftware.com) Received: from [172.16.1.72] (ool-457a77e8.dyn.optonline.net [69.122.119.232]) by mta6.srv.hcvlny.cv.net (Sun Java System Messaging Server 6.2-6.01 (built Apr 3 2006)) with ESMTP id <0IZT002STWDNHXZ0@mta6.srv.hcvlny.cv.net> for freebsd-threads@freebsd.org; Thu, 25 May 2006 11:58:36 -0400 (EDT) Date: Thu, 25 May 2006 11:58:34 -0400 From: Kurt Miller To: freebsd-threads@freebsd.org Message-id: <200605251158.34553.lists@intricatesoftware.com> MIME-version: 1.0 Content-type: text/plain; charset=us-ascii Content-transfer-encoding: 7BIT Content-disposition: inline User-Agent: KMail/1.9.1 Subject: close() socket deadlocks blocked threads X-BeenThere: freebsd-threads@freebsd.org X-Mailman-Version: 2.1.5 Precedence: list Reply-To: kurt@intricatesoftware.com List-Id: Threading on FreeBSD List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , X-List-Received-Date: Thu, 25 May 2006 15:58:44 -0000 Here's the other deadlock I mentioned. When a thread is blocked waiting for data on a socket and another thread closes the socket, the blocked thread remains blocked indefinitely. Both kse and thr have this issue. c_r returns with -1 errno==EBADF. Solaris returns with -1 errno==0. #include #include #include #include #include #include #include #include #include #include #include static void * start_routine(void *arg) { int sock1 = (int)arg; struct sockaddr remote_addr; char readBuf; int n, remote_addr_len = sizeof(struct sockaddr); n = recvfrom(sock1, &readBuf, 1, 0, &remote_addr, &remote_addr_len); if (n == -1) { printf("unblocked with errno = %d\n", errno); } return (0); } void buildAddr4(struct sockaddr_in *addr4, int address, short port) { memset((char *) addr4, 0, sizeof(struct sockaddr_in)); addr4->sin_port = htons(port); addr4->sin_addr.s_addr = (uint32_t) htonl(address); addr4->sin_family = AF_INET; } int main() { int sock1; struct sockaddr addr; pthread_t thread1; void *value_ptr; buildAddr4((struct sockaddr_in *)&addr, 0, 0); if ((sock1 = socket(AF_INET, SOCK_DGRAM, 0)) < 0) exit(1); if (bind(sock1, (struct sockaddr *)&addr, sizeof(struct sockaddr_in)) != 0) exit(1); pthread_create(&thread1, NULL, start_routine, (void *)sock1); sleep(1); close(sock1); pthread_join(thread1, &value_ptr); return (0); }