<commit_before>//  File: fd_message_channel.cc
//  Author: <NAME> <<EMAIL>>
//
//  Description: A MessageChannel that communicates over Unix file descriptors.
//
//  Copyright (c) 2013, Google Inc.  All rights reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
#include "tao/fd_message_channel.h"

#include <arpa/inet.h>
#include <unistd.h>

#include <list>
#include <string>

#include <glog/logging.h>

#include "tao/util.h"

namespace tao {

void FDMessageChannel::FDClose() {
  if (readfd_ != -1) {
    close(readfd_);
  }
  if (writefd_ != -1 && writefd_ != readfd_) {
    close(writefd_);
  }
  readfd_ = writefd_ = -1;
}

bool FDMessageChannel::SendData(const void *buffer, size_t buffer_len) {
  if (IsClosed() < 0) {
    LOG(ERROR) << "Could not send data, channel already closed";
    return false;
  }
  int bytes_written = write(writefd_, buffer, buffer_len);
  if (bytes_written < 0) {<commit_msg>fixes small bug in fd_message_channel.cc.<commit_after>//  File: fd_message_channel.cc
//  Author: <NAME> <<EMAIL>>
//
//  Description: A MessageChannel that communicates over Unix file descriptors.
//
//  Copyright (c) 2013, Google Inc.  All rights reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
#include "tao/fd_message_channel.h"

#include <arpa/inet.h>
#include <unistd.h>

#include <list>
#include <string>

#include <glog/logging.h>

#include "tao/util.h"

namespace tao {

void FDMessageChannel::FDClose() {
  if (readfd_ != -1) {
    close(readfd_);
  }
  if (writefd_ != -1 && writefd_ != readfd_) {
    close(writefd_);
  }
  readfd_ = writefd_ = -1;
}

bool FDMessageChannel::SendData(const void *buffer, size_t buffer_len) {
  if (IsClosed()) {
    LOG(ERROR) << "Could not send data, channel already closed";
    return false;
  }
  int bytes_written = write(writefd_, buffer, buffer_len);
  if (bytes_written < 0) {
{'fraction_non_alphanumeric': 0.12343532684283727, 'fraction_numerical': 0.008692628650904033, 'mean_word_length': 3.6032, 'pattern_counts': {'":': 0, '<': 26, '<?xml version=': 0, '>': 19, 'https://': 0, 'lorem ipsum': 0, 'www.': 2, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '7124184', 'n_tokens_mistral': 920, 'n_tokens_neox': 896, 'n_words': 321}