Extract SIGPIPE ignoring code to a common place.

chrome/browser/chromeos/web_socket_proxy.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/chromeos/web_socket_proxy.h"
 
 #include <stdio.h>
 #include <stdlib.h>
 #include <string.h>
 
@@ skipping 14 matching lines @@
 #include "base/base64.h"
 #include "base/basictypes.h"
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/lazy_instance.h"
 #include "base/logging.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/memory/weak_ptr.h"
 #include "base/message_loop.h"
+#include "base/process_util.h"
 #include "base/sequenced_task_runner_helpers.h"
 #include "base/sha1.h"
 #include "base/stl_util.h"
 #include "base/string_number_conversions.h"
 #include "base/string_util.h"
 #include "base/sys_byteorder.h"
 #include "chrome/browser/chromeos/web_socket_proxy_helper.h"
 #include "chrome/browser/internal_auth.h"
 #include "chrome/common/chrome_notification_types.h"
 #include "content/public/browser/browser_thread.h"
@@ skipping 49 matching lines @@
 // Fixed-size (one-byte) messages communicated via control pipe.
 const char kControlMessageShutdown[] = { '.' };
 const char kControlMessageNetworkChange[] = { ':' };
 
 // Returns true on success.
 bool SetNonBlock(int fd) {
   int flags = fcntl(fd, F_GETFL, 0);
   return flags >= 0 && fcntl(fd, F_SETFL, flags | O_NONBLOCK) == 0;
 }
 
-// Returns true on success.
-bool IgnoreSigPipe() {
-  struct sigaction sa;
-  sa.sa_handler = SIG_IGN;
-  sa.sa_flags = 0;
-  if (sigemptyset(&sa.sa_mask) || sigaction(SIGPIPE, &sa, 0)) {
-    LOG(ERROR) << "WebSocketProxy: Failed to disable sigpipe";
-    return false;
-  }
-  return true;
-}
-
 uint64 ReadNetworkInteger(uint8* buf, int num_bytes) {
   uint64 rv = 0;
   DCHECK_GE(num_bytes, 0);
   DCHECK_LE(num_bytes, 8);
   while (num_bytes--) {
     rv <<= 8;
     rv += *buf++;
   }
   return rv;
 }
@@ skipping 788 matching lines @@
   event_set(control_event_.get(), control_descriptor_[0], EV_READ | EV_PERSIST,
             &OnControlRequest, this);
   event_base_set(evbase_, control_event_.get());
   if (event_add(control_event_.get(), NULL)) {
     LOG(ERROR) << "WebSocketProxy: Failed to add control event";
     return;
   }
 
   if (evdns_init())
     LOG(WARNING) << "WebSocketProxy: Failed to initialize evDNS";
-  if (!IgnoreSigPipe()) {
+  if (!base::IgnoreSigPipe()) {
     LOG(ERROR) << "WebSocketProxy: Failed to ignore SIGPIPE";
     return;
   }
 
   memset(&addr, 0, sizeof(addr));
   socklen_t addr_len = sizeof(addr);
   if (getsockname(
       listening_sock_, reinterpret_cast<struct sockaddr*>(&addr), &addr_len)) {
     LOG(ERROR) << "Failed to determine listening port";
     return;
@@ skipping 966 matching lines @@
 
 void WebSocketProxy::Shutdown() {
   static_cast<Serv*>(impl_)->Shutdown();
 }
 
 void WebSocketProxy::OnNetworkChange() {
   static_cast<Serv*>(impl_)->OnNetworkChange();
 }
 
 }  // namespace chromeos