Add(MainForm,13581682,84,63)
{
Left=20
Top=105
Point(Close)
link(onCreate,13467478:##open,[])
}
Add(TCP_ServerEx,13467478,154,77)
{
ServerPort=23
}
BEGIN_SDK
Add(EditMultiEx,3385328,3,3)
{
WorkCount=#6:##open|
Width=258
Height=179
}
Add(TCP_Connection,11302843,91,105)
{
link(onRead,10490002:doInput,[])
link(onConnect,12040629:doData,[(133,118)(133,93)(39,93)(39,41)])
link(onDisconnect,10490002:doClose,[(142,125)(142,118)])
}
Add(InlineCode,10490002,161,98)
{
@Hint=#11:ConsoleExec|
WorkPoints=#7:doStart|7:doInput|7:doClose|
EventPoints=#8:onOutput|7:onError|6:onExit|
Code=#15:unit HiAsmUnit;|0:|9:interface|0:|29:uses KOL,Share,Debug,Windows;|0:|4:type|28: THiAsmClass = class(TDebug)|10: private|23: hProcess: THandle;|30: hPipeInputWrite: THandle;|30: hPipeOutputRead: THandle;|30: hPipeErrorsRead: THandle;|5: |27: dwReadThreadID: dword;|26: hReadThread: THandle;|20: FRead: boolean;|0:|9: public|24: onOutput:THI_Event;|23: onError:THI_Event;|22: onExit:THI_Event;|0:|20: procedure Read;|25: procedure Terminate;|51: procedure doStart(var Data:TData; Index:word);|51: procedure doInput(var Data:TData; Index:word);|51: procedure doClose(var Data:TData; Index:word);|29: destructor Destroy; |5: end;|0:|14:implementation|0:|56:function ReadFunc(Parent:THiAsmClass):cardinal; stdcall;|5:begin|15: Parent.Read;|15: Result := 0;|4:end;|0:|30:procedure THiAsmClass.doStart;|3:var|26: sa: TSECURITYATTRIBUTES;|19: si: TSTARTUPINFO;|26: pi: TPROCESSINFORMATION;|26: hPipeInputRead: THandle;|28: hPipeOutputWrite: THandle;|28: hPipeErrorsWrite: THandle;|15: Res: Boolean;|29: env: array[0..100] of Char;|5:begin|27: sa.nLength := sizeof(sa);|28: sa.bInheritHandle := true;|33: sa.lpSecurityDescriptor := nil;|2: |54: CreatePipe(hPipeInputRead, hPipeInputWrite, @sa, 0);|56: CreatePipe(hPipeOutputRead, hPipeOutputWrite, @sa, 0);|56: CreatePipe(hPipeErrorsRead, hPipeErrorsWrite, @sa, 0);|2: |32: ZeroMemory(@env, SizeOf(env));|30: ZeroMemory(@si, SizeOf(si));|30: ZeroMemory(@pi, SizeOf(pi));|2: |22: si.cb := SizeOf(si);|61: si.dwFlags := STARTF_USESHOWWINDOW or STARTF_USESTDHANDLES;|28: si.wShowWindow := SW_HIDE;|33: si.hStdInput := hPipeInputRead;|36: si.hStdOutput := hPipeOutputWrite;|35: si.hStdError := hPipeErrorsWrite;|0:|66: Res := CreateProcess(nil, PChar(ToString(Data)), nil, nil, true,|68: CREATE_NEW_CONSOLE or NORMAL_PRIORITY_CLASS, @env, nil, si, pi);|30: CloseHandle(hPipeInputRead);|32: CloseHandle(hPipeOutputWrite);|32: CloseHandle(hPipeErrorsWrite);|0:|23: if not Res then begin|33: CloseHandle(hPipeInputWrite);|33: CloseHandle(hPipeOutputRead);|33: CloseHandle(hPipeErrorsRead);|18: hProcess := 0;|9: Exit;|6: end;|2: |41: hProcess := pi.hProcess; FRead := true;|72: hReadThread := CreateThread(nil,1024,@ReadFunc,Self,0,dwReadThreadID);|4:end;|0:|27:procedure THiAsmClass.Read;|63:var Total:dword; bWait:boolean; hWait:THandle; bError:boolean; |34: pBuffer: array[0..1024] of char;|5:begin|61: hWait := CreateEvent(nil,false,false,nil); bError := false;|37: while FRead and not bError do begin|18: bWait := true;|83: if not PeekNamedPipe(hPipeErrorsRead,nil,0,nil,@Total,nil) then bError := true;|25: if Total>0 then begin|21: bWait := false;|72: if ReadFile(hPipeErrorsRead, pBuffer, 1024, Total, nil) then begin|30: pBuffer[Total] := #0;|38: _hi_OnEvent(onError, pBuffer);|10: end;|8: end;|83: if not PeekNamedPipe(hPipeOutputRead,nil,0,nil,@Total,nil) then bError := true;|25: if Total>0 then begin|21: bWait := false;|72: if ReadFile(hPipeOutputRead, pBuffer, 1024, Total, nil) then begin|30: pBuffer[Total] := #0;|39: _hi_OnEvent(onOutput, pBuffer);|10: end;|8: end;|47: if bWait then WaitForSingleObject(hWait,1);|6: end;|21: CloseHandle(hWait);|22: if bError then begin|14: Terminate;|24: _hi_OnEvent(onExit);|6: end;|4:end;|0:|30:procedure THiAsmClass.doInput;|26:var Total:dword; s:string;|5:begin|26: if hProcess=0 then Exit;|22: s := ToString(Data);|63: WriteFile(hPipeInputWrite, PChar(s)^, Length(s), Total, nil);|4:end;|0:|32:procedure THiAsmClass.Terminate;|5:begin|27: if hProcess<>0 then begin|19: FRead := false;|34: TerminateProcess(hProcess, 1);|40: WaitForSingleObject(hProcess, 1000);|26: CloseHandle(hProcess);|33: CloseHandle(hPipeInputWrite);|33: CloseHandle(hPipeOutputRead);|33: CloseHandle(hPipeErrorsRead);|43: WaitForSingleObject(hReadThread, 1000);|29: CloseHandle(hReadThread);|18: hProcess := 0;|6: end;|4:end;|0:|30:procedure THiAsmClass.doClose;|5:begin|12: Terminate;|4:end;|0:|31:destructor THiAsmClass.Destroy;|5:begin|12: Terminate;|4:end;|0:|4:end.|
link(onOutput,7361595:doWork2,[])
link(onError,7361595:doWork3,[(214,111)])
link(onExit,11302843:doClose,[(204,118)(204,146)(72,146)(72,111)])
}
Add(HubEx,7361595,210,91)
{
link(onEvent,11302843:doSend,[(229,104)(229,81)(63,81)(63,118)])
}
Add(InlineCode,7883727,105,35)
{
@Hint=#22:GetEnvironmentVariable|
WorkPoints=#8:doGetVar|
EventPoints=#8:onGetVar|
Code=#15:unit HiAsmUnit;|0:|9:interface|0:|29:uses KOL,Share,Debug,Windows;|0:|4:type|28: THiAsmClass = class(TDebug)|9: public|24: onGetVar:THI_Event;|52: procedure doGetVar(var Data:TData; Index:word);|5: end;|0:|14:implementation|0:|31:procedure THiAsmClass.doGetVar;|26:var s:string; sLen: dword;|5:begin|35: sLen := 1024; SetLength(s, sLen);|69: sLen := GetEnvironmentVariable(PChar(ToString(Data)), @s[1], sLen);|22: if sLen>0 then begin|23: SetLength(s, sLen);|29: _hi_OnEvent(onGetVar, s);|6: end;|4:end;|0:|4:end.|
link(onGetVar,10490002:doStart,[(149,41)(149,104)])
}
Add(DoData,12040629,49,35)
{
Data=String(ComSpec)
link(onEventData,7883727:doGetVar,[])
}
END_SDK
|
имеено это он и просит
Поиск
Друзья
Администрация