syscall_windows.go 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002
  1. // Copyright 2009 The Go Authors. All rights reserved.
  2. // Use of this source code is governed by a BSD-style
  3. // license that can be found in the LICENSE file.
  4. // Windows system calls.
  5. package windows
  6. import (
  7. errorspkg "errors"
  8. "sync"
  9. "unicode/utf16"
  10. "unsafe"
  11. )
  12. type Handle uintptr
  13. const InvalidHandle = ^Handle(0)
  14. // StringToUTF16 is deprecated. Use UTF16FromString instead.
  15. // If s contains a NUL byte this function panics instead of
  16. // returning an error.
  17. func StringToUTF16(s string) []uint16 {
  18. a, err := UTF16FromString(s)
  19. if err != nil {
  20. panic("windows: string with NUL passed to StringToUTF16")
  21. }
  22. return a
  23. }
  24. // UTF16FromString returns the UTF-16 encoding of the UTF-8 string
  25. // s, with a terminating NUL added. If s contains a NUL byte at any
  26. // location, it returns (nil, EINVAL).
  27. func UTF16FromString(s string) ([]uint16, error) {
  28. for i := 0; i < len(s); i++ {
  29. if s[i] == 0 {
  30. return nil, EINVAL
  31. }
  32. }
  33. return utf16.Encode([]rune(s + "\x00")), nil
  34. }
  35. // UTF16ToString returns the UTF-8 encoding of the UTF-16 sequence s,
  36. // with a terminating NUL removed.
  37. func UTF16ToString(s []uint16) string {
  38. for i, v := range s {
  39. if v == 0 {
  40. s = s[0:i]
  41. break
  42. }
  43. }
  44. return string(utf16.Decode(s))
  45. }
  46. // StringToUTF16Ptr is deprecated. Use UTF16PtrFromString instead.
  47. // If s contains a NUL byte this function panics instead of
  48. // returning an error.
  49. func StringToUTF16Ptr(s string) *uint16 { return &StringToUTF16(s)[0] }
  50. // UTF16PtrFromString returns pointer to the UTF-16 encoding of
  51. // the UTF-8 string s, with a terminating NUL added. If s
  52. // contains a NUL byte at any location, it returns (nil, EINVAL).
  53. func UTF16PtrFromString(s string) (*uint16, error) {
  54. a, err := UTF16FromString(s)
  55. if err != nil {
  56. return nil, err
  57. }
  58. return &a[0], nil
  59. }
  60. func Getpagesize() int { return 4096 }
  61. // Errno is the Windows error number.
  62. type Errno uintptr
  63. func langid(pri, sub uint16) uint32 { return uint32(sub)<<10 | uint32(pri) }
  64. func (e Errno) Error() string {
  65. // deal with special go errors
  66. idx := int(e - APPLICATION_ERROR)
  67. if 0 <= idx && idx < len(errors) {
  68. return errors[idx]
  69. }
  70. // ask windows for the remaining errors
  71. var flags uint32 = FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_ARGUMENT_ARRAY | FORMAT_MESSAGE_IGNORE_INSERTS
  72. b := make([]uint16, 300)
  73. n, err := FormatMessage(flags, 0, uint32(e), langid(LANG_ENGLISH, SUBLANG_ENGLISH_US), b, nil)
  74. if err != nil {
  75. n, err = FormatMessage(flags, 0, uint32(e), 0, b, nil)
  76. if err != nil {
  77. return "winapi error #" + itoa(int(e))
  78. }
  79. }
  80. // trim terminating \r and \n
  81. for ; n > 0 && (b[n-1] == '\n' || b[n-1] == '\r'); n-- {
  82. }
  83. return string(utf16.Decode(b[:n]))
  84. }
  85. func (e Errno) Temporary() bool {
  86. return e == EINTR || e == EMFILE || e.Timeout()
  87. }
  88. func (e Errno) Timeout() bool {
  89. return e == EAGAIN || e == EWOULDBLOCK || e == ETIMEDOUT
  90. }
  91. // Converts a Go function to a function pointer conforming
  92. // to the stdcall or cdecl calling convention. This is useful when
  93. // interoperating with Windows code requiring callbacks.
  94. // Implemented in runtime/syscall_windows.goc
  95. func NewCallback(fn interface{}) uintptr
  96. func NewCallbackCDecl(fn interface{}) uintptr
  97. // windows api calls
  98. //sys GetLastError() (lasterr error)
  99. //sys LoadLibrary(libname string) (handle Handle, err error) = LoadLibraryW
  100. //sys FreeLibrary(handle Handle) (err error)
  101. //sys GetProcAddress(module Handle, procname string) (proc uintptr, err error)
  102. //sys GetVersion() (ver uint32, err error)
  103. //sys FormatMessage(flags uint32, msgsrc uint32, msgid uint32, langid uint32, buf []uint16, args *byte) (n uint32, err error) = FormatMessageW
  104. //sys ExitProcess(exitcode uint32)
  105. //sys CreateFile(name *uint16, access uint32, mode uint32, sa *SecurityAttributes, createmode uint32, attrs uint32, templatefile int32) (handle Handle, err error) [failretval==InvalidHandle] = CreateFileW
  106. //sys ReadFile(handle Handle, buf []byte, done *uint32, overlapped *Overlapped) (err error)
  107. //sys WriteFile(handle Handle, buf []byte, done *uint32, overlapped *Overlapped) (err error)
  108. //sys SetFilePointer(handle Handle, lowoffset int32, highoffsetptr *int32, whence uint32) (newlowoffset uint32, err error) [failretval==0xffffffff]
  109. //sys CloseHandle(handle Handle) (err error)
  110. //sys GetStdHandle(stdhandle int) (handle Handle, err error) [failretval==InvalidHandle]
  111. //sys findFirstFile1(name *uint16, data *win32finddata1) (handle Handle, err error) [failretval==InvalidHandle] = FindFirstFileW
  112. //sys findNextFile1(handle Handle, data *win32finddata1) (err error) = FindNextFileW
  113. //sys FindClose(handle Handle) (err error)
  114. //sys GetFileInformationByHandle(handle Handle, data *ByHandleFileInformation) (err error)
  115. //sys GetCurrentDirectory(buflen uint32, buf *uint16) (n uint32, err error) = GetCurrentDirectoryW
  116. //sys SetCurrentDirectory(path *uint16) (err error) = SetCurrentDirectoryW
  117. //sys CreateDirectory(path *uint16, sa *SecurityAttributes) (err error) = CreateDirectoryW
  118. //sys RemoveDirectory(path *uint16) (err error) = RemoveDirectoryW
  119. //sys DeleteFile(path *uint16) (err error) = DeleteFileW
  120. //sys MoveFile(from *uint16, to *uint16) (err error) = MoveFileW
  121. //sys GetComputerName(buf *uint16, n *uint32) (err error) = GetComputerNameW
  122. //sys SetEndOfFile(handle Handle) (err error)
  123. //sys GetSystemTimeAsFileTime(time *Filetime)
  124. //sys GetTimeZoneInformation(tzi *Timezoneinformation) (rc uint32, err error) [failretval==0xffffffff]
  125. //sys CreateIoCompletionPort(filehandle Handle, cphandle Handle, key uint32, threadcnt uint32) (handle Handle, err error)
  126. //sys GetQueuedCompletionStatus(cphandle Handle, qty *uint32, key *uint32, overlapped **Overlapped, timeout uint32) (err error)
  127. //sys PostQueuedCompletionStatus(cphandle Handle, qty uint32, key uint32, overlapped *Overlapped) (err error)
  128. //sys CancelIo(s Handle) (err error)
  129. //sys CancelIoEx(s Handle, o *Overlapped) (err error)
  130. //sys CreateProcess(appName *uint16, commandLine *uint16, procSecurity *SecurityAttributes, threadSecurity *SecurityAttributes, inheritHandles bool, creationFlags uint32, env *uint16, currentDir *uint16, startupInfo *StartupInfo, outProcInfo *ProcessInformation) (err error) = CreateProcessW
  131. //sys OpenProcess(da uint32, inheritHandle bool, pid uint32) (handle Handle, err error)
  132. //sys TerminateProcess(handle Handle, exitcode uint32) (err error)
  133. //sys GetExitCodeProcess(handle Handle, exitcode *uint32) (err error)
  134. //sys GetStartupInfo(startupInfo *StartupInfo) (err error) = GetStartupInfoW
  135. //sys GetCurrentProcess() (pseudoHandle Handle, err error)
  136. //sys GetProcessTimes(handle Handle, creationTime *Filetime, exitTime *Filetime, kernelTime *Filetime, userTime *Filetime) (err error)
  137. //sys DuplicateHandle(hSourceProcessHandle Handle, hSourceHandle Handle, hTargetProcessHandle Handle, lpTargetHandle *Handle, dwDesiredAccess uint32, bInheritHandle bool, dwOptions uint32) (err error)
  138. //sys WaitForSingleObject(handle Handle, waitMilliseconds uint32) (event uint32, err error) [failretval==0xffffffff]
  139. //sys GetTempPath(buflen uint32, buf *uint16) (n uint32, err error) = GetTempPathW
  140. //sys CreatePipe(readhandle *Handle, writehandle *Handle, sa *SecurityAttributes, size uint32) (err error)
  141. //sys GetFileType(filehandle Handle) (n uint32, err error)
  142. //sys CryptAcquireContext(provhandle *Handle, container *uint16, provider *uint16, provtype uint32, flags uint32) (err error) = advapi32.CryptAcquireContextW
  143. //sys CryptReleaseContext(provhandle Handle, flags uint32) (err error) = advapi32.CryptReleaseContext
  144. //sys CryptGenRandom(provhandle Handle, buflen uint32, buf *byte) (err error) = advapi32.CryptGenRandom
  145. //sys GetEnvironmentStrings() (envs *uint16, err error) [failretval==nil] = kernel32.GetEnvironmentStringsW
  146. //sys FreeEnvironmentStrings(envs *uint16) (err error) = kernel32.FreeEnvironmentStringsW
  147. //sys GetEnvironmentVariable(name *uint16, buffer *uint16, size uint32) (n uint32, err error) = kernel32.GetEnvironmentVariableW
  148. //sys SetEnvironmentVariable(name *uint16, value *uint16) (err error) = kernel32.SetEnvironmentVariableW
  149. //sys SetFileTime(handle Handle, ctime *Filetime, atime *Filetime, wtime *Filetime) (err error)
  150. //sys GetFileAttributes(name *uint16) (attrs uint32, err error) [failretval==INVALID_FILE_ATTRIBUTES] = kernel32.GetFileAttributesW
  151. //sys SetFileAttributes(name *uint16, attrs uint32) (err error) = kernel32.SetFileAttributesW
  152. //sys GetFileAttributesEx(name *uint16, level uint32, info *byte) (err error) = kernel32.GetFileAttributesExW
  153. //sys GetCommandLine() (cmd *uint16) = kernel32.GetCommandLineW
  154. //sys CommandLineToArgv(cmd *uint16, argc *int32) (argv *[8192]*[8192]uint16, err error) [failretval==nil] = shell32.CommandLineToArgvW
  155. //sys LocalFree(hmem Handle) (handle Handle, err error) [failretval!=0]
  156. //sys SetHandleInformation(handle Handle, mask uint32, flags uint32) (err error)
  157. //sys FlushFileBuffers(handle Handle) (err error)
  158. //sys GetFullPathName(path *uint16, buflen uint32, buf *uint16, fname **uint16) (n uint32, err error) = kernel32.GetFullPathNameW
  159. //sys GetLongPathName(path *uint16, buf *uint16, buflen uint32) (n uint32, err error) = kernel32.GetLongPathNameW
  160. //sys GetShortPathName(longpath *uint16, shortpath *uint16, buflen uint32) (n uint32, err error) = kernel32.GetShortPathNameW
  161. //sys CreateFileMapping(fhandle Handle, sa *SecurityAttributes, prot uint32, maxSizeHigh uint32, maxSizeLow uint32, name *uint16) (handle Handle, err error) = kernel32.CreateFileMappingW
  162. //sys MapViewOfFile(handle Handle, access uint32, offsetHigh uint32, offsetLow uint32, length uintptr) (addr uintptr, err error)
  163. //sys UnmapViewOfFile(addr uintptr) (err error)
  164. //sys FlushViewOfFile(addr uintptr, length uintptr) (err error)
  165. //sys VirtualLock(addr uintptr, length uintptr) (err error)
  166. //sys VirtualUnlock(addr uintptr, length uintptr) (err error)
  167. //sys TransmitFile(s Handle, handle Handle, bytesToWrite uint32, bytsPerSend uint32, overlapped *Overlapped, transmitFileBuf *TransmitFileBuffers, flags uint32) (err error) = mswsock.TransmitFile
  168. //sys ReadDirectoryChanges(handle Handle, buf *byte, buflen uint32, watchSubTree bool, mask uint32, retlen *uint32, overlapped *Overlapped, completionRoutine uintptr) (err error) = kernel32.ReadDirectoryChangesW
  169. //sys CertOpenSystemStore(hprov Handle, name *uint16) (store Handle, err error) = crypt32.CertOpenSystemStoreW
  170. //sys CertOpenStore(storeProvider uintptr, msgAndCertEncodingType uint32, cryptProv uintptr, flags uint32, para uintptr) (handle Handle, err error) [failretval==InvalidHandle] = crypt32.CertOpenStore
  171. //sys CertEnumCertificatesInStore(store Handle, prevContext *CertContext) (context *CertContext, err error) [failretval==nil] = crypt32.CertEnumCertificatesInStore
  172. //sys CertAddCertificateContextToStore(store Handle, certContext *CertContext, addDisposition uint32, storeContext **CertContext) (err error) = crypt32.CertAddCertificateContextToStore
  173. //sys CertCloseStore(store Handle, flags uint32) (err error) = crypt32.CertCloseStore
  174. //sys CertGetCertificateChain(engine Handle, leaf *CertContext, time *Filetime, additionalStore Handle, para *CertChainPara, flags uint32, reserved uintptr, chainCtx **CertChainContext) (err error) = crypt32.CertGetCertificateChain
  175. //sys CertFreeCertificateChain(ctx *CertChainContext) = crypt32.CertFreeCertificateChain
  176. //sys CertCreateCertificateContext(certEncodingType uint32, certEncoded *byte, encodedLen uint32) (context *CertContext, err error) [failretval==nil] = crypt32.CertCreateCertificateContext
  177. //sys CertFreeCertificateContext(ctx *CertContext) (err error) = crypt32.CertFreeCertificateContext
  178. //sys CertVerifyCertificateChainPolicy(policyOID uintptr, chain *CertChainContext, para *CertChainPolicyPara, status *CertChainPolicyStatus) (err error) = crypt32.CertVerifyCertificateChainPolicy
  179. //sys RegOpenKeyEx(key Handle, subkey *uint16, options uint32, desiredAccess uint32, result *Handle) (regerrno error) = advapi32.RegOpenKeyExW
  180. //sys RegCloseKey(key Handle) (regerrno error) = advapi32.RegCloseKey
  181. //sys RegQueryInfoKey(key Handle, class *uint16, classLen *uint32, reserved *uint32, subkeysLen *uint32, maxSubkeyLen *uint32, maxClassLen *uint32, valuesLen *uint32, maxValueNameLen *uint32, maxValueLen *uint32, saLen *uint32, lastWriteTime *Filetime) (regerrno error) = advapi32.RegQueryInfoKeyW
  182. //sys RegEnumKeyEx(key Handle, index uint32, name *uint16, nameLen *uint32, reserved *uint32, class *uint16, classLen *uint32, lastWriteTime *Filetime) (regerrno error) = advapi32.RegEnumKeyExW
  183. //sys RegQueryValueEx(key Handle, name *uint16, reserved *uint32, valtype *uint32, buf *byte, buflen *uint32) (regerrno error) = advapi32.RegQueryValueExW
  184. //sys getCurrentProcessId() (pid uint32) = kernel32.GetCurrentProcessId
  185. //sys GetConsoleMode(console Handle, mode *uint32) (err error) = kernel32.GetConsoleMode
  186. //sys WriteConsole(console Handle, buf *uint16, towrite uint32, written *uint32, reserved *byte) (err error) = kernel32.WriteConsoleW
  187. //sys ReadConsole(console Handle, buf *uint16, toread uint32, read *uint32, inputControl *byte) (err error) = kernel32.ReadConsoleW
  188. //sys CreateToolhelp32Snapshot(flags uint32, processId uint32) (handle Handle, err error) [failretval==InvalidHandle] = kernel32.CreateToolhelp32Snapshot
  189. //sys Process32First(snapshot Handle, procEntry *ProcessEntry32) (err error) = kernel32.Process32FirstW
  190. //sys Process32Next(snapshot Handle, procEntry *ProcessEntry32) (err error) = kernel32.Process32NextW
  191. //sys DeviceIoControl(handle Handle, ioControlCode uint32, inBuffer *byte, inBufferSize uint32, outBuffer *byte, outBufferSize uint32, bytesReturned *uint32, overlapped *Overlapped) (err error)
  192. // This function returns 1 byte BOOLEAN rather than the 4 byte BOOL.
  193. //sys CreateSymbolicLink(symlinkfilename *uint16, targetfilename *uint16, flags uint32) (err error) [failretval&0xff==0] = CreateSymbolicLinkW
  194. //sys CreateHardLink(filename *uint16, existingfilename *uint16, reserved uintptr) (err error) [failretval&0xff==0] = CreateHardLinkW
  195. // syscall interface implementation for other packages
  196. func Exit(code int) { ExitProcess(uint32(code)) }
  197. func makeInheritSa() *SecurityAttributes {
  198. var sa SecurityAttributes
  199. sa.Length = uint32(unsafe.Sizeof(sa))
  200. sa.InheritHandle = 1
  201. return &sa
  202. }
  203. func Open(path string, mode int, perm uint32) (fd Handle, err error) {
  204. if len(path) == 0 {
  205. return InvalidHandle, ERROR_FILE_NOT_FOUND
  206. }
  207. pathp, err := UTF16PtrFromString(path)
  208. if err != nil {
  209. return InvalidHandle, err
  210. }
  211. var access uint32
  212. switch mode & (O_RDONLY | O_WRONLY | O_RDWR) {
  213. case O_RDONLY:
  214. access = GENERIC_READ
  215. case O_WRONLY:
  216. access = GENERIC_WRITE
  217. case O_RDWR:
  218. access = GENERIC_READ | GENERIC_WRITE
  219. }
  220. if mode&O_CREAT != 0 {
  221. access |= GENERIC_WRITE
  222. }
  223. if mode&O_APPEND != 0 {
  224. access &^= GENERIC_WRITE
  225. access |= FILE_APPEND_DATA
  226. }
  227. sharemode := uint32(FILE_SHARE_READ | FILE_SHARE_WRITE)
  228. var sa *SecurityAttributes
  229. if mode&O_CLOEXEC == 0 {
  230. sa = makeInheritSa()
  231. }
  232. var createmode uint32
  233. switch {
  234. case mode&(O_CREAT|O_EXCL) == (O_CREAT | O_EXCL):
  235. createmode = CREATE_NEW
  236. case mode&(O_CREAT|O_TRUNC) == (O_CREAT | O_TRUNC):
  237. createmode = CREATE_ALWAYS
  238. case mode&O_CREAT == O_CREAT:
  239. createmode = OPEN_ALWAYS
  240. case mode&O_TRUNC == O_TRUNC:
  241. createmode = TRUNCATE_EXISTING
  242. default:
  243. createmode = OPEN_EXISTING
  244. }
  245. h, e := CreateFile(pathp, access, sharemode, sa, createmode, FILE_ATTRIBUTE_NORMAL, 0)
  246. return h, e
  247. }
  248. func Read(fd Handle, p []byte) (n int, err error) {
  249. var done uint32
  250. e := ReadFile(fd, p, &done, nil)
  251. if e != nil {
  252. if e == ERROR_BROKEN_PIPE {
  253. // NOTE(brainman): work around ERROR_BROKEN_PIPE is returned on reading EOF from stdin
  254. return 0, nil
  255. }
  256. return 0, e
  257. }
  258. if raceenabled {
  259. if done > 0 {
  260. raceWriteRange(unsafe.Pointer(&p[0]), int(done))
  261. }
  262. raceAcquire(unsafe.Pointer(&ioSync))
  263. }
  264. return int(done), nil
  265. }
  266. func Write(fd Handle, p []byte) (n int, err error) {
  267. if raceenabled {
  268. raceReleaseMerge(unsafe.Pointer(&ioSync))
  269. }
  270. var done uint32
  271. e := WriteFile(fd, p, &done, nil)
  272. if e != nil {
  273. return 0, e
  274. }
  275. if raceenabled && done > 0 {
  276. raceReadRange(unsafe.Pointer(&p[0]), int(done))
  277. }
  278. return int(done), nil
  279. }
  280. var ioSync int64
  281. func Seek(fd Handle, offset int64, whence int) (newoffset int64, err error) {
  282. var w uint32
  283. switch whence {
  284. case 0:
  285. w = FILE_BEGIN
  286. case 1:
  287. w = FILE_CURRENT
  288. case 2:
  289. w = FILE_END
  290. }
  291. hi := int32(offset >> 32)
  292. lo := int32(offset)
  293. // use GetFileType to check pipe, pipe can't do seek
  294. ft, _ := GetFileType(fd)
  295. if ft == FILE_TYPE_PIPE {
  296. return 0, EPIPE
  297. }
  298. rlo, e := SetFilePointer(fd, lo, &hi, w)
  299. if e != nil {
  300. return 0, e
  301. }
  302. return int64(hi)<<32 + int64(rlo), nil
  303. }
  304. func Close(fd Handle) (err error) {
  305. return CloseHandle(fd)
  306. }
  307. var (
  308. Stdin = getStdHandle(STD_INPUT_HANDLE)
  309. Stdout = getStdHandle(STD_OUTPUT_HANDLE)
  310. Stderr = getStdHandle(STD_ERROR_HANDLE)
  311. )
  312. func getStdHandle(h int) (fd Handle) {
  313. r, _ := GetStdHandle(h)
  314. CloseOnExec(r)
  315. return r
  316. }
  317. const ImplementsGetwd = true
  318. func Getwd() (wd string, err error) {
  319. b := make([]uint16, 300)
  320. n, e := GetCurrentDirectory(uint32(len(b)), &b[0])
  321. if e != nil {
  322. return "", e
  323. }
  324. return string(utf16.Decode(b[0:n])), nil
  325. }
  326. func Chdir(path string) (err error) {
  327. pathp, err := UTF16PtrFromString(path)
  328. if err != nil {
  329. return err
  330. }
  331. return SetCurrentDirectory(pathp)
  332. }
  333. func Mkdir(path string, mode uint32) (err error) {
  334. pathp, err := UTF16PtrFromString(path)
  335. if err != nil {
  336. return err
  337. }
  338. return CreateDirectory(pathp, nil)
  339. }
  340. func Rmdir(path string) (err error) {
  341. pathp, err := UTF16PtrFromString(path)
  342. if err != nil {
  343. return err
  344. }
  345. return RemoveDirectory(pathp)
  346. }
  347. func Unlink(path string) (err error) {
  348. pathp, err := UTF16PtrFromString(path)
  349. if err != nil {
  350. return err
  351. }
  352. return DeleteFile(pathp)
  353. }
  354. func Rename(oldpath, newpath string) (err error) {
  355. from, err := UTF16PtrFromString(oldpath)
  356. if err != nil {
  357. return err
  358. }
  359. to, err := UTF16PtrFromString(newpath)
  360. if err != nil {
  361. return err
  362. }
  363. return MoveFile(from, to)
  364. }
  365. func ComputerName() (name string, err error) {
  366. var n uint32 = MAX_COMPUTERNAME_LENGTH + 1
  367. b := make([]uint16, n)
  368. e := GetComputerName(&b[0], &n)
  369. if e != nil {
  370. return "", e
  371. }
  372. return string(utf16.Decode(b[0:n])), nil
  373. }
  374. func Ftruncate(fd Handle, length int64) (err error) {
  375. curoffset, e := Seek(fd, 0, 1)
  376. if e != nil {
  377. return e
  378. }
  379. defer Seek(fd, curoffset, 0)
  380. _, e = Seek(fd, length, 0)
  381. if e != nil {
  382. return e
  383. }
  384. e = SetEndOfFile(fd)
  385. if e != nil {
  386. return e
  387. }
  388. return nil
  389. }
  390. func Gettimeofday(tv *Timeval) (err error) {
  391. var ft Filetime
  392. GetSystemTimeAsFileTime(&ft)
  393. *tv = NsecToTimeval(ft.Nanoseconds())
  394. return nil
  395. }
  396. func Pipe(p []Handle) (err error) {
  397. if len(p) != 2 {
  398. return EINVAL
  399. }
  400. var r, w Handle
  401. e := CreatePipe(&r, &w, makeInheritSa(), 0)
  402. if e != nil {
  403. return e
  404. }
  405. p[0] = r
  406. p[1] = w
  407. return nil
  408. }
  409. func Utimes(path string, tv []Timeval) (err error) {
  410. if len(tv) != 2 {
  411. return EINVAL
  412. }
  413. pathp, e := UTF16PtrFromString(path)
  414. if e != nil {
  415. return e
  416. }
  417. h, e := CreateFile(pathp,
  418. FILE_WRITE_ATTRIBUTES, FILE_SHARE_WRITE, nil,
  419. OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, 0)
  420. if e != nil {
  421. return e
  422. }
  423. defer Close(h)
  424. a := NsecToFiletime(tv[0].Nanoseconds())
  425. w := NsecToFiletime(tv[1].Nanoseconds())
  426. return SetFileTime(h, nil, &a, &w)
  427. }
  428. func UtimesNano(path string, ts []Timespec) (err error) {
  429. if len(ts) != 2 {
  430. return EINVAL
  431. }
  432. pathp, e := UTF16PtrFromString(path)
  433. if e != nil {
  434. return e
  435. }
  436. h, e := CreateFile(pathp,
  437. FILE_WRITE_ATTRIBUTES, FILE_SHARE_WRITE, nil,
  438. OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, 0)
  439. if e != nil {
  440. return e
  441. }
  442. defer Close(h)
  443. a := NsecToFiletime(TimespecToNsec(ts[0]))
  444. w := NsecToFiletime(TimespecToNsec(ts[1]))
  445. return SetFileTime(h, nil, &a, &w)
  446. }
  447. func Fsync(fd Handle) (err error) {
  448. return FlushFileBuffers(fd)
  449. }
  450. func Chmod(path string, mode uint32) (err error) {
  451. if mode == 0 {
  452. return EINVAL
  453. }
  454. p, e := UTF16PtrFromString(path)
  455. if e != nil {
  456. return e
  457. }
  458. attrs, e := GetFileAttributes(p)
  459. if e != nil {
  460. return e
  461. }
  462. if mode&S_IWRITE != 0 {
  463. attrs &^= FILE_ATTRIBUTE_READONLY
  464. } else {
  465. attrs |= FILE_ATTRIBUTE_READONLY
  466. }
  467. return SetFileAttributes(p, attrs)
  468. }
  469. func LoadCancelIoEx() error {
  470. return procCancelIoEx.Find()
  471. }
  472. func LoadSetFileCompletionNotificationModes() error {
  473. return procSetFileCompletionNotificationModes.Find()
  474. }
  475. // net api calls
  476. const socket_error = uintptr(^uint32(0))
  477. //sys WSAStartup(verreq uint32, data *WSAData) (sockerr error) = ws2_32.WSAStartup
  478. //sys WSACleanup() (err error) [failretval==socket_error] = ws2_32.WSACleanup
  479. //sys WSAIoctl(s Handle, iocc uint32, inbuf *byte, cbif uint32, outbuf *byte, cbob uint32, cbbr *uint32, overlapped *Overlapped, completionRoutine uintptr) (err error) [failretval==socket_error] = ws2_32.WSAIoctl
  480. //sys socket(af int32, typ int32, protocol int32) (handle Handle, err error) [failretval==InvalidHandle] = ws2_32.socket
  481. //sys Setsockopt(s Handle, level int32, optname int32, optval *byte, optlen int32) (err error) [failretval==socket_error] = ws2_32.setsockopt
  482. //sys Getsockopt(s Handle, level int32, optname int32, optval *byte, optlen *int32) (err error) [failretval==socket_error] = ws2_32.getsockopt
  483. //sys bind(s Handle, name unsafe.Pointer, namelen int32) (err error) [failretval==socket_error] = ws2_32.bind
  484. //sys connect(s Handle, name unsafe.Pointer, namelen int32) (err error) [failretval==socket_error] = ws2_32.connect
  485. //sys getsockname(s Handle, rsa *RawSockaddrAny, addrlen *int32) (err error) [failretval==socket_error] = ws2_32.getsockname
  486. //sys getpeername(s Handle, rsa *RawSockaddrAny, addrlen *int32) (err error) [failretval==socket_error] = ws2_32.getpeername
  487. //sys listen(s Handle, backlog int32) (err error) [failretval==socket_error] = ws2_32.listen
  488. //sys shutdown(s Handle, how int32) (err error) [failretval==socket_error] = ws2_32.shutdown
  489. //sys Closesocket(s Handle) (err error) [failretval==socket_error] = ws2_32.closesocket
  490. //sys AcceptEx(ls Handle, as Handle, buf *byte, rxdatalen uint32, laddrlen uint32, raddrlen uint32, recvd *uint32, overlapped *Overlapped) (err error) = mswsock.AcceptEx
  491. //sys GetAcceptExSockaddrs(buf *byte, rxdatalen uint32, laddrlen uint32, raddrlen uint32, lrsa **RawSockaddrAny, lrsalen *int32, rrsa **RawSockaddrAny, rrsalen *int32) = mswsock.GetAcceptExSockaddrs
  492. //sys WSARecv(s Handle, bufs *WSABuf, bufcnt uint32, recvd *uint32, flags *uint32, overlapped *Overlapped, croutine *byte) (err error) [failretval==socket_error] = ws2_32.WSARecv
  493. //sys WSASend(s Handle, bufs *WSABuf, bufcnt uint32, sent *uint32, flags uint32, overlapped *Overlapped, croutine *byte) (err error) [failretval==socket_error] = ws2_32.WSASend
  494. //sys WSARecvFrom(s Handle, bufs *WSABuf, bufcnt uint32, recvd *uint32, flags *uint32, from *RawSockaddrAny, fromlen *int32, overlapped *Overlapped, croutine *byte) (err error) [failretval==socket_error] = ws2_32.WSARecvFrom
  495. //sys WSASendTo(s Handle, bufs *WSABuf, bufcnt uint32, sent *uint32, flags uint32, to *RawSockaddrAny, tolen int32, overlapped *Overlapped, croutine *byte) (err error) [failretval==socket_error] = ws2_32.WSASendTo
  496. //sys GetHostByName(name string) (h *Hostent, err error) [failretval==nil] = ws2_32.gethostbyname
  497. //sys GetServByName(name string, proto string) (s *Servent, err error) [failretval==nil] = ws2_32.getservbyname
  498. //sys Ntohs(netshort uint16) (u uint16) = ws2_32.ntohs
  499. //sys GetProtoByName(name string) (p *Protoent, err error) [failretval==nil] = ws2_32.getprotobyname
  500. //sys DnsQuery(name string, qtype uint16, options uint32, extra *byte, qrs **DNSRecord, pr *byte) (status error) = dnsapi.DnsQuery_W
  501. //sys DnsRecordListFree(rl *DNSRecord, freetype uint32) = dnsapi.DnsRecordListFree
  502. //sys GetAddrInfoW(nodename *uint16, servicename *uint16, hints *AddrinfoW, result **AddrinfoW) (sockerr error) = ws2_32.GetAddrInfoW
  503. //sys FreeAddrInfoW(addrinfo *AddrinfoW) = ws2_32.FreeAddrInfoW
  504. //sys GetIfEntry(pIfRow *MibIfRow) (errcode error) = iphlpapi.GetIfEntry
  505. //sys GetAdaptersInfo(ai *IpAdapterInfo, ol *uint32) (errcode error) = iphlpapi.GetAdaptersInfo
  506. //sys SetFileCompletionNotificationModes(handle Handle, flags uint8) (err error) = kernel32.SetFileCompletionNotificationModes
  507. //sys WSAEnumProtocols(protocols *int32, protocolBuffer *WSAProtocolInfo, bufferLength *uint32) (n int32, err error) [failretval==-1] = ws2_32.WSAEnumProtocolsW
  508. // For testing: clients can set this flag to force
  509. // creation of IPv6 sockets to return EAFNOSUPPORT.
  510. var SocketDisableIPv6 bool
  511. type RawSockaddrInet4 struct {
  512. Family uint16
  513. Port uint16
  514. Addr [4]byte /* in_addr */
  515. Zero [8]uint8
  516. }
  517. type RawSockaddrInet6 struct {
  518. Family uint16
  519. Port uint16
  520. Flowinfo uint32
  521. Addr [16]byte /* in6_addr */
  522. Scope_id uint32
  523. }
  524. type RawSockaddr struct {
  525. Family uint16
  526. Data [14]int8
  527. }
  528. type RawSockaddrAny struct {
  529. Addr RawSockaddr
  530. Pad [96]int8
  531. }
  532. type Sockaddr interface {
  533. sockaddr() (ptr unsafe.Pointer, len int32, err error) // lowercase; only we can define Sockaddrs
  534. }
  535. type SockaddrInet4 struct {
  536. Port int
  537. Addr [4]byte
  538. raw RawSockaddrInet4
  539. }
  540. func (sa *SockaddrInet4) sockaddr() (unsafe.Pointer, int32, error) {
  541. if sa.Port < 0 || sa.Port > 0xFFFF {
  542. return nil, 0, EINVAL
  543. }
  544. sa.raw.Family = AF_INET
  545. p := (*[2]byte)(unsafe.Pointer(&sa.raw.Port))
  546. p[0] = byte(sa.Port >> 8)
  547. p[1] = byte(sa.Port)
  548. for i := 0; i < len(sa.Addr); i++ {
  549. sa.raw.Addr[i] = sa.Addr[i]
  550. }
  551. return unsafe.Pointer(&sa.raw), int32(unsafe.Sizeof(sa.raw)), nil
  552. }
  553. type SockaddrInet6 struct {
  554. Port int
  555. ZoneId uint32
  556. Addr [16]byte
  557. raw RawSockaddrInet6
  558. }
  559. func (sa *SockaddrInet6) sockaddr() (unsafe.Pointer, int32, error) {
  560. if sa.Port < 0 || sa.Port > 0xFFFF {
  561. return nil, 0, EINVAL
  562. }
  563. sa.raw.Family = AF_INET6
  564. p := (*[2]byte)(unsafe.Pointer(&sa.raw.Port))
  565. p[0] = byte(sa.Port >> 8)
  566. p[1] = byte(sa.Port)
  567. sa.raw.Scope_id = sa.ZoneId
  568. for i := 0; i < len(sa.Addr); i++ {
  569. sa.raw.Addr[i] = sa.Addr[i]
  570. }
  571. return unsafe.Pointer(&sa.raw), int32(unsafe.Sizeof(sa.raw)), nil
  572. }
  573. type SockaddrUnix struct {
  574. Name string
  575. }
  576. func (sa *SockaddrUnix) sockaddr() (unsafe.Pointer, int32, error) {
  577. // TODO(brainman): implement SockaddrUnix.sockaddr()
  578. return nil, 0, EWINDOWS
  579. }
  580. func (rsa *RawSockaddrAny) Sockaddr() (Sockaddr, error) {
  581. switch rsa.Addr.Family {
  582. case AF_UNIX:
  583. return nil, EWINDOWS
  584. case AF_INET:
  585. pp := (*RawSockaddrInet4)(unsafe.Pointer(rsa))
  586. sa := new(SockaddrInet4)
  587. p := (*[2]byte)(unsafe.Pointer(&pp.Port))
  588. sa.Port = int(p[0])<<8 + int(p[1])
  589. for i := 0; i < len(sa.Addr); i++ {
  590. sa.Addr[i] = pp.Addr[i]
  591. }
  592. return sa, nil
  593. case AF_INET6:
  594. pp := (*RawSockaddrInet6)(unsafe.Pointer(rsa))
  595. sa := new(SockaddrInet6)
  596. p := (*[2]byte)(unsafe.Pointer(&pp.Port))
  597. sa.Port = int(p[0])<<8 + int(p[1])
  598. sa.ZoneId = pp.Scope_id
  599. for i := 0; i < len(sa.Addr); i++ {
  600. sa.Addr[i] = pp.Addr[i]
  601. }
  602. return sa, nil
  603. }
  604. return nil, EAFNOSUPPORT
  605. }
  606. func Socket(domain, typ, proto int) (fd Handle, err error) {
  607. if domain == AF_INET6 && SocketDisableIPv6 {
  608. return InvalidHandle, EAFNOSUPPORT
  609. }
  610. return socket(int32(domain), int32(typ), int32(proto))
  611. }
  612. func SetsockoptInt(fd Handle, level, opt int, value int) (err error) {
  613. v := int32(value)
  614. return Setsockopt(fd, int32(level), int32(opt), (*byte)(unsafe.Pointer(&v)), int32(unsafe.Sizeof(v)))
  615. }
  616. func Bind(fd Handle, sa Sockaddr) (err error) {
  617. ptr, n, err := sa.sockaddr()
  618. if err != nil {
  619. return err
  620. }
  621. return bind(fd, ptr, n)
  622. }
  623. func Connect(fd Handle, sa Sockaddr) (err error) {
  624. ptr, n, err := sa.sockaddr()
  625. if err != nil {
  626. return err
  627. }
  628. return connect(fd, ptr, n)
  629. }
  630. func Getsockname(fd Handle) (sa Sockaddr, err error) {
  631. var rsa RawSockaddrAny
  632. l := int32(unsafe.Sizeof(rsa))
  633. if err = getsockname(fd, &rsa, &l); err != nil {
  634. return
  635. }
  636. return rsa.Sockaddr()
  637. }
  638. func Getpeername(fd Handle) (sa Sockaddr, err error) {
  639. var rsa RawSockaddrAny
  640. l := int32(unsafe.Sizeof(rsa))
  641. if err = getpeername(fd, &rsa, &l); err != nil {
  642. return
  643. }
  644. return rsa.Sockaddr()
  645. }
  646. func Listen(s Handle, n int) (err error) {
  647. return listen(s, int32(n))
  648. }
  649. func Shutdown(fd Handle, how int) (err error) {
  650. return shutdown(fd, int32(how))
  651. }
  652. func WSASendto(s Handle, bufs *WSABuf, bufcnt uint32, sent *uint32, flags uint32, to Sockaddr, overlapped *Overlapped, croutine *byte) (err error) {
  653. rsa, l, err := to.sockaddr()
  654. if err != nil {
  655. return err
  656. }
  657. return WSASendTo(s, bufs, bufcnt, sent, flags, (*RawSockaddrAny)(unsafe.Pointer(rsa)), l, overlapped, croutine)
  658. }
  659. func LoadGetAddrInfo() error {
  660. return procGetAddrInfoW.Find()
  661. }
  662. var connectExFunc struct {
  663. once sync.Once
  664. addr uintptr
  665. err error
  666. }
  667. func LoadConnectEx() error {
  668. connectExFunc.once.Do(func() {
  669. var s Handle
  670. s, connectExFunc.err = Socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)
  671. if connectExFunc.err != nil {
  672. return
  673. }
  674. defer CloseHandle(s)
  675. var n uint32
  676. connectExFunc.err = WSAIoctl(s,
  677. SIO_GET_EXTENSION_FUNCTION_POINTER,
  678. (*byte)(unsafe.Pointer(&WSAID_CONNECTEX)),
  679. uint32(unsafe.Sizeof(WSAID_CONNECTEX)),
  680. (*byte)(unsafe.Pointer(&connectExFunc.addr)),
  681. uint32(unsafe.Sizeof(connectExFunc.addr)),
  682. &n, nil, 0)
  683. })
  684. return connectExFunc.err
  685. }
  686. func connectEx(s Handle, name unsafe.Pointer, namelen int32, sendBuf *byte, sendDataLen uint32, bytesSent *uint32, overlapped *Overlapped) (err error) {
  687. r1, _, e1 := Syscall9(connectExFunc.addr, 7, uintptr(s), uintptr(name), uintptr(namelen), uintptr(unsafe.Pointer(sendBuf)), uintptr(sendDataLen), uintptr(unsafe.Pointer(bytesSent)), uintptr(unsafe.Pointer(overlapped)), 0, 0)
  688. if r1 == 0 {
  689. if e1 != 0 {
  690. err = error(e1)
  691. } else {
  692. err = EINVAL
  693. }
  694. }
  695. return
  696. }
  697. func ConnectEx(fd Handle, sa Sockaddr, sendBuf *byte, sendDataLen uint32, bytesSent *uint32, overlapped *Overlapped) error {
  698. err := LoadConnectEx()
  699. if err != nil {
  700. return errorspkg.New("failed to find ConnectEx: " + err.Error())
  701. }
  702. ptr, n, err := sa.sockaddr()
  703. if err != nil {
  704. return err
  705. }
  706. return connectEx(fd, ptr, n, sendBuf, sendDataLen, bytesSent, overlapped)
  707. }
  708. // Invented structures to support what package os expects.
  709. type Rusage struct {
  710. CreationTime Filetime
  711. ExitTime Filetime
  712. KernelTime Filetime
  713. UserTime Filetime
  714. }
  715. type WaitStatus struct {
  716. ExitCode uint32
  717. }
  718. func (w WaitStatus) Exited() bool { return true }
  719. func (w WaitStatus) ExitStatus() int { return int(w.ExitCode) }
  720. func (w WaitStatus) Signal() Signal { return -1 }
  721. func (w WaitStatus) CoreDump() bool { return false }
  722. func (w WaitStatus) Stopped() bool { return false }
  723. func (w WaitStatus) Continued() bool { return false }
  724. func (w WaitStatus) StopSignal() Signal { return -1 }
  725. func (w WaitStatus) Signaled() bool { return false }
  726. func (w WaitStatus) TrapCause() int { return -1 }
  727. // Timespec is an invented structure on Windows, but here for
  728. // consistency with the corresponding package for other operating systems.
  729. type Timespec struct {
  730. Sec int64
  731. Nsec int64
  732. }
  733. func TimespecToNsec(ts Timespec) int64 { return int64(ts.Sec)*1e9 + int64(ts.Nsec) }
  734. func NsecToTimespec(nsec int64) (ts Timespec) {
  735. ts.Sec = nsec / 1e9
  736. ts.Nsec = nsec % 1e9
  737. return
  738. }
  739. // TODO(brainman): fix all needed for net
  740. func Accept(fd Handle) (nfd Handle, sa Sockaddr, err error) { return 0, nil, EWINDOWS }
  741. func Recvfrom(fd Handle, p []byte, flags int) (n int, from Sockaddr, err error) {
  742. return 0, nil, EWINDOWS
  743. }
  744. func Sendto(fd Handle, p []byte, flags int, to Sockaddr) (err error) { return EWINDOWS }
  745. func SetsockoptTimeval(fd Handle, level, opt int, tv *Timeval) (err error) { return EWINDOWS }
  746. // The Linger struct is wrong but we only noticed after Go 1.
  747. // sysLinger is the real system call structure.
  748. // BUG(brainman): The definition of Linger is not appropriate for direct use
  749. // with Setsockopt and Getsockopt.
  750. // Use SetsockoptLinger instead.
  751. type Linger struct {
  752. Onoff int32
  753. Linger int32
  754. }
  755. type sysLinger struct {
  756. Onoff uint16
  757. Linger uint16
  758. }
  759. type IPMreq struct {
  760. Multiaddr [4]byte /* in_addr */
  761. Interface [4]byte /* in_addr */
  762. }
  763. type IPv6Mreq struct {
  764. Multiaddr [16]byte /* in6_addr */
  765. Interface uint32
  766. }
  767. func GetsockoptInt(fd Handle, level, opt int) (int, error) { return -1, EWINDOWS }
  768. func SetsockoptLinger(fd Handle, level, opt int, l *Linger) (err error) {
  769. sys := sysLinger{Onoff: uint16(l.Onoff), Linger: uint16(l.Linger)}
  770. return Setsockopt(fd, int32(level), int32(opt), (*byte)(unsafe.Pointer(&sys)), int32(unsafe.Sizeof(sys)))
  771. }
  772. func SetsockoptInet4Addr(fd Handle, level, opt int, value [4]byte) (err error) {
  773. return Setsockopt(fd, int32(level), int32(opt), (*byte)(unsafe.Pointer(&value[0])), 4)
  774. }
  775. func SetsockoptIPMreq(fd Handle, level, opt int, mreq *IPMreq) (err error) {
  776. return Setsockopt(fd, int32(level), int32(opt), (*byte)(unsafe.Pointer(mreq)), int32(unsafe.Sizeof(*mreq)))
  777. }
  778. func SetsockoptIPv6Mreq(fd Handle, level, opt int, mreq *IPv6Mreq) (err error) { return EWINDOWS }
  779. func Getpid() (pid int) { return int(getCurrentProcessId()) }
  780. func FindFirstFile(name *uint16, data *Win32finddata) (handle Handle, err error) {
  781. // NOTE(rsc): The Win32finddata struct is wrong for the system call:
  782. // the two paths are each one uint16 short. Use the correct struct,
  783. // a win32finddata1, and then copy the results out.
  784. // There is no loss of expressivity here, because the final
  785. // uint16, if it is used, is supposed to be a NUL, and Go doesn't need that.
  786. // For Go 1.1, we might avoid the allocation of win32finddata1 here
  787. // by adding a final Bug [2]uint16 field to the struct and then
  788. // adjusting the fields in the result directly.
  789. var data1 win32finddata1
  790. handle, err = findFirstFile1(name, &data1)
  791. if err == nil {
  792. copyFindData(data, &data1)
  793. }
  794. return
  795. }
  796. func FindNextFile(handle Handle, data *Win32finddata) (err error) {
  797. var data1 win32finddata1
  798. err = findNextFile1(handle, &data1)
  799. if err == nil {
  800. copyFindData(data, &data1)
  801. }
  802. return
  803. }
  804. func getProcessEntry(pid int) (*ProcessEntry32, error) {
  805. snapshot, err := CreateToolhelp32Snapshot(TH32CS_SNAPPROCESS, 0)
  806. if err != nil {
  807. return nil, err
  808. }
  809. defer CloseHandle(snapshot)
  810. var procEntry ProcessEntry32
  811. procEntry.Size = uint32(unsafe.Sizeof(procEntry))
  812. if err = Process32First(snapshot, &procEntry); err != nil {
  813. return nil, err
  814. }
  815. for {
  816. if procEntry.ProcessID == uint32(pid) {
  817. return &procEntry, nil
  818. }
  819. err = Process32Next(snapshot, &procEntry)
  820. if err != nil {
  821. return nil, err
  822. }
  823. }
  824. }
  825. func Getppid() (ppid int) {
  826. pe, err := getProcessEntry(Getpid())
  827. if err != nil {
  828. return -1
  829. }
  830. return int(pe.ParentProcessID)
  831. }
  832. // TODO(brainman): fix all needed for os
  833. func Fchdir(fd Handle) (err error) { return EWINDOWS }
  834. func Link(oldpath, newpath string) (err error) { return EWINDOWS }
  835. func Symlink(path, link string) (err error) { return EWINDOWS }
  836. func Fchmod(fd Handle, mode uint32) (err error) { return EWINDOWS }
  837. func Chown(path string, uid int, gid int) (err error) { return EWINDOWS }
  838. func Lchown(path string, uid int, gid int) (err error) { return EWINDOWS }
  839. func Fchown(fd Handle, uid int, gid int) (err error) { return EWINDOWS }
  840. func Getuid() (uid int) { return -1 }
  841. func Geteuid() (euid int) { return -1 }
  842. func Getgid() (gid int) { return -1 }
  843. func Getegid() (egid int) { return -1 }
  844. func Getgroups() (gids []int, err error) { return nil, EWINDOWS }
  845. type Signal int
  846. func (s Signal) Signal() {}
  847. func (s Signal) String() string {
  848. if 0 <= s && int(s) < len(signals) {
  849. str := signals[s]
  850. if str != "" {
  851. return str
  852. }
  853. }
  854. return "signal " + itoa(int(s))
  855. }
  856. func LoadCreateSymbolicLink() error {
  857. return procCreateSymbolicLinkW.Find()
  858. }
  859. // Readlink returns the destination of the named symbolic link.
  860. func Readlink(path string, buf []byte) (n int, err error) {
  861. fd, err := CreateFile(StringToUTF16Ptr(path), GENERIC_READ, 0, nil, OPEN_EXISTING,
  862. FILE_FLAG_OPEN_REPARSE_POINT|FILE_FLAG_BACKUP_SEMANTICS, 0)
  863. if err != nil {
  864. return -1, err
  865. }
  866. defer CloseHandle(fd)
  867. rdbbuf := make([]byte, MAXIMUM_REPARSE_DATA_BUFFER_SIZE)
  868. var bytesReturned uint32
  869. err = DeviceIoControl(fd, FSCTL_GET_REPARSE_POINT, nil, 0, &rdbbuf[0], uint32(len(rdbbuf)), &bytesReturned, nil)
  870. if err != nil {
  871. return -1, err
  872. }
  873. rdb := (*reparseDataBuffer)(unsafe.Pointer(&rdbbuf[0]))
  874. if uintptr(bytesReturned) < unsafe.Sizeof(*rdb) ||
  875. rdb.ReparseTag != IO_REPARSE_TAG_SYMLINK {
  876. // the path is not a symlink but another type of reparse point
  877. return -1, ENOENT
  878. }
  879. s := UTF16ToString((*[0xffff]uint16)(unsafe.Pointer(&rdb.PathBuffer[0]))[:rdb.PrintNameLength/2])
  880. n = copy(buf, []byte(s))
  881. return n, nil
  882. }