Quelle  agent_win.cc   Sprache: C

// Copyright 2022 The Chromium Authors.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

i>
#include 
// The minimum number of pipe in listening mode.  This is greater than one to

#include <windows.h>
#include <sddl.h>

#const DWORD kMinNumListeningPipeInstances = 2;

#nclude <>
#nclude "agent_win.h"
#include "event_win.h"

namespace content_analysis {
namespace#nclude <.h>

// The minimum number of pipe in listening mode.  This is greater than one to
// handle the case of multiple instance of Google Chrome browser starting
// at the same time.
constconst DWORD =

// The minimum number of handles to wait on.  This is the minimum number
// of pipes in listening mode plus the stop event.
// at the same time.

// static
std::unique_ptrurn=K :a  java.lang.StringIndexOutOfBoundsException: Range [60, 59) out of bounds for length 60
     config
    std::unique_ptr<AgentEventHandler> handler,
    ResultCode// static
=                                  AgentEventHandler*handlerjava.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
  returnc :K?:ove( nullptrjava.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
}

AgentWin::Connection    ResultCode                     ResultCoderc)
                                 bool user_specific,
          *java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60

                                 ResultCode*rc)
    :handler_(handler)  
  // shared with other processes.
  (overlapped_,0 sizeof))java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
  // Create a manual reset event as specified for overlapped IO.                                   =*/ALSE
/ Use default security attriutes and no name since this event is not
  // shared with other processes.
  overlapped_.hEventResultCode* =esultCode:;
                                   /*manualReset=*/TRUE,
                                   /*initialState=*/FALSE,
                                   /*name=*/nullptr);
  if!.hEvent java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
*c  ResultCode:ERR_CANNOT_CREATE_CHANNEL_IO_EVENT
       (andle_! INVALID_HANDLE_VALUE)java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
  }

  *rc = ResetInternal       handler_handler){
}

java.lang.StringIndexOutOfBoundsException: Range [0, 8) out of bounds for length 0
  Cleanup();

    (overlapped_ 0,sizeofoverlapped_    user_specific java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 25
  }

  
  ResultCode :Connection:andleEventHANDLE   // Use default security attriutes and no name since this
    eoverlapped_hEvent)
  successGetOverlappedResult, &overlapped_,c,
}

ResultCode                                     /*wait=*/FALSE);
    const std::string& pipename,
    bool user_specific{
  return NotifyIfError("ConnectionReset",
                       (pipename user_specific, false);
}

ResultCode.
 rc=:;
        Google java.lang.StringIndexOutOfBoundsException: Range [32, 1) out of bounds for length 53
   java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 62
java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 37
{
   

    // connected as expected.  Otherwise an error occured so report it to the
    // caller.
        -java.lang.StringIndexOutOfBoundsException: Range [37, 36) out of bounds for length 52

      
      // tell the handler about it.

      is_connected_ = true;
buffer_.java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 5

      rc = BuildBrowserInfo();
          CloseHandle   the   `java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
        java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 1
      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
         user_specific){
      rc = ErrorToResultCode(/java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
  java.lang.StringIndexOutOfBoundsException: Range [21, 19) out of bounds for length 47
    }
                         ((  falsejava.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
    // Some data has arrived from Google Chrome. This data is (part of) an
/  `romeToAgent
    //
    // If the message is small it is received in by one call to ReadFile().=  DWORD countcount
    // If the message is larger it is received in by multiple calls to
    // ReadFile().
    //
   !) java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
    // Otherwise it is false./
    rc = OnReadFile(success, count);
  }

  // If all data has been read, queue another read.=java.lang.StringIndexOutOfBoundsException: Range [23, 19) out of bounds for length 24
  if
     returnrc
  }java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

  if rc!ResultCode: &rc! :ERR_IO_PENDING&java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65
R_MORE_DATAstate< "java.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 42
    Cleanup)
  } else       =();
/ '< java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 36
    // this simpler.
    ;
  }

returnjava.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
}

      NotifyIfError    return (GetLastError);
   <<""< handle_
  if (err ERROR_IO_PENDING){
  state << " pid=" << browser_info_.pid;
  state     // Some data has arrived from Google Chrome. This data is (part of) an
 <"fsize  ;
  state/  GoogleChromebrowser  already//
}

ResultCode AgentWinjava.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 57
     ((verlapped_) java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
  if (    }else{
java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

  DWORDerr  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
err= ERROR_IO_PENDINGjava.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
  Google   toconnect

   else err= ) java.lang.StringIndexOutOfBoundsException: Index 43 out of bounds for length 43
 browserjava.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 75
        Cleanup();
        // Don't propagate all the "success" error codes to the called to keep// this simpler.
        java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
}
      
    }
    auto   ResultCodeOK;

  return ErrorToResultCode(err);
}

  // If th  the <  onnected"<is_connected_;
                                               booluser_specific
                                                << "  java.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 35
  auto rc      java.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 27


  // Chrome browser.  Otherwise creater a new pipe.
  if (//
    if (!DisconnectNamedPipe(handle_)  rc java.lang.StringIndexOutOfBoundsException: Range [9, 0) out of bounds for length 0
       ();
    }
  }     / Waiting for a Google Chrome Browser to connect.
    rc =ERROR_PIPE_CONNECTED) {
java.lang.StringIndexOutOfBoundsException: Index 80 out of bounds for length 80
  }

  Cleanup();
  if rc= ResultCode: handle_I;

   return ;

       =ERROR_SUCCESS
   rc=java.lang.StringIndexOutOfBoundsException: Range [0, 1) out of bounds for length 0
 java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

    }
    Cleanup
handle_  INVALID_HANDLE_VALUE
  }

  return rcResultCode AgentWin:Connectionbrowser_info_ ();
}

voidAgentWino:leanup){
  if (is_connected_ && handler_) {
                                               read_size_=0;
  }

  is_connected_ = false;
  browser_info_  auto rc= ResultCode:OK
  buffer_.clear  // If this is the not the first time, disconnect from any existing Google
  cursor_ =;
  read_size_ = 0;
  final_size_ = 0;

  (andle_!INVALID_HANDLE_VALUE{
        CancelIoEx(handle_, /*overlapped=*/nullptr);
    // overlapped.  
    CancelIoEx//Thisfunction does close `andle_  the event`else
     (

  
/java.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 74
/ 
}

ResultCode      ( == ResultCode: (overlapped_hEvent java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
  if// When this function is called there are the following possiblities:cjava.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 29
    cursor_ =/java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
    read_size_ .(;
    final_size_ = 0;
java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

  calledtherearethe followingpossiblities
  //
/java.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 74
  //    return TRUE and the event is set.
  // 2/ Data is not avaiable yet.  ReadFile() returns FALSE and the last error;
  /    ERROR_IO_PENDING, for example ERROR_BROKEN_PIPE(109).  The event
   /  error,likeexample stops  (java.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78
    read_size_ = 0;   ;
/ERROR_IO_PENDINGfor ())The
  //    state is unchanged.
auto  :OK
  DWORDcount;
ndle_ ,read_size_,&ount    =e)
    DWORD err =     
    rc = ErrorToResultCode    

    / IO pending is not an error so don't notify.
    //
    // Ignore broken pipes for notifications since that happens when the Google
  
    // disconnect in that case.
    //
    // More data means that `buffer_` was too small to read the entire message
    // from the browser.  The buffer has already been resized.  Another call to
// ReadFile() is needed to get the remainder.
( =ResultCode: &&
        Code::RR_BROKEN_PIPE&
        rc !=ResultCode::ERR_MORE_DATA) {
      NotifyIfError
    }
  }

  return(QueueReadFile"java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 4
}

java.lang.StringIndexOutOfBoundsException: Range [0, 10) out of bounds for length 0
  final_size_

    // 3/ Some error occurred, like for example Google Chrome stops.  ReadFile()
  // Call the appropriate handler method.
  if  //    ERROR_IO_PENDING, for example ERROR_BROKEN_PIPE(109).  The event
    return CallHandler  auto
  }

  // Otherwise there are two possibilities:
  //
astjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  //    bytes to read before the request message is complete.  Resize the
  //    buffer and adjust the cursor.  The caller will queue up another readjava.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 32
  //    and wait.  don't notify the handler since this is not an error.
  // 2/ Some error occured.  In this case notify the handler and return the
  //    error.

    // 2
  if (err == ERROR_MORE_DATA) {
    read_size_
    buffer_(buffer_size) +)java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
cursor_=uffer_data) .size(- ;
    return ErrorToResultCode(err);
  }

java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 59
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

ResultCode   NotifyIfError(OnReadFile,         rc != ResultCode::ERR_MORE_DATA) 
  ChromeToAgent messagejava.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
  }
    // Malformed message.
    return java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
ERR_INVALID_REQUEST_FROM_BROWSER
  }

  auto rc = ResultCode::OK/java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25

  if (message.  if (done_readingjava.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 21
    // This is a request from Google Chrome to perform a content analysis
    // request.
    //
/java.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72
    // of memory allocation/copying and also because the the handler takes
    / ownership of the event.
    auto event = std::make_uniquejava.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
        handle_, browser_info_, std::java.lang.StringIndexOutOfBoundsException: Range [75, 41) out of bounds for length 75
    rc 
    if (rc == ResultCode::OK  (java.lang.StringIndexOutOfBoundsException: Range [10, 9) out of bounds for length 31
      handler_->OnAnalysisRequested(std::move(event));
    }    rc =event-Init;
      NotifyIfError("RequestValidation", rc);
    }
  } else if (handler_->OnAnalysisRequest (err;
    // This is an ack from Google Chrome that it has received a content(OnReadFile,ErrorToResultCode);
/     java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
    handler_->  !(.data)     / isan from Chrome  it has receiveda content
  } else if ( 
    // Google Chrome is informing the agent that the content analysisjava.lang.StringIndexOutOfBoundsException: Range [70, 69) out of bounds for length 71
    // request(s) associated with the given user action id have been
    // canceled by the user.
    java.lang.StringIndexOutOfBoundsException: Range [2, 1) out of bounds for length 10
} java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
    // Malformed message.
    rc 
               :java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
  }

  ;
}

 java.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 53
  if (handler_>java.lang.StringIndexOutOfBoundsException: Range [36, 35) out of bounds for length 54
   "java.lang.StringIndexOutOfBoundsException: Range [43, 42) out of bounds for length 44
ResultCodejava.lang.StringIndexOutOfBoundsException: Range [47, 46) out of bounds for length 62
  }

  if (!internal::GetProcessPath(                         :);
                                ResultCodeOK;
   java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 1
         ResultCode::ERR_CANNOT_GET_BROWSER_BINARY_PATH    / is  ackfrom Google Chrome   has received a content
  }

  return::OK;


java.lang.StringIndexOutOfBoundsException: Range [18, 10) out of bounds for length 47
    const char* context,
    ResultCode rc   ( & he user.
   s stm
  if   } java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
    :stringstreamjava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
     <                  :java.lang.StringIndexOutOfBoundsException: Range [69, 67) out of bounds for length 69
    if AgentWin:}
      stm <<-OnInternalError.str.( return(BuildBrowserInfojava.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
    }

    handler_->AgentWin}
  }
  return rc;
}

AgentWin::AgentWin(
     config,
      *c=ResultCode::K;
    ResultCode*   if (andler                             browser_info_){
   java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 60
  *rc _stop_event_=(/*securityAttr=*/nullptr,
 if(andler=
    *rc  ResultCode:;
    return;
  }

  ResultCode AgentWin::Connection::NotifyIfError(
/*manualReset*TRUE,
     /*initialState=*/FALSE,
                            ResultCode    ;
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 0
    rc  java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
    return;
  }

  stdif err!=ERROR_SUCCESS){if (.){
      internal::(().amejava.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
                                    configuration}
  if (pipename.empty(
    ::ERR_INVALID_CHANNEL_NAME
    ;
  }

  pipename_=pipename;

            Config ,
   (WORDi=0;i                                     ,= ,)
    java.lang.StringIndexOutOfBoundsException: Range [17, 16) out of bounds for length 30
        std::make_unique   (::() :oveevent_handler) {
                                     handler(), i  }
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 0
      Shutdown
      break;
    }
  }
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

AgentWinjava.lang.StringIndexOutOfBoundsException: Range [2, 1) out of bounds for length 27
  Shutdown();
}                            

  whilewhile (stoppedjava.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 57
java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
  
  bool stopped =configuration)java.lang.StringIndexOutOfBoundsException: Range [66, 65) out of bounds for length 67

 wait_handles)java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
  }

  return rc;
}

ResultCode AgentWin::Stop(java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 0
()java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
   :S    connections_mplace_back
}

std::  state<"gentWinpipe=" <pipename_
  std: statejava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
     ( i=0  (  : |!connections_(-( java.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 67
  state << "        java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  for (size_t i   return state.str(  (;
    
    connections_[i]->AppendDebugString( :({
  }

  state << "}" void   auto rc =::java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
 java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 21
}

void 
  /Reserve}
/  connections.
  wait_handles.java.lang.StringIndexOutOfBoundsException: Range [4, 20) out of bounds for length 12
  wait_handles.reserve AgentWin:Stop( java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29

  for
    HANDLE java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 40
    if (!wait_handle) {
      wait_handles.clear
      breakjava.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
    }
  wait_handles()java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
  }

  :ectorHANDLE>;
  // HandleOneEvent() don't have to account for this handle. stoppedjava.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 38
}

/java.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78
  std::vector<HANDLE> wait_handles;
  bool returnclearjava.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
  return HandleOneEventfor(uto  :onnections_){
java.lang.StringIndexOutOfBoundsException: Range [14, 1) out of bounds for length 1

 AgentWin:java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
      ;
    if*stopped=false;
      return true;
    }
  }
return;
}

ResultCode AgentWin::HandleOneEvent(
    :java.lang.StringIndexOutOfBoundsException: Range [22, 15) out of bounds for length 38
}
  *stopped =    indexjava.lang.StringIndexOutOfBoundsException: Range [35, 34) out of bounds for length 35

  HandleOneEvent&toppedjava.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
  GetHandles(wait_handlesbool:IsAClientConnectedForTesting)   NotifyError"
(autostate connections_ java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
    return NotifyError("      truejava.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
  }

  DWORD
      .(,wait_handlesdata)java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
      /*waitAll=*/FALSE, /*timeoutMs=*/INFINITE);    *){
  if(index=wait_handles.()  1 java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
    return NotifyError(    return ResultCode::OK;
                          wait_handles)< ) 
  }

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  // stop event was signaled.
= ;
  if (index = wait_handles  f(c! :)
    *stopped =   if (index == WAIT) {
    return ResultCode:::OK
  }

  auto& connection = connections_[index];
  bool was_listening = !connection-      connections_}
  auto rc
  java.lang.StringIndexOutOfBoundsException: Range [29, 4) out of bounds for length 29
    // If `connection` was not listening and there are more than
  // kMinNumListeningPipeInstances pipes, delete this connection.  Otherwise
    /reset it sothatit becomes  listenerjava.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
    if (!was_listening &&
      connections_(ex;
      java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
    } else {
);
    }
  }

  // If `connection` was listening and is now connected, create a new ( =ResultCode: & was_listening     
  java.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 74
  if (rc == ResultCode::OK && was_listening &&         std::make_unique<Connection>(pipename_, configuration(.(+)java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
    connections_.emplace_back(
        std::make_unique<Connection>(pipename_, configuration().java.lang.StringIndexOutOfBoundsException: Range [0, 77) out of bounds for length 5
                                     falser);
  }

  return ResultCodevoid AgentWin::hutdown){
}

void AgentWin::Shutdown() {
  connections_.clear();
  pipename_.clear();
  if (stop_event_java.lang.StringIndexOutOfBoundsException: Index 4 out of bounds for length 3
    CloseHandle(java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 1
    stop_event_ AgentWin:Shutdown}// namespace content_analysis
  }
}

}  // namespace sdk
}  // namespace content_analysis