15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/sync_socket.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <errno.h> 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <limits.h> 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <stdio.h> 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <sys/types.h> 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/logging.h" 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace base { 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)const SyncSocket::Handle SyncSocket::kInvalidHandle = -1; 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SyncSocket::SyncSocket() : handle_(kInvalidHandle) { 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SyncSocket::~SyncSocket() { 228bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) Close(); 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// static 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool SyncSocket::CreatePair(SyncSocket* socket_a, SyncSocket* socket_b) { 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return false; 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 301320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci// static 311320f92c476a1ad9d19dba2a48c72b75566198e9Primiano TucciSyncSocket::Handle SyncSocket::UnwrapHandle( 321320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci const SyncSocket::TransitDescriptor& descriptor) { 331320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // TODO(xians): Still unclear how NaCl uses SyncSocket. 341320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // See http://crbug.com/409656 351320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci NOTIMPLEMENTED(); 361320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci return SyncSocket::kInvalidHandle; 371320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci} 381320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 391320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tuccibool SyncSocket::PrepareTransitDescriptor( 401320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci ProcessHandle peer_process_handle, 411320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci SyncSocket::TransitDescriptor* descriptor) { 421320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // TODO(xians): Still unclear how NaCl uses SyncSocket. 431320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci // See http://crbug.com/409656 441320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci NOTIMPLEMENTED(); 451320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci return false; 461320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci} 471320f92c476a1ad9d19dba2a48c72b75566198e9Primiano Tucci 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool SyncSocket::Close() { 495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (handle_ != kInvalidHandle) { 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (close(handle_) < 0) 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DPLOG(ERROR) << "close"; 528bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) handle_ = kInvalidHandle; 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return true; 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)size_t SyncSocket::Send(const void* buffer, size_t length) { 588bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) const ssize_t bytes_written = write(handle_, buffer, length); 598bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) return bytes_written > 0 ? bytes_written : 0; 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)size_t SyncSocket::Receive(void* buffer, size_t length) { 638bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) const ssize_t bytes_read = read(handle_, buffer, length); 648bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) return bytes_read > 0 ? bytes_read : 0; 658bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles)} 668bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) 678bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles)size_t SyncSocket::ReceiveWithTimeout(void* buffer, size_t length, TimeDelta) { 688bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) NOTIMPLEMENTED(); 698bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) return 0; 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)size_t SyncSocket::Peek() { 738bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) NOTIMPLEMENTED(); 748bcbed890bc3ce4d7a057a8f32cab53fa534672eTorne (Richard Coles) return 0; 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)CancelableSyncSocket::CancelableSyncSocket() { 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)CancelableSyncSocket::CancelableSyncSocket(Handle handle) 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : SyncSocket(handle) { 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)size_t CancelableSyncSocket::Send(const void* buffer, size_t length) { 851e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) return SyncSocket::Send(buffer, length); 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool CancelableSyncSocket::Shutdown() { 891e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) return SyncSocket::Close(); 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// static 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)bool CancelableSyncSocket::CreatePair(CancelableSyncSocket* socket_a, 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CancelableSyncSocket* socket_b) { 955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) return SyncSocket::CreatePair(socket_a, socket_b); 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace base 99