ecee434fae
This method works around the downsides of ENDPOINT_ALLOC, namely that it is not affected by memory fragmentation and it uses an upstream interface. Also add libasyncio to provide the necessary syscalls to both adb and mtp. Add some small optimizations to file_sync. Bug: 37916658 Test: run adb push/pull Change-Id: If3b3be02b5e2d4f9cffec1b8ddc02a5768a51a1f
60 lines
1.7 KiB
C++
60 lines
1.7 KiB
C++
#pragma once
|
|
|
|
/*
|
|
* Copyright (C) 2017 The Android Open Source Project
|
|
*
|
|
* 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 <atomic>
|
|
#include <condition_variable>
|
|
#include <mutex>
|
|
|
|
#include <asyncio/AsyncIO.h>
|
|
|
|
struct aio_block {
|
|
std::vector<struct iocb> iocb;
|
|
std::vector<struct iocb*> iocbs;
|
|
std::vector<struct io_event> events;
|
|
aio_context_t ctx;
|
|
int num_submitted;
|
|
int fd;
|
|
};
|
|
|
|
struct usb_handle {
|
|
usb_handle() : kicked(false) {
|
|
}
|
|
|
|
std::condition_variable notify;
|
|
std::mutex lock;
|
|
std::atomic<bool> kicked;
|
|
bool open_new_connection = true;
|
|
|
|
int (*write)(usb_handle* h, const void* data, int len);
|
|
int (*read)(usb_handle* h, void* data, int len);
|
|
void (*kick)(usb_handle* h);
|
|
void (*close)(usb_handle* h);
|
|
|
|
// FunctionFS
|
|
int control = -1;
|
|
int bulk_out = -1; /* "out" from the host's perspective => source for adbd */
|
|
int bulk_in = -1; /* "in" from the host's perspective => sink for adbd */
|
|
|
|
// Access to these blocks is very not thread safe. Have one block for both the
|
|
// read and write threads.
|
|
struct aio_block read_aiob;
|
|
struct aio_block write_aiob;
|
|
|
|
int max_rw;
|
|
};
|
|
|