diff options
-rw-r--r-- | adb/commandline.c | 2 | ||||
-rw-r--r-- | adb/sockets.c | 30 | ||||
-rw-r--r-- | fastboot/usb_linux.c | 9 | ||||
-rw-r--r-- | fastboot/usb_windows.c | 5 | ||||
-rw-r--r-- | include/cutils/bitops.h | 41 | ||||
-rw-r--r-- | include/cutils/uevent.h | 32 | ||||
-rw-r--r-- | include/private/android_filesystem_config.h | 3 | ||||
-rw-r--r-- | include/system/audio.h | 393 | ||||
-rw-r--r-- | include/sysutils/SocketClient.h | 11 | ||||
-rw-r--r-- | init/devices.c | 34 | ||||
-rw-r--r-- | libcutils/Android.mk | 2 | ||||
-rw-r--r-- | libcutils/uevent.c | 70 | ||||
-rw-r--r-- | libpixelflinger/scanline.cpp | 882 | ||||
-rw-r--r-- | libsysutils/src/SocketClient.cpp | 24 | ||||
-rw-r--r-- | libsysutils/src/SocketListener.cpp | 14 | ||||
-rw-r--r-- | rootdir/etc/ueventd.goldfish.rc | 1 |
16 files changed, 1470 insertions, 83 deletions
diff --git a/adb/commandline.c b/adb/commandline.c index 5ed1b52..b0c2b80 100644 --- a/adb/commandline.c +++ b/adb/commandline.c @@ -104,7 +104,7 @@ void help() " Port 5555 is used by default if no port number is specified.\n" " disconnect [<host>[:<port>]] - disconnect from a TCP/IP device.\n" " Port 5555 is used by default if no port number is specified.\n" - " Using this ocmmand with no additional arguments\n" + " Using this command with no additional arguments\n" " will disconnect from all connected TCP/IP devices.\n" "\n" "device commands:\n" diff --git a/adb/sockets.c b/adb/sockets.c index 43925e4..aa4d5fc 100644 --- a/adb/sockets.c +++ b/adb/sockets.c @@ -569,6 +569,32 @@ unsigned unhex(unsigned char *s, int len) return n; } +/* skip_host_serial return the position in a string + skipping over the 'serial' parameter in the ADB protocol, + where parameter string may be a host:port string containing + the protocol delimiter (colon). */ +char *skip_host_serial(char *service) { + char *first_colon, *serial_end; + + first_colon = strchr(service, ':'); + if (!first_colon) { + /* No colon in service string. */ + return NULL; + } + serial_end = first_colon; + if (isdigit(serial_end[1])) { + serial_end++; + while ((*serial_end) && isdigit(*serial_end)) { + serial_end++; + } + if ((*serial_end) != ':') { + // Something other than numbers was found, reset the end. + serial_end = first_colon; + } + } + return serial_end; +} + static int smart_socket_enqueue(asocket *s, apacket *p) { unsigned len; @@ -624,8 +650,8 @@ static int smart_socket_enqueue(asocket *s, apacket *p) char* serial_end; service += strlen("host-serial:"); - // serial number should follow "host:" - serial_end = strchr(service, ':'); + // serial number should follow "host:" and could be a host:port string. + serial_end = skip_host_serial(service); if (serial_end) { *serial_end = 0; // terminate string serial = service; diff --git a/fastboot/usb_linux.c b/fastboot/usb_linux.c index 78b7b98..1ba87e6 100644 --- a/fastboot/usb_linux.c +++ b/fastboot/usb_linux.c @@ -61,6 +61,11 @@ #define DBG1(x...) #endif +/* The max bulk size for linux is 16384 which is defined + * in drivers/usb/core/devio.c. + */ +#define MAX_USBFS_BULK_SIZE (16 * 1024) + struct usb_handle { char fname[64]; @@ -289,7 +294,7 @@ int usb_write(usb_handle *h, const void *_data, int len) while(len > 0) { int xfer; - xfer = (len > 4096) ? 4096 : len; + xfer = (len > MAX_USBFS_BULK_SIZE) ? MAX_USBFS_BULK_SIZE : len; bulk.ep = h->ep_out; bulk.len = xfer; @@ -323,7 +328,7 @@ int usb_read(usb_handle *h, void *_data, int len) } while(len > 0) { - int xfer = (len > 4096) ? 4096 : len; + int xfer = (len > MAX_USBFS_BULK_SIZE) ? MAX_USBFS_BULK_SIZE : len; bulk.ep = h->ep_in; bulk.len = xfer; diff --git a/fastboot/usb_windows.c b/fastboot/usb_windows.c index 54008a4..1050293 100644 --- a/fastboot/usb_windows.c +++ b/fastboot/usb_windows.c @@ -42,6 +42,7 @@ #define DBG(x...) #endif +#define MAX_USBFS_BULK_SIZE (1024 * 1024) /** Structure usb_handle describes our connection to the usb device via AdbWinApi.dll. This structure is returned from usb_open() routine and @@ -160,7 +161,7 @@ int usb_write(usb_handle* handle, const void* data, int len) { if (NULL != handle) { // Perform write while(len > 0) { - int xfer = (len > 4096) ? 4096 : len; + int xfer = (len > MAX_USBFS_BULK_SIZE) ? MAX_USBFS_BULK_SIZE : len; ret = AdbWriteEndpointSync(handle->adb_write_pipe, (void*)data, (unsigned long)xfer, @@ -200,7 +201,7 @@ int usb_read(usb_handle *handle, void* data, int len) { DBG("usb_read %d\n", len); if (NULL != handle) { while (1) { - int xfer = (len > 4096) ? 4096 : len; + int xfer = (len > MAX_USBFS_BULK_SIZE) ? MAX_USBFS_BULK_SIZE : len; ret = AdbReadEndpointSync(handle->adb_read_pipe, (void*)data, diff --git a/include/cutils/bitops.h b/include/cutils/bitops.h new file mode 100644 index 0000000..1b3b762 --- /dev/null +++ b/include/cutils/bitops.h @@ -0,0 +1,41 @@ +/* + * Copyright (C) 2011 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. + */ + +#ifndef __CUTILS_BITOPS_H +#define __CUTILS_BITOPS_H + +#include <sys/cdefs.h> + +__BEGIN_DECLS + +static inline int popcount(unsigned int x) +{ + return __builtin_popcount(x); +} + +static inline int popcountl(unsigned long x) +{ + return __builtin_popcountl(x); +} + +static inline int popcountll(unsigned long long x) +{ + return __builtin_popcountll(x); +} + +__END_DECLS + +#endif /* __CUTILS_BITOPS_H */ diff --git a/include/cutils/uevent.h b/include/cutils/uevent.h new file mode 100644 index 0000000..587149c --- /dev/null +++ b/include/cutils/uevent.h @@ -0,0 +1,32 @@ +/* + * Copyright (C) 2011 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. + */ + +#ifndef __CUTILS_UEVENT_H +#define __CUTILS_UEVENT_H + +#include <sys/socket.h> + +#ifdef __cplusplus +extern "C" { +#endif + +ssize_t uevent_checked_recv(int socket, void *buffer, size_t length); + +#ifdef __cplusplus +} +#endif + +#endif /* __CUTILS_UEVENT_H */ diff --git a/include/private/android_filesystem_config.h b/include/private/android_filesystem_config.h index 1db8065..f23c235 100644 --- a/include/private/android_filesystem_config.h +++ b/include/private/android_filesystem_config.h @@ -55,9 +55,10 @@ #define AID_DRM 1019 /* DRM server */ #define AID_AVAILABLE 1020 /* available for use */ #define AID_GPS 1021 /* GPS daemon */ -#define AID_NFC 1022 /* nfc subsystem */ +#define AID_UNUSED1 1022 /* deprecated, DO NOT USE */ #define AID_MEDIA_RW 1023 /* internal media storage write access */ #define AID_MTP 1024 /* MTP USB driver access */ +#define AID_NFC 1025 /* nfc subsystem */ #define AID_SHELL 2000 /* adb and debug shell user */ #define AID_CACHE 2001 /* cache access */ diff --git a/include/system/audio.h b/include/system/audio.h new file mode 100644 index 0000000..8f2ac0c --- /dev/null +++ b/include/system/audio.h @@ -0,0 +1,393 @@ +/* + * Copyright (C) 2011 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. + */ + + +#ifndef ANDROID_AUDIO_CORE_H +#define ANDROID_AUDIO_CORE_H + +#include <stdbool.h> +#include <stdint.h> +#include <sys/cdefs.h> +#include <sys/types.h> + +#include <cutils/bitops.h> + +__BEGIN_DECLS + +/* The enums were moved here mostly from + * frameworks/base/include/media/AudioSystem.h + */ + +typedef int audio_io_handle_t; + +/* Audio stream types */ +typedef enum { + AUDIO_STREAM_DEFAULT = -1, + AUDIO_STREAM_VOICE_CALL = 0, + AUDIO_STREAM_SYSTEM = 1, + AUDIO_STREAM_RING = 2, + AUDIO_STREAM_MUSIC = 3, + AUDIO_STREAM_ALARM = 4, + AUDIO_STREAM_NOTIFICATION = 5, + AUDIO_STREAM_BLUETOOTH_SCO = 6, + AUDIO_STREAM_ENFORCED_AUDIBLE = 7, /* Sounds that cannot be muted by user and must be routed to speaker */ + AUDIO_STREAM_DTMF = 8, + AUDIO_STREAM_TTS = 9, + + AUDIO_STREAM_CNT, + AUDIO_STREAM_MAX = AUDIO_STREAM_CNT - 1, +} audio_stream_type_t; + +/* Do not change these values without updating their counterparts + * in media/java/android/media/MediaRecorder.java! + */ +typedef enum { + AUDIO_SOURCE_DEFAULT = 0, + AUDIO_SOURCE_MIC = 1, + AUDIO_SOURCE_VOICE_UPLINK = 2, + AUDIO_SOURCE_VOICE_DOWNLINK = 3, + AUDIO_SOURCE_VOICE_CALL = 4, + AUDIO_SOURCE_CAMCORDER = 5, + AUDIO_SOURCE_VOICE_RECOGNITION = 6, + AUDIO_SOURCE_VOICE_COMMUNICATION = 7, + + AUDIO_SOURCE_CNT, + AUDIO_SOURCE_MAX = AUDIO_SOURCE_CNT - 1, +} audio_source_t; + +/* special audio session values + * (XXX: should this be living in the audio effects land?) + */ +typedef enum { + /* session for effects attached to a particular output stream + * (value must be less than 0) + */ + AUDIO_SESSION_OUTPUT_STAGE = -1, + + /* session for effects applied to output mix. These effects can + * be moved by audio policy manager to another output stream + * (value must be 0) + */ + AUDIO_SESSION_OUTPUT_MIX = 0, +} audio_session_t; + +/* Audio sub formats (see enum audio_format). */ + +/* PCM sub formats */ +typedef enum { + AUDIO_FORMAT_PCM_SUB_16_BIT = 0x1, /* DO NOT CHANGE */ + AUDIO_FORMAT_PCM_SUB_8_BIT = 0x2, /* DO NOT CHANGE */ +} audio_format_pcm_sub_fmt_t; + +/* MP3 sub format field definition : can use 11 LSBs in the same way as MP3 + * frame header to specify bit rate, stereo mode, version... + */ +typedef enum { + AUDIO_FORMAT_MP3_SUB_NONE = 0x0, +} audio_format_mp3_sub_fmt_t; + +/* AMR NB/WB sub format field definition: specify frame block interleaving, + * bandwidth efficient or octet aligned, encoding mode for recording... + */ +typedef enum { + AUDIO_FORMAT_AMR_SUB_NONE = 0x0, +} audio_format_amr_sub_fmt_t; + +/* AAC sub format field definition: specify profile or bitrate for recording... */ +typedef enum { + AUDIO_FORMAT_AAC_SUB_NONE = 0x0, +} audio_format_aac_sub_fmt_t; + +/* VORBIS sub format field definition: specify quality for recording... */ +typedef enum { + AUDIO_FORMAT_VORBIS_SUB_NONE = 0x0, +} audio_format_vorbis_sub_fmt_t; + +/* Audio format consists in a main format field (upper 8 bits) and a sub format + * field (lower 24 bits). + * + * The main format indicates the main codec type. The sub format field + * indicates options and parameters for each format. The sub format is mainly + * used for record to indicate for instance the requested bitrate or profile. + * It can also be used for certain formats to give informations not present in + * the encoded audio stream (e.g. octet alignement for AMR). + */ +typedef enum { + AUDIO_FORMAT_INVALID = 0xFFFFFFFFUL, + AUDIO_FORMAT_DEFAULT = 0, + AUDIO_FORMAT_PCM = 0x00000000UL, /* DO NOT CHANGE */ + AUDIO_FORMAT_MP3 = 0x01000000UL, + AUDIO_FORMAT_AMR_NB = 0x02000000UL, + AUDIO_FORMAT_AMR_WB = 0x03000000UL, + AUDIO_FORMAT_AAC = 0x04000000UL, + AUDIO_FORMAT_HE_AAC_V1 = 0x05000000UL, + AUDIO_FORMAT_HE_AAC_V2 = 0x06000000UL, + AUDIO_FORMAT_VORBIS = 0x07000000UL, + AUDIO_FORMAT_MAIN_MASK = 0xFF000000UL, + AUDIO_FORMAT_SUB_MASK = 0x00FFFFFFUL, + + /* Aliases */ + AUDIO_FORMAT_PCM_16_BIT = (AUDIO_FORMAT_PCM | + AUDIO_FORMAT_PCM_SUB_16_BIT), + AUDIO_FORMAT_PCM_8_BIT = (AUDIO_FORMAT_PCM | + AUDIO_FORMAT_PCM_SUB_8_BIT), +} audio_format_t; + +/* Channel mask definitions must be kept in sync with JAVA values in + * frameworks/base/media/java/android/media/AudioFormat.java */ +typedef enum { + /* output channels */ + AUDIO_CHANNEL_OUT_FRONT_LEFT = 0x4, + AUDIO_CHANNEL_OUT_FRONT_RIGHT = 0x8, + AUDIO_CHANNEL_OUT_FRONT_CENTER = 0x10, + AUDIO_CHANNEL_OUT_LOW_FREQUENCY = 0x20, + AUDIO_CHANNEL_OUT_BACK_LEFT = 0x40, + AUDIO_CHANNEL_OUT_BACK_RIGHT = 0x80, + AUDIO_CHANNEL_OUT_FRONT_LEFT_OF_CENTER = 0x100, + AUDIO_CHANNEL_OUT_FRONT_RIGHT_OF_CENTER = 0x200, + AUDIO_CHANNEL_OUT_BACK_CENTER = 0x400, + + AUDIO_CHANNEL_OUT_MONO = AUDIO_CHANNEL_OUT_FRONT_LEFT, + AUDIO_CHANNEL_OUT_STEREO = (AUDIO_CHANNEL_OUT_FRONT_LEFT | + AUDIO_CHANNEL_OUT_FRONT_RIGHT), + AUDIO_CHANNEL_OUT_QUAD = (AUDIO_CHANNEL_OUT_FRONT_LEFT | + AUDIO_CHANNEL_OUT_FRONT_RIGHT | + AUDIO_CHANNEL_OUT_BACK_LEFT | + AUDIO_CHANNEL_OUT_BACK_RIGHT), + AUDIO_CHANNEL_OUT_SURROUND = (AUDIO_CHANNEL_OUT_FRONT_LEFT | + AUDIO_CHANNEL_OUT_FRONT_RIGHT | + AUDIO_CHANNEL_OUT_FRONT_CENTER | + AUDIO_CHANNEL_OUT_BACK_CENTER), + AUDIO_CHANNEL_OUT_5POINT1 = (AUDIO_CHANNEL_OUT_FRONT_LEFT | + AUDIO_CHANNEL_OUT_FRONT_RIGHT | + AUDIO_CHANNEL_OUT_FRONT_CENTER | + AUDIO_CHANNEL_OUT_LOW_FREQUENCY | + AUDIO_CHANNEL_OUT_BACK_LEFT | + AUDIO_CHANNEL_OUT_BACK_RIGHT), + AUDIO_CHANNEL_OUT_7POINT1 = (AUDIO_CHANNEL_OUT_FRONT_LEFT | + AUDIO_CHANNEL_OUT_FRONT_RIGHT | + AUDIO_CHANNEL_OUT_FRONT_CENTER | + AUDIO_CHANNEL_OUT_LOW_FREQUENCY | + AUDIO_CHANNEL_OUT_BACK_LEFT | + AUDIO_CHANNEL_OUT_BACK_RIGHT | + AUDIO_CHANNEL_OUT_FRONT_LEFT_OF_CENTER | + AUDIO_CHANNEL_OUT_FRONT_RIGHT_OF_CENTER), + AUDIO_CHANNEL_OUT_ALL = (AUDIO_CHANNEL_OUT_FRONT_LEFT | + AUDIO_CHANNEL_OUT_FRONT_RIGHT | + AUDIO_CHANNEL_OUT_FRONT_CENTER | + AUDIO_CHANNEL_OUT_LOW_FREQUENCY | + AUDIO_CHANNEL_OUT_BACK_LEFT | + AUDIO_CHANNEL_OUT_BACK_RIGHT | + AUDIO_CHANNEL_OUT_FRONT_LEFT_OF_CENTER | + AUDIO_CHANNEL_OUT_FRONT_RIGHT_OF_CENTER | + AUDIO_CHANNEL_OUT_BACK_CENTER), + + /* input channels */ + AUDIO_CHANNEL_IN_LEFT = 0x4, + AUDIO_CHANNEL_IN_RIGHT = 0x8, + AUDIO_CHANNEL_IN_FRONT = 0x10, + AUDIO_CHANNEL_IN_BACK = 0x20, + AUDIO_CHANNEL_IN_LEFT_PROCESSED = 0x40, + AUDIO_CHANNEL_IN_RIGHT_PROCESSED = 0x80, + AUDIO_CHANNEL_IN_FRONT_PROCESSED = 0x100, + AUDIO_CHANNEL_IN_BACK_PROCESSED = 0x200, + AUDIO_CHANNEL_IN_PRESSURE = 0x400, + AUDIO_CHANNEL_IN_X_AXIS = 0x800, + AUDIO_CHANNEL_IN_Y_AXIS = 0x1000, + AUDIO_CHANNEL_IN_Z_AXIS = 0x2000, + AUDIO_CHANNEL_IN_VOICE_UPLINK = 0x4000, + AUDIO_CHANNEL_IN_VOICE_DNLINK = 0x8000, + + AUDIO_CHANNEL_IN_MONO = AUDIO_CHANNEL_IN_FRONT, + AUDIO_CHANNEL_IN_STEREO = (AUDIO_CHANNEL_IN_LEFT | AUDIO_CHANNEL_IN_RIGHT), + AUDIO_CHANNEL_IN_ALL = (AUDIO_CHANNEL_IN_LEFT | + AUDIO_CHANNEL_IN_RIGHT | + AUDIO_CHANNEL_IN_FRONT | + AUDIO_CHANNEL_IN_BACK| + AUDIO_CHANNEL_IN_LEFT_PROCESSED | + AUDIO_CHANNEL_IN_RIGHT_PROCESSED | + AUDIO_CHANNEL_IN_FRONT_PROCESSED | + AUDIO_CHANNEL_IN_BACK_PROCESSED| + AUDIO_CHANNEL_IN_PRESSURE | + AUDIO_CHANNEL_IN_X_AXIS | + AUDIO_CHANNEL_IN_Y_AXIS | + AUDIO_CHANNEL_IN_Z_AXIS | + AUDIO_CHANNEL_IN_VOICE_UPLINK | + AUDIO_CHANNEL_IN_VOICE_DNLINK), +} audio_channels_t; + +typedef enum { + AUDIO_MODE_INVALID = -2, + AUDIO_MODE_CURRENT = -1, + AUDIO_MODE_NORMAL = 0, + AUDIO_MODE_RINGTONE = 1, + AUDIO_MODE_IN_CALL = 2, + AUDIO_MODE_IN_COMMUNICATION = 3, + + AUDIO_MODE_CNT, + AUDIO_MODE_MAX = AUDIO_MODE_CNT - 1, +} audio_mode_t; + +typedef enum { + AUDIO_IN_ACOUSTICS_AGC_ENABLE = 0x0001, + AUDIO_IN_ACOUSTICS_AGC_DISABLE = 0, + AUDIO_IN_ACOUSTICS_NS_ENABLE = 0x0002, + AUDIO_IN_ACOUSTICS_NS_DISABLE = 0, + AUDIO_IN_ACOUSTICS_TX_IIR_ENABLE = 0x0004, + AUDIO_IN_ACOUSTICS_TX_DISABLE = 0, +} audio_in_acoustics_t; + +typedef enum { + /* output devices */ + AUDIO_DEVICE_OUT_EARPIECE = 0x1, + AUDIO_DEVICE_OUT_SPEAKER = 0x2, + AUDIO_DEVICE_OUT_WIRED_HEADSET = 0x4, + AUDIO_DEVICE_OUT_WIRED_HEADPHONE = 0x8, + AUDIO_DEVICE_OUT_BLUETOOTH_SCO = 0x10, + AUDIO_DEVICE_OUT_BLUETOOTH_SCO_HEADSET = 0x20, + AUDIO_DEVICE_OUT_BLUETOOTH_SCO_CARKIT = 0x40, + AUDIO_DEVICE_OUT_BLUETOOTH_A2DP = 0x80, + AUDIO_DEVICE_OUT_BLUETOOTH_A2DP_HEADPHONES = 0x100, + AUDIO_DEVICE_OUT_BLUETOOTH_A2DP_SPEAKER = 0x200, + AUDIO_DEVICE_OUT_AUX_DIGITAL = 0x400, + AUDIO_DEVICE_OUT_ANLG_DOCK_HEADSET = 0x800, + AUDIO_DEVICE_OUT_DGTL_DOCK_HEADSET = 0x1000, + AUDIO_DEVICE_OUT_DEFAULT = 0x8000, + AUDIO_DEVICE_OUT_ALL = (AUDIO_DEVICE_OUT_EARPIECE | + AUDIO_DEVICE_OUT_SPEAKER | + AUDIO_DEVICE_OUT_WIRED_HEADSET | + AUDIO_DEVICE_OUT_WIRED_HEADPHONE | + AUDIO_DEVICE_OUT_BLUETOOTH_SCO | + AUDIO_DEVICE_OUT_BLUETOOTH_SCO_HEADSET | + AUDIO_DEVICE_OUT_BLUETOOTH_SCO_CARKIT | + AUDIO_DEVICE_OUT_BLUETOOTH_A2DP | + AUDIO_DEVICE_OUT_BLUETOOTH_A2DP_HEADPHONES | + AUDIO_DEVICE_OUT_BLUETOOTH_A2DP_SPEAKER | + AUDIO_DEVICE_OUT_AUX_DIGITAL | + AUDIO_DEVICE_OUT_ANLG_DOCK_HEADSET | + AUDIO_DEVICE_OUT_DGTL_DOCK_HEADSET | + AUDIO_DEVICE_OUT_DEFAULT), + AUDIO_DEVICE_OUT_ALL_A2DP = (AUDIO_DEVICE_OUT_BLUETOOTH_A2DP | + AUDIO_DEVICE_OUT_BLUETOOTH_A2DP_HEADPHONES | + AUDIO_DEVICE_OUT_BLUETOOTH_A2DP_SPEAKER), + AUDIO_DEVICE_OUT_ALL_SCO = (AUDIO_DEVICE_OUT_BLUETOOTH_SCO | + AUDIO_DEVICE_OUT_BLUETOOTH_SCO_HEADSET | + AUDIO_DEVICE_OUT_BLUETOOTH_SCO_CARKIT), + + /* input devices */ + AUDIO_DEVICE_IN_COMMUNICATION = 0x10000, + AUDIO_DEVICE_IN_AMBIENT = 0x20000, + AUDIO_DEVICE_IN_BUILTIN_MIC = 0x40000, + AUDIO_DEVICE_IN_BLUETOOTH_SCO_HEADSET = 0x80000, + AUDIO_DEVICE_IN_WIRED_HEADSET = 0x100000, + AUDIO_DEVICE_IN_AUX_DIGITAL = 0x200000, + AUDIO_DEVICE_IN_VOICE_CALL = 0x400000, + AUDIO_DEVICE_IN_BACK_MIC = 0x800000, + AUDIO_DEVICE_IN_DEFAULT = 0x80000000, + + AUDIO_DEVICE_IN_ALL = (AUDIO_DEVICE_IN_COMMUNICATION | + AUDIO_DEVICE_IN_AMBIENT | + AUDIO_DEVICE_IN_BUILTIN_MIC | + AUDIO_DEVICE_IN_BLUETOOTH_SCO_HEADSET | + AUDIO_DEVICE_IN_WIRED_HEADSET | + AUDIO_DEVICE_IN_AUX_DIGITAL | + AUDIO_DEVICE_IN_VOICE_CALL | + AUDIO_DEVICE_IN_BACK_MIC | + AUDIO_DEVICE_IN_DEFAULT), + AUDIO_DEVICE_IN_ALL_SCO = AUDIO_DEVICE_IN_BLUETOOTH_SCO_HEADSET, +} audio_devices_t; + +static inline bool audio_is_output_device(audio_devices_t device) +{ + if ((popcount(device) == 1) && ((device & ~AUDIO_DEVICE_OUT_ALL) == 0)) + return true; + else + return false; +} + +static inline bool audio_is_input_device(audio_devices_t device) +{ + if ((popcount(device) == 1) && ((device & ~AUDIO_DEVICE_IN_ALL) == 0)) + return true; + else + return false; +} + +static inline bool audio_is_a2dp_device(audio_devices_t device) +{ + if ((popcount(device) == 1) && (device & AUDIO_DEVICE_OUT_ALL_A2DP)) + return true; + else + return false; +} + +static inline bool audio_is_bluetooth_sco_device(audio_devices_t device) +{ + if ((popcount(device) == 1) && (device & (AUDIO_DEVICE_OUT_ALL_SCO | + AUDIO_DEVICE_IN_BLUETOOTH_SCO_HEADSET))) + return true; + else + return false; +} + +static inline bool audio_is_input_channel(uint32_t channel) +{ + if ((channel & ~AUDIO_CHANNEL_IN_ALL) == 0) + return true; + else + return false; +} + +static inline bool audio_is_output_channel(uint32_t channel) +{ + if ((channel & ~AUDIO_CHANNEL_OUT_ALL) == 0) + return true; + else + return false; +} + +static inline bool audio_is_valid_format(uint32_t format) +{ + switch (format & AUDIO_FORMAT_MAIN_MASK) { + case AUDIO_FORMAT_PCM: + case AUDIO_FORMAT_MP3: + case AUDIO_FORMAT_AMR_NB: + case AUDIO_FORMAT_AMR_WB: + case AUDIO_FORMAT_AAC: + case AUDIO_FORMAT_HE_AAC_V1: + case AUDIO_FORMAT_HE_AAC_V2: + case AUDIO_FORMAT_VORBIS: + return true; + default: + return false; + } +} + +static inline bool audio_is_linear_pcm(uint32_t format) +{ + switch (format) { + case AUDIO_FORMAT_PCM_16_BIT: + case AUDIO_FORMAT_PCM_8_BIT: + return true; + default: + return false; + } +} + + +__END_DECLS + +#endif // ANDROID_AUDIO_CORE_H diff --git a/include/sysutils/SocketClient.h b/include/sysutils/SocketClient.h index 2fcc331..d6bb7d5 100644 --- a/include/sysutils/SocketClient.h +++ b/include/sysutils/SocketClient.h @@ -19,6 +19,10 @@ class SocketClient { /* Peer group ID */ gid_t mGid; + /* Reference count (starts at 1) */ + pthread_mutex_t mRefCountMutex; + int mRefCount; + public: SocketClient(int sock); virtual ~SocketClient() {} @@ -34,6 +38,13 @@ public: // Sending binary data: int sendData(const void *data, int len); + + // Optional reference counting. Reference count starts at 1. If + // it's decremented to 0, it deletes itself. + // SocketListener creates a SocketClient (at refcount 1) and calls + // decRef() when it's done with the client. + void incRef(); + bool decRef(); // returns true at 0 (but note: SocketClient already deleted) }; typedef android::List<SocketClient *> SocketClientCollection; diff --git a/init/devices.c b/init/devices.c index 036b8f7..9c07e99 100644 --- a/init/devices.c +++ b/init/devices.c @@ -34,6 +34,8 @@ #include <asm/page.h> #include <sys/wait.h> +#include <cutils/uevent.h> + #include "devices.h" #include "util.h" #include "log.h" @@ -644,35 +646,9 @@ static void handle_firmware_event(struct uevent *uevent) #define UEVENT_MSG_LEN 1024 void handle_device_fd() { - for(;;) { - char msg[UEVENT_MSG_LEN+2]; - char cred_msg[CMSG_SPACE(sizeof(struct ucred))]; - struct iovec iov = {msg, sizeof(msg)}; - struct sockaddr_nl snl; - struct msghdr hdr = {&snl, sizeof(snl), &iov, 1, cred_msg, sizeof(cred_msg), 0}; - - ssize_t n = recvmsg(device_fd, &hdr, 0); - if (n <= 0) { - break; - } - - if ((snl.nl_groups != 1) || (snl.nl_pid != 0)) { - /* ignoring non-kernel netlink multicast message */ - continue; - } - - struct cmsghdr * cmsg = CMSG_FIRSTHDR(&hdr); - if (cmsg == NULL || cmsg->cmsg_type != SCM_CREDENTIALS) { - /* no sender credentials received, ignore message */ - continue; - } - - struct ucred * cred = (struct ucred *)CMSG_DATA(cmsg); - if (cred->uid != 0) { - /* message from non-root user, ignore */ - continue; - } - + char msg[UEVENT_MSG_LEN+2]; + int n; + while ((n = uevent_checked_recv(device_fd, msg, UEVENT_MSG_LEN)) > 0) { if(n >= UEVENT_MSG_LEN) /* overflow -- discard */ continue; diff --git a/libcutils/Android.mk b/libcutils/Android.mk index b6c5382..25d36da 100644 --- a/libcutils/Android.mk +++ b/libcutils/Android.mk @@ -109,7 +109,7 @@ else #!sim # ======================================================== include $(CLEAR_VARS) LOCAL_MODULE := libcutils -LOCAL_SRC_FILES := $(commonSources) ashmem-dev.c mq.c android_reboot.c +LOCAL_SRC_FILES := $(commonSources) ashmem-dev.c mq.c android_reboot.c uevent.c ifeq ($(TARGET_ARCH),arm) LOCAL_SRC_FILES += arch-arm/memset32.S diff --git a/libcutils/uevent.c b/libcutils/uevent.c new file mode 100644 index 0000000..3533c00 --- /dev/null +++ b/libcutils/uevent.c @@ -0,0 +1,70 @@ +/* + * Copyright (C) 2011 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 <cutils/uevent.h> + +#include <errno.h> +#include <strings.h> + +#include <linux/netlink.h> + +/** + * Like recv(), but checks that messages actually originate from the kernel. + */ +ssize_t uevent_checked_recv(int socket, void *buffer, size_t length) { + struct iovec iov = { buffer, length }; + struct sockaddr_nl addr; + char control[CMSG_SPACE(sizeof(struct ucred))]; + struct msghdr hdr = { + &addr, + sizeof(addr), + &iov, + 1, + control, + sizeof(control), + 0, + }; + + ssize_t n = recvmsg(socket, &hdr, 0); + if (n <= 0) { + return n; + } + + if (addr.nl_groups == 0 || addr.nl_pid != 0) { + /* ignoring non-kernel or unicast netlink message */ + goto out; + } + + struct cmsghdr *cmsg = CMSG_FIRSTHDR(&hdr); + if (cmsg == NULL || cmsg->cmsg_type != SCM_CREDENTIALS) { + /* ignoring netlink message with no sender credentials */ + goto out; + } + + struct ucred *cred = (struct ucred *)CMSG_DATA(cmsg); + if (cred->uid != 0) { + /* ignoring netlink message from non-root user */ + goto out; + } + + return n; + +out: + /* clear residual potentially malicious data */ + bzero(buffer, length); + errno = EIO; + return -1; +} diff --git a/libpixelflinger/scanline.cpp b/libpixelflinger/scanline.cpp index 931d648..8fba147 100644 --- a/libpixelflinger/scanline.cpp +++ b/libpixelflinger/scanline.cpp @@ -1,6 +1,6 @@ /* libs/pixelflinger/scanline.cpp ** -** Copyright 2006, The Android Open Source Project +** Copyright 2006-2011, 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. @@ -57,6 +57,11 @@ #define DEBUG__CODEGEN_ONLY 0 +/* Set to 1 to dump to the log the states that need a new + * code-generated scanline callback, i.e. those that don't + * have a corresponding shortcut function. + */ +#define DEBUG_NEEDS 0 #define ASSEMBLY_SCRATCH_SIZE 2048 @@ -79,8 +84,21 @@ static void scanline(context_t* c); static void scanline_perspective(context_t* c); static void scanline_perspective_single(context_t* c); static void scanline_t32cb16blend(context_t* c); +static void scanline_t32cb16blend_dither(context_t* c); +static void scanline_t32cb16blend_srca(context_t* c); +static void scanline_t32cb16blend_clamp(context_t* c); +static void scanline_t32cb16blend_clamp_dither(context_t* c); +static void scanline_t32cb16blend_clamp_mod(context_t* c); +static void scanline_x32cb16blend_clamp_mod(context_t* c); +static void scanline_t32cb16blend_clamp_mod_dither(context_t* c); +static void scanline_x32cb16blend_clamp_mod_dither(context_t* c); static void scanline_t32cb16(context_t* c); +static void scanline_t32cb16_dither(context_t* c); +static void scanline_t32cb16_clamp(context_t* c); +static void scanline_t32cb16_clamp_dither(context_t* c); static void scanline_col32cb16blend(context_t* c); +static void scanline_t16cb16_clamp(context_t* c); +static void scanline_t16cb16blend_clamp_mod(context_t* c); static void scanline_memcpy(context_t* c); static void scanline_memset8(context_t* c); static void scanline_memset16(context_t* c); @@ -99,6 +117,13 @@ extern "C" void scanline_col32cb16blend_arm(uint16_t *dst, uint32_t col, size_t // ---------------------------------------------------------------------------- +static inline uint16_t convertAbgr8888ToRgb565(uint32_t pix) +{ + return uint16_t( ((pix << 8) & 0xf800) | + ((pix >> 5) & 0x07e0) | + ((pix >> 19) & 0x001f) ); +} + struct shortcut_t { needs_filter_t filter; const char* desc; @@ -107,13 +132,95 @@ struct shortcut_t { }; // Keep in sync with needs + +/* To understand the values here, have a look at: + * system/core/include/private/pixelflinger/ggl_context.h + * + * Especially the lines defining and using GGL_RESERVE_NEEDS + * + * Quick reminders: + * - the last nibble of the first value is the destination buffer format. + * - the last nibble of the third value is the source texture format + * - formats: 4=rgb565 1=abgr8888 2=xbgr8888 + * + * In the descriptions below: + * + * SRC means we copy the source pixels to the destination + * + * SRC_OVER means we blend the source pixels to the destination + * with dstFactor = 1-srcA, srcFactor=1 (premultiplied source). + * This mode is otherwise called 'blend'. + * + * SRCA_OVER means we blend the source pixels to the destination + * with dstFactor=srcA*(1-srcA) srcFactor=srcA (non-premul source). + * This mode is otherwise called 'blend_srca' + * + * clamp means we fetch source pixels from a texture with u/v clamping + * + * mod means the source pixels are modulated (multiplied) by the + * a/r/g/b of the current context's color. Typically used for + * fade-in / fade-out. + * + * dither means we dither 32 bit values to 16 bits + */ static shortcut_t shortcuts[] = { { { { 0x03515104, 0x00000077, { 0x00000A01, 0x00000000 } }, { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, - "565 fb, 8888 tx, blend", scanline_t32cb16blend, init_y_noop }, + "565 fb, 8888 tx, blend SRC_OVER", scanline_t32cb16blend, init_y_noop }, { { { 0x03010104, 0x00000077, { 0x00000A01, 0x00000000 } }, { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, - "565 fb, 8888 tx", scanline_t32cb16, init_y_noop }, + "565 fb, 8888 tx, SRC", scanline_t32cb16, init_y_noop }, + /* same as first entry, but with dithering */ + { { { 0x03515104, 0x00000177, { 0x00000A01, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, 8888 tx, blend SRC_OVER dither", scanline_t32cb16blend_dither, init_y_noop }, + /* same as second entry, but with dithering */ + { { { 0x03010104, 0x00000177, { 0x00000A01, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, 8888 tx, SRC dither", scanline_t32cb16_dither, init_y_noop }, + /* this is used during the boot animation - CHEAT: ignore dithering */ + { { { 0x03545404, 0x00000077, { 0x00000A01, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFEFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, 8888 tx, blend dst:ONE_MINUS_SRCA src:SRCA", scanline_t32cb16blend_srca, init_y_noop }, + /* special case for arbitrary texture coordinates (think scaling) */ + { { { 0x03515104, 0x00000077, { 0x00000001, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, 8888 tx, SRC_OVER clamp", scanline_t32cb16blend_clamp, init_y }, + { { { 0x03515104, 0x00000177, { 0x00000001, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, 8888 tx, SRC_OVER clamp dither", scanline_t32cb16blend_clamp_dither, init_y }, + /* another case used during emulation */ + { { { 0x03515104, 0x00000077, { 0x00001001, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, 8888 tx, SRC_OVER clamp modulate", scanline_t32cb16blend_clamp_mod, init_y }, + /* and this */ + { { { 0x03515104, 0x00000077, { 0x00001002, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, x888 tx, SRC_OVER clamp modulate", scanline_x32cb16blend_clamp_mod, init_y }, + { { { 0x03515104, 0x00000177, { 0x00001001, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, 8888 tx, SRC_OVER clamp modulate dither", scanline_t32cb16blend_clamp_mod_dither, init_y }, + { { { 0x03515104, 0x00000177, { 0x00001002, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, x888 tx, SRC_OVER clamp modulate dither", scanline_x32cb16blend_clamp_mod_dither, init_y }, + { { { 0x03010104, 0x00000077, { 0x00000001, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, 8888 tx, SRC clamp", scanline_t32cb16_clamp, init_y }, + { { { 0x03010104, 0x00000077, { 0x00000002, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, x888 tx, SRC clamp", scanline_t32cb16_clamp, init_y }, + { { { 0x03010104, 0x00000177, { 0x00000001, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, 8888 tx, SRC clamp dither", scanline_t32cb16_clamp_dither, init_y }, + { { { 0x03010104, 0x00000177, { 0x00000002, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, x888 tx, SRC clamp dither", scanline_t32cb16_clamp_dither, init_y }, + { { { 0x03010104, 0x00000077, { 0x00000004, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, 565 tx, SRC clamp", scanline_t16cb16_clamp, init_y }, + { { { 0x03515104, 0x00000077, { 0x00001004, 0x00000000 } }, + { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0x0000003F } } }, + "565 fb, 565 tx, SRC_OVER clamp", scanline_t16cb16blend_clamp_mod, init_y }, { { { 0x03515104, 0x00000077, { 0x00000000, 0x00000000 } }, { 0xFFFFFFFF, 0xFFFFFFFF, { 0xFFFFFFFF, 0xFFFFFFFF } } }, "565 fb, 8888 fixed color", scanline_col32cb16blend, init_y_packed }, @@ -243,6 +350,12 @@ static void pick_scanline(context_t* c) } } +#ifdef DEBUG_NEEDS + LOGI("Needs: n=0x%08x p=0x%08x t0=0x%08x t1=0x%08x", + c->state.needs.n, c->state.needs.p, + c->state.needs.t[0], c->state.needs.t[1]); +#endif + #endif // DEBUG__CODEGEN_ONLY c->init_y = init_y; @@ -797,6 +910,678 @@ discard: #pragma mark Scanline #endif +/* Used to parse a 32-bit source texture linearly. Usage is: + * + * horz_iterator32 hi(context); + * while (...) { + * uint32_t src_pixel = hi.get_pixel32(); + * ... + * } + * + * Use only for one-to-one texture mapping. + */ +struct horz_iterator32 { + horz_iterator32(context_t* c) { + const int x = c->iterators.xl; + const int y = c->iterators.y; + texture_t& tx = c->state.texture[0]; + const int32_t u = (tx.shade.is0>>16) + x; + const int32_t v = (tx.shade.it0>>16) + y; + m_src = reinterpret_cast<uint32_t*>(tx.surface.data)+(u+(tx.surface.stride*v)); + } + uint32_t get_pixel32() { + return *m_src++; + } +protected: + uint32_t* m_src; +}; + +/* A variant for 16-bit source textures. */ +struct horz_iterator16 { + horz_iterator16(context_t* c) { + const int x = c->iterators.xl; + const int y = c->iterators.y; + texture_t& tx = c->state.texture[0]; + const int32_t u = (tx.shade.is0>>16) + x; + const int32_t v = (tx.shade.it0>>16) + y; + m_src = reinterpret_cast<uint16_t*>(tx.surface.data)+(u+(tx.surface.stride*v)); + } + uint16_t get_pixel16() { + return *m_src++; + } +protected: + uint16_t* m_src; +}; + +/* A clamp iterator is used to iterate inside a texture with GGL_CLAMP. + * After initialization, call get_src16() or get_src32() to get the current + * texture pixel value. + */ +struct clamp_iterator { + clamp_iterator(context_t* c) { + const int xs = c->iterators.xl; + texture_t& tx = c->state.texture[0]; + texture_iterators_t& ti = tx.iterators; + m_s = (xs * ti.dsdx) + ti.ydsdy; + m_t = (xs * ti.dtdx) + ti.ydtdy; + m_ds = ti.dsdx; + m_dt = ti.dtdx; + m_width_m1 = tx.surface.width - 1; + m_height_m1 = tx.surface.height - 1; + m_data = tx.surface.data; + m_stride = tx.surface.stride; + } + uint16_t get_pixel16() { + int u, v; + get_uv(u, v); + uint16_t* src = reinterpret_cast<uint16_t*>(m_data) + (u + (m_stride*v)); + return src[0]; + } + uint32_t get_pixel32() { + int u, v; + get_uv(u, v); + uint32_t* src = reinterpret_cast<uint32_t*>(m_data) + (u + (m_stride*v)); + return src[0]; + } +private: + void get_uv(int& u, int& v) { + int uu = m_s >> 16; + int vv = m_t >> 16; + if (uu < 0) + uu = 0; + if (uu > m_width_m1) + uu = m_width_m1; + if (vv < 0) + vv = 0; + if (vv > m_height_m1) + vv = m_height_m1; + u = uu; + v = vv; + m_s += m_ds; + m_t += m_dt; + } + + GGLfixed m_s, m_t; + GGLfixed m_ds, m_dt; + int m_width_m1, m_height_m1; + uint8_t* m_data; + int m_stride; +}; + +/* + * The 'horizontal clamp iterator' variant corresponds to the case where + * the 'v' coordinate doesn't change. This is useful to avoid one mult and + * extra adds / checks per pixels, if the blending/processing operation after + * this is very fast. + */ +static int is_context_horizontal(const context_t* c) { + return (c->state.texture[0].iterators.dtdx == 0); +} + +struct horz_clamp_iterator { + uint16_t get_pixel16() { + int u = m_s >> 16; + m_s += m_ds; + if (u < 0) + u = 0; + if (u > m_width_m1) + u = m_width_m1; + const uint16_t* src = reinterpret_cast<const uint16_t*>(m_data); + return src[u]; + } + uint32_t get_pixel32() { + int u = m_s >> 16; + m_s += m_ds; + if (u < 0) + u = 0; + if (u > m_width_m1) + u = m_width_m1; + const uint32_t* src = reinterpret_cast<const uint32_t*>(m_data); + return src[u]; + } +protected: + void init(const context_t* c, int shift); + GGLfixed m_s; + GGLfixed m_ds; + int m_width_m1; + const uint8_t* m_data; +}; + +void horz_clamp_iterator::init(const context_t* c, int shift) +{ + const int xs = c->iterators.xl; + const texture_t& tx = c->state.texture[0]; + const texture_iterators_t& ti = tx.iterators; + m_s = (xs * ti.dsdx) + ti.ydsdy; + m_ds = ti.dsdx; + m_width_m1 = tx.surface.width-1; + m_data = tx.surface.data; + + GGLfixed t = (xs * ti.dtdx) + ti.ydtdy; + int v = t >> 16; + if (v < 0) + v = 0; + else if (v >= (int)tx.surface.height) + v = (int)tx.surface.height-1; + + m_data += (tx.surface.stride*v) << shift; +} + +struct horz_clamp_iterator16 : horz_clamp_iterator { + horz_clamp_iterator16(const context_t* c) { + init(c,1); + }; +}; + +struct horz_clamp_iterator32 : horz_clamp_iterator { + horz_clamp_iterator32(context_t* c) { + init(c,2); + }; +}; + +/* This is used to perform dithering operations. + */ +struct ditherer { + ditherer(const context_t* c) { + const int x = c->iterators.xl; + const int y = c->iterators.y; + m_line = &c->ditherMatrix[ ((y & GGL_DITHER_MASK)<<GGL_DITHER_ORDER_SHIFT) ]; + m_index = x & GGL_DITHER_MASK; + } + void step(void) { + m_index++; + } + int get_value(void) { + int ret = m_line[m_index & GGL_DITHER_MASK]; + m_index++; + return ret; + } + uint16_t abgr8888ToRgb565(uint32_t s) { + uint32_t r = s & 0xff; + uint32_t g = (s >> 8) & 0xff; + uint32_t b = (s >> 16) & 0xff; + return rgb888ToRgb565(r,g,b); + } + /* The following assumes that r/g/b are in the 0..255 range each */ + uint16_t rgb888ToRgb565(uint32_t& r, uint32_t& g, uint32_t &b) { + int threshold = get_value(); + /* dither in on GGL_DITHER_BITS, and each of r, g, b is on 8 bits */ + r += (threshold >> (GGL_DITHER_BITS-8 +5)); + g += (threshold >> (GGL_DITHER_BITS-8 +6)); + b += (threshold >> (GGL_DITHER_BITS-8 +5)); + if (r > 0xff) + r = 0xff; + if (g > 0xff) + g = 0xff; + if (b > 0xff) + b = 0xff; + return uint16_t(((r & 0xf8) << 8) | ((g & 0xfc) << 3) | (b >> 3)); + } +protected: + const uint8_t* m_line; + int m_index; +}; + +/* This structure is used to blend (SRC_OVER) 32-bit source pixels + * onto 16-bit destination ones. Usage is simply: + * + * blender.blend(<32-bit-src-pixel-value>,<ptr-to-16-bit-dest-pixel>) + */ +struct blender_32to16 { + blender_32to16(context_t* c) { } + void write(uint32_t s, uint16_t* dst) { + if (s == 0) + return; + s = GGL_RGBA_TO_HOST(s); + int sA = (s>>24); + if (sA == 0xff) { + *dst = convertAbgr8888ToRgb565(s); + } else { + int f = 0x100 - (sA + (sA>>7)); + int sR = (s >> ( 3))&0x1F; + int sG = (s >> ( 8+2))&0x3F; + int sB = (s >> (16+3))&0x1F; + uint16_t d = *dst; + int dR = (d>>11)&0x1f; + int dG = (d>>5)&0x3f; + int dB = (d)&0x1f; + sR += (f*dR)>>8; + sG += (f*dG)>>8; + sB += (f*dB)>>8; + *dst = uint16_t((sR<<11)|(sG<<5)|sB); + } + } + void write(uint32_t s, uint16_t* dst, ditherer& di) { + if (s == 0) { + di.step(); + return; + } + s = GGL_RGBA_TO_HOST(s); + int sA = (s>>24); + if (sA == 0xff) { + *dst = di.abgr8888ToRgb565(s); + } else { + int threshold = di.get_value() << (8 - GGL_DITHER_BITS); + int f = 0x100 - (sA + (sA>>7)); + int sR = (s >> ( 3))&0x1F; + int sG = (s >> ( 8+2))&0x3F; + int sB = (s >> (16+3))&0x1F; + uint16_t d = *dst; + int dR = (d>>11)&0x1f; + int dG = (d>>5)&0x3f; + int dB = (d)&0x1f; + sR = ((sR << 8) + f*dR + threshold)>>8; + sG = ((sG << 8) + f*dG + threshold)>>8; + sB = ((sB << 8) + f*dB + threshold)>>8; + if (sR > 0x1f) sR = 0x1f; + if (sG > 0x3f) sG = 0x3f; + if (sB > 0x1f) sB = 0x1f; + *dst = uint16_t((sR<<11)|(sG<<5)|sB); + } + } +}; + +/* This blender does the same for the 'blend_srca' operation. + * where dstFactor=srcA*(1-srcA) srcFactor=srcA + */ +struct blender_32to16_srcA { + blender_32to16_srcA(const context_t* c) { } + void write(uint32_t s, uint16_t* dst) { + if (!s) { + return; + } + uint16_t d = *dst; + s = GGL_RGBA_TO_HOST(s); + int sR = (s >> ( 3))&0x1F; + int sG = (s >> ( 8+2))&0x3F; + int sB = (s >> (16+3))&0x1F; + int sA = (s>>24); + int f1 = (sA + (sA>>7)); + int f2 = 0x100-f1; + int dR = (d>>11)&0x1f; + int dG = (d>>5)&0x3f; + int dB = (d)&0x1f; + sR = (f1*sR + f2*dR)>>8; + sG = (f1*sG + f2*dG)>>8; + sB = (f1*sB + f2*dB)>>8; + *dst = uint16_t((sR<<11)|(sG<<5)|sB); + } +}; + +/* Common init code the modulating blenders */ +struct blender_modulate { + void init(const context_t* c) { + const int r = c->iterators.ydrdy >> (GGL_COLOR_BITS-8); + const int g = c->iterators.ydgdy >> (GGL_COLOR_BITS-8); + const int b = c->iterators.ydbdy >> (GGL_COLOR_BITS-8); + const int a = c->iterators.ydady >> (GGL_COLOR_BITS-8); + m_r = r + (r >> 7); + m_g = g + (g >> 7); + m_b = b + (b >> 7); + m_a = a + (a >> 7); + } +protected: + int m_r, m_g, m_b, m_a; +}; + +/* This blender does a normal blend after modulation. + */ +struct blender_32to16_modulate : blender_modulate { + blender_32to16_modulate(const context_t* c) { + init(c); + } + void write(uint32_t s, uint16_t* dst) { + // blend source and destination + if (!s) { + return; + } + s = GGL_RGBA_TO_HOST(s); + + /* We need to modulate s */ + uint32_t sA = (s >> 24); + uint32_t sB = (s >> 16) & 0xff; + uint32_t sG = (s >> 8) & 0xff; + uint32_t sR = s & 0xff; + + sA = (sA*m_a) >> 8; + /* Keep R/G/B scaled to 5.8 or 6.8 fixed float format */ + sR = (sR*m_r) >> (8 - 5); + sG = (sG*m_g) >> (8 - 6); + sB = (sB*m_b) >> (8 - 5); + + /* Now do a normal blend */ + int f = 0x100 - (sA + (sA>>7)); + uint16_t d = *dst; + int dR = (d>>11)&0x1f; + int dG = (d>>5)&0x3f; + int dB = (d)&0x1f; + sR = (sR + f*dR)>>8; + sG = (sG + f*dG)>>8; + sB = (sB + f*dB)>>8; + *dst = uint16_t((sR<<11)|(sG<<5)|sB); + } + void write(uint32_t s, uint16_t* dst, ditherer& di) { + // blend source and destination + if (!s) { + di.step(); + return; + } + s = GGL_RGBA_TO_HOST(s); + + /* We need to modulate s */ + uint32_t sA = (s >> 24); + uint32_t sB = (s >> 16) & 0xff; + uint32_t sG = (s >> 8) & 0xff; + uint32_t sR = s & 0xff; + + sA = (sA*m_a) >> 8; + /* keep R/G/B scaled to 5.8 or 6.8 fixed float format */ + sR = (sR*m_r) >> (8 - 5); + sG = (sG*m_g) >> (8 - 6); + sB = (sB*m_b) >> (8 - 5); + + /* Scale threshold to 0.8 fixed float format */ + int threshold = di.get_value() << (8 - GGL_DITHER_BITS); + int f = 0x100 - (sA + (sA>>7)); + uint16_t d = *dst; + int dR = (d>>11)&0x1f; + int dG = (d>>5)&0x3f; + int dB = (d)&0x1f; + sR = (sR + f*dR + threshold)>>8; + sG = (sG + f*dG + threshold)>>8; + sB = (sB + f*dB + threshold)>>8; + if (sR > 0x1f) sR = 0x1f; + if (sG > 0x3f) sG = 0x3f; + if (sB > 0x1f) sB = 0x1f; + *dst = uint16_t((sR<<11)|(sG<<5)|sB); + } +}; + +/* same as 32to16_modulate, except that the input is xRGB, instead of ARGB */ +struct blender_x32to16_modulate : blender_modulate { + blender_x32to16_modulate(const context_t* c) { + init(c); + } + void write(uint32_t s, uint16_t* dst) { + s = GGL_RGBA_TO_HOST(s); + + uint32_t sB = (s >> 16) & 0xff; + uint32_t sG = (s >> 8) & 0xff; + uint32_t sR = s & 0xff; + + /* Keep R/G/B in 5.8 or 6.8 format */ + sR = (sR*m_r) >> (8 - 5); + sG = (sG*m_g) >> (8 - 6); + sB = (sB*m_b) >> (8 - 5); + + int f = 0x100 - m_a; + uint16_t d = *dst; + int dR = (d>>11)&0x1f; + int dG = (d>>5)&0x3f; + int dB = (d)&0x1f; + sR = (sR + f*dR)>>8; + sG = (sG + f*dG)>>8; + sB = (sB + f*dB)>>8; + *dst = uint16_t((sR<<11)|(sG<<5)|sB); + } + void write(uint32_t s, uint16_t* dst, ditherer& di) { + s = GGL_RGBA_TO_HOST(s); + + uint32_t sB = (s >> 16) & 0xff; + uint32_t sG = (s >> 8) & 0xff; + uint32_t sR = s & 0xff; + + sR = (sR*m_r) >> (8 - 5); + sG = (sG*m_g) >> (8 - 6); + sB = (sB*m_b) >> (8 - 5); + + /* Now do a normal blend */ + int threshold = di.get_value() << (8 - GGL_DITHER_BITS); + int f = 0x100 - m_a; + uint16_t d = *dst; + int dR = (d>>11)&0x1f; + int dG = (d>>5)&0x3f; + int dB = (d)&0x1f; + sR = (sR + f*dR + threshold)>>8; + sG = (sG + f*dG + threshold)>>8; + sB = (sB + f*dB + threshold)>>8; + if (sR > 0x1f) sR = 0x1f; + if (sG > 0x3f) sG = 0x3f; + if (sB > 0x1f) sB = 0x1f; + *dst = uint16_t((sR<<11)|(sG<<5)|sB); + } +}; + +/* Same as above, but source is 16bit rgb565 */ +struct blender_16to16_modulate : blender_modulate { + blender_16to16_modulate(const context_t* c) { + init(c); + } + void write(uint16_t s16, uint16_t* dst) { + uint32_t s = s16; + + uint32_t sR = s >> 11; + uint32_t sG = (s >> 5) & 0x3f; + uint32_t sB = s & 0x1f; + + sR = (sR*m_r); + sG = (sG*m_g); + sB = (sB*m_b); + + int f = 0x100 - m_a; + uint16_t d = *dst; + int dR = (d>>11)&0x1f; + int dG = (d>>5)&0x3f; + int dB = (d)&0x1f; + sR = (sR + f*dR)>>8; + sG = (sG + f*dG)>>8; + sB = (sB + f*dB)>>8; + *dst = uint16_t((sR<<11)|(sG<<5)|sB); + } +}; + +/* This is used to iterate over a 16-bit destination color buffer. + * Usage is: + * + * dst_iterator16 di(context); + * while (di.count--) { + * <do stuff with dest pixel at di.dst> + * di.dst++; + * } + */ +struct dst_iterator16 { + dst_iterator16(const context_t* c) { + const int x = c->iterators.xl; + const int width = c->iterators.xr - x; + const int32_t y = c->iterators.y; + const surface_t* cb = &(c->state.buffers.color); + count = width; + dst = reinterpret_cast<uint16_t*>(cb->data) + (x+(cb->stride*y)); + } + int count; + uint16_t* dst; +}; + + +static void scanline_t32cb16_clamp(context_t* c) +{ + dst_iterator16 di(c); + + if (is_context_horizontal(c)) { + /* Special case for simple horizontal scaling */ + horz_clamp_iterator32 ci(c); + while (di.count--) { + uint32_t s = ci.get_pixel32(); + *di.dst++ = convertAbgr8888ToRgb565(s); + } + } else { + /* General case */ + clamp_iterator ci(c); + while (di.count--) { + uint32_t s = ci.get_pixel32(); + *di.dst++ = convertAbgr8888ToRgb565(s); + } + } +} + +static void scanline_t32cb16_dither(context_t* c) +{ + horz_iterator32 si(c); + dst_iterator16 di(c); + ditherer dither(c); + + while (di.count--) { + uint32_t s = si.get_pixel32(); + *di.dst++ = dither.abgr8888ToRgb565(s); + } +} + +static void scanline_t32cb16_clamp_dither(context_t* c) +{ + dst_iterator16 di(c); + ditherer dither(c); + + if (is_context_horizontal(c)) { + /* Special case for simple horizontal scaling */ + horz_clamp_iterator32 ci(c); + while (di.count--) { + uint32_t s = ci.get_pixel32(); + *di.dst++ = dither.abgr8888ToRgb565(s); + } + } else { + /* General case */ + clamp_iterator ci(c); + while (di.count--) { + uint32_t s = ci.get_pixel32(); + *di.dst++ = dither.abgr8888ToRgb565(s); + } + } +} + +static void scanline_t32cb16blend_dither(context_t* c) +{ + dst_iterator16 di(c); + ditherer dither(c); + blender_32to16 bl(c); + horz_iterator32 hi(c); + while (di.count--) { + uint32_t s = hi.get_pixel32(); + bl.write(s, di.dst, dither); + di.dst++; + } +} + +static void scanline_t32cb16blend_clamp(context_t* c) +{ + dst_iterator16 di(c); + blender_32to16 bl(c); + + if (is_context_horizontal(c)) { + horz_clamp_iterator32 ci(c); + while (di.count--) { + uint32_t s = ci.get_pixel32(); + bl.write(s, di.dst); + di.dst++; + } + } else { + clamp_iterator ci(c); + while (di.count--) { + uint32_t s = ci.get_pixel32(); + bl.write(s, di.dst); + di.dst++; + } + } +} + +static void scanline_t32cb16blend_clamp_dither(context_t* c) +{ + dst_iterator16 di(c); + ditherer dither(c); + blender_32to16 bl(c); + + clamp_iterator ci(c); + while (di.count--) { + uint32_t s = ci.get_pixel32(); + bl.write(s, di.dst, dither); + di.dst++; + } +} + +void scanline_t32cb16blend_clamp_mod(context_t* c) +{ + dst_iterator16 di(c); + blender_32to16_modulate bl(c); + + clamp_iterator ci(c); + while (di.count--) { + uint32_t s = ci.get_pixel32(); + bl.write(s, di.dst); + di.dst++; + } +} + +void scanline_t32cb16blend_clamp_mod_dither(context_t* c) +{ + dst_iterator16 di(c); + blender_32to16_modulate bl(c); + ditherer dither(c); + + clamp_iterator ci(c); + while (di.count--) { + uint32_t s = ci.get_pixel32(); + bl.write(s, di.dst, dither); + di.dst++; + } +} + +/* Variant of scanline_t32cb16blend_clamp_mod with a xRGB texture */ +void scanline_x32cb16blend_clamp_mod(context_t* c) +{ + dst_iterator16 di(c); + blender_x32to16_modulate bl(c); + + clamp_iterator ci(c); + while (di.count--) { + uint32_t s = ci.get_pixel32(); + bl.write(s, di.dst); + di.dst++; + } +} + +void scanline_x32cb16blend_clamp_mod_dither(context_t* c) +{ + dst_iterator16 di(c); + blender_x32to16_modulate bl(c); + ditherer dither(c); + + clamp_iterator ci(c); + while (di.count--) { + uint32_t s = ci.get_pixel32(); + bl.write(s, di.dst, dither); + di.dst++; + } +} + +void scanline_t16cb16_clamp(context_t* c) +{ + dst_iterator16 di(c); + + /* Special case for simple horizontal scaling */ + if (is_context_horizontal(c)) { + horz_clamp_iterator16 ci(c); + while (di.count--) { + *di.dst++ = ci.get_pixel16(); + } + } else { + clamp_iterator ci(c); + while (di.count--) { + *di.dst++ = ci.get_pixel16(); + } + } +} + + + template <typename T, typename U> static inline __attribute__((const)) T interpolate(int y, T v0, U dvdx, U dvdy) { @@ -1322,30 +2107,24 @@ void scanline_t32cb16(context_t* c) if (ct==1 || uint32_t(dst)&2) { last_one: s = GGL_RGBA_TO_HOST( *src++ ); - sR = (s >> ( 3))&0x1F; - sG = (s >> ( 8+2))&0x3F; - sB = (s >> (16+3))&0x1F; - *dst++ = uint16_t((sR<<11)|(sG<<5)|sB); + *dst++ = convertAbgr8888ToRgb565(s); ct--; } while (ct >= 2) { +#if BYTE_ORDER == BIG_ENDIAN s = GGL_RGBA_TO_HOST( *src++ ); - sR = (s >> ( 3))&0x1F; - sG = (s >> ( 8+2))&0x3F; - sB = (s >> (16+3))&0x1F; - d = (sR<<11)|(sG<<5)|sB; - + d = convertAbgr8888ToRgb565_hi16(s); + + s = GGL_RGBA_TO_HOST( *src++ ); + d |= convertAbgr8888ToRgb565(s); +#else s = GGL_RGBA_TO_HOST( *src++ ); - sR = (s >> ( 3))&0x1F; - sG = (s >> ( 8+2))&0x3F; - sB = (s >> (16+3))&0x1F; - d |= ((sR<<11)|(sG<<5)|sB)<<16; + d = convertAbgr8888ToRgb565(s); -#if BYTE_ORDER == BIG_ENDIAN - d = (d>>16) | (d<<16); + s = GGL_RGBA_TO_HOST( *src++ ); + d |= convertAbgr8888ToRgb565(s) << 16; #endif - *dst32++ = d; ct -= 2; } @@ -1357,6 +2136,7 @@ last_one: void scanline_t32cb16blend(context_t* c) { +#if ((ANDROID_CODEGEN >= ANDROID_CODEGEN_ASM) && defined(__arm__)) int32_t x = c->iterators.xl; size_t ct = c->iterators.xr - x; int32_t y = c->iterators.y; @@ -1368,33 +2148,55 @@ void scanline_t32cb16blend(context_t* c) const int32_t v = (c->state.texture[0].shade.it0>>16) + y; uint32_t *src = reinterpret_cast<uint32_t*>(tex->data)+(u+(tex->stride*v)); -#if ((ANDROID_CODEGEN >= ANDROID_CODEGEN_ASM) && defined(__arm__)) scanline_t32cb16blend_arm(dst, src, ct); #else - while (ct--) { - uint32_t s = *src++; - if (!s) { - dst++; - continue; - } - uint16_t d = *dst; - s = GGL_RGBA_TO_HOST(s); - int sR = (s >> ( 3))&0x1F; - int sG = (s >> ( 8+2))&0x3F; - int sB = (s >> (16+3))&0x1F; - int sA = (s>>24); - int f = 0x100 - (sA + (sA>>7)); - int dR = (d>>11)&0x1f; - int dG = (d>>5)&0x3f; - int dB = (d)&0x1f; - sR += (f*dR)>>8; - sG += (f*dG)>>8; - sB += (f*dB)>>8; - *dst++ = uint16_t((sR<<11)|(sG<<5)|sB); + dst_iterator16 di(c); + horz_iterator32 hi(c); + blender_32to16 bl(c); + while (di.count--) { + uint32_t s = hi.get_pixel32(); + bl.write(s, di.dst); + di.dst++; } #endif } +void scanline_t32cb16blend_srca(context_t* c) +{ + dst_iterator16 di(c); + horz_iterator32 hi(c); + blender_32to16_srcA blender(c); + + while (di.count--) { + uint32_t s = hi.get_pixel32(); + blender.write(s,di.dst); + di.dst++; + } +} + +void scanline_t16cb16blend_clamp_mod(context_t* c) +{ + const int a = c->iterators.ydady >> (GGL_COLOR_BITS-8); + if (a == 0) { + return; + } + + if (a == 255) { + scanline_t16cb16_clamp(c); + return; + } + + dst_iterator16 di(c); + blender_16to16_modulate blender(c); + clamp_iterator ci(c); + + while (di.count--) { + uint16_t s = ci.get_pixel16(); + blender.write(s, di.dst); + di.dst++; + } +} + void scanline_memcpy(context_t* c) { int32_t x = c->iterators.xl; diff --git a/libsysutils/src/SocketClient.cpp b/libsysutils/src/SocketClient.cpp index a6aed26..90ca52e 100644 --- a/libsysutils/src/SocketClient.cpp +++ b/libsysutils/src/SocketClient.cpp @@ -15,8 +15,10 @@ SocketClient::SocketClient(int socket) , mPid(-1) , mUid(-1) , mGid(-1) + , mRefCount(1) { pthread_mutex_init(&mWriteMutex, NULL); + pthread_mutex_init(&mRefCountMutex, NULL); struct ucred creds; socklen_t szCreds = sizeof(creds); @@ -100,3 +102,25 @@ int SocketClient::sendData(const void* data, int len) { pthread_mutex_unlock(&mWriteMutex); return 0; } + +void SocketClient::incRef() { + pthread_mutex_lock(&mRefCountMutex); + mRefCount++; + pthread_mutex_unlock(&mRefCountMutex); +} + +bool SocketClient::decRef() { + bool deleteSelf = false; + pthread_mutex_lock(&mRefCountMutex); + mRefCount--; + if (mRefCount == 0) { + deleteSelf = true; + } else if (mRefCount < 0) { + SLOGE("SocketClient refcount went negative!"); + } + pthread_mutex_unlock(&mRefCountMutex); + if (deleteSelf) { + delete this; + } + return deleteSelf; +} diff --git a/libsysutils/src/SocketListener.cpp b/libsysutils/src/SocketListener.cpp index 611d5fe..fcad624 100644 --- a/libsysutils/src/SocketListener.cpp +++ b/libsysutils/src/SocketListener.cpp @@ -55,7 +55,7 @@ SocketListener::~SocketListener() { } SocketClientCollection::iterator it; for (it = mClients->begin(); it != mClients->end();) { - delete (*it); + (*it)->decRef(); it = mClients->erase(it); } delete mClients; @@ -213,8 +213,9 @@ void SocketListener::runListener() { it = pendingList->begin(); SocketClient* c = *it; pendingList->erase(it); - /* Process it, if false is returned, remove and destroy it */ - if (!onDataAvailable(c)) { + /* Process it, if false is returned and our sockets are + * connection-based, remove and destroy it */ + if (!onDataAvailable(c) && mListen) { /* Remove the client from our array */ pthread_mutex_lock(&mClientsLock); for (it = mClients->begin(); it != mClients->end(); ++it) { @@ -225,8 +226,11 @@ void SocketListener::runListener() { } pthread_mutex_unlock(&mClientsLock); /* Destroy the client */ - close(c->getSocket()); - delete c; + int socket = c->getSocket(); + if (c->decRef()) { + // Note: 'c' is deleted memory at this point. + close(socket); + } } } } diff --git a/rootdir/etc/ueventd.goldfish.rc b/rootdir/etc/ueventd.goldfish.rc index b5828e7..8de7049 100644 --- a/rootdir/etc/ueventd.goldfish.rc +++ b/rootdir/etc/ueventd.goldfish.rc @@ -1,4 +1,5 @@ # These settings are specific to running under the Android emulator /dev/qemu_trace 0666 system system +/dev/qemu_pipe 0666 system system /dev/ttyS* 0666 system system /proc 0666 system system |