entered advanced internal development stage.

2 files changed, 280 insertions, 0 deletions

diff --git a/src/ipc/ntapi_tt_create_pipe_v1.c b/src/ipc/ntapi_tt_create_pipe_v1.c
new file mode 100644
index 0000000..3185fbd
--- /dev/null
+++ b/src/ipc/ntapi_tt_create_pipe_v1.c
@@ -0,0 +1,164 @@
+/********************************************************/
+/*  ntapi: Native API core library                      */
+/*  Copyright (C) 2013,2014,2015  Z. Gilboa             */
+/*  Released under GPLv2 and GPLv3; see COPYING.NTAPI.  */
+/********************************************************/
+
+#include <psxtypes/psxtypes.h>
+#include <ntapi/nt_file.h>
+#include <ntapi/nt_string.h>
+#include <ntapi/nt_atomic.h>
+#include <ntapi/ntapi.h>
+#include "ntapi_impl.h"
+
+
+typedef struct __attr_ptr_size_aligned__ _nt_tty_pipe_name {
+	wchar16_t	pipe_dir[8];
+	wchar16_t	back_slash;
+	wchar16_t	key_1st[8];
+	wchar16_t	uscore_1st;
+	wchar16_t	key_2nd[8];
+	wchar16_t	uscore_2nd;
+	wchar16_t	key_3rd[8];
+	wchar16_t	uscore_3rd;
+	wchar16_t	key_4th[8];
+	wchar16_t	uscore_4th;
+	wchar16_t	key_5th[8];
+	wchar16_t	uscore_5th;
+	wchar16_t	key_6th[8];
+	wchar16_t	null_termination;
+} nt_tty_pipe_name;
+
+
+int32_t __stdcall	__ntapi_ipc_create_pipe_v1(
+	__out		void **			hpipe_read,
+	__out		void **			hpipe_write,
+	__in		uint32_t		advisory_buffer_size	__optional)
+{
+	int32_t			status;
+
+	void *				hread;
+	void *				hwrite;
+
+	nt_object_attributes		oa;
+	nt_io_status_block		iosb;
+	nt_unicode_string		nt_name;
+	nt_security_quality_of_service	sqos;
+	nt_large_integer		timeout;
+	intptr_t *			counter;
+
+	nt_tty_pipe_name pipe_name =  {
+		{'\\','?','?','\\','p','i','p','e'},
+		'\\',
+		{0},'_',
+		{0},'_',
+		{0},'_',
+		{0},'_',
+		{0},'_',
+		{0},
+		0
+	};
+
+	/* pipe_count  */
+	counter = (intptr_t *)&__ntapi_internals()->v1_pipe_counter;
+	at_locked_inc(counter);
+
+	/* get system time */
+	status = __ntapi->zw_query_system_time(&timeout);
+
+	if (status != NT_STATUS_SUCCESS)
+		return status;
+
+	/* pipe name (no anonymous pipe prior to vista) */
+	__ntapi->tt_uint32_to_hex_utf16(	pe_get_current_process_id(),pipe_name.key_1st);
+	__ntapi->tt_uint32_to_hex_utf16(	pe_get_current_thread_id(),pipe_name.key_2nd);
+
+	__ntapi->tt_uint32_to_hex_utf16(	timeout.ihigh + (uint32_t)*counter,pipe_name.key_3rd);
+	__ntapi->tt_uint32_to_hex_utf16(timeout.ulow + (uint32_t)*counter,pipe_name.key_4th);
+
+	__ntapi->tt_uint32_to_hex_utf16(
+		__ntapi->tt_buffer_crc32(0,(char *)&pipe_name,sizeof(pipe_name)),
+		pipe_name.key_5th);
+
+	__ntapi->tt_uint32_to_hex_utf16(
+		__ntapi->tt_buffer_crc32(0,(char *)&pipe_name,sizeof(pipe_name)),
+		pipe_name.key_6th);
+
+	__ntapi->tt_uint32_to_hex_utf16(
+		__ntapi->tt_buffer_crc32(0,(char *)&pipe_name,sizeof(pipe_name)),
+		pipe_name.key_1st);
+
+	__ntapi->tt_uint32_to_hex_utf16(
+		__ntapi->tt_buffer_crc32(0,(char *)&pipe_name,sizeof(pipe_name)),
+		pipe_name.key_2nd);
+
+	__ntapi->tt_uint32_to_hex_utf16(
+		__ntapi->tt_buffer_crc32(0,(char *)&pipe_name,sizeof(pipe_name)),
+		pipe_name.key_3rd);
+
+	__ntapi->tt_uint32_to_hex_utf16(
+		__ntapi->tt_buffer_crc32(0,(char *)&pipe_name,sizeof(pipe_name)),
+		pipe_name.key_4th);
+
+	/* nt_name */
+	nt_name.strlen = (uint16_t)(sizeof(pipe_name) - sizeof(wchar16_t));
+	nt_name.maxlen = (uint16_t)(sizeof(pipe_name));
+	nt_name.buffer = (uint16_t *)&pipe_name;
+
+	/* init security structure */
+	sqos.length 			= sizeof(sqos);
+	sqos.impersonation_level	= NT_SECURITY_IMPERSONATION;
+	sqos.context_tracking_mode	= NT_SECURITY_TRACKING_DYNAMIC;
+	sqos.effective_only		= 1;
+
+	/* oa */
+	oa.len		= sizeof(oa);
+	oa.root_dir	= (void *)0;
+	oa.obj_name	= &nt_name;
+	oa.obj_attr	= 0x0;
+	oa.sec_desc	= (nt_security_descriptor *)0;
+	oa.sec_qos	= &sqos;
+
+	timeout.ihigh = 0xffffffff;
+	timeout.ulow  = 0x0;
+
+	/* the reading end */
+	status = __ntapi->zw_create_named_pipe_file(
+		&hread,
+		NT_GENERIC_READ | NT_SEC_SYNCHRONIZE | NT_FILE_WRITE_ATTRIBUTES,
+		&oa,
+		&iosb,
+		NT_FILE_SHARE_READ | NT_FILE_SHARE_WRITE,
+		NT_FILE_CREATE,
+		NT_FILE_ASYNCHRONOUS_IO,
+		0,
+		0,
+		0,
+		1,
+		0x2000,
+		0x2000,
+		&timeout);
+
+	if (status != NT_STATUS_SUCCESS) {
+		return status;
+	}
+
+	/* the writing end(s) */
+	status = __ntapi->zw_open_file(
+		&hwrite,
+		NT_GENERIC_WRITE | NT_SEC_SYNCHRONIZE | NT_FILE_READ_ATTRIBUTES,
+		&oa,
+		&iosb,
+		NT_FILE_SHARE_READ | NT_FILE_SHARE_WRITE,
+		NT_FILE_WRITE_THROUGH | NT_FILE_ASYNCHRONOUS_IO | NT_FILE_NON_DIRECTORY_FILE);
+
+	if (status != NT_STATUS_SUCCESS) {
+		__ntapi->zw_close(hread);
+		return status;
+	}
+
+	*hpipe_read  = hread;
+	*hpipe_write = hwrite;
+
+	return status;
+}
diff --git a/src/ipc/ntapi_tt_create_pipe_v2.c b/src/ipc/ntapi_tt_create_pipe_v2.c
new file mode 100644
index 0000000..c1f4b4b
--- /dev/null
+++ b/src/ipc/ntapi_tt_create_pipe_v2.c
@@ -0,0 +1,116 @@
+/********************************************************/
+/*  ntapi: Native API core library                      */
+/*  Copyright (C) 2013,2014,2015  Z. Gilboa             */
+/*  Released under GPLv2 and GPLv3; see COPYING.NTAPI.  */
+/********************************************************/
+
+#include <psxtypes/psxtypes.h>
+#include <ntapi/nt_file.h>
+#include <ntapi/nt_string.h>
+#include <ntapi/nt_tty.h>
+#include <ntapi/ntapi.h>
+#include "ntapi_impl.h"
+
+int32_t __stdcall	__ntapi_ipc_create_pipe_v2(
+	__out		void **			hpipe_read,
+	__out		void **			hpipe_write,
+	__in		uint32_t		advisory_buffer_size	__optional)
+{
+	int32_t			status;
+
+	void *			hdevpipes;
+	void *			hwrite;
+	void *			hread;
+
+	nt_object_attributes	oa;
+	nt_io_status_block	iosb;
+	nt_sqos			sqos;
+	nt_unicode_string	nt_name;
+	nt_large_integer	timeout;
+
+	const wchar16_t pipe_dir[] =  {
+		'\\','D','e','v','i','c','e',
+		'\\','N','a','m','e','d','P','i','p','e','\\',0
+	};
+
+	/* nt_name: pipe device directory */
+	nt_name.strlen = (uint16_t)(sizeof(pipe_dir) - sizeof(wchar16_t));
+	nt_name.maxlen = 0;
+	nt_name.buffer = (uint16_t *)pipe_dir;
+
+	/* init security structure */
+	sqos.length 			= sizeof(sqos);
+	sqos.impersonation_level	= NT_SECURITY_IMPERSONATION;
+	sqos.context_tracking_mode	= NT_SECURITY_TRACKING_DYNAMIC;
+	sqos.effective_only		= 1;
+
+	/* oa */
+	oa.len		= sizeof(oa);
+	oa.root_dir	= (void *)0;
+	oa.obj_name	= &nt_name;
+	oa.obj_attr	= NT_OBJ_CASE_INSENSITIVE | NT_OBJ_INHERIT;
+	oa.sec_desc	= (nt_security_descriptor *)0;
+	oa.sec_qos	= &sqos;
+
+	status = __ntapi->zw_open_file(
+		&hdevpipes,
+		NT_GENERIC_READ | NT_SEC_SYNCHRONIZE,
+		&oa,
+		&iosb,
+		NT_FILE_SHARE_READ | NT_FILE_SHARE_WRITE,
+		NT_FILE_DIRECTORY_FILE);
+
+	if (status != NT_STATUS_SUCCESS)
+		return status;
+
+	timeout.ihigh = 0xffffffff;
+	timeout.ulow  = 0x0;
+
+	oa.root_dir = hdevpipes;
+
+	nt_name.strlen=0;
+	nt_name.buffer = (uint16_t *)0;
+
+	status = __ntapi->zw_create_named_pipe_file(
+		&hread,
+		NT_GENERIC_READ | NT_SEC_SYNCHRONIZE | NT_FILE_WRITE_ATTRIBUTES,
+		&oa,
+		&iosb,
+		NT_FILE_SHARE_READ | NT_FILE_SHARE_WRITE,
+		NT_FILE_CREATE,
+		NT_FILE_ASYNCHRONOUS_IO,
+		0,
+		0,
+		0,
+		1,
+		0X2000,
+		0x2000,
+		&timeout);
+
+	if (status != NT_STATUS_SUCCESS) {
+		__ntapi->zw_close(hdevpipes);
+		return status;
+	}
+
+	/* the pipe is now our root directory */
+	oa.root_dir = hread;
+
+	status = __ntapi->zw_open_file(
+		&hwrite,
+		NT_GENERIC_WRITE | NT_SEC_SYNCHRONIZE | NT_FILE_READ_ATTRIBUTES,
+		&oa,
+		&iosb,
+		NT_FILE_SHARE_READ | NT_FILE_SHARE_WRITE,
+		NT_FILE_WRITE_THROUGH | NT_FILE_ASYNCHRONOUS_IO | NT_FILE_NON_DIRECTORY_FILE);
+
+	if (status != NT_STATUS_SUCCESS) {
+		__ntapi->zw_close(hdevpipes);
+		__ntapi->zw_close(hread);
+		return status;
+	}
+
+	*hpipe_read  = hread;
+	*hpipe_write = hwrite;
+
+	return status;
+}