ref: d00878118ad48befd85c7499a6db4bdfd42c83e1
dir: /msg_test.c/
#include "msg.c"
char Ebignum[]= "number too big";
static int
testputmsg1(void){
int n;
char *s, *want;
uchar buf[1042];
Msg m;
m.type = Xconnect;
m.negproto = ProtoTLS;
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg1: unexpected error: %r\n");
s = smprint("%.*H", n, buf);
want = "0300002722E00000000000436F6F6B69653A206D737473686173683D780D0A0100080001000000";
if(strcmp(s, want) != 0)
sysfatal("testputmsg1: want %s, got %s", want, s);
free(s);
return 0;
}
static int
testputmsg2(void){
int n;
char *s, *want;
uchar buf[1042];
Msg m;
m.type = Xhangup;
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg2: unexpected error: %r\n");
s = smprint("%.*H", n, buf);
if(strcmp(s, want = "03000007028080") != 0)
sysfatal("testputmsg2: want %s, got %s", want, s);
free(s);
return 0;
}
static int
testputmsg3(void){
int n;
char *s, *want;
uchar buf[1042];
Msg m;
m.type = Mattach;
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg3: unexpected error: %r\n");
s = smprint("%.*H", n, buf);
if(strcmp(s, want = "0300000802F08028") != 0)
sysfatal("testputmsg3: want %s, got %s", want, s);
free(s);
return 0;
}
static int
testputmsg4(void){
int n;
char *s, *want;
uchar buf[1042];
Msg m;
m.type = Mjoin;
m.mcsuid = 0xdead;
m.chanid = 0xbeef;
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg4: unexpected error: %r\n");
s = smprint("%.*H", n, buf);
if(strcmp(s, want = "0300000C02F08038DEADBEEF") != 0)
sysfatal("testputmsg4: want %s, got %s", want, s);
free(s);
return 0;
}
static int
testputmsg5(void){
int n;
char *s, *want;
uchar buf[1042];
Msg m;
m.type = Merectdom;
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg5: unexpected error: %r\n");
s = smprint("%.*H", n, buf);
if(strcmp(s, want = "0300000C02F0800400010001") != 0)
sysfatal("testputmsg5: want %s, got %s", want, s);
free(s);
return 0;
}
static int
testputmsg6(void){
int n;
char *s, *want;
uchar buf[1024];
Msg m;
Vchan vctab[] = {
{ .mcsid = GLOBALCHAN+1, .name = "CLIPRDR", .flags = 1<<31 },
{ .mcsid = GLOBALCHAN+2, .name = "RDPDR", .flags = 1<<31 },
};
m.type = Mconnect;
m.ver = 0x80004; /* RDP5 */
m.depth = 32;
m.xsz = 1024;
m.ysz = 768;
m.sysname = "TSCLIENT-TEST";
m.sproto = ProtoTLS;
m.wantconsole = 0;
m.nvc = 2;
m.vctab = vctab;
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg6: unexpected error: %r\n");
want = "030001A602F0807F6582019A0401010401010101FF30200202002202020002020200000202000102020000020200010202FFFF020200023020020200010202000102020001020200010202000002020001020204200202000230200202FFFF0202FFFF0202FFFF0202000102020000020200010202FFFF0202000204820127000500147C0001811E000800100001C00044756361811001C0D800040008000004000301CA03AA09040000280A00005400530043004C00490045004E0054002D00540045005300540000000000000004000000000000000C0000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000001CA01000000000018000F0003000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000007000100000002C00C00000000000000000004C00C00090000000000000003C0200002000000434C49505244520080000000524450445200000080000000";
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0){
fprint(2, "testputmsg6: want '%s', got '%s'\n", want, s);
sysfatal("testputmsg6");
}
free(s);
return 0;
}
static int
testputmsg7(void){
int n;
char *s, *want;
uchar buf[4*1024];
Msg m;
m.type = Dclientinfo;
m.mcsuid = 0xBEEF;
m.dom = "TESTDOM";
m.user = "testuser";
m.pass = "secret";
m.rshell = "explorer.exe";
m.rwd = "C:\\";
m.dologin = 1;
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg7: unexpected error: %r\n");
want = "0300013302F08064BEEF03EB7081244000000000000000BB0300000E0010000C0018000600540045005300540044004F004D00000074006500730074007500730065007200000073006500630072006500740000006500780070006C006F007200650072002E00650078006500000043003A005C00000002000000020000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000CE000000";
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0){
fprint(2, "testputmsg7: want '%s', got '%s'\n", want, s);
sysfatal("testputmsg7");
}
free(s);
return 0;
}
static int
testputmsg8(void){
int n;
char *s, *want;
uchar buf[1042];
Msg m;
m.type = Mactivated;
m.originid = 0xAAAA;
m.mcsuid = 0xBBBB;
m.shareid = 0xCCCC;
m.xsz = 1024;
m.ysz = 600;
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg8: unexpected error: %r\n");
want = "0300018402F08064BBBB03EB70817575011300BBBBCCCC0000AAAA07005E01506C616E2039000800000001001800000000000002000200000504000000000000000002001E000000010001000100000458020000010001000000010000000002030058000000000000000000000000000000000000000000010014000000010000006A000000010100000000000000000000000000000000000000000000000000000000A1060000000000000084030000000000E40004001300280000000003780000007800000050010000000000000000000000000000000000000000000008000800000014000D005800110000000904000004000000000000000C000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000C00080000000000140008000000000010003400FE000400FE000400FE000800FE000800FE001000FE002000FE004000FE008000FE000001400000080001000100000000";
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0){
fprint(2, "testputmsg8: want '%s', got '%s'\n", want, s);
sysfatal("testputmsg8");
}
free(s);
return 0;
}
static int
testputmsg9(void){
int n;
char *s, *want;
uchar buf[1042];
enum {
First= 1<<0,
Last= 1<<1,
Vis= 1<<4,
};
Msg m = {
.type = Mvchan,
.originid = 0x1111,
.chanid = 0x2222,
.flags = First | Vis | Last,
.len = 7,
.ndata = 7,
.data = (uchar*)"abcdefg",
};
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg9: unexpected error: %r\n");
want = "0300001E02F080641111222270800F070000001300000061626364656667";
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0)
sysfatal("testputmsg9: want '%s', got '%s'", want, s);
free(s);
return 0;
}
static int
testputmsg10(void){
int n;
char *s, *want;
uchar buf[512];
Msg m = {
.type = Async,
.mcsuid = 0x1111,
.originid = 0x2222,
.shareid = 0x3333,
};
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg10: unexpected error: %r\n");
want = "0300002502F08064222203EB70801616001700222233330000000116001F00000001001111";
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0)
sysfatal("testputmsg10: want '%s', got '%s'", want, s);
free(s);
return 0;
}
static int
testputmsg11(void){
int n;
char *s, *want;
uchar buf[1024];
Msg m = {.type = Actl, .action = CAcooperate, .originid = 0x1111, .shareid = 0x2222};
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg11: unexpected error: %r\n");
want = "0300002902F08064111103EB70801A1A00170011112222000000011A00140000000400000000000000";
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0)
sysfatal("testputmsg11: want '%s', got '%s'", want, s);
free(s);
return 0;
}
static int
testputmsg12(void){
int n;
char *s, *want;
uchar buf[1024];
Msg m = {.type = Actl, .action = CAreqctl, .originid = 0x3333, .shareid = 0x4444};
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg12: unexpected error: %r\n");
want = "0300002902F08064333303EB70801A1A00170033334444000000011A00140000000100000000000000";
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0)
sysfatal("testputmsg12: want '%s', got '%s'", want, s);
free(s);
return 0;
}
static int
testputmsg13(void){
int n;
char *s, *want;
uchar buf[1024];
Msg m = {.type = Afontls, .originid = 0x4444, .shareid = 0x5555};
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg13: unexpected error: %r\n");
want = "0300002902F08064444403EB70801A1A00170044445555000000011A00270000000000000003003200";
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0)
sysfatal("testputmsg13: want '%s', got '%s'", want, s);
free(s);
return 0;
}
static int
testputmsg14(void){
int n;
char *s, *want;
uchar buf[1042];
Msg m;
m.type = Ainput;
m.originid = 0x1111;
m.shareid = 0x2222;
m.msec = 0;
m.mtype = InputSync;
m.flags = 0;
m.iarg[0] = 0;
m.iarg[1] = 0;
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg14: unexpected error: %r\n");
want = "0300003102F08064111103EB70802222001700111122220000000122001C00000001000000000000000000000000000000";
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0)
sysfatal("testputmsg14: want '%s', got '%s'", want, s);
free(s);
return 0;
}
static int
testputmsg15(void){
int n;
char *s, *want;
uchar buf[1042];
Msg m;
enum {
Slshift= 42,
};
m.type = Ainput;
m.originid = 0x1111;
m.shareid = 0x2222;
m.msec = 0x3333;
m.mtype = InputKeycode;
m.flags = 0x44;
m.iarg[0] = Slshift;
m.iarg[1] = 0;
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg15: unexpected error: %r\n");
want = "0300003102F08064111103EB70802222001700111122220000000122001C0000000100000033330000040044002A000000";
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0)
sysfatal("testputmsg15: want '%s', got '%s'", want, s);
free(s);
return 0;
}
static int
testputmsg16(void){
int n;
char *s, *want;
uchar buf[2*1024];
Msg m = {.type = Lreq, .sysname = "TESTSYS", .user = "testuser", .originid=0x1111};
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg16: unexpected error: %r\n");
want =
// TPKT header
"03" // version[1] = 3
"00" // unused[1] = 0
"008C" // len[2]
// TPDU header
"02" // hdlen[1] = 2
"F0" // type[1] = Data
"80" // seqno[1] = (0 in Class 0) + EOT mark (1<<7)
// MCS Send Data Request: header
"64" // type = Msdr(25) <<2
"1111" // mcsuid = m.originid (0x1111)
"03EB" // chanid = GLOBALCHAN(1003)
"70" // always 0x70
"807D" // 0x8000 | ndata(125)
// MCS Send Data Request: data
"80000000" // sechdr[4]: secflags[4] = Slicensepk(0x80)
"13" // type[1] = CNeedLicense
"03" // flags[1] = PreambleV3
"7900" // size[2]
"01000000" // kexalg[4] = KeyExRSA
"00000000" // platfid[4] = 0
"0000000000000000" "0000000000000000"
"0000000000000000" "0000000000000000"
// crandom[32] = 32 {0}
// premaster[blob]
"0200" // type[2] = Brandom(2)
"3000" // len[2] = 48
"0000000000000000" "0000000000000000"
"0000000000000000" "0000000000000000"
"0000000000000000" "0000000000000000"
// data[len] = 48 {0}
// cuser[blob]
"0F00" // type[2] = Bcuser(15)
"0900" // len[2] = 9
"746573747573657200"
// data[len] = "testuser\0"
// chost[blob]
"1000" // type[2] = Bchost(16)
"0800" // len[2] = 8
"5445535453595300"
// data[len] = "TESTSYS\0"
;
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0){
fprint(2, "testputmsg16: want '%s', got '%s'\n", want, s);
sysfatal("testputmsg16");
}
free(s);
return 0;
}
static int
testputmsg17(void){
int n;
char *s, *want;
uchar buf[1024];
Msg m = {.type = Lnolicense, .originid=0x1111};
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg17: unexpected error: %r\n");
want =
"0300002302F08064111103EB70801480000000FF031000020000000100000004000000";
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0)
sysfatal("testputmsg17: want '%s', got '%s'", want, s);
free(s);
return 0;
}
static int
testputmsg18(void){
int n;
char *s, *want;
uchar buf[512];
Msg m = {
.type = Dsupress,
.originid = 0x2222,
.shareid = 0x3333,
.xsz = 1280,
.ysz = 800,
.allow = 1,
};
n = putmsg(buf, sizeof buf, &m);
if(n < 0)
sysfatal("testputmsg18: unexpected error: %r\n");
want =
"0300002D02F08064222203EB70801E1E00170022223333000000011E00230000000100000000000000FF041F03";
s = smprint("%.*H", n, buf);
if(strcmp(s, want) != 0)
sysfatal("testputmsg18: want '%s', got '%s'", want, s);
free(s);
return 0;
}
static int
testgetmsg1(void)
{
/* Fast-path update: 2-byte length header */
int n, nb;
uchar buf[16];
Msg m = {0};
char *hex = "0006DEADBEEF";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg1: unexpected error: %r");
if(m.type != Aupdate)
sysfatal("testgetmsg1: type: want %d, got %d", Aupdate, m.type);
if(m.ndata != 4)
sysfatal("testgetmsg1: ndata: want 4, got %d", m.ndata);
if(m.getshare != getshareF)
sysfatal("testgetmsg1: getshare: expected getshareF");
return 0;
}
static int
testgetmsg2(void)
{
/* Fast-path update: 3-byte length header */
int n, nb;
uchar buf[16];
Msg m = {0};
char *hex = "008006AABBCC";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg2: unexpected error: %r");
if(m.type != Aupdate)
sysfatal("testgetmsg2: type: want %d, got %d", Aupdate, m.type);
if(m.ndata != 3)
sysfatal("testgetmsg2: ndata: want 3, got %d", m.ndata);
if(m.getshare != getshareF)
sysfatal("testgetmsg2: getshare: expected getshareF");
return 0;
}
static int
testgetmsg3(void)
{
/* X.224 connection confirm with TLS negotiation response */
int n, nb;
uchar buf[32];
Msg m = {0};
char *hex = "0300001306D000000000000200080001000000";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg3: unexpected error: %r");
if(m.type != Xconnected)
sysfatal("testgetmsg3: type: want %d, got %d", Xconnected, m.type);
if(m.negproto != ProtoTLS)
sysfatal("testgetmsg3: negproto: want %d (ProtoTLS), got %d", ProtoTLS, m.negproto);
return 0;
}
static int
testgetmsg4(void)
{
/* X.224 connection confirm with non-matching nego type: negproto stays 0 */
int n, nb;
uchar buf[32];
Msg m = {0};
char *hex = "0300001306D000000000000100080000000000";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg4: unexpected error: %r");
if(m.type != Xconnected)
sysfatal("testgetmsg4: type: want %d, got %d", Xconnected, m.type);
if(m.negproto != 0)
sysfatal("testgetmsg4: negproto: want 0, got %d", m.negproto);
return 0;
}
static int
testgetmsg5(void)
{
/* MCS Attach User Confirm with userId present */
int n, nb;
uchar buf[16];
Msg m = {0};
char *hex = "0300000B02F0802E00BEEF";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg5: unexpected error: %r");
if(m.type != Mattached)
sysfatal("testgetmsg5: type: want %d, got %d", Mattached, m.type);
if(m.mcsuid != 0xBEEF)
sysfatal("testgetmsg5: mcsuid: want 0xBEEF, got 0x%X", m.mcsuid);
return 0;
}
static int
testgetmsg6(void)
{
/* MCS Attach User Confirm without userId */
int n, nb;
uchar buf[16];
Msg m = {0};
char *hex = "0300000902F0802C00";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg6: unexpected error: %r");
if(m.type != Mattached)
sysfatal("testgetmsg6: type: want %d, got %d", Mattached, m.type);
if(m.mcsuid != 0)
sysfatal("testgetmsg6: mcsuid: want 0, got 0x%X", m.mcsuid);
return 0;
}
static int
testgetmsg7(void)
{
/* MCS Channel Join Confirm */
int n, nb;
uchar buf[16];
Msg m = {0};
char *hex = "0300000902F0803C00";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg7: unexpected error: %r");
if(m.type != Mjoined)
sysfatal("testgetmsg7: type: want %d, got %d", Mjoined, m.type);
return 0;
}
static int
testgetmsg8(void)
{
/* Disconnect Provider Ultimatum */
int n, nb;
uchar buf[16];
Msg m = {0};
char *hex = "0300000902F0802180";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg8: unexpected error: %r");
if(m.type != Mclosing)
sysfatal("testgetmsg8: type: want %d, got %d", Mclosing, m.type);
return 0;
}
static int
testgetmsg9(void)
{
/* MCS virtual channel data (non-global channel) */
int n, nb;
uchar buf[64];
Msg m = {0};
char *hex = "0300001E02F080681111222270800F070000001300000061626364656667";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg9: unexpected error: %r");
if(m.type != Mvchan)
sysfatal("testgetmsg9: type: want %d, got %d", Mvchan, m.type);
if(m.chanid != 0x2222)
sysfatal("testgetmsg9: chanid: want 0x2222, got 0x%X", m.chanid);
if(m.len != 7)
sysfatal("testgetmsg9: len: want 7, got %d", m.len);
if(m.flags != 0x13)
sysfatal("testgetmsg9: flags: want 0x13, got 0x%lX", m.flags);
if(m.ndata != 7)
sysfatal("testgetmsg9: ndata: want 7, got %d", m.ndata);
if(memcmp(m.data, "abcdefg", 7) != 0)
sysfatal("testgetmsg9: data mismatch");
return 0;
}
static int
testgetmsg10(void)
{
/* Slow-path update on global channel */
int n, nb;
uchar buf[32];
Msg m = {0};
char *hex = "0300001302F08068111103EB70800400000000";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg10: unexpected error: %r");
if(m.type != Aupdate)
sysfatal("testgetmsg10: type: want %d, got %d", Aupdate, m.type);
if(m.ndata != 4)
sysfatal("testgetmsg10: ndata: want 4, got %d", m.ndata);
if(m.getshare != getshareT)
sysfatal("testgetmsg10: getshare: expected getshareT");
return 0;
}
static int
testgetmsg11(void)
{
/* Error: MCS Attach User Confirm with non-zero error result */
int n, nb;
uchar buf[16];
Msg m = {0};
char *hex = "0300000902F0802C01";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n >= 0)
sysfatal("testgetmsg11: expected error, got %d", n);
return 0;
}
static int
testgetmsg12(void)
{
/* Error: MCS Channel Join Confirm with non-zero error result */
int n, nb;
uchar buf[16];
Msg m = {0};
char *hex = "0300000902F0803C01";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n >= 0)
sysfatal("testgetmsg12: expected error, got %d", n);
return 0;
}
static int
testgetmsg13(void)
{
/* Error: legacy encryption in fast-path PDU */
int n, nb;
uchar buf[16];
Msg m = {0};
char *hex = "8006DEADBEEF";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n >= 0)
sysfatal("testgetmsg13: expected error, got %d", n);
return 0;
}
static int
testgetmsg14(void)
{
/* Flow PDU on global channel (isflowpdu): GSHORT = 0x8000 → Aflow */
int n, nb;
uchar buf[32];
Msg m = {0};
char *hex = "0300001302F08068111103EB70800400800000";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg14: unexpected error: %r");
if(m.type != Aflow)
sysfatal("testgetmsg14: type: want %d (Aflow), got %d", Aflow, m.type);
return 0;
}
static int
testgetmsg15(void)
{
/*
* Slow-path on global channel with Slicensepk flag but sctlver==1.
* The condition "secflg&Slicensepk && sctlver != 1" is false, so
* getlicensemsg is NOT called and the PDU falls through to Aupdate.
*/
int n, nb;
uchar buf[32];
Msg m = {0};
char *hex = "0300001302F08068111103EB70800480001000";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg15: unexpected error: %r");
if(m.type != Aupdate)
sysfatal("testgetmsg15: type: want %d (Aupdate), got %d", Aupdate, m.type);
if(m.ndata != 4)
sysfatal("testgetmsg15: ndata: want 4, got %d", m.ndata);
if(m.getshare != getshareT)
sysfatal("testgetmsg15: getshare: expected getshareT");
return 0;
}
static int
testgetmsg16(void)
{
/* License PDU with Notify (0xFF) type → Ldone */
int n, nb;
uchar buf[32];
Msg m = {0};
char *hex = "0300001402F08068111103EB70800580000000FF";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg16: unexpected error: %r");
if(m.type != Ldone)
sysfatal("testgetmsg16: type: want %d (Ldone), got %d", Ldone, m.type);
return 0;
}
static int
testgetmsg17(void)
{
/* License PDU with SNeedLicense (0x01) type → Lneedlicense */
int n, nb;
uchar buf[32];
Msg m = {0};
char *hex = "0300001402F08068111103EB7080058000000001";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg17: unexpected error: %r");
if(m.type != Lneedlicense)
sysfatal("testgetmsg17: type: want %d (Lneedlicense), got %d", Lneedlicense, m.type);
return 0;
}
static int
testgetmsg18(void)
{
/* License PDU with SHaveChal (0x02) type → Lhavechal */
int n, nb;
uchar buf[32];
Msg m = {0};
char *hex = "0300001402F08068111103EB7080058000000002";
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetmsg18: unexpected error: %r");
if(m.type != Lhavechal)
sysfatal("testgetmsg18: type: want %d (Lhavechal), got %d", Lhavechal, m.type);
return 0;
}
static int
testgetcaps1(void)
{
/*
* Server Demand Active PDU containing two capability sets:
* CapGeneral (type=1, len=24): canrefresh=1, cansupress=1
* CapBitmap (type=2, len=16): depth=32, xsz=1024, ysz=768
* getcaps is exercised via getmsg → getshareT → getcaps.
*/
int n, nb;
uchar buf[128];
Msg m = {0};
Share as = {0};
Caps caps;
char *hex =
/* TPKT + X.224 Data */
"0300004902F080"
/* MCS Send Data Indication on GLOBALCHAN */
"68" "1111" "03EB" "70" "803A"
/* Share Control Header: totalLength=58, PDUactivate, source */
"3A00" "0100" "1111"
/* shareid(LE), nsrc=0, capsLen=44 */
"EFBEADDE" "0000" "2C00"
/* ncap=2, pad */
"02000000"
/* CapGeneral: type=1, len=24; canrefresh=p[22]=1, cansupress=p[23]=1 */
"01001800"
"00000000000000000000" // data[4..13]
"0000000000000000" // data[14..21]
"0101" // canrefresh, cansupress
/* CapBitmap: type=2, len=16; depth=32, xsz=1024, ysz=768 */
"02001000"
"2000" // depth=32
"000000000000" // receive* fields
"00040003"; // xsz=1024 (LE), ysz=768 (LE)
nb = dec16(buf, sizeof buf, hex, strlen(hex));
n = getmsg(&m, buf, nb);
if(n <= 0)
sysfatal("testgetcaps1: getmsg: unexpected error: %r");
if(m.type != Aupdate)
sysfatal("testgetcaps1: type: want Aupdate, got %d", m.type);
if(m.getshare != getshareT)
sysfatal("testgetcaps1: getshare: expected getshareT");
n = m.getshare(&as, m.data, m.ndata);
if(n <= 0)
sysfatal("testgetcaps1: getshare: unexpected error: %r");
if(as.type != ShActivate)
sysfatal("testgetcaps1: share type: want ShActivate, got %d", as.type);
n = getcaps(&caps, as.data, as.ndata);
if(n < 0)
sysfatal("testgetcaps1: getcaps: unexpected error: %r");
if(!caps.general)
sysfatal("testgetcaps1: caps.general: want 1, got 0");
if(caps.canrefresh != 1)
sysfatal("testgetcaps1: canrefresh: want 1, got %d", caps.canrefresh);
if(caps.cansupress != 1)
sysfatal("testgetcaps1: cansupress: want 1, got %d", caps.cansupress);
if(!caps.bitmap)
sysfatal("testgetcaps1: caps.bitmap: want 1, got 0");
if(caps.depth != 32)
sysfatal("testgetcaps1: depth: want 32, got %d", caps.depth);
if(caps.xsz != 1024)
sysfatal("testgetcaps1: xsz: want 1024, got %d", caps.xsz);
if(caps.ysz != 768)
sysfatal("testgetcaps1: ysz: want 768, got %d", caps.ysz);
return 0;
}
int
msgtests(void)
{
fmtinstall('H', encodefmt);
testputmsg1();
testputmsg2();
testputmsg3();
testputmsg4();
testputmsg5();
testputmsg6();
testputmsg7();
testputmsg8();
testputmsg9();
testputmsg10();
testputmsg11();
testputmsg12();
testputmsg13();
testputmsg14();
testputmsg15();
testputmsg16();
testputmsg17();
testputmsg18();
testgetmsg1();
testgetmsg2();
testgetmsg3();
testgetmsg4();
testgetmsg5();
testgetmsg6();
testgetmsg7();
testgetmsg8();
testgetmsg9();
testgetmsg10();
testgetmsg11();
testgetmsg12();
testgetmsg13();
testgetmsg14();
testgetmsg15();
testgetmsg16();
testgetmsg17();
testgetmsg18();
testgetcaps1();
return 0;
}