Spec-Zone.ru › OCaml 4.14

Модуль Unix

module Unix: sig .. end

Интерфейс к системе Unix.

Для использования помеченной версии этого модуля добавьте module Unix = UnixLabels в вашей реализации.

Примечание: все функции этого модуля (кроме Unix.error_message и Unix.handle_unix_error) могут вызывать исключение Unix.Unix_error, когда системный вызов сообщает об ошибке.

Отчёт об ошибке

type error = 
| E2BIG (*

Список аргументов слишком длинный

*)
| EACCES (*

Доступ запрещён

*)
| EAGAIN (*

Ресурс временно недоступен; попробуйте ещё раз

*)
| EBADF (*

Неверный дескриптор файла

*)
| EBUSY (*

Ресурс недоступен

*)
| ECHILD (*

Нет дочернего процесса

*)
| EDEADLK (*

Возникнет тупик ресурсов

*)
| EDOM (*

Ошибка области для математических функций и т.п.

*)
| EEXIST (*

Файл существует

*)
| EFAULT (*

Неверный адрес

*)
| EFBIG (*

Файл слишком большой

*)
| EINTR (*

Функция прервана сигналом

*)
| EINVAL (*

Неверный аргумент

*)
| EIO (*

Ошибка ввода-вывода оборудования

*)
| EISDIR (*

Является каталогом

*)
| EMFILE (*

Слишком много открытых файлов в процессе

*)
| EMLINK (*

Слишком много ссылок

*)
| ENAMETOOLONG (*

Имя файла слишком длинное

*)
| ENFILE (*

Слишком много открытых файлов в системе

*)
| ENODEV (*

Устройства нет

*)
| ENOENT (*

Файл или каталог не найден

*)
| ENOEXEC (*

Файл не является исполняемым

*)
| ENOLCK (*

Нет доступных блокировок

*)
| ENOMEM (*

Недостаточно памяти

*)
| ENOSPC (*

На устройстве закончилось место

*)
| ENOSYS (*

Функция не поддерживается

*)
| ENOTDIR (*

Это не каталог

*)
| ENOTEMPTY (*

Каталог не пуст

*)
| ENOTTY (*

Неподходящая операция управления вводом-выводом

*)
| ENXIO (*

Такого устройства или адреса нет

*)
| EPERM (*

Операция запрещена

*)
| EPIPE (*

Разрыв канала

*)
| ERANGE (*

Результат слишком большой

*)
| EROFS (*

Файловая система только для чтения

*)
| ESPIPE (*

Неверный сдвиг, например, в случае с каналом

*)
| ESRCH (*

Процесс не найден

*)
| EXDEV (*

Неверная ссылка

*)
| EWOULDBLOCK (*

Операция заблокируется

*)
| EINPROGRESS (*

Операция выполняется в данный момент

*)
| EALREADY (*

Операция уже выполняется

*)
| ENOTSOCK (*

Операция сокета выполняется на объекте, который не является сокетом

*)
| EDESTADDRREQ (*

Требуется адрес назначения

*)
| EMSGSIZE (*

Сообщение слишком длинное

*)
| EPROTOTYPE (*

Неправильный тип протокола для сокета

*)
| ENOPROTOOPT (*

Протокол недоступен

*)
| EPROTONOSUPPORT (*

Протокол не поддерживается

*)
| ESOCKTNOSUPPORT (*

Тип сокета не поддерживается

*)
| EOPNOTSUPP (*

Операция не поддерживается для сокета

*)
| EPFNOSUPPORT (*

Семейство протоколов не поддерживается

*)
| EAFNOSUPPORT (*

Семейство адресов не поддерживается семейством протоколов

*)
| EADDRINUSE (*

Адрес уже используется

*)
| EADDRNOTAVAIL (*

Невозможно назначить запрашиваемый адрес

*)
| ENETDOWN (*

Сеть отключена

*)
| ENETUNREACH (*

Сеть недоступна

*)
| ENETRESET (*

Сеть разорвала соединение при сбросе

*)
| ECONNABORTED (*

Программное обеспечение вызвало прерывание соединения

*)
| ECONNRESET (*

Соединение сброшено удалённым узлом

*)
| ENOBUFS (*

Нет доступного буферного пространства

*)
| EISCONN (*

Сокет уже подключен

*)
| ENOTCONN (*

Сокет не подключен

*)
| ESHUTDOWN (*

Нельзя отправить после завершения работы сокета

*)
| ETOOMANYREFS (*

Слишком много ссылок: нельзя выполнить операцию

*)
| ETIMEDOUT (*

Таймаут соединения

*)
| ECONNREFUSED (*

Соединение отклонено

*)
| EHOSTDOWN (*

Узел не работает

*)
| EHOSTUNREACH (*

Маршрут к узлу недоступен

*)
| ELOOP (*

Слишком много уровней символических ссылок

*)
| EOVERFLOW (*

Размер или позиция файла не могут быть представлены

*)
| EUNKNOWNERR of int (*

Неизвестная ошибка

*)

Тип кодов ошибок. Ошибки, определённые в стандарте POSIX, и дополнительные ошибки из UNIX98 и BSD. Все другие ошибки сопоставляются с EUNKNOWNERR.

exception Unix_error of error * string * string

Возникают в системных вызовах ниже, когда возникает ошибка. Первый компонент — код ошибки; второй компонент — имя функции; третий компонент — строковый параметр функции (если он есть), иначе — пустая строка.

UnixLabels.Unix_error и Unix.Unix_error одинаковы, и перехват одной из них перехватывает и другую.

val error_message : error -> string

Возвращает строку, описывающую данный код ошибки.

val handle_unix_error : ('a -> 'b) -> 'a -> 'b

handle_unix_error f x применяет f к x и возвращает результат. Если возникает исключение Unix.Unix_error, выводится сообщение об ошибке и программа завершается с кодом 2.

Доступ к среде процесса

val environment : unit -> string array

Возвращает среду процесса в виде массива строк с форматом «переменная=значение». Возвращаемый массив пустой, если у процесса есть особые привилегии.

val unsafe_environment : unit -> string array

Возвращает среду процесса в виде массива строк с форматом «переменная=значение». В отличие от Unix.environment, эта функция возвращает заполненный массив даже если у процесса есть особые привилегии. Подробнее см. документацию к Unix.unsafe_getenv.

  • Since 4.06.0 (4.12.0 в UnixLabels)
val getenv : string -> string

Возвращает значение, связанное с переменной в среде процесса, если у процесса нет особых привилегий.

  • Raises Not_found если переменная не определена или у процесса есть особые привилегии. Эта функция идентична Sys.getenv.
val unsafe_getenv : string -> string

Возвращает значение, связанное с переменной в среде процесса.

В отличие от Unix.getenv, эта функция возвращает значение даже если у процесса есть особые привилегии. Она считается небезопасной, так как программист программы с установленным setuid или setgid должен быть внимателен, чтобы избежать использования злонамеренно составленных переменных среды в пути поиска исполняемых файлов, местоположения временных файлов или логов, и т.п.

  • Since 4.06.0
  • Raises Not_found если переменная не определена.
val putenv : string -> string -> unit

putenv name value устанавливает значение, связанное с переменной в среде процесса. name — имя переменной среды, а value — её новое значение.

Обработка процессов

type process_status = 
| WEXITED of int (*

Процесс завершился нормально; аргументом является код возврата.

*)
| WSIGNALED of int (*

Процесс был завершён сигналом; аргументом является номер сигнала.

*)
| WSTOPPED of int (*

Процесс был приостановлен сигналом; аргументом является номер сигнала.

*)

Код завершения процесса. Смотрите модуль Sys для определений стандартных номеров сигналов. Обратите внимание, что они не являются номерами, используемыми ОС.

type wait_flag = 
| WNOHANG (*

Не блокировать, если ни один дочерний процесс ещё не завершился, но немедленно вернуть 0 в качестве pid.

*)
| WUNTRACED (*

Отчитываться также о дочерних процессах, получивших сигналы остановки.

*)

Флаги для Unix.waitpid.

val execv : string -> string array -> 'a

execv prog args выполнить программу в файле prog, с аргументами args, и текущей средой процесса. Эти execv* функции никогда не возвращаются: при успехе текущая программа заменяется новой.

  • Raises Unix_error при ошибке
val execve : string -> string array -> string array -> 'a

Аналогично Unix.execv, за исключением того, что третий аргумент предоставляет среду для исполняемой программы.

val execvp : string -> string array -> 'a

Аналогично Unix.execv, за исключением того, что программа ищется в пути.

val execvpe : string -> string array -> string array -> 'a

Аналогично Unix.execve, за исключением того, что программа ищется в пути.

val fork : unit -> int

Создать новый процесс. Возвращаемое целое число равно 0 для дочернего процесса и pid дочернего процесса для родительского процесса.

  • Raises Invalid_argument в Windows. Используйте Unix.create_process или потоки вместо этого.
val wait : unit -> int * process_status

Ожидать, пока один из дочерних процессов завершится, и вернуть его pid и код завершения.

  • Raises Invalid_argument в Windows. Используйте Unix.waitpid вместо этого.
val waitpid : wait_flag list -> int -> int * process_status

Аналогично Unix.wait, но ожидает завершения дочернего процесса с заданным pid. Значение pid, равное -1, означает ожидание любого дочернего процесса. Значение pid, равное 0, означает ожидание любого дочернего процесса в той же группе процессов, что и текущий процесс. Отрицательные значения pid представляют группы процессов. Список опций указывает, должен ли waitpid возвращаться немедленно без ожидания, и должен ли он отчитываться о приостановленных дочерних процессах.

В Windows: можно ожидать только процесса с заданным PID, а не любого дочернего процесса.

val system : string -> process_status

Выполнить заданную команду, дождаться её завершения и вернуть код завершения. Строка интерпретируется оболочкой /bin/sh (или интерпретатором команд cmd.exe в Windows) и поэтому может содержать перенаправления, кавычки, переменные и т.п. Для правильной цитирования пробелов и специальных символов оболочки, встречающихся в именах файлов или аргументах команд, рекомендуется использовать Filename.quote_command. Результат WEXITED 127 указывает, что оболочка не могла быть запущена.

val _exit : int -> 'a

Немедленно завершить вызывающий процесс, вернув указанный код состояния операционной системе: обычно 0, чтобы указать отсутствие ошибок, и небольшое положительное целое число, чтобы указать ошибку. В отличие от exit, Unix._exit не выполняет никакой финализации: функции, зарегистрированные с помощью at_exit, не вызываются, каналы ввода/вывода не очищаются, и система выполнения C не завершается.

Типичное использование Unix._exit происходит после операции Unix.fork, когда дочерний процесс сталкивается с фатальной ошибкой и должен выйти. В этом случае предпочтительно не выполнять никаких действий финализации в дочернем процессе, так как эти действия могут конфликтовать с аналогичными действиями, выполняемыми родительским процессом. Например, каналы вывода не должны быть очищены дочерним процессом, так как родительский процесс может очистить их позже, что приведёт к дублированию вывода.

  • Since 4.12.0
val getpid : unit -> int

Возвращает pid процесса.

val getppid : unit -> int

Возвращает pid родительского процесса.

  • Raises Invalid_argument в Windows (потому что это бессмысленно)
val nice : int -> int

Изменить приоритет процесса. Целое число аргумента добавляется к значению «nice» (большие значения «nice» означают меньшие приоритеты). Возвращает новое значение nice.

  • Raises Invalid_argument в Windows

Основные ввод/вывод файлов

type file_descr 

Абстрактный тип дескрипторов файлов.

val stdin : file_descr

Дескриптор файла для стандартного ввода.

val stdout : file_descr

Дескриптор файла для стандартного вывода.

val stderr : file_descr

Дескриптор файла для стандартной ошибки.

type open_flag = 
| O_RDONLY (*

Открыто для чтения

*)
| O_WRONLY (*

Открыто для записи

*)
| O_RDWR (*

Открыто для чтения и записи

*)
| O_NONBLOCK (*

Открыто в режиме без блокировки

*)
| O_APPEND (*

Открыто для добавления

*)
| O_CREAT (*

Создать, если не существует

*)
| O_TRUNC (*

Усечь до длины 0, если существует

*)
| O_EXCL (*

Ошибка, если существует

*)
| O_NOCTTY (*

Не делать этот dev управляющей tty

*)
| O_DSYNC (*

Запись завершена как «Завершение целостности синхронизированных операций ввода-вывода»

*)
| O_SYNC (*

Запись завершена как «Завершение целостности файла синхронизированных операций ввода-вывода»

*)
| O_RSYNC (*

Чтение завершается как записи (в зависимости от O_SYNC/O_DSYNC)

*)
| O_SHARE_DELETE (*

Только Windows: разрешить удаление файла во время открытия

*)
| O_CLOEXEC (*

Установить флаг close-on-exec для дескриптора, возвращаемого Unix.openfile. Дополнительная информация в Unix.set_close_on_exec.

*)
| O_KEEPEXEC (*

Сбросить флаг close-on-exec. В настоящее время это значение по умолчанию.

*)

Флаги для Unix.openfile.

type file_perm = int 

Тип прав доступа к файлу, например, 0o640 — чтение и запись для пользователя, чтение для группы, отсутствуют для других.

val openfile : string -> open_flag list -> file_perm -> file_descr

Открыть указанный файл с заданными флагами. Третий аргумент — права доступа, предоставляемые файлу при создании (см. Unix.umask). Возвращает дескриптор файла.

val close : file_descr -> unit

Закрыть дескриптор файла.

val fsync : file_descr -> unit

Очистить буферы файла в диск.

  • Since 4.08.0 (4.12.0 в UnixLabels)
val read : file_descr -> bytes -> int -> int -> int

read fd buf pos len читает len байта из дескриптора fd, сохраняя их в последовательности байтов buf, начиная с позиции pos в buf. Возвращает количество фактически прочитанных байтов.

val write : file_descr -> bytes -> int -> int -> int

write fd buf pos len записывает len байта в дескриптор fd, беря их из последовательности байтов buf, начиная с позиции pos в buff. Возвращает количество фактически записанных байтов. write повторяет операцию записи, пока все байты не будут записаны или не произойдёт ошибка.

val single_write : file_descr -> bytes -> int -> int -> int

То же, что и Unix.write, но пытается записать только один раз. Таким образом, в случае ошибки single_write гарантирует, что данные не были записаны.

val write_substring : file_descr -> string -> int -> int -> int

То же, что и Unix.write, но данные берутся из строки вместо последовательности байтов.

  • Since 4.02.0
val single_write_substring : file_descr -> string -> int -> int -> int

То же, что и Unix.single_write, но данные берутся из строки вместо последовательности байтов.

  • Since 4.02.0

Взаимодействие с стандартной библиотекой ввода/вывода

val in_channel_of_descr : file_descr -> in_channel

Создать канал ввода, читающий из заданного дескриптора. Канал изначально в двоичном режиме; используйте set_binary_mode_in ic false если нужен текстовый режим. Текстовый режим поддерживается только если дескриптор относится к файлу или пайпу, но не поддерживается, если он относится к сокету.

В Windows: set_binary_mode_in всегда возвращает ошибку при создании каналов с помощью этой функции.

Обратите внимание, что каналы ввода буферизованы, поэтому может быть прочитано больше символов из дескриптора, чем доступно с помощью функций канала. Каналы также хранят копию текущей позиции в файле.

Закрытие канала ic возвращаемого in_channel_of_descr fd с помощью close_in ic также закрывает основной дескриптор fd. Неправильно закрывать и канал ic и дескриптор fd.

Если несколько каналов созданы на одном дескрипторе, один из каналов должен быть закрыт, но не остальные. Рассмотрим, например, дескриптор s подключенный к сокету и два канала ic = in_channel_of_descr s и oc = out_channel_of_descr s. Рекомендуемый протокол закрытия — выполнить close_out oc, что сбросит буферизованный вывод в сокет, а затем закроет сокет. Канал ic не должен закрываться и будет убран сборщиком мусора.

val out_channel_of_descr : file_descr -> out_channel

Создайте канал вывода, записывающий в указанный дескриптор. Канал изначально находится в двоичном режиме; используйте set_binary_mode_out oc false для текстового режима. Текстовый режим поддерживается только если дескриптор относится к файлу или конвейпу, но не поддерживается, если он относится к сокету.

В Windows: set_binary_mode_out всегда завершается неудачей для каналов, созданных с помощью этой функции.

Обратите внимание, что каналы вывода буферизованы, поэтому может потребоваться вызвать flush, чтобы убедиться, что все данные были отправлены в дескриптор. Каналы также сохраняют копию текущей позиции в файле.

Закрытие канала oc возвращаемого out_channel_of_descr fd с помощью close_out oc также закрывает базовый дескриптор fd. Неправильно закрывать как канал ic, так и дескриптор fd.

См. Unix.in_channel_of_descr для обсуждения протокола закрытия, когда несколько каналов создаются на одном дескрипторе.

val descr_of_in_channel : in_channel -> file_descr

Возвращает дескриптор, соответствующий каналу ввода.

val descr_of_out_channel : out_channel -> file_descr

Возвращает дескриптор, соответствующий каналу вывода.

Поиск и обрезка

type seek_command = 
| SEEK_SET (*

указывает позиции относительно начала файла

*)
| SEEK_CUR (*

указывает позиции относительно текущей позиции

*)
| SEEK_END (*

указывает позиции относительно конца файла

*)

Режимы позиционирования для Unix.lseek.

val lseek : file_descr -> int -> seek_command -> int

Устанавливает текущую позицию для дескриптора файла и возвращает полученный смещение (от начала файла).

val truncate : string -> int -> unit

Усекает указанный файл до заданного размера.

val ftruncate : file_descr -> int -> unit

Усекает файл, соответствующий данному дескриптору, до заданного размера.

Статус файла

type file_kind = 
| S_REG (*

Обычный файл

*)
| S_DIR (*

Директория

*)
| S_CHR (*

Символьное устройство

*)
| S_BLK (*

Блочное устройство

*)
| S_LNK (*

Символическая ссылка

*)
| S_FIFO (*

Именованная труба

*)
| S_SOCK (*

Сокет

*)
type stats = {
st_dev : int; (*

Номер устройства

*)
st_ino : int; (*

Номер узла

*)
st_kind : file_kind; (*

Тип файла

*)
st_perm : file_perm; (*

Права доступа

*)
st_nlink : int; (*

Количество ссылок

*)
st_uid : int; (*

ID пользователя владельца

*)
st_gid : int; (*

ID группы файла

*)
st_rdev : int; (*

ID устройства (если специальный файл)

*)
st_size : int; (*

Размер в байтах

*)
st_atime : float; (*

Время последнего доступа

*)
st_mtime : float; (*

Время последней модификации

*)
st_ctime : float; (*

Время последнего изменения статуса

*)
}

Информация, возвращаемая вызовами Unix.stat.

val stat : string -> stats

Возвращает информацию о заданном файле.

val lstat : string -> stats

То же, что и Unix.stat, но в случае, если файл является символической ссылкой, возвращает информацию о самой ссылке.

val fstat : file_descr -> stats

Возвращает информацию о файле, связанном с данным дескриптором.

val isatty : file_descr -> bool

Возвращает true, если данный дескриптор файла относится к терминалу или консольному окну, false, в противном случае.

Операции с большими файлами

module LargeFile: sig .. end

Операции с большими файлами.

Мапинг файлов в память

val map_file : file_descr ->       ?pos:int64 ->       ('a, 'b) Bigarray.kind ->       'c Bigarray.layout ->       bool -> int array -> ('a, 'b, 'c) Bigarray.Genarray.t

Мапинг файла в память как Bigarray. map_file fd kind layout shared dims возвращает Bigarray типа kind, расположения layout, и размерности, как указано в dims. Данные в этом Bigarray содержат содержимое файла, указанного дескриптором файла fd (как открытый ранее с Unix.openfile, например). Необязательный параметр pos — смещение в файле в байтах; по умолчанию 0 (мапинг с начала файла).

Если shared равен true, все изменения, внесённые в массив, отражаются в файле. Это требует, чтобы fd был открыт с разрешением на запись. Если shared равен false, изменения в массиве производятся только в памяти, используя копирование при записи измененных страниц; исходный файл не затрагивается.

Genarray.map_file намного эффективнее, чем чтение всего файла в Bigarray, изменение этого Bigarray и последующая запись.

Для автоматической подстройки размерности Bigarray под фактический размер файла, главная размерность (то есть первая размерность для массива с расположением C и последняя размерность для массива с расположением Fortran) может быть задана как -1. Genarray.map_file затем определяет главную размерность по размеру файла. Файл должен содержать целое число под-массивов, определяемых неглавными размерностями, в противном случае возникает Failure.

Если все размерности Bigarray заданы, размер файла сопоставляется с размером Bigarray. Если файл больше, чем Bigarray, в Bigarray отображается только начальная часть файла. Если файл меньше, чем Bigarray, файл автоматически увеличивается до размера Bigarray. Это требует разрешения на запись на fd.

Доступы к массивам проверяются на границу, но границы определяются начальным вызовом map_file. Поэтому необходимо убедиться, что ни один другой процесс не изменяет сопоставленный файл во время доступа, иначе может быть поднято исключение SIGBUS. Это происходит, например, если файл уменьшается.

Invalid_argument или Failure могут быть подняты в случае, если проверка аргументов завершится неудачей.

  • Since 4.06.0

Операции с именами файлов

val unlink : string -> unit

Удаляет указанный файл.

Если указанный файл является каталогом, возникает:

  • EPERM на совместимых с POSIX системах
  • EISDIR на Linux >= 2.1.132
  • EACCESS на Windows
val rename : string -> string -> unit

rename src dst изменяет имя файла с src на dst, перемещая его между каталогами при необходимости. Если dst уже существует, его содержимое заменяется содержимым src. В зависимости от операционной системы метаданные (разрешения, владелец и т. д.) dst могут быть сохранены или заменены метаданными src.

val link : ?follow:bool -> string -> string -> unit

link ?follow src dst создаёт жёсткую ссылку с именем dst на файл с именем src.

  • Raises
    • ENOSYS На Unix, если требуется ~follow:_, но linkat недоступен.
    • ENOSYS На Windows, если требуется ~follow:false.
follow : указывает, следует ли src символическая ссылка или создаётся жёсткая ссылка на src. На Unix системах это делается с помощью функции linkat(2). Если ?follow не указан, используется функция link(2), поведение которой зависит от ОС, но более широко доступна.
val realpath : string -> string

realpath p — абсолютный путь к p, полученный путём разрешения всех дополнительных символов /, сегментов относительного пути и символических ссылок.

  • Since 4.13.0

Права доступа и владение файлами

type access_permission = 
| R_OK (*

Разрешение на чтение

*)
| W_OK (*

Разрешение на запись

*)
| X_OK (*

Разрешение на выполнение

*)
| F_OK (*

Файл существует

*)

Флаги для вызова Unix.access.

val chmod : string -> file_perm -> unit

Изменить разрешения указанного файла.

val fchmod : file_descr -> file_perm -> unit

Изменить разрешения открытого файла.

  • Raises Invalid_argument в Windows
val chown : string -> int -> int -> unit

Изменить идентификаторы владельца (uid и gid) указанного файла.

  • Raises Invalid_argument в Windows
val fchown : file_descr -> int -> int -> unit

Изменить идентификаторы владельца (uid и gid) открытого файла.

  • Raises Invalid_argument в Windows
val umask : int -> int

Установить маску создания режима файла процесса и вернуть предыдущую маску.

  • Raises Invalid_argument в Windows
val access : string -> access_permission list -> unit

Проверить, обладает ли процесс заданными разрешениями на указанный файл.

В Windows: разрешение на выполнение X_OK нельзя проверить, вместо этого проверяется только разрешение на чтение.

  • Raises Unix_error в противном случае.

Операции с дескрипторами файлов

val dup : ?cloexec:bool -> file_descr -> file_descr

Возвращает новый дескриптор файла, ссылающийся на тот же файл, что и заданный дескриптор. См. Unix.set_close_on_exec для документации по необязательному аргументу cloexec.

val dup2 : ?cloexec:bool -> file_descr -> file_descr -> unit

dup2 src dst дублирует src в dst, закрывая dst если он уже открыт. См. Unix.set_close_on_exec для документации по необязательному аргументу cloexec.

val set_nonblock : file_descr -> unit

Устанавливает флаг «без блокировки» для данного дескриптора. Когда флаг «без блокировки» установлен, чтение из дескриптора, для которого временно нет доступных данных, вызывает ошибку EAGAIN или EWOULDBLOCK, вместо блокировки; запись в дескриптор, для которого временно нет места для записи, также вызывает ошибку EAGAIN или EWOULDBLOCK.

val clear_nonblock : file_descr -> unit

Снимает флаг «без блокировки» для данного дескриптора. См. Unix.set_nonblock.

val set_close_on_exec : file_descr -> unit

Устанавливает флаг «закрыть при exec» для данного дескриптора. Дескриптор с флагом «закрыть при exec» автоматически закрывается, когда текущий процесс запускает другую программу с помощью одной из функций exec, create_process и open_process.

Часто утечка дескрипторов файлов, открытых, например, на частном файле во внешнюю программу, является уязвимостью: программа затем получает доступ к частному файлу и может совершить нежелательные действия. Поэтому настоятельно рекомендуется устанавливать для всех дескрипторов файлов флаг «закрыть при exec», за исключением тех немногих случаев, когда дескриптор файла действительно нужно передать другой программе.

Лучший способ установить флаг «закрыть при exec» — создать дескриптор в этом состоянии. Для этой цели функция openfile имеет флаги O_CLOEXEC и O_KEEPEXEC для принудительного включения режима «закрыть при exec» или «сохранить при exec» соответственно. Все остальные операции в модуле Unix, создающие дескрипторы файлов, имеют необязательный аргумент ?cloexec:bool, чтобы указать, должен ли дескриптор файла быть создан в режиме «закрыть при exec» (путем написания ~cloexec:true) или в режиме «сохранить при exec» (путем написания ~cloexec:false). По историческим причинам, по умолчанию, режим создания дескриптора файлов — «сохранить при exec», если необязательный аргумент cloexec не задан. Это небезопасный по умолчанию режим, поэтому настоятельно рекомендуется передавать явные аргументы cloexec при операциях создания дескрипторов файлов.

Необязательные аргументы cloexec и флаг O_KEEPEXEC были введены в OCaml 4.05. Раньше общим подходом было создание дескрипторов файлов в режиме по умолчанию «сохранить при exec», а затем вызов set_close_on_exec для этих только что созданных дескрипторов файлов. Это не так безопасно, как создание дескриптора файла в режиме «закрыть при exec», потому что в многопоточных программах существует окно уязвимости между временем создания дескриптора файла и временем завершения ~cloexec:true. Если другой поток запускает другую программу в течение этого окна, дескриптор утечет, поскольку он все еще находится в режиме «сохранить при exec».

Что касается гарантий атомарности, предоставляемых ~cloexec:true или флагом O_CLOEXEC, на всех платформах гарантируется, что выполняющийся одновременно поток Caml не может утечь дескриптор, запустив новый процесс. В Linux эта гарантия распространяется на одновременно выполняющиеся потоки C. По состоянию на февраль 2017 года другие операционные системы не имеют необходимых системных вызовов и по-прежнему подвержены окну уязвимости, в течение которого поток C может видеть только что созданный дескриптор файла в режиме «сохранить при exec».

val clear_close_on_exec : file_descr -> unit

Снимает флаг «закрыть при exec» для данного дескриптора. См. Unix.set_close_on_exec.

Директории

val mkdir : string -> file_perm -> unit

Создать директорию с заданными разрешениями (см. Unix.umask).

val rmdir : string -> unit

Удалить пустую директорию.

val chdir : string -> unit

Изменить рабочую директорию процесса.

val getcwd : unit -> string

Возвращает имя текущей рабочей директории.

val chroot : string -> unit

Изменить корневую директорию процесса.

  • Raises Invalid_argument в Windows
type dir_handle 

Тип дескрипторов открытых директорий.

val opendir : string -> dir_handle

Открыть дескриптор на директорию

val readdir : dir_handle -> string

Возвращает следующую запись в каталоге.

  • Raises End_of_file при достижении конца каталога.
val rewinddir : dir_handle -> unit

Переместить дескриптор в начало каталога

val closedir : dir_handle -> unit

Закрыть дескриптор каталога.

Каналы и перенаправления

val pipe : ?cloexec:bool -> unit -> file_descr * file_descr

Создать канал. Первый компонент результата открыт для чтения, это выходной канал. Второй компонент открыт для записи, это входной канал. См. Unix.set_close_on_exec для документации по необязательному аргументу cloexec.

val mkfifo : string -> file_perm -> unit

Создать именованный канал с заданными разрешениями (см. Unix.umask).

  • Raises Invalid_argument в Windows

Управление процессами и перенаправлениями высокого уровня

val create_process : string ->       string array -> file_descr -> file_descr -> file_descr -> int

create_process prog args stdin stdout stderr запускает новый процесс, который выполняет программу в файле prog, с аргументами args. ID нового процесса возвращается немедленно; новый процесс выполняется одновременно с текущим процессом. Стандартный ввод и выводы нового процесса подключены к дескрипторам stdin, stdout и stderr. Передача, например, Unix.stdout для stdout предотвращает перенаправление и заставляет новый процесс иметь такой же стандартный вывод, как и текущий процесс. Исполняемый файл prog ищется в пути. Новый процесс имеет такую же среду, как и текущий процесс.

val create_process_env : string ->       string array ->       string array -> file_descr -> file_descr -> file_descr -> int

create_process_env prog args env stdin stdout stderr работает как Unix.create_process, за исключением того, что дополнительный аргумент env указывает среду, переданную программе.

val open_process_in : string -> in_channel

Управление каналами и процессами высокого уровня. Эта функция выполняет заданную команду параллельно с программой. Стандартный вывод команды перенаправляется в канал, который можно читать с помощью возвращаемого входного канала. Команда интерпретируется оболочкой /bin/sh (или cmd.exe в Windows), см. Unix.system. Функцию Filename.quote_command можно использовать для цитирования команды и её аргументов в соответствии с оболочкой, используемой для их выполнения. Если нет необходимости запускать команду через оболочку, Unix.open_process_args_in можно использовать в качестве более надёжной и эффективной альтернативы Unix.open_process_in.

val open_process_out : string -> out_channel

То же, что и Unix.open_process_in, но перенаправляет стандартный ввод команды в канал. Данные, записанные в возвращаемый выходной канал, отправляются в стандартный ввод команды. Предупреждение: записи в выходные каналы буферизуются, поэтому будьте внимательны и вызывайте flush в нужные моменты, чтобы обеспечить правильную синхронизацию. Если нет необходимости запускать команду через оболочку, Unix.open_process_args_out можно использовать вместо Unix.open_process_out.

val open_process : string -> in_channel * out_channel

То же, что и Unix.open_process_out, но перенаправляет и стандартный ввод, и стандартный вывод команды в каналы, подключённые к двум возвращаемым каналам. Входной канал подключен к выводу команды, а выходной — к её вводу. Если нет необходимости запускать команду через оболочку, Unix.open_process_args можно использовать вместо Unix.open_process.

val open_process_full : string ->       string array -> in_channel * out_channel * in_channel

Аналогично Unix.open_process, но второй аргумент указывает на переданную команде среду. Результатом является тройка каналов, подключённых соответственно к стандартному выводу, стандартному вводу и стандартной ошибке команды. Если нет необходимости запускать команду через оболочку, Unix.open_process_args_full можно использовать вместо Unix.open_process_full.

val open_process_args_in : string -> string array -> in_channel

open_process_args_in prog args запускает программу prog с аргументами args. Новый процесс выполняется параллельно с текущим. Стандартный вывод нового процесса перенаправляется в канал, который можно читать через возвращаемый входной канал.

Исполняемый файл prog ищется в пути. Это поведение изменилось в версии 4.12; ранее prog искался только в текущем каталоге.

Новый процесс имеет ту же среду, что и текущий процесс.

  • Since 4.08.0
val open_process_args_out : string -> string array -> out_channel

То же, что и Unix.open_process_args_in, но перенаправляет стандартный ввод нового процесса в канал. Данные, записанные в возвращаемый выходной канал, отправляются в стандартный ввод программы. Предупреждение: записи в выходные каналы буферизуются, поэтому будьте внимательны и вызывайте flush в нужные моменты, чтобы обеспечить правильную синхронизацию.

  • Since 4.08.0
val open_process_args : string -> string array -> in_channel * out_channel

То же, что и Unix.open_process_args_out, но перенаправляет и стандартный ввод, и стандартный вывод нового процесса в каналы, подключённые к двум возвращаемым каналам. Входной канал подключен к выводу программы, а выходной — к её вводу.

  • Since 4.08.0
val open_process_args_full : string ->       string array ->       string array -> in_channel * out_channel * in_channel

Аналогично Unix.open_process_args, но третий аргумент указывает на среду, переданную новому процессу. Результатом является тройка каналов, подключённых соответственно к стандартному выводу, стандартному вводу и стандартной ошибке программы.

  • Since 4.08.0
val process_in_pid : in_channel -> int

Возвращает pid процесса, открытого с помощью Unix.open_process_in или Unix.open_process_args_in.

  • Since 4.08.0 (4.12.0 в UnixLabels)
val process_out_pid : out_channel -> int

Возвращает pid процесса, открытого с помощью Unix.open_process_out или Unix.open_process_args_out.

  • Since 4.08.0 (4.12.0 в UnixLabels)
val process_pid : in_channel * out_channel -> int

Возвращает pid процесса, открытого с помощью Unix.open_process или Unix.open_process_args.

  • Since 4.08.0 (4.12.0 в UnixLabels)
val process_full_pid : in_channel * out_channel * in_channel -> int

Возвращает pid процесса, открытого с помощью Unix.open_process_full или Unix.open_process_args_full.

  • Since 4.08.0 (4.12.0 в UnixLabels)
val close_process_in : in_channel -> process_status

Закрывает каналы, открытые с помощью Unix.open_process_in, ждёт завершения связанной команды и возвращает её код завершения.

val close_process_out : out_channel -> process_status

Закрывает каналы, открытые с помощью Unix.open_process_out, ждёт завершения связанной команды и возвращает её код завершения.

val close_process : in_channel * out_channel -> process_status

Закрывает каналы, открытые с помощью Unix.open_process, ждёт завершения связанной команды и возвращает её код завершения.

val close_process_full : in_channel * out_channel * in_channel ->       process_status

Закрывает каналы, открытые с помощью Unix.open_process_full, ждёт завершения связанной команды и возвращает её код завершения.

Символические ссылки

val symlink : ?to_dir:bool -> string -> string -> unit

symlink ?to_dir src dst создаёт файл dst как символическую ссылку на файл src. В Windows, to_dir указывает, ссылается ли символическая ссылка на каталог или файл; если опущено, symlink проверяет src с помощью stat и выбирает соответствующий вариант, если src не существует, то подразумевается false (по этой причине рекомендуется указывать параметр to_dir в новом коде). В Unix параметр to_dir игнорируется.

Символические ссылки в Windows доступны начиная с Windows Vista. Существуют некоторые важные различия между символическими ссылками в Windows и их POSIX аналогами.

Символические ссылки в Windows бывают двух типов: каталоги и обычные, которые обозначают, ссылается ли символическая ссылка на каталог или файл. Тип ссылки должен быть корректным — символическая ссылка на каталог, которая фактически ссылается на файл, не может быть выбрана с помощью chdir, а символическая ссылка на файл, которая фактически ссылается на каталог, не может быть прочитана или записана (обратите внимание, что эмуляционная среда Cygwin игнорирует это различие).

Когда символические ссылки создаются для существующих целей, это различие не имеет значения и symlink автоматически создаст правильный тип символической ссылки. Различие имеет значение, когда символическая ссылка создаётся для несуществующей цели.

Ещё одно ограничение заключается в том, что по умолчанию создание символических ссылок требует привилегий. Администраторы всегда должны запускаться с повышенными привилегиями (или с отключённым UAC), а обычные учётные записи пользователей по умолчанию должны получить привилегию SeCreateSymbolicLinkPrivilege через локальную политику безопасности (secpol.msc) или через Active Directory.

Unix.has_symlink можно использовать для проверки возможности создания символических ссылок процессом.

val has_symlink : unit -> bool

Возвращает true если пользователь может создавать символические ссылки. В Windows это означает, что пользователь не только имеет привилегию SeCreateSymbolicLinkPrivilege, но и работает с повышенными привилегиями, если это необходимо. На других платформах это просто означает, что вызов symlink доступен.

  • Since 4.03.0
val readlink : string -> string

Прочитать содержимое символической ссылки.

Опрос

val select : file_descr list ->       file_descr list ->       file_descr list ->       float -> file_descr list * file_descr list * file_descr list

Дождаться, пока операции ввода-вывода станут возможными в некоторых каналах. Три списка аргументов соответственно содержат дескрипторы для проверки на чтение (первый аргумент), на запись (второй аргумент) или на исключительные условия (третий аргумент). Четвёртый аргумент — максимальное время ожидания в секундах; отрицательный четвёртый аргумент означает отсутствие таймаута (неограниченное ожидание). Результатом является три набора дескрипторов: готовые к чтению (первый компонент), готовые к записи (второй компонент) и те, для которых ожидается исключительное условие (третий компонент).

Блокировка

type lock_command = 
| F_ULOCK (*

Разблокировать область

*)
| F_LOCK (*

Заблокировать область для записи и заблокировать, если она уже заблокирована

*)
| F_TLOCK (*

Заблокировать область для записи или вернуть ошибку, если она уже заблокирована

*)
| F_TEST (*

Проверить область на наличие блокировок других процессов

*)
| F_RLOCK (*

Заблокировать область для чтения и заблокировать, если она уже заблокирована

*)
| F_TRLOCK (*

Заблокировать область для чтения или вернуть ошибку, если она уже заблокирована

*)

Команды для Unix.lockf.

val lockf : file_descr -> lock_command -> int -> unit

lockf fd mode len устанавливает блокировку на область файла, открытого как fd. Область начинается с текущей позиции чтения/записи для fd (как установлено Unix.lseek), и расширяется на len байт вперед, если len положительно, на len байт назад, если len отрицательно, или до конца файла, если len равно нулю. Блокировка на запись предотвращает приобретение другим процессом блокировки на чтение или запись в данной области. Блокировка на чтение предотвращает приобретение другим процессом блокировки на запись в данной области, но позволяет другим процессам приобретать блокировки на чтение.

Команды F_LOCK и F_RLOCK пытаются установить блокировку на запись в указанной области. Команды F_TLOCK и F_TRLOCK пытаются установить блокировку на чтение в указанной области. Если одна или несколько блокировок, установленных другим процессом, препятствуют приобретению блокировки текущим процессом, F_LOCK и F_RLOCK ожидают, пока эти блокировки не будут сняты, в то время как F_TLOCK и F_TRLOCK немедленно завершаются с исключением. Команда F_ULOCK удаляет все блокировки, установленные текущим процессом в указанной области. Наконец, команда F_TEST проверяет, может ли быть приобретена блокировка на запись в указанной области, не устанавливая фактически блокировку. Она возвращает результат немедленно, если это возможно, или завершается ошибкой в противном случае.

Что произойдет, когда процесс попытается заблокировать область файла, которая уже заблокирована тем же процессом, зависит от ОС. В POSIX-совместимых системах вторая операция блокировки выполняется успешно и может «повысить» старую блокировку с чтения до записи. В Windows вторая операция блокировки будет заблокирована или завершится ошибкой.

Сигналы

Примечание: установка обработчиков сигналов выполняется с помощью функций Sys.signal и Sys.set_signal.

val kill : int -> int -> unit

kill pid signal отправляет сигнал с номером signal процессу с id pid.

В Windows: эмулируется только сигнал Sys.sigkill.

type sigprocmask_command = 
| SIG_SETMASK
| SIG_BLOCK
| SIG_UNBLOCK
val sigprocmask : sigprocmask_command -> int list -> int list

sigprocmask mode sigs изменяет набор заблокированных сигналов. Если mode равно SIG_SETMASK, заблокированные сигналы устанавливаются на те, которые указаны в списке sigs. Если mode равно SIG_BLOCK, сигналы в sigs добавляются к набору заблокированных сигналов. Если mode равно SIG_UNBLOCK, сигналы в sigs удаляются из набора заблокированных сигналов. sigprocmask возвращает набор ранее заблокированных сигналов.

При загрузке модуля Thread версии systhreads эта функция перенаправляется на Thread.sigmask. Т.е., sigprocmask изменяет только маску текущего потока.

  • Возбуждает Invalid_argument в Windows (межпроцессных сигналов в Windows нет)
val sigpending : unit -> int list

Возвращает набор заблокированных сигналов, которые в настоящее время ожидают обработки.

  • Возбуждает Invalid_argument в Windows (межпроцессных сигналов в Windows нет)
val sigsuspend : int list -> unit

sigsuspend sigs атомарно устанавливает заблокированные сигналы на sigs и ожидает, пока не будет доставлен неигнорируемый, незаблокированный сигнал. При возвращении заблокированные сигналы сбрасываются до их начального значения.

  • Возбуждает Invalid_argument в Windows (межпроцессных сигналов в Windows нет)
val pause : unit -> unit

Ожидать, пока не будет доставлен неигнорируемый, незаблокированный сигнал.

  • Возбуждает Invalid_argument в Windows (межпроцессных сигналов в Windows нет)

Функции времени

type process_times = {
tms_utime : float; (*

Время пользователя для процесса

*)
tms_stime : float; (*

Время системы для процесса

*)
tms_cutime : float; (*

Время пользователя для дочерних процессов

*)
tms_cstime : float; (*

Время системы для дочерних процессов

*)
}

Времена выполнения (времена процессора) процесса.

type tm = {
tm_sec : int; (*

Секунды 0..60

*)
tm_min : int; (*

Минуты 0..59

*)
tm_hour : int; (*

Часы 0..23

*)
tm_mday : int; (*

День месяца 1..31

*)
tm_mon : int; (*

Месяц года 0..11

*)
tm_year : int; (*

Год - 1900

*)
tm_wday : int; (*

День недели (воскресенье - 0)

*)
tm_yday : int; (*

День года 0..365

*)
tm_isdst : bool; (*

Действует летнее время

*)
}

Тип, представляющий время по часам и календарную дату.

val time : unit -> float

Возвращает текущее время с 00:00:00 по Гринвичу, 1 января 1970 г., в секундах.

val gettimeofday : unit -> float

То же, что и Unix.time, но с разрешением лучше, чем 1 секунда.

val gmtime : float -> tm

Преобразует время в секундах, возвращённое функцией Unix.time, в дату и время. Предполагается UTC (Координированное универсальное время), также известное как GMT. Для выполнения обратного преобразования установите переменную среды TZ в «UTC», используйте Unix.mktime, а затем восстановите исходное значение TZ.

val localtime : float -> tm

Преобразует время в секундах, возвращённое функцией Unix.time, в дату и время. Предполагается местное часовое пояс. Функция, выполняющая обратное преобразование, — Unix.mktime.

val mktime : tm -> float * tm

Преобразует дату и время, заданные аргументом tm, во время в секундах, возвращённое функцией Unix.time. Поля tm_isdst, tm_wday и tm_yday структуры tm игнорируются. Также возвращается нормализованная копия заданной записи tm, с пересчитанными полями tm_wday, tm_yday и tm_isdst из других полей и нормализованными другими полями (например, 40 октября изменяется на 9 ноября). Аргумент tm интерпретируется в местном часовом поясе.

val alarm : int -> int

Планирует сигнал SIGALRM через заданное количество секунд.

  • Возбуждает Invalid_argument в Windows
val sleep : int -> unit

Приостановить выполнение на заданное количество секунд.

val sleepf : float -> unit

Приостановить выполнение на заданное количество секунд. Похоже на sleep, но поддерживаются доли секунд.

  • С тех пор как 4.03.0 (4.12.0 в UnixLabels)
val times : unit -> process_times

Возвращает время выполнения процесса.

В Windows: частично реализовано, не будет сообщать о времени выполнения дочерних процессов.

val utimes : string -> float -> float -> unit

Установить время последнего доступа (второй аргумент) и время последней модификации (третий аргумент) для файла. Время выражается в секундах с 00:00:00 по Гринвичу, 1 января 1970 года. Если оба времени 0.0, время доступа и последней модификации устанавливаются на текущее время.

type interval_timer = 
| ITIMER_REAL (*

уменьшается в реальном времени и отправляет сигнал SIGALRM при истечении срока действия.

*)
| ITIMER_VIRTUAL (*

уменьшается в виртуальном времени процесса и отправляет SIGVTALRM при истечении срока действия.

*)
| ITIMER_PROF (*

(для профилирования) уменьшается как во время выполнения процесса, так и во время выполнения системы от имени процесса; отправляет SIGPROF при истечении срока действия.

*)

Три вида таймеров интервалов.

type interval_timer_status = {
it_interval : float; (*

Период

*)
it_value : float; (*

Текущее значение таймера

*)
}

Тип, описывающий состояние таймера интервалов

val getitimer : interval_timer -> interval_timer_status

Возвращает текущее состояние заданного таймера интервалов.

  • Возбуждает Invalid_argument в Windows
val setitimer : interval_timer ->       interval_timer_status -> interval_timer_status

setitimer t s устанавливает таймер интервалов t и возвращает его предыдущее состояние. Аргумент s интерпретируется следующим образом: s.it_value, если не равно нулю, — время до следующего истечения таймера; s.it_interval, если не равно нулю, — значение, используемое для перезагрузки it_value при истечении таймера. Установка s.it_value в ноль отключает таймер. Установка s.it_interval в ноль приводит к отключению таймера после его следующего истечения.

  • Возбуждает Invalid_argument в Windows

Идентификатор пользователя, идентификатор группы

val getuid : unit -> int

Возвращает идентификатор пользователя, выполняющего процесс.

В Windows: всегда возвращает 1.

val geteuid : unit -> int

Возвращает эффективного идентификатор пользователя, под которым работает процесс.

В Windows: всегда возвращает 1.

val setuid : int -> unit

Установить реальный идентификатор пользователя и эффективный идентификатор пользователя для процесса.

  • Возбуждает Invalid_argument в Windows
val getgid : unit -> int

Возвращает идентификатор группы пользователя, выполняющего процесс.

В Windows: всегда возвращает 1.

val getegid : unit -> int

Возвращает эффективную группу, под которой выполняется процесс.

В Windows: всегда возвращает 1.

val setgid : int -> unit

Устанавливает реальный и эффективный идентификаторы группы для процесса.

  • Возбуждает Invalid_argument в Windows
val getgroups : unit -> int array

Возвращает список групп, к которым принадлежит пользователь, выполняющий процесс.

В Windows: всегда возвращает [|1|].

val setgroups : int array -> unit

setgroups groups устанавливает дополнительные идентификаторы групп для вызывающего процесса. Требуются соответствующие привилегии.

  • Возбуждает Invalid_argument в Windows
val initgroups : string -> int -> unit

initgroups user group инициализирует список доступа к группам, считывая базу данных групп /etc/group и используя все группы, членами которых является user. Дополнительная группа group также добавляется в список.

  • Возбуждает Invalid_argument в Windows
type passwd_entry = {
pw_name : string;
pw_passwd : string;
pw_uid : int;
pw_gid : int;
pw_gecos : string;
pw_dir : string;
pw_shell : string;
}

Структура записей в базе данных passwd.

type group_entry = {
gr_name : string;
gr_passwd : string;
gr_gid : int;
gr_mem : string array;
}

Структура записей в базе данных groups.

val getlogin : unit -> string

Возвращает имя пользователя, выполняющего процесс.

val getpwnam : string -> passwd_entry

Найти запись в passwd с заданным именем.

  • Возбуждает Not_found если такая запись не существует, или всегда в Windows.
val getgrnam : string -> group_entry

Найти запись в group с заданным именем.

  • Возбуждает Not_found если такая запись не существует, или всегда в Windows.
val getpwuid : int -> passwd_entry

Найти запись в passwd с заданным идентификатором пользователя.

  • Возбуждает Not_found если такая запись не существует, или всегда в Windows.
val getgrgid : int -> group_entry

Найти запись в group с заданным идентификатором группы.

  • Возбуждает Not_found если такая запись не существует, или всегда в Windows.

Интернет-адреса

type inet_addr 

Абстрактный тип интернет-адресов.

val inet_addr_of_string : string -> inet_addr

Преобразование из печатного представления интернет-адреса в его внутреннее представление. Строка-аргумент состоит из 4 чисел, разделенных точками (XXX.YYY.ZZZ.TTT) для IPv4-адресов и до 8 чисел, разделенных двоеточиями, для IPv6-адресов.

  • Возбуждает Failure при получении строки, не соответствующей этим форматам.
val string_of_inet_addr : inet_addr -> string

Возвращает печатное представление данного интернет-адреса. См. Unix.inet_addr_of_string для описания печатного представления.

val inet_addr_any : inet_addr

Специальный IPv4-адрес, предназначенный только для использования с bind, представляющий все интернет-адреса, которыми обладает хост-машина.

val inet_addr_loopback : inet_addr

Специальный IPv4-адрес, представляющий хост-машину (127.0.0.1).

val inet6_addr_any : inet_addr

Является ли данный inet_addr IPv6-адресом.

  • Since 4.12.0

Сокеты

type socket_domain = 
| PF_UNIX (*

Домен Unix

*)
| PF_INET (*

Домен Интернета (IPv4)

*)
| PF_INET6 (*

Домен Интернета (IPv6)

*)

Тип доменов сокетов. Не все платформы поддерживают IPv6-сокеты (тип PF_INET6).

В Windows: PF_UNIX поддерживается с версии 4.14.0 на Windows 10 1803 и более поздних версиях.

type socket_type = 
| SOCK_STREAM (*

Потоковый сокет

*)
| SOCK_DGRAM (*

Сокет дейтаграмм

*)
| SOCK_RAW (*

Сокет «сырой»

*)
| SOCK_SEQPACKET (*

Сокет упорядоченных пакетов

*)

Тип видов сокетов, определяющий семантику связи. SOCK_SEQPACKET включён для полноты, но редко поддерживается ОС и требует системных вызовов, недоступных в этой библиотеке.

type sockaddr = 
| ADDR_UNIX of string
| ADDR_INET of inet_addr * int

Тип адресов сокетов. ADDR_UNIX name — адрес сокета в домене Unix; name — имя файла в файловой системе. ADDR_INET(addr,port) — адрес сокета в интернет-домене; addr — интернет-адрес машины, а port — номер порта.

val socket : ?cloexec:bool ->       socket_domain -> socket_type -> int -> file_descr

Создать новый сокет в заданном домене и с заданным типом. Третий аргумент — тип протокола; 0 выбирает протокол по умолчанию для этого типа сокетов. См. Unix.set_close_on_exec для документации по необязательному аргументу cloexec.

val domain_of_sockaddr : sockaddr -> socket_domain

Возвращает домен сокета, соответствующий данному адресу сокета.

val socketpair : ?cloexec:bool ->       socket_domain ->       socket_type -> int -> file_descr * file_descr

Создайте пару сокетов без имени, соединённых между собой. См. Unix.set_close_on_exec для документации по необязательному аргументу cloexec.

  • Возбуждает Invalid_argument в Windows
val accept : ?cloexec:bool -> file_descr -> file_descr * sockaddr

Принимайте соединения на заданном сокете. Возвращаемый дескриптор — это сокет, подключённый к клиенту; возвращаемый адрес — это адрес подключающегося клиента. См. Unix.set_close_on_exec для документации по необязательному аргументу cloexec.

val bind : file_descr -> sockaddr -> unit

Привяжите сокет к адресу.

val connect : file_descr -> sockaddr -> unit

Подключите сокет к адресу.

val listen : file_descr -> int -> unit

Настройте сокет для получения запросов на подключение. Целое число — это максимальное количество ожидающих запросов.

type shutdown_command = 
| SHUTDOWN_RECEIVE (*

Закрытие для приема

*)
| SHUTDOWN_SEND (*

Закрытие для отправки

*)
| SHUTDOWN_ALL (*

Закрытие обоих

*)

Тип команд для shutdown.

val shutdown : file_descr -> shutdown_command -> unit

Закрытие подключения сокета. SHUTDOWN_SEND в качестве второго аргумента приводит к тому, что чтения на другом конце подключения возвращают состояние конца файла. SHUTDOWN_RECEIVE приводит к тому, что записи на другом конце подключения возвращают состояние закрытой трубы (сигнал SIGPIPE).

val getsockname : file_descr -> sockaddr

Возвращает адрес данного сокета.

val getpeername : file_descr -> sockaddr

Возвращает адрес хоста, подключённого к данному сокету.

type msg_flag = 
| MSG_OOB
| MSG_DONTROUTE
| MSG_PEEK

Флаги для Unix.recv, Unix.recvfrom, Unix.send и Unix.sendto.

val recv : file_descr -> bytes -> int -> int -> msg_flag list -> int

Получение данных от подключённого сокета.

val recvfrom : file_descr ->       bytes -> int -> int -> msg_flag list -> int * sockaddr

Получение данных от неподключённого сокета.

val send : file_descr -> bytes -> int -> int -> msg_flag list -> int

Отправка данных по подключённому сокету.

val send_substring : file_descr -> string -> int -> int -> msg_flag list -> int

То же, что и send, но данные берутся из строки вместо последовательности байтов.

  • Since 4.02.0
val sendto : file_descr ->       bytes -> int -> int -> msg_flag list -> sockaddr -> int

Отправка данных по неподключённому сокету.

val sendto_substring : file_descr ->       string -> int -> int -> msg_flag list -> sockaddr -> int

То же, что и sendto, но данные берутся из строки вместо последовательности байтов.

  • Since 4.02.0

Параметры сокета

type socket_bool_option = 
| SO_DEBUG (*

Запись отладочной информации

*)
| SO_BROADCAST (*

Разрешение отправки широковещательных сообщений

*)
| SO_REUSEADDR (*

Разрешение повторного использования локальных адресов для привязки

*)
| SO_KEEPALIVE (*

Поддержание активного подключения

*)
| SO_DONTROUTE (*

Обход стандартных алгоритмов маршрутизации

*)
| SO_OOBINLINE (*

Оставить данные вне очереди в строке

*)
| SO_ACCEPTCONN (*

Сообщить, включено ли прослушивание сокета

*)
| TCP_NODELAY (*

Управление алгоритмом Nagle для сокетов TCP

*)
| IPV6_ONLY (*

Запретить привязку IPv6-сокета к IPv4-адресу

*)
| SO_REUSEPORT (*

Разрешить повторное использование привязок адреса и порта

*)

Параметры сокета, которые можно проконсультировать с помощью Unix.getsockopt и изменить с помощью Unix.setsockopt. Эти параметры имеют булево значение (true/false).

type socket_int_option = 
| SO_SNDBUF (*

Размер буфера отправки

*)
| SO_RCVBUF (*

Размер буфера приема

*)
| SO_ERROR (*

Устарело. Используйте Unix.getsockopt_error вместо этого.

*)
| SO_TYPE (*

Отчет о типе сокета

*)
| SO_RCVLOWAT (*

Минимальное количество байтов для обработки входных операций

*)
| SO_SNDLOWAT (*

Минимальное количество байтов для обработки выходных операций

*)

Параметры сокета, которые можно просмотреть с помощью Unix.getsockopt_int и изменить с помощью Unix.setsockopt_int. Эти параметры имеют целое значение.

type socket_optint_option = 
| SO_LINGER (*

Задержка при закрытии соединений, имеющих данные (в секундах)

*)

Параметры сокета, которые можно просмотреть с помощью Unix.getsockopt_optint и изменить с помощью Unix.setsockopt_optint. Эти параметры имеют значение типа int option, где None означает «выключено».

type socket_float_option = 
| SO_RCVTIMEO (*

Таймаут для входных операций

*)
| SO_SNDTIMEO (*

Таймаут для выходных операций

*)

Параметры сокета, которые можно просмотреть с помощью Unix.getsockopt_float и изменить с помощью Unix.setsockopt_float. Эти параметры имеют значение с плавающей точкой, представляющее время в секундах. Значение 0 означает бесконечный таймаут.

val getsockopt : file_descr -> socket_bool_option -> bool

Возвращает текущее состояние булевого параметра заданного сокета.

val setsockopt : file_descr -> socket_bool_option -> bool -> unit

Устанавливает или сбрасывает булевый параметр заданного сокета.

val getsockopt_int : file_descr -> socket_int_option -> int

То же, что и Unix.getsockopt для целочисленного параметра сокета.

val setsockopt_int : file_descr -> socket_int_option -> int -> unit

То же, что и Unix.setsockopt для целочисленного параметра сокета.

val getsockopt_optint : file_descr -> socket_optint_option -> int option

То же, что и Unix.getsockopt для параметра сокета, значение которого является int option.

val setsockopt_optint : file_descr -> socket_optint_option -> int option -> unit

То же, что и Unix.setsockopt для параметра сокета, значение которого является int option.

val getsockopt_float : file_descr -> socket_float_option -> float

То же, что и Unix.getsockopt для параметра сокета, значение которого является числом с плавающей точкой.

val setsockopt_float : file_descr -> socket_float_option -> float -> unit

То же, что и Unix.setsockopt для параметра сокета, значение которого является числом с плавающей точкой.

val getsockopt_error : file_descr -> error option

Возвращает условие ошибки, связанное с данным сокетом, и очищает его.

Функции высокоуровневого подключения к сети

val open_connection : sockaddr -> in_channel * out_channel

Подключение к серверу по заданному адресу. Возвращает пару буферизованных каналов, подключенных к серверу. Не забудьте вызвать flush на канале вывода в нужные моменты для обеспечения правильной синхронизации.

Два канала, возвращенные функцией open_connection, используют один дескриптор сокета. Поэтому при завершении соединения необходимо вызвать close_out на канале вывода, что также закроет сокет. Не вызывайте close_in на канале ввода; он будет собран сборщиком мусора.

val shutdown_connection : in_channel -> unit

«Завершение» соединения, установленного с помощью Unix.open_connection; т. е. передача условия конца файла серверу, читающему на другом конце соединения. Это не закрывает сокет и каналы, используемые соединением. См. Unix.open_connection, как их закрыть после завершения соединения.

val establish_server : (in_channel -> out_channel -> unit) -> sockaddr -> unit

Устанавливает сервер по заданному адресу. Переданная как первый аргумент функция вызывается для каждого подключения с двумя буферизованными каналами, подключенными к клиенту. Для каждого подключения создается новый процесс. Функция Unix.establish_server никогда не возвращается нормально.

Два канала, передаваемые функции, используют один дескриптор сокета. Функции не нужно закрывать каналы, так как это происходит автоматически при возвращении функции. Если функция предпочитает явное закрытие, она должна закрыть канал вывода с помощью close_out и оставить канал ввода не закрытым по причинам, объясненным в Unix.in_channel_of_descr.

  • Возбуждает Invalid_argument в Windows. Используйте потоки вместо этого.

Базы данных хостов и протоколов

type host_entry = {
h_name : string;
h_aliases : string array;
h_addrtype : socket_domain;
h_addr_list : inet_addr array;
}

Структура записей в базе данных hosts.

type protocol_entry = {
p_name : string;
p_aliases : string array;
p_proto : int;
}

Структура записей в базе данных protocols.

type service_entry = {
s_name : string;
s_aliases : string array;
s_port : int;
s_proto : string;
}

Структура записей в базе данных services.

val gethostname : unit -> string

Возвращает имя локального хоста.

val gethostbyname : string -> host_entry

Найдите запись в hosts с заданным именем.

  • Raises Not_found если такая запись не существует.
val gethostbyaddr : inet_addr -> host_entry

Найдите запись в hosts по заданному адресу.

  • Raises Not_found если такая запись не существует.
val getprotobyname : string -> protocol_entry

Найдите запись в protocols по заданному имени.

  • Raises Not_found если такая запись не существует.
val getprotobynumber : int -> protocol_entry

Найдите запись в protocols по заданному номеру протокола.

  • Raises Not_found если такая запись не существует.
val getservbyname : string -> string -> service_entry

Найдите запись в services по заданному имени.

  • Raises Not_found если такая запись не существует.
val getservbyport : int -> string -> service_entry

Найдите запись в services по заданному номеру службы.

  • Raises Not_found если такая запись не существует.
type addr_info = {
ai_family : socket_domain; (*

Домен сокета

*)
ai_socktype : socket_type; (*

Тип сокета

*)
ai_protocol : int; (*

Номер протокола сокета

*)
ai_addr : sockaddr; (*

Адрес

*)
ai_canonname : string; (*

Каноническое имя хоста

*)
}

Информация об адресе, возвращаемая функцией Unix.getaddrinfo.

type getaddrinfo_option = 
| AI_FAMILY of socket_domain (*

Установить заданный домен сокета

*)
| AI_SOCKTYPE of socket_type (*

Установить заданный тип сокета

*)
| AI_PROTOCOL of int (*

Установить заданный протокол

*)
| AI_NUMERICHOST (*

Не вызывать разрешитель имен, ожидать числовой IP-адрес

*)
| AI_CANONNAME (*

Заполнить поле ai_canonname результата

*)
| AI_PASSIVE (*

Установить адрес на адрес ``любой'' для использования с Unix.bind

*)

Параметры для Unix.getaddrinfo.

val getaddrinfo : string -> string -> getaddrinfo_option list -> addr_info list

getaddrinfo host service opts возвращает список записей Unix.addr_info, описывающих параметры сокета и адреса, подходящие для связи с данным хостом и службой. Пустой список возвращается, если имена хоста или службы неизвестны, или ограничения, выраженные в opts, не могут быть выполнены.

host — это имя хоста или строковое представление IP-адреса. host может быть задано как пустая строка; в этом случае используется адрес ``любой'' или адрес ``обратной петли'', в зависимости от того, содержит ли opts AI_PASSIVE. service — это имя службы или строковое представление номера порта. service может быть задано как пустая строка; в этом случае поле порта возвращаемых адресов устанавливается в 0. opts — это, возможно, пустой список параметров, который позволяет вызывающей стороне принудительно использовать определённый домен сокета (например, только IPv6 или только IPv4) или определённый тип сокета (например, только TCP или только UDP).

type name_info = {
ni_hostname : string; (*

Имя или IP-адрес хоста

*)
ni_service : string; (*

Имя службы или номер порта

*)
}

Информация о хосте и службе, возвращаемая функцией Unix.getnameinfo.

type getnameinfo_option = 
| NI_NOFQDN (*

Не квалифицировать имена локальных хостов

*)
| NI_NUMERICHOST (*

Всегда возвращать хост в виде IP-адреса

*)
| NI_NAMEREQD (*

Прекратить выполнение, если имя хоста невозможно определить

*)
| NI_NUMERICSERV (*

Всегда возвращать службу в виде номера порта

*)
| NI_DGRAM (*

Рассматривать службу как основанную на UDP вместо стандартного TCP

*)

Опции для Unix.getnameinfo.

val getnameinfo : sockaddr -> getnameinfo_option list -> name_info

getnameinfo addr opts возвращает имя хоста и имя службы, соответствующие адресу сокета addr. opts — это, возможно, пустой список опций, определяющий способ получения этих имён.

  • Raises Not_found если произошла ошибка.

Интерфейс терминала

Следующие функции реализуют стандарт POSIX для интерфейса терминала. Они обеспечивают управление асинхронными коммуникационными портами и псевдотерминалами. Обратитесь к termios man-странице для полного описания.

type terminal_io = {
mutable c_ignbrk : bool; (*

Игнорировать условие прерывания.

*)
mutable c_brkint : bool; (*

Сигнализировать прерывание при условии прерывания.

*)
mutable c_ignpar : bool; (*

Игнорировать символы с ошибками чётности.

*)
mutable c_parmrk : bool; (*

Помечать ошибки чётности.

*)
mutable c_inpck : bool; (*

Включить проверку чётности на входе.

*)
mutable c_istrip : bool; (*

Удалять 8-й бит у входных символов.

*)
mutable c_inlcr : bool; (*

Преобразовывать NL в CR на входе.

*)
mutable c_igncr : bool; (*

Игнорировать CR на входе.

*)
mutable c_icrnl : bool; (*

Преобразовывать CR в NL на входе.

*)
mutable c_ixon : bool; (*

Распознавать символы XON/XOFF на входе.

*)
mutable c_ixoff : bool; (*

Выводить символы XON/XOFF для управления потоком ввода.

*)
mutable c_opost : bool; (*

Включить обработку вывода.

*)
mutable c_obaud : int; (*

Скорость передачи данных на выходе (0 означает закрытие соединения).

*)
mutable c_ibaud : int; (*

Скорость передачи данных на входе.

*)
mutable c_csize : int; (*

Количество бит на символ (5-8).

*)
mutable c_cstopb : int; (*

Количество стоповых бит (1-2).

*)
mutable c_cread : bool; (*

Включение приема.

*)
mutable c_parenb : bool; (*

Включить генерацию и детектирование чётности.

*)
mutable c_parodd : bool; (*

Указать нечётную чётность вместо чётной.

*)
mutable c_hupcl : bool; (*

Закрытие соединения после последнего закрытия.

*)
mutable c_clocal : bool; (*

Игнорировать линии статуса модема.

*)
mutable c_isig : bool; (*

Генерировать сигнал при событиях INTR, QUIT, SUSP.

*)
mutable c_icanon : bool; (*

Включить каноническую обработку (буферизацию строк и редактирование).

*)
mutable c_noflsh : bool; (*

Отключить сброс после INTR, QUIT, SUSP.

*)
mutable c_echo : bool; (*

Выводить входные символы.

*)
mutable c_echoe : bool; (*

Выводить ERASE (для стирания предыдущего символа).

*)
mutable c_echok : bool; (*

Эхо KILL (для удаления текущей строки).

*)
mutable c_echonl : bool; (*

Эхо NL даже если c_echo не задан.

*)
mutable c_vintr : char; (*

Символ прерывания (обычно Ctrl-C).

*)
mutable c_vquit : char; (*

Символ выхода (обычно Ctrl-\).

*)
mutable c_verase : char; (*

Символ стирания (обычно DEL или Ctrl-H).

*)
mutable c_vkill : char; (*

Символ удаления строки (обычно Ctrl-U).

*)
mutable c_veof : char; (*

Символ конца файла (обычно Ctrl-D).

*)
mutable c_veol : char; (*

Альтернативный символ конца строки (обычно отсутствует).

*)
mutable c_vmin : int; (*

Минимальное количество символов для чтения, прежде чем запрос чтения будет удовлетворён.

*)
mutable c_vtime : int; (*

Максимальное время ожидания чтения (в единицах 0,1 с).

*)
mutable c_vstart : char; (*

Символ начала (обычно Ctrl-Q).

*)
mutable c_vstop : char; (*

Символ остановки (обычно Ctrl-S).

*)
}
val tcgetattr : file_descr -> terminal_io

Возвращает состояние терминала, указанного заданным дескриптором файла.

  • Raises Invalid_argument на Windows
type setattr_when = 
| TCSANOW
| TCSADRAIN
| TCSAFLUSH
val tcsetattr : file_descr -> setattr_when -> terminal_io -> unit

Устанавливает состояние терминала, указанного заданным дескриптором файла. Второй аргумент указывает, когда происходит изменение состояния: немедленно (TCSANOW), когда весь ожидающий вывод был передан (TCSADRAIN) или после очистки всего входящего, но ещё не прочитанного ввода (TCSAFLUSH). Рекомендуется использовать TCSADRAIN, при изменении параметров вывода; TCSAFLUSH, при изменении параметров ввода.

  • Raises Invalid_argument на Windows
val tcsendbreak : file_descr -> int -> unit

Отправляет условие прерывания для данного дескриптора файла. Второй аргумент — продолжительность прерывания в единицах 0,1 с; 0 означает стандартную продолжительность (0,25 с).

  • Raises Invalid_argument на Windows
val tcdrain : file_descr -> unit

Ожидает, пока весь вывод, записанный в заданный дескриптор файла, не будет передан.

  • Raises Invalid_argument на Windows
type flush_queue = 
| TCIFLUSH
| TCOFLUSH
| TCIOFLUSH
val tcflush : file_descr -> flush_queue -> unit

Отбрасывает данные, записанные в заданный дескриптор файла, но ещё не переданные, или данные, полученные, но ещё не прочитанные, в зависимости от второго аргумента: TCIFLUSH очищает полученные, но не прочитанные данные, TCOFLUSH очищает данные, записанные, но не переданные, и TCIOFLUSH очищает оба вида данных.

  • Raises Invalid_argument на Windows
type flow_action = 
| TCOOFF
| TCOON
| TCIOFF
| TCION
val tcflow : file_descr -> flow_action -> unit

Приостанавливает или возобновляет приём или передачу данных по указанному дескриптору файла в зависимости от второго аргумента: TCOOFF приостанавливает вывод, TCOON возобновляет вывод, TCIOFF отправляет символ STOP для приостановки ввода, и TCION отправляет символ START для возобновления ввода.

  • Raises Invalid_argument на Windows
val setsid : unit -> int

Переводит вызывающий процесс в новую сессию и отсоединяет его от управляющего терминала.

  • Raises Invalid_argument на Windows

© 1995-2022 INRIA.
https://v2.ocaml.org/releases/4.14/htmlman/libref/Unix.html

Spec-Zone.ru

Настройки Оффлайн Что нового Помощь О нас
Spec-Zone .ru
спецификации, руководства, описания, API