rdpsnd.c File Reference

#include "rdesktop.h"

Include dependency graph for rdpsnd.c:

Go to the source code of this file.

Macros
#define	RDPSND_CLOSE   1
#define	RDPSND_WRITE   2
#define	RDPSND_SET_VOLUME   3
#define	RDPSND_UNKNOWN4   4
#define	RDPSND_COMPLETION   5
#define	RDPSND_SERVERTICK   6
#define	RDPSND_NEGOTIATE   7

Functions
static STREAM	rdpsnd_init_packet (RDPCLIENT *This, uint16 type, uint16 size)
static void	rdpsnd_send (RDPCLIENT *This, STREAM s)
void	rdpsnd_send_completion (RDPCLIENT *This, uint16 tick, uint8 packet_index)
static void	rdpsnd_process_negotiate (RDPCLIENT *This, STREAM in)
static void	rdpsnd_process_servertick (RDPCLIENT *This, STREAM in)
static void	rdpsnd_process (RDPCLIENT *This, STREAM s)
BOOL	rdpsnd_init (RDPCLIENT *This)

Macro Definition Documentation

RDPSND_CLOSE

#define RDPSND_CLOSE   1

Definition at line 24 of file rdpsnd.c.

RDPSND_COMPLETION

#define RDPSND_COMPLETION   5

Definition at line 28 of file rdpsnd.c.

RDPSND_NEGOTIATE

#define RDPSND_NEGOTIATE   7

Definition at line 30 of file rdpsnd.c.

RDPSND_SERVERTICK

#define RDPSND_SERVERTICK   6

Definition at line 29 of file rdpsnd.c.

RDPSND_SET_VOLUME

#define RDPSND_SET_VOLUME   3

Definition at line 26 of file rdpsnd.c.

RDPSND_UNKNOWN4

#define RDPSND_UNKNOWN4   4

Definition at line 27 of file rdpsnd.c.

RDPSND_WRITE

#define RDPSND_WRITE   2

Definition at line 25 of file rdpsnd.c.

Function Documentation

rdpsnd_init()

BOOL rdpsnd_init

(

RDPCLIENT *

This

)

Definition at line 249 of file rdpsnd.c.

{
    This->rdpsnd.channel =
        channel_register(This, "rdpsnd", CHANNEL_OPTION_INITIALIZED | CHANNEL_OPTION_ENCRYPT_RDP,
                 rdpsnd_process);
    return (This->rdpsnd.channel != NULL);
}

rdpsnd_init_packet()

static STREAM rdpsnd_init_packet ( RDPCLIENT *  This, uint16  type, uint16  size  )

static

Definition at line 33 of file rdpsnd.c.

{
    STREAM s;
 
    s = channel_init(This, This->rdpsnd.channel, size + 4);
    out_uint16_le(s, type);
    out_uint16_le(s, size);
    return s;
}

Referenced by rdpsnd_process_negotiate(), rdpsnd_process_servertick(), and rdpsnd_send_completion().

rdpsnd_process()

static void rdpsnd_process ( RDPCLIENT *  This, STREAM  s  )

static

Definition at line 168 of file rdpsnd.c.

{
    uint8 type;
    uint16 datalen;
    uint32 volume;
    static uint16 tick, format;
    static uint8 packet_index;
    static BOOL awaiting_data_packet;
 
#ifdef RDPSND_DEBUG
    printf("RDPSND recv:\n");
    hexdump(s->p, s->end - s->p);
#endif
 
    if (awaiting_data_packet)
    {
        if (format >= MAX_FORMATS)
        {
            error("RDPSND: Invalid format index\n");
            return;
        }
 
        if (!This->rdpsnd.device_open || (format != This->rdpsnd.current_format))
        {
            if (!This->rdpsnd.device_open && !wave_out_open())
            {
                rdpsnd_send_completion(This, tick, packet_index);
                return;
            }
            if (!wave_out_set_format(&This->rdpsnd.formats[format]))
            {
                rdpsnd_send_completion(This, tick, packet_index);
                wave_out_close();
                This->rdpsnd.device_open = False;
                return;
            }
            This->rdpsnd.device_open = True;
            This->rdpsnd.current_format = format;
        }
 
        wave_out_write(s, tick, packet_index);
        awaiting_data_packet = False;
        return;
    }
 
    in_uint8(s, type);
    in_uint8s(s, 1);    /* unknown? */
    in_uint16_le(s, datalen);
 
    switch (type)
    {
        case RDPSND_WRITE:
            in_uint16_le(s, tick);
            in_uint16_le(s, format);
            in_uint8(s, packet_index);
            awaiting_data_packet = True;
            break;
        case RDPSND_CLOSE:
            wave_out_close();
            This->rdpsnd.device_open = False;
            break;
        case RDPSND_NEGOTIATE:
            rdpsnd_process_negotiate(This, s);
            break;
        case RDPSND_SERVERTICK:
            rdpsnd_process_servertick(This, s);
            break;
        case RDPSND_SET_VOLUME:
            in_uint32(s, volume);
            if (This->rdpsnd.device_open)
            {
                wave_out_volume((volume & 0xffff), (volume & 0xffff0000) >> 16);
            }
            break;
        default:
            unimpl("RDPSND packet type %d\n", type);
            break;
    }
}

Referenced by rdpsnd_init().

rdpsnd_process_negotiate()

static void rdpsnd_process_negotiate ( RDPCLIENT *  This, STREAM  in  )

static

Definition at line 68 of file rdpsnd.c.

{
    unsigned int in_format_count, i;
    WAVEFORMATEX *format;
    STREAM out;
    BOOL device_available = False;
    int readcnt;
    int discardcnt;
 
    in_uint8s(in, 14);  /* flags, volume, pitch, UDP port */
    in_uint16_le(in, in_format_count);
    in_uint8s(in, 4);   /* pad, status, pad */
 
    if (wave_out_open())
    {
        wave_out_close();
        device_available = True;
    }
 
    This->rdpsnd.format_count = 0;
    if (s_check_rem(in, 18 * in_format_count))
    {
        for (i = 0; i < in_format_count; i++)
        {
            format = &This->rdpsnd.formats[This->rdpsnd.format_count];
            in_uint16_le(in, format->wFormatTag);
            in_uint16_le(in, format->nChannels);
            in_uint32_le(in, format->nSamplesPerSec);
            in_uint32_le(in, format->nAvgBytesPerSec);
            in_uint16_le(in, format->nBlockAlign);
            in_uint16_le(in, format->wBitsPerSample);
            in_uint16_le(in, format->cbSize);
 
            /* read in the buffer of unknown use */
            readcnt = format->cbSize;
            discardcnt = 0;
            if (format->cbSize > MAX_CBSIZE)
            {
                fprintf(stderr, "cbSize too large for buffer: %d\n",
                    format->cbSize);
                readcnt = MAX_CBSIZE;
                discardcnt = format->cbSize - MAX_CBSIZE;
            }
            in_uint8a(in, format->cb, readcnt);
            in_uint8s(in, discardcnt);
 
            if (device_available && wave_out_format_supported(format))
            {
                This->rdpsnd.format_count++;
                if (This->rdpsnd.format_count == MAX_FORMATS)
                    break;
            }
        }
    }
 
    out = rdpsnd_init_packet(This, RDPSND_NEGOTIATE | 0x200, 20 + 18 * This->rdpsnd.format_count);
    out_uint32_le(out, 3);  /* flags */
    out_uint32(out, 0xffffffff);    /* volume */
    out_uint32(out, 0); /* pitch */
    out_uint16(out, 0); /* UDP port */
 
    out_uint16_le(out, This->rdpsnd.format_count);
    out_uint8(out, 0x95);   /* pad? */
    out_uint16_le(out, 2);  /* status */
    out_uint8(out, 0x77);   /* pad? */
 
    for (i = 0; i < This->rdpsnd.format_count; i++)
    {
        format = &This->rdpsnd.formats[i];
        out_uint16_le(out, format->wFormatTag);
        out_uint16_le(out, format->nChannels);
        out_uint32_le(out, format->nSamplesPerSec);
        out_uint32_le(out, format->nAvgBytesPerSec);
        out_uint16_le(out, format->nBlockAlign);
        out_uint16_le(out, format->wBitsPerSample);
        out_uint16(out, 0); /* cbSize */
    }
 
    s_mark_end(out);
    rdpsnd_send(This, out);
}

Referenced by rdpsnd_process().

rdpsnd_process_servertick()

static void rdpsnd_process_servertick ( RDPCLIENT *  This, STREAM  in  )

static

Definition at line 151 of file rdpsnd.c.

{
    uint16 tick1, tick2;
    STREAM out;
 
    /* in_uint8s(in, 4); unknown */
    in_uint16_le(in, tick1);
    in_uint16_le(in, tick2);
 
    out = rdpsnd_init_packet(This, RDPSND_SERVERTICK | 0x2300, 4);
    out_uint16_le(out, tick1);
    out_uint16_le(out, tick2);
    s_mark_end(out);
    rdpsnd_send(This, out);
}

Referenced by rdpsnd_process().

rdpsnd_send()

static void rdpsnd_send ( RDPCLIENT *  This, STREAM  s  )

static

Definition at line 44 of file rdpsnd.c.

{
#ifdef RDPSND_DEBUG
    printf("RDPSND send:\n");
    hexdump(s->channel_hdr + 8, s->end - s->channel_hdr - 8);
#endif
 
    channel_send(This, s, This->rdpsnd.channel);
}

Referenced by rdpsnd_process_negotiate(), rdpsnd_process_servertick(), and rdpsnd_send_completion().

rdpsnd_send_completion()

void rdpsnd_send_completion	(	RDPCLIENT *	This,
		uint16	tick,
		uint8	packet_index
	)

Definition at line 55 of file rdpsnd.c.

{
    STREAM s;
 
    s = rdpsnd_init_packet(This, RDPSND_COMPLETION, 4);
    out_uint16_le(s, tick + 50);
    out_uint8(s, packet_index);
    out_uint8(s, 0);
    s_mark_end(s);
    rdpsnd_send(This, s);
}

Referenced by rdpsnd_process(), wave_out_close(), and wave_out_play().