lilalo

annotate l3-agent @ 31:196c82b6e538

find changesets by author, revision, files, or words in the commit message
l3-cgi:
* Сделана поддержка кодировок клиента отличных от utf-8 (пока что почему-то не работает)
* Сделана поддержка комментирования из самой командной строки.
Комментарии вставлюятся с помощью символов #^, #v или #=
Комментарии записываются в элементы note и note_title

l3-frontend:

* Сделана поддержка комментирования из самой командной строки.
Комментарии вставлюятся с помощью символов #^, #v или #=
* Вместо использования программы mywi-client, обращение к mywi-серверу выполняется самостоятельно
* Выполняется разбор команды с целью выявления новых команд, ведения статистики, генерирования подсказок и т.д.
* Во всплывающих командах к подсказкам выводится информация от mywi
* Выводится статистическая информация о журнале
"Время первой команды журнала"
"Время последней команды журнала"
"Количество командных строк в журнале"
"Процент команд с кодом ненулевым кодом завершения, %"
"Суммарное время работы с терминалом <sup><font size='-2'>*</font></sup>, час"
"Количество командных строк в единицу времени, команда/мин"
"Частота использования команд"
"Частота использования команд"
"Частота использования этих команд < 0.5%"
* В заголовке страницы выводится информация о курсе и имя слушателя
* Расшифровка к информации о курсе выводится только если есть сама информация
* В оглавлении учитваются пометки notes, вставленные с помощью #=
* Добавлена справка по использованию журнала

Новые параметры:
show_notes - нужно ли показывать заметки "notes"
> note_width - ширина заметок "notes"
mywi_server - IP-адрес сервера mywi
mywi_port - порт сервера mywi
stat_inactivity_interval - при подсчёте времени работы с терминалом,
интервалы превышающие какую длительность не должны учитываться, сек
author devi
date Fri Nov 11 21:29:49 2005 +0200 (2005-11-11)
parents f5f07049bd4f
children 4d252e7dd478
rev   line source
devi@23 1 #!/usr/bin/perl -w
devi@23 2
devi@23 3 #
devi@23 4 # (c) Igor Chubin, imchubin@mail.ru, 2004-2005
devi@23 5 #
devi@23 6
devi@23 7 use strict;
devi@25 8 use POSIX;
devi@23 9 use Term::VT102;
devi@23 10 use Text::Iconv;
devi@23 11 use Data::Dumper;
devi@23 12 use Time::Local 'timelocal_nocheck';
devi@27 13 use IO::Socket;
devi@23 14
devi@23 15 use lib ".";
devi@23 16 use l3config;
devi@23 17
devi@23 18
devi@23 19 our @Command_Lines;
devi@23 20 our @Command_Lines_Index;
devi@28 21 our %Diffs;
devi@27 22 our %Sessions;
devi@23 23
devi@23 24 our %Commands_Stat; # Statistics about commands usage
devi@23 25 our %Files_Stat; # Statistics about commands usage
devi@23 26
devi@25 27 our %Script_Files; # Информация о позициях в скрипт-файлах,
devi@25 28 # до которых уже выполнен разбор
devi@25 29 # и информация о времени модификации файла
devi@25 30 # $Script_Files{$file}->{size}
devi@25 31 # $Script_Files{$file}->{tell}
devi@25 32
devi@25 33 our $Killed =0; # В режиме демона -- процесс получил сигнал о завершении
devi@23 34
devi@23 35 sub init_variables;
devi@23 36 sub main;
devi@23 37
devi@23 38 sub load_diff_files;
devi@23 39 sub bind_diff;
devi@23 40 sub extract_from_cline;
devi@23 41 sub load_command_lines;
devi@23 42 sub sort_command_lines;
devi@23 43 sub process_command_lines;
devi@23 44 sub print_command_lines;
devi@23 45 sub printq;
devi@23 46
devi@25 47 sub save_cache_stat;
devi@25 48 sub load_cache_stat;
devi@27 49 sub print_session;
devi@25 50
devi@23 51 sub load_diff_files
devi@23 52 {
devi@23 53 my @pathes = @_;
devi@23 54
devi@23 55 for my $path (@pathes) {
devi@23 56 my $template = "*.diff";
devi@23 57 my @files = <$path/$template>;
devi@23 58 my $i=0;
devi@23 59 for my $file (@files) {
devi@28 60
devi@28 61 next if defined($Diffs{$file});
devi@28 62
devi@23 63 my %diff;
devi@23 64
devi@23 65 $diff{"path"}=$path;
devi@23 66 $diff{"uid"}="SET THIS";
devi@23 67
devi@23 68 # Сейчас UID определяется из названия каталога
devi@23 69 # откуда берутся diff-файлы
devi@23 70 # Это неправильно
devi@23 71 #
devi@23 72 # ВАРИАНТ:
devi@23 73 # К файлам жураналам должны прилагаться ситемны файлы,
devi@23 74 # мз которых и будет определяться соответствие
devi@23 75 # имён пользователей их uid'ам
devi@23 76 #
devi@23 77 $diff{"uid"} = 0 if $path =~ m@/root/@;
devi@23 78
devi@23 79 $diff{"bind_to"}="";
devi@23 80 $diff{"time_range"}=-1;
devi@23 81
devi@23 82 next if not $file=~m@/(D?[0-9][0-9]?[0-9]?)[^/]*?([0-9]*):([0-9]*):?([0-9]*)@;
devi@23 83 $diff{"day"}=$1 || "";
devi@23 84 $diff{"hour"}=$2;
devi@23 85 $diff{"min"}=$3;
devi@23 86 $diff{"sec"}=$4 || 0;
devi@23 87
devi@23 88 $diff{"index"}=$i;
devi@23 89
devi@23 90 print "diff loaded: $diff{day} $diff{hour}:$diff{min}:$diff{sec}\n";
devi@23 91
devi@23 92 local $/;
devi@23 93 open (F, "$file")
devi@23 94 or return "Can't open file $file ($_[0]) for reading";
devi@23 95 my $text = <F>;
devi@23 96 if ($Config{"encoding"} && $Config{"encoding"} !~ /^utf-8$/i) {
devi@23 97 my $converter = Text::Iconv->new($Config{"encoding"}, "utf-8");
devi@23 98 $text = $converter->convert($text);
devi@23 99 }
devi@23 100 close(F);
devi@23 101 $diff{"text"}=$text;
devi@23 102 #print "$file loaded ($diff{day})\n";
devi@23 103
devi@28 104 #push @Diffs, \%diff;
devi@28 105 $Diffs{$file} = \%diff;
devi@23 106 $i++;
devi@23 107 }
devi@23 108 }
devi@23 109 }
devi@23 110
devi@23 111
devi@23 112 sub bind_diff
devi@23 113 {
devi@23 114 # my $path = shift;
devi@23 115 # my $pid = shift;
devi@23 116 # my $day = shift;
devi@23 117 # my $lab = shift;
devi@23 118
devi@23 119 print "Trying to bind diff...\n";
devi@23 120
devi@23 121 my $cl = shift;
devi@23 122 my $hour = $cl->{"hour"};
devi@23 123 my $min = $cl->{"min"};
devi@23 124 my $sec = $cl->{"sec"};
devi@23 125
devi@23 126 my $min_dt = 10000;
devi@23 127
devi@28 128 for my $diff_key (keys %Diffs) {
devi@28 129 my $diff = $Diffs{$diff_key};
devi@23 130 # Check here date, time and user
devi@23 131 next if ($diff->{"day"} && $cl->{"day"} && ($cl->{"day"} ne $diff->{"day"}));
devi@23 132 #next if (!$diff->{"uid"} && $cl->{"euid"} != $diff->{"uid"});
devi@23 133
devi@23 134 my $dt=($diff->{"hour"}-$hour)*3600 +($diff->{"min"}-$min)*60 + ($diff->{"sec"}-$sec);
devi@23 135 if ($dt >0 && $dt < $min_dt && ($diff->{"time_range"} <0 || $dt < $diff->{"time_range"})) {
devi@23 136 print "Approppriate diff found: dt=$dt\n";
devi@23 137 if ($diff->{"bind_to"}) {
devi@23 138 undef $diff->{"bind_to"}->{"diff"};
devi@23 139 };
devi@23 140 $diff->{"time_range"}=$dt;
devi@23 141 $diff->{"bind_to"}=$cl;
devi@23 142
devi@28 143 #$cl->{"diff"} = $diff->{"index"};
devi@28 144 $cl->{"diff"} = $diff_key;
devi@23 145 $min_dt = $dt;
devi@23 146 }
devi@23 147
devi@23 148 }
devi@23 149 }
devi@23 150
devi@23 151
devi@23 152 sub extract_from_cline
devi@23 153 # Разобрать командную строку $_[1] и возвратить хэш, содержащий
devi@23 154 # номер первого появление команды в строке:
devi@23 155 # команда => первая позиция
devi@23 156 {
devi@23 157 my $what = $_[0];
devi@23 158 my $cline = $_[1];
devi@23 159 my @lists = split /\;/, $cline;
devi@23 160
devi@23 161
devi@23 162 my @commands = ();
devi@23 163 for my $list (@lists) {
devi@23 164 push @commands, split /\|/, $list;
devi@23 165 }
devi@23 166
devi@23 167 my %commands;
devi@23 168 my %files;
devi@23 169 my $i=0;
devi@23 170 for my $command (@commands) {
devi@23 171 $command =~ /\s*(\S+)\s*(.*)/;
devi@23 172 if ($1 && $1 eq "sudo" ) {
devi@23 173 $commands{"$1"}=$i++;
devi@23 174 $command =~ s/\s*sudo\s+//;
devi@23 175 }
devi@23 176 $command =~ /\s*(\S+)\s*(.*)/;
devi@23 177 if ($1 && !defined $commands{"$1"}) {
devi@23 178 $commands{"$1"}=$i++;
devi@23 179 };
devi@23 180 if ($2) {
devi@23 181 my $args = $2;
devi@23 182 my @args = split (/\s+/, $args);
devi@23 183 for my $a (@args) {
devi@23 184 $files{"$a"}=$i++
devi@23 185 if !defined $files{"$a"};
devi@23 186 };
devi@23 187
devi@23 188
devi@23 189 }
devi@23 190 }
devi@23 191
devi@23 192 if ($what eq "commands") {
devi@23 193 return %commands;
devi@23 194 } else {
devi@23 195 return %files;
devi@23 196 }
devi@23 197
devi@23 198 }
devi@23 199
devi@23 200 sub load_command_lines
devi@23 201 {
devi@23 202 my $lab_scripts_path = $_[0];
devi@23 203 my $lab_scripts_mask = $_[1];
devi@23 204
devi@23 205 my $cline_re_base = qq'
devi@25 206 (
devi@25 207 (?:\\^?([0-9]*C?)) # exitcode
devi@23 208 (?:_([0-9]+)_)? # uid
devi@23 209 (?:_([0-9]+)_) # pid
devi@23 210 (...?) # day
devi@23 211 (.?.?) # lab
devi@23 212 \\s # space separator
devi@23 213 ([0-9][0-9]):([0-9][0-9]):([0-9][0-9]) # time
devi@23 214 .\\[50D.\\[K # killing symbols
devi@23 215 (.*?([\$\#]\\s?)) # prompt
devi@23 216 (.*) # command line
devi@25 217 )
devi@23 218 ';
devi@23 219 #my $cline_re = qr/$cline_re_base(?:$cline_re_base|$)/x;
devi@23 220 #my $cline_re = qr/(?:$cline_re_base)*$cline_re_base$/x;
devi@23 221 my $cline_re = qr/$cline_re_base/sx;
devi@23 222 my $cline_re1 = qr/$cline_re_base\x0D/sx;
devi@23 223 my $cline_re2 = qr/$cline_re_base$/sx;
devi@23 224
devi@23 225 my $vt = Term::VT102->new ( 'cols' => $Config{"terminal_width"},
devi@23 226 'rows' => $Config{"terminal_height"});
devi@23 227 my $cline_vt = Term::VT102->new ('cols' => $Config{"terminal_width"},
devi@23 228 'rows' => $Config{"terminal_height"});
devi@23 229
devi@23 230 my $converter = Text::Iconv->new($Config{"encoding"}, "utf-8")
devi@23 231 if ($Config{"encoding"} && $Config{"encoding"} !~ /^utf-8$/i);
devi@23 232
devi@23 233 print "Loading lm-scripts...\n" if $Config{"verbose"} =~ /y/;
devi@23 234
devi@23 235 my $file;
devi@23 236 my $skip_info;
devi@23 237
devi@23 238 my $commandlines_loaded =0;
devi@23 239 my $commandlines_processed =0;
devi@23 240
devi@27 241 my @lab_scripts = <$lab_scripts_path/$lab_scripts_mask>;
devi@23 242 for $file (@lab_scripts){
devi@25 243
devi@25 244 # Пропускаем файл, если он не изменялся со времени нашего предудущего прохода
devi@25 245 my $size = (stat($file))[7];
devi@25 246 next if ($Script_Files{$file} && $Script_Files{$file}->{size} && $Script_Files{$file}->{size} >= $size);
devi@23 247
devi@27 248
devi@27 249 my $local_session_id;
devi@27 250 # Начальное значение идентификатора текущего сеанса определяем из имени скрипта
devi@27 251 # Впоследствии оно может быть уточнено
devi@30 252 $file =~ m@.*/([^/]*)\.script$@;
devi@27 253 $local_session_id = $1;
devi@27 254
devi@27 255 #Если файл только что появился,
devi@27 256 #пытаемся найти и загрузить информацию о соответствующей ему сессии
devi@27 257 if (!$Script_Files{$file}) {
devi@27 258 my $session_file = $file;
devi@27 259 $session_file =~ s/\.script/.info/;
devi@27 260 if (open(SESSION, $session_file)) {
devi@27 261 local $/;
devi@27 262 my $data = <SESSION>;
devi@27 263 close(SESSION);
devi@27 264
devi@27 265 for my $session_data ($data =~ m@<session>(.*?)</session>@sg) {
devi@27 266 my %session;
devi@27 267 while ($session_data =~ m@<([^>]*?)>(.*?)</\1>@sg) {
devi@27 268 $session{$1} = $2;
devi@27 269 }
devi@27 270 $local_session_id = $session{"local_session_id"} if $session{"local_session_id"};
devi@28 271 $Sessions{$local_session_id}=\%session;
devi@27 272 }
devi@27 273
devi@27 274 #Загруженную информацию сразу же отправляем в поток
devi@27 275 print_session($Config{cache}, $local_session_id);
devi@27 276 }
devi@27 277 }
devi@27 278
devi@23 279 open (FILE, "$file");
devi@23 280 binmode FILE;
devi@25 281
devi@25 282 # Переходим к тому месту, где мы окончили разбор
devi@25 283 seek (FILE, $Script_Files{$file}->{tell}, 0) if $Script_Files{$file}->{tell};
devi@25 284 $Script_Files{$file}->{size} = $size;
devi@25 285 $Script_Files{$file}->{tell} = 0 unless $Script_Files{$file}->{tell};
devi@25 286
devi@25 287
devi@23 288 $file =~ m@.*/(.*?)-.*@;
devi@23 289
devi@23 290 my $tty = $1;
devi@23 291 my $first_pass = 1;
devi@23 292 my %cl;
devi@23 293 my $last_output_length=0;
devi@23 294 while (<FILE>) {
devi@25 295
devi@23 296 $commandlines_processed++;
devi@23 297 # time
devi@23 298
devi@23 299 if (/[0-9][0-9]:[0-9][0-9]:[0-9][0-9].\[[0-9][0-9]D.\[K/ && m/$cline_re/) {
devi@23 300 s/.*\x0d(?!\x0a)//;
devi@23 301 # print "!!!",$_,"!!!\n";
devi@23 302 # next;
devi@23 303 # while (m/$cline_re1/gs) {
devi@23 304 # }
devi@23 305 m/$cline_re2/gs;
devi@23 306
devi@23 307 $commandlines_loaded++;
devi@23 308 $last_output_length=0;
devi@23 309
devi@23 310 # Previous command
devi@23 311 my %last_cl = %cl;
devi@25 312 my $err = $2 || "";
devi@23 313
devi@23 314
devi@23 315 =cut
devi@23 316
devi@27 317 Атрибуты cline
devi@27 318 Список полей, характеризующих командную строку
devi@23 319
devi@23 320 uid
devi@23 321 Идентификатор пользователя
devi@23 322
devi@23 323 tty
devi@23 324 Идентификатор терминала, на котором была вызвана команда
devi@23 325
devi@23 326 pid
devi@23 327 PID-процесса командного интерпретатора,
devi@23 328 в котором была вызвана команда
devi@23 329
devi@23 330 lab
devi@23 331 лабораторная работа, к которой относится команда.
devi@23 332 Идентификатор текущей лабораторной работы
devi@23 333 хранится в файле ~/.labmaker/lab
devi@23 334
devi@23 335 pwd (!)
devi@23 336 текущий каталог, из которого была вызвана команда
devi@23 337
devi@23 338 day
devi@23 339 время вызова, день
devi@23 340 В действительности здесь хранится не время вызова команды,
devi@23 341 а с момента появления приглашения командного интерпретатора
devi@23 342 для ввода команды
devi@23 343
devi@23 344
devi@23 345 hour
devi@23 346 время вызова, час
devi@23 347
devi@23 348 min
devi@23 349 время вызова, минута
devi@23 350
devi@23 351 sec
devi@23 352 время вызова, секунда
devi@23 353
devi@23 354 time (!)
devi@23 355 время вызова команды в Unix-формате.
devi@23 356 Предпочтительнее использовать этот формат чем hour:min:sec,
devi@23 357 использовавшийся в Labmaker
devi@23 358
devi@23 359 fullprompt
devi@23 360 Приглашение командной строки
devi@23 361
devi@23 362 prompt
devi@23 363 Сокращённое приглашение командной строки
devi@23 364
devi@23 365 cline
devi@23 366 Командная строка
devi@23 367
devi@23 368 output
devi@23 369 Результат выполнения команды
devi@23 370
devi@23 371 diff
devi@23 372 Указатель на ассоциированный с командой diff
devi@23 373
devi@23 374 note (!)
devi@23 375 Текстовый комментарий к команде.
devi@23 376 Может генерироваться из самого лога с помощью команд
devi@23 377 #^ Комментарий
devi@27 378 #= Комментарий
devi@23 379 #v Комментарий
devi@23 380 в том случае, если для комментирования достаточно одной строки,
devi@23 381 или с помощью команд
devi@23 382 cat > /dev/null #^ Заголовок
devi@23 383 Текст
devi@23 384 ^D
devi@23 385 в том случае, если комментарий развёрнутый.
devi@23 386 В последнем случае комментарий может содержать
devi@23 387 заголовок, абзацы и несложное форматирование.
devi@23 388
devi@27 389 Символы ^, v или = после знака комментария # обозначает,
devi@23 390 к какой команде относится комментарий:
devi@27 391 к предыдущей (^), последующей (v)
devi@27 392 или это общий комментарий по тексту, не относящийся непосредственно
devi@27 393 ни к одной из них (=)
devi@23 394
devi@23 395 err
devi@23 396 Код завершения командной строки
devi@23 397
devi@23 398 histnum (!)
devi@23 399 Номер команды в истории командного интерпретатора
devi@23 400
devi@23 401 status (!)
devi@23 402 Является ли данная команда вызванной (r), запомненной (s)
devi@23 403 или это подсказка completion (c).
devi@23 404
devi@23 405 Команды, которые были вызваны и обработаны интерпретатором
devi@23 406 имеют состояние "r". К таким командам относится большинство
devi@23 407 команд вводимых в интерпретатор.
devi@23 408
devi@23 409 Если команда набрана, но вызывать её по какой-либо причине
devi@23 410 не хочется (например, команда может быть не полной, вредоносной
devi@23 411 или просто бессмысленной в текущих условиях),
devi@23 412 её можно сбросить с помощью комбинации клавиш Ctrl-C
devi@23 413 (не путайте с прерыванием работающей команды! здесь она даже
devi@23 414 не запускается!).
devi@23 415 В таком случае она не выполняется, но попадает в журнал
devi@23 416 со статусом "s".
devi@23 417
devi@23 418 Если команда появилась в журнале благодаря автопроолжению
devi@23 419 -- когда было показано несколько вариантов --
devi@23 420 она имеет статус "c".
devi@23 421
devi@23 422 euid
devi@23 423 Идентификатор пользователя от имени которого будет
devi@23 424 выполняться команда.
devi@23 425 Может отличаться от реального uid в том случае,
devi@23 426 если вызывается с помощью sudo
devi@23 427
devi@23 428
devi@23 429 version (!)
devi@23 430 Версия lilalo-prompt использовавшаяся при записи
devi@23 431 команды.
devi@23 432
devi@23 433 0 - версия использовавшая в labmaker.
devi@23 434 Отсутствует информация о текущем каталоге и номере в истории.
devi@23 435 Информация о версии также не указана в приглашении.
devi@23 436
devi@23 437
devi@23 438 1 - версия использующаяся в lilalo
devi@23 439
devi@27 440 raw_file
devi@23 441 Имя файла, в котором находится бинарное представление журнала.
devi@23 442 Может содержать ключевое слово HERE,
devi@23 443 обозначающее что бинарное представление хранится
devi@23 444 непосредственно в базе данных в атрибуте raw_data
devi@23 445
devi@27 446 raw_start
devi@23 447 Начало блока командной строки в файле бинарного представления
devi@23 448
devi@27 449 raw_output_start
devi@25 450 Начало блока вывода
devi@25 451
devi@27 452 raw_end
devi@23 453 Конец блока командной строки в файле бинарного представления
devi@23 454
devi@27 455 raw_cline
devi@25 456 Необработанная командная строка (без приглашения) в бинарном виде
devi@23 457
devi@23 458 raw_data (*)
devi@23 459 Бинарное представление команды и результатов её выполнения
devi@23 460
devi@23 461
devi@23 462
devi@23 463
devi@23 464 ТАБЛИЦА SESSION
devi@23 465
devi@23 466 Информация о сеансах
devi@23 467
devi@27 468 (см. lm-install)
devi@23 469
devi@23 470
devi@23 471 =cut
devi@23 472
devi@27 473 $cl{"local_session_id"} = $local_session_id;
devi@23 474 # Parse new command
devi@25 475 $cl{"uid"} = $3;
devi@23 476 $cl{"euid"} = $cl{"uid"}; # Если в команде обнаружится sudo, euid поменяем на 0
devi@25 477 $cl{"pid"} = $4;
devi@25 478 $cl{"day"} = $5;
devi@25 479 $cl{"lab"} = $6;
devi@25 480 $cl{"hour"} = $7;
devi@25 481 $cl{"min"} = $8;
devi@25 482 $cl{"sec"} = $9;
devi@25 483 $cl{"fullprompt"} = $10;
devi@25 484 $cl{"prompt"} = $11;
devi@25 485 $cl{"raw_cline"} = $12;
devi@25 486
devi@25 487 {
devi@25 488 use bytes;
devi@25 489 $cl{"raw_start"} = tell (FILE) - length($1);
devi@25 490 $cl{"raw_output_start"} = tell FILE;
devi@25 491 }
devi@25 492 $cl{"raw_file"} = $file;
devi@23 493
devi@23 494 $cl{"err"} = 0;
devi@23 495 $cl{"output"} = "";
devi@23 496 $cl{"tty"} = $tty;
devi@23 497
devi@23 498 $cline_vt->process($cl{"raw_cline"}."\n");
devi@23 499 $cl{"cline"} = $cline_vt->row_plaintext (1);
devi@23 500 $cl{"cline"} =~ s/\s*$//;
devi@23 501 $cline_vt->reset();
devi@23 502
devi@23 503 my %commands = extract_from_cline("commands", $cl{"cline"});
devi@23 504 $cl{"euid"}=0 if defined $commands{"sudo"};
devi@23 505 my @comms = sort { $commands{$a} cmp $commands{$b} } keys %commands;
devi@23 506 $cl{"last_command"} = $comms[$#comms] || "";
devi@23 507
devi@23 508 if (
devi@23 509 $Config{"suppress_editors"} =~ /^y/i
devi@23 510 && grep ($_ eq $cl{"last_command"}, @{$Config{"editors"}}) ||
devi@23 511 $Config{"suppress_pagers"} =~ /^y/i
devi@23 512 && grep ($_ eq $cl{"last_command"}, @{$Config{"pagers"}}) ||
devi@23 513 $Config{"suppress_terminal"}=~ /^y/i
devi@23 514 && grep ($_ eq $cl{"last_command"}, @{$Config{"terminal"}})
devi@23 515 ) {
devi@23 516 $cl{"suppress_output"} = "1";
devi@23 517 }
devi@23 518 else {
devi@23 519 $cl{"suppress_output"} = "0";
devi@23 520
devi@23 521 }
devi@23 522 $skip_info = 0;
devi@23 523
devi@23 524
devi@23 525 print " ",$cl{"last_command"};
devi@23 526
devi@23 527 # Processing previous command line
devi@23 528 if ($first_pass) {
devi@23 529 $first_pass = 0;
devi@23 530 next;
devi@23 531 }
devi@23 532
devi@23 533 # Error code
devi@25 534 $last_cl{"raw_end"} = $cl{"raw_start"};
devi@23 535 $last_cl{"err"}=$err;
devi@23 536 $last_cl{"err"}=130 if $err eq "^C";
devi@23 537
devi@23 538 if (grep ($_ eq $last_cl{"last_command"}, @{$Config{"editors"}})) {
devi@23 539 bind_diff(\%last_cl);
devi@23 540 }
devi@23 541
devi@23 542 # Output
devi@23 543 if (!$last_cl{"suppress_output"} || $last_cl{"err"}) {
devi@23 544 for (my $i=0; $i<$Config{"terminal_height"}; $i++) {
devi@23 545 my $line= $vt->row_plaintext($i);
devi@31 546 next if !defined ($line) ; #|| $line =~ /^\s*$/;
devi@23 547 $line =~ s/\s*$//;
devi@31 548 $line .= "\n" unless $line =~ /^\s*$/;
devi@31 549 $last_cl{"output"} .= $line;
devi@23 550 }
devi@23 551 }
devi@23 552 else {
devi@23 553 $last_cl{"output"}= "";
devi@23 554 }
devi@23 555
devi@23 556 $vt->reset();
devi@23 557
devi@23 558
devi@23 559 # Classifying the command line
devi@23 560
devi@23 561
devi@23 562 # Save
devi@23 563 if (!$Config{"lab"} || $cl{"lab"} eq $Config{"lab"}) {
devi@23 564 # Changing encoding
devi@23 565 for (keys %last_cl) {
devi@25 566 next if /raw/;
devi@23 567 $last_cl{$_} = $converter->convert($last_cl{$_})
devi@23 568 if ($Config{"encoding"} &&
devi@23 569 $Config{"encoding"} !~ /^utf-8$/i);
devi@23 570 }
devi@23 571 push @Command_Lines, \%last_cl;
devi@25 572
devi@25 573 # Сохранение позиции в файле, до которой выполнен
devi@25 574 # успешный разбор
devi@25 575 $Script_Files{$file}->{tell} = $last_cl{raw_end};
devi@23 576 }
devi@23 577 next;
devi@23 578 }
devi@23 579 $last_output_length+=length($_);
devi@23 580 #if (!$cl{"suppress_output"} || $last_output_length < 5000) {
devi@23 581 if ($last_output_length < 50000) {
devi@23 582 #print "(",length($_),")" if (length($_) > 2000) ;
devi@23 583 $vt->process("$_"."\n")
devi@23 584 }
devi@23 585 else
devi@23 586 {
devi@23 587 if (!$skip_info) {
devi@23 588 print "($cl{last_command})";
devi@23 589 $skip_info = 1;
devi@23 590 }
devi@23 591 }
devi@23 592 }
devi@23 593 close(FILE);
devi@23 594
devi@23 595 }
devi@23 596 if ($Config{"verbose"} =~ /y/) {
devi@23 597 print "...finished." ;
devi@23 598 print "Lines loaded: $commandlines_processed\n";
devi@23 599 print "Command lines: $commandlines_loaded\n";
devi@23 600 }
devi@23 601 }
devi@23 602
devi@23 603
devi@23 604
devi@23 605 sub printq
devi@23 606 {
devi@23 607 my $TO = shift;
devi@23 608 my $text = join "", @_;
devi@23 609 $text =~ s/&/&amp;/g;
devi@23 610 $text =~ s/</&lt;/g;
devi@23 611 $text =~ s/>/&gt;/g;
devi@23 612 print $TO $text;
devi@23 613 }
devi@23 614
devi@23 615
devi@23 616 sub sort_command_lines
devi@23 617 {
devi@23 618 print "Sorting command lines...\n" if $Config{"verbose"} =~ /y/;
devi@23 619
devi@23 620 # Sort Command_Lines
devi@23 621 # Write Command_Lines to Command_Lines_Index
devi@23 622
devi@23 623 my @index;
devi@23 624 for (my $i=0;$i<=$#Command_Lines;$i++) {
devi@23 625 $index[$i]=$i;
devi@23 626 }
devi@23 627
devi@23 628 @Command_Lines_Index = sort {
devi@23 629 $Command_Lines[$index[$a]]->{"day"} cmp $Command_Lines[$index[$b]]->{"day"} ||
devi@23 630 $Command_Lines[$index[$a]]->{"hour"} <=> $Command_Lines[$index[$b]]->{"hour"} ||
devi@23 631 $Command_Lines[$index[$a]]->{"min"} <=> $Command_Lines[$index[$b]]->{"min"} ||
devi@23 632 $Command_Lines[$index[$a]]->{"sec"} <=> $Command_Lines[$index[$b]]->{"sec"}
devi@23 633 } @index;
devi@23 634
devi@23 635 print "...finished\n" if $Config{"verbose"} =~ /y/;
devi@23 636
devi@23 637 }
devi@23 638
devi@23 639 sub process_command_lines
devi@23 640 {
devi@23 641 for my $i (@Command_Lines_Index) {
devi@23 642
devi@23 643 my $cl = \$Command_Lines[$i];
devi@23 644 @{${$cl}->{"new_commands"}} =();
devi@23 645 @{${$cl}->{"new_files"}} =();
devi@23 646 $$cl->{"class"} = "";
devi@23 647
devi@23 648 if ($$cl->{"err"}) {
devi@23 649 $$cl->{"class"}="wrong";
devi@23 650 $$cl->{"class"}="interrupted"
devi@23 651 if ($$cl->{"err"} eq 130);
devi@23 652 }
devi@23 653 if (!$$cl->{"euid"}) {
devi@23 654 $$cl->{"class"}.="_root";
devi@23 655 }
devi@23 656
devi@23 657 #tab# my @tab_words=split /\s+/, $$cl->{"output"};
devi@23 658 #tab# my $last_word= $$cl->{"cline"} =~ /(\S*)$/;
devi@23 659 #tab# $last_word =~ s@.*/@@;
devi@23 660 #tab# my $this_is_tab=1;
devi@23 661 #tab#
devi@23 662 #tab# if ($last_word && @tab_words >2) {
devi@23 663 #tab# for my $tab_words (@tab_words) {
devi@23 664 #tab# if ($tab_words !~ /^$last_word/) {
devi@23 665 #tab# $this_is_tab=0;
devi@23 666 #tab# last;
devi@23 667 #tab# }
devi@23 668 #tab# }
devi@23 669 #tab# }
devi@23 670 #tab# $$cl->{"class"}="tab" if $this_is_tab;
devi@23 671
devi@23 672
devi@23 673 if ( !$$cl->{"err"}) {
devi@23 674 # Command does not contain mistakes
devi@23 675
devi@23 676 my %commands = extract_from_cline("commands", ${$cl}->{"cline"});
devi@23 677 my %files = extract_from_cline("files", ${$cl}->{"cline"});
devi@23 678
devi@23 679 # Searching for new commands only
devi@23 680 for my $command (keys %commands) {
devi@23 681 if (!defined $Commands_Stat{$command}) {
devi@23 682 push @{$$cl->{new_commands}}, $command;
devi@23 683 }
devi@23 684 $Commands_Stat{$command}++;
devi@23 685 }
devi@23 686
devi@23 687 for my $file (keys %files) {
devi@23 688 if (!defined $Files_Stat{$file}) {
devi@23 689 push @{$$cl->{new_files}}, $file;
devi@23 690 }
devi@23 691 $Files_Stat{$file}++;
devi@23 692 }
devi@23 693 }
devi@31 694
devi@31 695 #if ($$cl->{cline}=~ /#\^(.*)/) {
devi@31 696 # my $j=$i-1;
devi@31 697 # $j-- while ($j >=0 && $Command_Lines[$j]->{tty} ne $$cl->{tty});
devi@31 698 # $Command_Lines[$j]->{note_title}="Замечание";
devi@31 699 # $Command_Lines[$j]->{note}="$1";
devi@31 700 #}
devi@23 701 }
devi@23 702
devi@23 703 }
devi@23 704
devi@23 705
devi@23 706 =cut
devi@23 707 Вывести результат обработки журнала.
devi@23 708 =cut
devi@23 709
devi@23 710
devi@23 711 sub print_command_lines
devi@23 712 {
devi@23 713 my $output_filename=$_[0];
devi@25 714 my $mode = ">";
devi@25 715 $mode =">>" if $Config{mode} eq "daemon";
devi@25 716 open(OUT, $mode, $output_filename)
devi@23 717 or die "Can't open $output_filename for writing\n";
devi@23 718
devi@23 719
devi@23 720
devi@25 721 #print OUT "<livelablog>\n";
devi@23 722
devi@23 723 my $cl;
devi@23 724 my $in_range=0;
devi@23 725 for my $i (@Command_Lines_Index) {
devi@23 726 $cl = $Command_Lines[$i];
devi@23 727
devi@23 728 if ($Config{"from"} && $cl->{"cline"} =~ /$Config{"signature"}\s*$Config{"from"}/) {
devi@23 729 $in_range=1;
devi@23 730 next;
devi@23 731 }
devi@23 732 if ($Config{"to"} && $cl->{"cline"} =~ /$Config{"signature"}\s*$Config{"to"}/) {
devi@23 733 $in_range=0;
devi@23 734 next;
devi@23 735 }
devi@23 736 next if ($Config{"from"} && $Config{"to"} && !$in_range)
devi@23 737 ||
devi@23 738 ($Config{"skip_empty"} =~ /^y/i && $cl->{"cline"} =~ /^\s*$/ )
devi@23 739 ||
devi@23 740 ($Config{"skip_wrong"} =~ /^y/i && $cl->{"err"} != 0)
devi@23 741 ||
devi@23 742 ($Config{"skip_interrupted"} =~ /^y/i && $cl->{"err"} == 130);
devi@23 743
devi@23 744 my @new_commands=@{$cl->{"new_commands"}};
devi@23 745 my @new_files=@{$cl->{"new_files"}};
devi@23 746
devi@23 747 my $cl_class="cline";
devi@23 748 my $out_class="output";
devi@23 749 if ($cl->{"class"}) {
devi@23 750 $cl_class = $cl->{"class"}."_".$cl_class;
devi@23 751 $out_class = $cl->{"class"}."_".$out_class;
devi@23 752 }
devi@23 753
devi@23 754 # Вырезаем из вывода только нужное количество строк
devi@23 755
devi@23 756 my $output="";
devi@23 757 if ($Config{"head_lines"} || $Config{"tail_lines"}) {
devi@23 758 # Partialy output
devi@23 759 my @lines = split '\n', $cl->{"output"};
devi@23 760 # head
devi@23 761 my $mark=1;
devi@23 762 for (my $i=0; $i<= $#lines && $i < $Config{"cache_head_lines"}; $i++) {
devi@23 763 $output .= $lines[$i]."\n";
devi@23 764 }
devi@23 765 # tail
devi@23 766 my $start=$#lines-$Config{"cache_tail_lines"}+1;
devi@23 767 if ($start < 0) {
devi@23 768 $start=0;
devi@23 769 $mark=0;
devi@23 770 }
devi@23 771 if ($start < $Config{"cache_head_lines"}) {
devi@23 772 $start=$Config{"cache_head_lines"};
devi@23 773 $mark=0;
devi@23 774 }
devi@23 775 $output .= $Config{"skip_text"}."\n" if $mark;
devi@23 776 for (my $i=$start; $i<= $#lines; $i++) {
devi@23 777 $output .= $lines[$i]."\n";
devi@23 778 }
devi@23 779 }
devi@23 780 else {
devi@23 781 # Full output
devi@23 782 $output .= $cl->{"output"};
devi@23 783 }
devi@31 784 #$output .= "^C\n" if ($cl->{"err"} eq "130");
devi@23 785
devi@23 786
devi@23 787 # Совместимость с labmaker
devi@23 788
devi@23 789 # Переводим в секунды Эпохи
devi@23 790 # В labmaker'е данные хранились в неудобной форме: hour, min, sec, day of year
devi@23 791 # Информация о годе отсутствовала
devi@23 792 # Её можно внести:
devi@23 793 # Декабрь 2004 год; остальные -- 2005 год.
devi@23 794
devi@23 795 my $year = 2005;
devi@23 796 $year = 2004 if ( $cl->{day} > 330 );
devi@23 797 # timelocal( $sec, $min, $hour, $mday,$mon,$year);
devi@23 798 $cl->{time} = timelocal_nocheck($cl->{sec},$cl->{min},$cl->{hour},$cl->{day},0,$year);
devi@23 799
devi@23 800
devi@23 801 # Начинаем вывод команды
devi@23 802 print OUT "<command>\n";
devi@30 803 print OUT "<local_session_id>",$cl->{local_session_id},"</local_session_id>\n";
devi@23 804 print OUT "<time>",$cl->{time},"</time>\n";
devi@25 805 print OUT "<raw_start>",$cl->{raw_start},"</raw_start>\n";
devi@25 806 print OUT "<raw_output_start>",$cl->{raw_output_start},"</raw_output_start>\n";
devi@25 807 print OUT "<raw_end>",$cl->{raw_end},"</raw_end>\n";
devi@25 808 print OUT "<raw_file>",$cl->{raw_file},"</raw_file>\n";
devi@23 809 print OUT "<tty>",$cl->{tty},"</tty>\n";
devi@23 810 print OUT "<out_class>",$out_class,"</out_class>\n";
devi@23 811 print OUT "<prompt>";
devi@23 812 printq(\*OUT,,$cl->{"prompt"});
devi@23 813 print OUT "</prompt>";
devi@23 814 print OUT "<cline>";
devi@23 815 printq(\*OUT,$cl->{"cline"});
devi@23 816 print OUT "</cline>\n";
devi@23 817 print OUT "<last_command>",$cl->{"last_command"},"</last_command>\n";
devi@23 818 if (@new_commands) {
devi@23 819 print OUT "<new_commands>";
devi@23 820 printq(\*OUT, join (" ", @new_commands));
devi@23 821 print OUT "</new_commands>";
devi@23 822 }
devi@23 823 if (@new_files) {
devi@23 824 print OUT "<new_files>";
devi@23 825 printq(\*OUT, join (" ", @new_files));
devi@23 826 print OUT "</new_files>";
devi@23 827 }
devi@23 828 print OUT "<output>";
devi@23 829 printq(\*OUT,$output);
devi@23 830 print OUT "</output>\n";
devi@23 831 if ($cl->{"diff"}) {
devi@23 832 print OUT "<diff>";
devi@28 833 printq(\*OUT,${$Diffs{$cl->{"diff"}}}{"text"});
devi@23 834 print OUT "</diff>\n";
devi@23 835 }
devi@31 836 if ($cl->{"note"}) {
devi@31 837 print OUT "<note>";
devi@31 838 printq(\*OUT,$cl->{"note"});
devi@31 839 print OUT "</note>\n";
devi@31 840 }
devi@31 841 if ($cl->{"note_title"}) {
devi@31 842 print OUT "<note_title>";
devi@31 843 printq(\*OUT,$cl->{"note_title"});
devi@31 844 print OUT "</note_title>\n";
devi@31 845 }
devi@23 846 print OUT "</command>\n";
devi@23 847
devi@23 848 }
devi@23 849
devi@25 850 #print OUT "</livelablog>\n";
devi@23 851 close(OUT);
devi@27 852 }
devi@27 853
devi@27 854 sub print_session
devi@27 855 {
devi@27 856 my $output_filename = $_[0];
devi@27 857 my $local_session_id = $_[1];
devi@27 858 return if not defined($Sessions{$local_session_id});
devi@27 859
devi@27 860 open(OUT, ">>", $output_filename)
devi@27 861 or die "Can't open $output_filename for writing\n";
devi@27 862 print OUT "<session>\n";
devi@27 863 my %session = %{$Sessions{$local_session_id}};
devi@27 864 for my $key (keys %session) {
devi@27 865 print OUT "<$key>".$session{$key}."</$key>\n"
devi@27 866 }
devi@27 867 print OUT "</session>\n";
devi@27 868 close(OUT);
devi@27 869 }
devi@27 870
devi@27 871 sub send_cache
devi@27 872 {
devi@27 873 # Если в кэше что-то накопилось,
devi@27 874 # попытаемся отправить это на сервер
devi@27 875 #
devi@27 876 my $cache_was_sent=0;
devi@27 877
devi@27 878 if (open(CACHE, $Config{cache})) {
devi@27 879 local $/;
devi@27 880 my $cache = <CACHE>;
devi@27 881 close(CACHE);
devi@27 882
devi@27 883 my $socket = IO::Socket::INET->new(
devi@27 884 PeerAddr => $Config{backend_address},
devi@27 885 PeerPort => $Config{backend_port},
devi@27 886 proto => "tcp",
devi@27 887 Type => SOCK_STREAM
devi@27 888 );
devi@27 889
devi@27 890 if ($socket) {
devi@27 891 print $socket $cache;
devi@27 892 close($socket);
devi@27 893 $cache_was_sent = 1;
devi@27 894 }
devi@27 895 }
devi@27 896 return $cache_was_sent;
devi@23 897 }
devi@23 898
devi@25 899 sub save_cache_stat
devi@25 900 {
devi@25 901 open (CACHE, ">$Config{cache_stat}");
devi@25 902 for my $f (keys %Script_Files) {
devi@25 903 print CACHE "$f\t",$Script_Files{$f}->{size},"\t",$Script_Files{$f}->{tell},"\n";
devi@25 904 }
devi@25 905 close(CACHE);
devi@25 906 }
devi@25 907
devi@25 908 sub load_cache_stat
devi@25 909 {
devi@25 910 if (open (CACHE, "$Config{cache_stat}")) {
devi@25 911 while(<CACHE>) {
devi@27 912 chomp;
devi@25 913 my ($f, $size, $tell) = split /\t/;
devi@25 914 $Script_Files{$f}->{size} = $size;
devi@25 915 $Script_Files{$f}->{tell} = $tell;
devi@25 916 }
devi@25 917 close(CACHE);
devi@25 918 };
devi@25 919 }
devi@23 920
devi@23 921
devi@23 922 main();
devi@23 923
devi@25 924 sub process_was_killed
devi@25 925 {
devi@25 926 $Killed = 1;
devi@25 927 }
devi@25 928
devi@23 929 sub main
devi@23 930 {
devi@23 931
devi@27 932 $| = 1;
devi@23 933
devi@27 934 init_variables();
devi@27 935 init_config();
devi@23 936
devi@27 937
devi@27 938 if ($Config{"mode"} ne "daemon") {
devi@27 939
devi@27 940 =cut
devi@27 941 В нормальном режиме работы нужно
devi@27 942 считать скрипты, обработать их и записать
devi@27 943 результат выполнения в результриующий файл.
devi@27 944 После этого завершить работу.
devi@27 945 =cut
devi@28 946 for my $lab_log (split (/\s+/, $Config{"diffs"} || $Config{"input"})) {
devi@28 947 load_diff_files($lab_log);
devi@28 948 }
devi@27 949 load_command_lines($Config{"input"}, $Config{"input_mask"});
devi@27 950 sort_command_lines;
devi@27 951 process_command_lines;
devi@27 952 print_command_lines($Config{"cache"});
devi@27 953 }
devi@27 954 else {
devi@27 955 if (open(PIDFILE, $Config{agent_pidfile})) {
devi@27 956 my $pid = <PIDFILE>;
devi@27 957 close(PIDFILE);
devi@27 958 if ( ! -e "/proc/$pid" || !`grep $Config{"l3-agent"} /proc/$pid/cmdline && grep "uid:.*\b$<\b" /proc/$pid/status`) {
devi@27 959 print "Removing stale pidfile\n";
devi@27 960 unlink $Config{agent_pidfile}
devi@27 961 or die "Can't remove stale pidfile ". $Config{agent_pidfile}. " : $!";
devi@27 962 }
devi@27 963 else {
devi@27 964 print "l3-agent is already running\n";
devi@27 965 exit(0);
devi@27 966 }
devi@25 967 }
devi@27 968 if ($Config{detach} =~ /^y/i) {
devi@27 969 #$Config{verbose} = "no";
devi@27 970 my $pid = fork;
devi@27 971 exit if $pid;
devi@27 972 die "Couldn't fork: $!" unless defined ($pid);
devi@27 973
devi@27 974 open(PIDFILE, ">", $Config{agent_pidfile})
devi@27 975 or die "Can't open pidfile ". $Config{agent_pidfile}. " for wrting: $!";
devi@27 976 print PIDFILE $$;
devi@27 977 close(PIDFILE);
devi@27 978
devi@27 979 for my $handle (*STDIN, *STDOUT, *STDERR) {
devi@27 980 open ($handle, "+<", "/dev/null")
devi@27 981 or die "can't reopen $handle to /dev/null: $!"
devi@27 982 }
devi@27 983
devi@27 984 POSIX::setsid()
devi@27 985 or die "Can't start a new session: $!";
devi@27 986
devi@27 987 $0 = $Config{"l3-agent"};
devi@27 988
devi@27 989 $SIG{INT} = $SIG{TERM} = $SIG{HUP} = \&process_was_killed;
devi@25 990 }
devi@27 991 while (not $Killed) {
devi@27 992 @Command_Lines = ();
devi@27 993 @Command_Lines_Index = ();
devi@28 994 for my $lab_log (split (/\s+/, $Config{"diffs"} || $Config{"input"})) {
devi@28 995 load_diff_files($lab_log);
devi@28 996 }
devi@27 997 load_cache_stat();
devi@27 998 load_command_lines($Config{"input"}, $Config{"input_mask"});
devi@27 999 if (@Command_Lines) {
devi@27 1000 sort_command_lines;
devi@27 1001 process_command_lines;
devi@27 1002 print_command_lines($Config{"cache"});
devi@27 1003 }
devi@27 1004 save_cache_stat();
devi@27 1005 if (-e $Config{cache} && (stat($Config{cache}))[7]) {
devi@27 1006 send_cache() && unlink($Config{cache});
devi@27 1007 }
devi@27 1008 sleep($Config{"daemon_sleep_interval"} || 1);
devi@27 1009 }
devi@27 1010
devi@27 1011 unlink $Config{agent_pidfile};
devi@25 1012 }
devi@23 1013
devi@23 1014 }
devi@23 1015
devi@23 1016 sub init_variables
devi@23 1017 {
devi@23 1018 }