HTML code for sharing source code

HTML Copy To Clipboarddone!

<div class="highlight" style="background: #f8f8f8"><pre style="line-height: 125%"><div id="lc1"><span style="color: #408080; font-style: italic">#!/usr/bin/perl</span>
</div><div id="lc2">
</div><div id="lc3"><span style="color: #008000; font-weight: bold">use</span> Pg;
</div><div id="lc4"><span style="color: #008000; font-weight: bold">use</span> <span style="color: #0000FF; font-weight: bold">IO::</span>Select;
</div><div id="lc5"><span style="color: #008000; font-weight: bold">use</span> Socket <span style="color: #008000">qw(inet_aton)</span>;
</div><div id="lc6">
</div><div id="lc7"><span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$dbname</span> <span style="color: #666666">=</span> <span style="color: #BA2121">&quot;xxxx&quot;</span>;
</div><div id="lc8"><span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$dbhost</span> <span style="color: #666666">=</span> <span style="color: #BA2121">&quot;::1&quot;</span>;
</div><div id="lc9"><span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$dbuser</span> <span style="color: #666666">=</span> <span style="color: #BA2121">&quot;xxxx&quot;</span>;
</div><div id="lc10"><span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$dbpass</span> <span style="color: #666666">=</span> <span style="color: #BA2121">&quot;xxxx&quot;</span>;
</div><div id="lc11"><span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$max_ttl</span> <span style="color: #666666">=</span> <span style="color: #666666">1800</span>;
</div><div id="lc12"><span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$ping_ttl</span> <span style="color: #666666">=</span> <span style="color: #666666">60</span>;
</div><div id="lc13"><span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">%notify</span> <span style="color: #666666">=</span> (<span style="color: #BA2121">&quot;acl_user_insert&quot;</span> <span style="color: #666666">=&gt;</span> <span style="color: #BA2121">&quot;process_user_insert&quot;</span>, <span style="color: #BA2121">&quot;acl_user_update&quot;</span> <span style="color: #666666">=&gt;</span> <span style="color: #BA2121">&quot;check_user_update&quot;</span>, <span style="color: #BA2121">&quot;acl_user_delete&quot;</span> <span style="color: #666666">=&gt;</span> <span style="color: #BA2121">&quot;process_user_delete&quot;</span>);
</div><div id="lc14"><span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$log</span> <span style="color: #666666">=</span> <span style="color: #BA2121">&quot;/var/log/acl_change.log&quot;</span>;
</div><div id="lc15">
</div><div id="lc16"><span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$till</span> <span style="color: #666666">=</span> <span style="color: #008000">time</span>() <span style="color: #666666">+</span> <span style="color: #19177C">$max_ttl</span> <span style="color: #666666">-</span> <span style="color: #666666">3</span>;
</div><div id="lc17"><span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$last_ping</span> <span style="color: #666666">=</span> <span style="color: #008000">time</span>();
</div><div id="lc18">
</div><div id="lc19"><span style="color: #408080; font-style: italic">#daemonize();</span>
</div><div id="lc20">
</div><div id="lc21"><span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$conn</span>;
</div><div id="lc22">
</div><div id="lc23"><span style="color: #008000; font-weight: bold">for</span>(;;)
</div><div id="lc24">{
</div><div id="lc25">	<span style="color: #008000; font-weight: bold">if</span> (<span style="color: #008000">time</span>() <span style="color: #666666">&gt;</span> <span style="color: #19177C">$till</span>) { <span style="color: #008000">exit</span>; }
</div><div id="lc26">	<span style="color: #19177C">$conn</span> <span style="color: #666666">=</span> <span style="color: #0000FF; font-weight: bold">Pg::</span>setdbLogin(<span style="color: #19177C">$dbhost</span>, <span style="color: #666666">5432</span>, <span style="color: #19177C">$pgoptions</span>, <span style="color: #BA2121">&quot;&quot;</span>, <span style="color: #19177C">$dbname</span>, <span style="color: #19177C">$dbuser</span>, <span style="color: #19177C">$dbpass</span>);
</div><div id="lc27">
</div><div id="lc28">	<span style="color: #008000; font-weight: bold">if</span> ((<span style="color: #19177C">$conn</span><span style="color: #666666">-&gt;</span>status <span style="color: #666666">!=</span> PGRES_CONNECTION_OK))
</div><div id="lc29">	{
</div><div id="lc30">		_log(<span style="color: #BA2121">&quot;Err: $conn-&gt;errorMessage&quot;</span>);
</div><div id="lc31">		<span style="color: #008000">undef</span> <span style="color: #19177C">$conn</span>;
</div><div id="lc32">		<span style="color: #008000; font-weight: bold">next</span>;
</div><div id="lc33">	}
</div><div id="lc34">
</div><div id="lc35">	<span style="color: #008000; font-weight: bold">foreach</span> <span style="color: #19177C">$event</span> (<span style="color: #008000">keys</span>(<span style="color: #19177C">%notify</span>))
</div><div id="lc36">	{
</div><div id="lc37">		<span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$res</span> <span style="color: #666666">=</span> <span style="color: #19177C">$conn</span><span style="color: #666666">-&gt;</span><span style="color: #008000">exec</span>(<span style="color: #BA2121">&quot;LISTEN $event&quot;</span>);
</div><div id="lc38">		<span style="color: #008000; font-weight: bold">if</span> (<span style="color: #19177C">$res</span><span style="color: #666666">-&gt;</span>resultStatus <span style="color: #666666">!=</span> PGRES_COMMAND_OK)
</div><div id="lc39">		{
</div><div id="lc40">			_log(<span style="color: #BA2121">&quot;LISTEN error: &quot;</span> <span style="color: #666666">.</span> <span style="color: #19177C">$conn</span><span style="color: #666666">-&gt;</span>errorMessage <span style="color: #666666">.</span> <span style="color: #BA2121">&quot;&quot;</span>);
</div><div id="lc41">			<span style="color: #008000; font-weight: bold">next</span>;
</div><div id="lc42">		}
</div><div id="lc43">	}
</div><div id="lc44">
</div><div id="lc45">	<span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$s</span> <span style="color: #666666">=</span> <span style="color: #0000FF; font-weight: bold">IO::</span>Select<span style="color: #666666">-&gt;</span><span style="color: #008000; font-weight: bold">new</span>();
</div><div id="lc46">	<span style="color: #19177C">$s</span><span style="color: #666666">-&gt;</span>add(<span style="color: #19177C">$conn</span><span style="color: #666666">-&gt;</span><span style="color: #008000">socket</span>);
</div><div id="lc47">	<span style="color: #008000; font-weight: bold">for</span>(;;)
</div><div id="lc48">	{
</div><div id="lc49">		<span style="color: #008000; font-weight: bold">if</span> (<span style="color: #008000">time</span>() <span style="color: #666666">&gt;</span> <span style="color: #19177C">$till</span>)
</div><div id="lc50">		{
</div><div id="lc51">		
</div><div id="lc52">			<span style="color: #008000">exit</span>;
</div><div id="lc53">		}
</div><div id="lc54">		<span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">@x</span> <span style="color: #666666">=</span> <span style="color: #19177C">$s</span><span style="color: #666666">-&gt;</span>can_read(<span style="color: #666666">2</span>);
</div><div id="lc55">		<span style="color: #008000; font-weight: bold">if</span> (<span style="color: #19177C">@x</span> <span style="color: #666666">&gt;</span> <span style="color: #666666">0</span>)
</div><div id="lc56">		{
</div><div id="lc57">			_log(<span style="color: #BA2121">&quot;a-ha! socket event&quot;</span>);
</div><div id="lc58">			<span style="color: #19177C">$conn</span><span style="color: #666666">-&gt;</span>consumeInput;
</div><div id="lc59">			<span style="color: #008000; font-weight: bold">while</span> (<span style="color: #008000; font-weight: bold">my</span> (<span style="color: #19177C">$table</span>, <span style="color: #19177C">$pid</span>) <span style="color: #666666">=</span> <span style="color: #19177C">$conn</span><span style="color: #666666">-&gt;</span>notifies)
</div><div id="lc60">			{
</div><div id="lc61">				<span style="color: #008000; font-weight: bold">if</span> (<span style="color: #008000">exists</span>(<span style="color: #19177C">$notify</span>{<span style="color: #19177C">$table</span>}))
</div><div id="lc62">				{
</div><div id="lc63">					_log(<span style="color: #BA2121">&quot;Got notify for $table!&quot;</span>);
</div><div id="lc64">					<span style="color: #19177C">$notify</span>{<span style="color: #19177C">$table</span>}();
</div><div id="lc65">					<span style="color: #008000">sleep</span> <span style="color: #666666">1</span>; <span style="color: #408080; font-style: italic"># Filtering too many updates/sec</span>
</div><div id="lc66">				}
</div><div id="lc67">			}
</div><div id="lc68">		}
</div><div id="lc69">		<span style="color: #008000; font-weight: bold">else</span>
</div><div id="lc70">		{
</div><div id="lc71">			<span style="color: #408080; font-style: italic"># _log(&quot;empty loop..&quot;);</span>
</div><div id="lc72">			<span style="color: #408080; font-style: italic"># some kind of ping</span>
</div><div id="lc73">			<span style="color: #008000; font-weight: bold">if</span> (<span style="color: #008000">time</span>() <span style="color: #666666">&gt;</span> <span style="color: #19177C">$last_ping</span> <span style="color: #666666">+</span> <span style="color: #19177C">$ping_ttl</span>)
</div><div id="lc74">			{
</div><div id="lc75">				<span style="color: #19177C">$last_ping</span> <span style="color: #666666">=</span> <span style="color: #008000">time</span>();
</div><div id="lc76">				<span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$res</span> <span style="color: #666666">=</span> <span style="color: #19177C">$conn</span><span style="color: #666666">-&gt;</span><span style="color: #008000">exec</span>(<span style="color: #BA2121">&quot;SELECT 42&quot;</span>);
</div><div id="lc77">				<span style="color: #008000; font-weight: bold">if</span> (<span style="color: #19177C">$res</span><span style="color: #666666">-&gt;</span>resultStatus <span style="color: #666666">!=</span> PGRES_TUPLES_OK) {
</div><div id="lc78">					_log(<span style="color: #BA2121">&quot;DB connection failed (ping check)&quot;</span>);
</div><div id="lc79">					<span style="color: #008000; font-weight: bold">last</span>;
</div><div id="lc80">				}
</div><div id="lc81">			}
</div><div id="lc82">		}
</div><div id="lc83">
</div><div id="lc84">		<span style="color: #008000; font-weight: bold">if</span> (<span style="color: #19177C">$conn</span><span style="color: #666666">-&gt;</span>status <span style="color: #666666">!=</span> PGRES_CONNECTION_OK) {
</div><div id="lc85">			_log(<span style="color: #BA2121">&quot;DB connection failed&quot;</span>);
</div><div id="lc86">			<span style="color: #008000; font-weight: bold">last</span>;
</div><div id="lc87">		}
</div><div id="lc88">	}
</div><div id="lc89">
</div><div id="lc90">	<span style="color: #008000">undef</span> <span style="color: #19177C">$s</span>;
</div><div id="lc91">}
</div><div id="lc92">
</div><div id="lc93">
</div><div id="lc94"><span style="color: #008000; font-weight: bold">sub </span><span style="color: #0000FF">process_user_insert</span> {
</div><div id="lc95">	<span style="color: #008000; font-weight: bold">print</span> <span style="color: #BA2121">&quot;process_user_insert\n&quot;</span>;
</div><div id="lc96">}
</div><div id="lc97">
</div><div id="lc98"><span style="color: #008000; font-weight: bold">sub </span><span style="color: #0000FF">process_user_update</span> {
</div><div id="lc99">	<span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$user_id</span> <span style="color: #666666">=</span> <span style="color: #19177C">$_</span>[<span style="color: #666666">0</span>];
</div><div id="lc100">	<span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$sql</span> <span style="color: #666666">=</span> <span style="color: #BA2121">&quot;UPDATE phpbb_users SET ldap_task_status = 2 WHERE user_id = &quot;</span> <span style="color: #666666">.</span> <span style="color: #19177C">$user_id</span>;
</div><div id="lc101">	<span style="color: #19177C">$conn</span><span style="color: #666666">-&gt;</span><span style="color: #008000">exec</span>(<span style="color: #19177C">$sql</span>);
</div><div id="lc102">}
</div><div id="lc103">
</div><div id="lc104"><span style="color: #008000; font-weight: bold">sub </span><span style="color: #0000FF">check_user_update</span> {
</div><div id="lc105">	<span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$sql</span> <span style="color: #666666">=</span> <span style="color: #BA2121">&quot;SELECT user_id FROM phpbb_users WHERE ldap_task_status = 0&quot;</span>;
</div><div id="lc106">	<span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">$res</span> <span style="color: #666666">=</span> <span style="color: #19177C">$conn</span><span style="color: #666666">-&gt;</span><span style="color: #008000">exec</span>(<span style="color: #19177C">$sql</span>);
</div><div id="lc107">	<span style="color: #008000; font-weight: bold">if</span> (<span style="color: #19177C">$res</span><span style="color: #666666">-&gt;</span>resultStatus <span style="color: #666666">!=</span> PGRES_TUPLES_OK) {
</div><div id="lc108">		_log(<span style="color: #BA2121">&quot;SELECT error: $conn-&gt;errorMessage&quot;</span>);
</div><div id="lc109">		<span style="color: #008000; font-weight: bold">return</span> <span style="color: #666666">-1</span>;
</div><div id="lc110">	}
</div><div id="lc111">	<span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">@rows</span>;
</div><div id="lc112">	<span style="color: #008000; font-weight: bold">while</span> (<span style="color: #008000; font-weight: bold">my</span> <span style="color: #19177C">@row</span> <span style="color: #666666">=</span> <span style="color: #19177C">$res</span><span style="color: #666666">-&gt;</span>fetchrow()) { <span style="color: #008000">push</span> <span style="color: #19177C">@rows</span>, <span style="color: #19177C">$row</span>[<span style="color: #666666">0</span>]; }
</div><div id="lc113">	<span style="color: #008000; font-weight: bold">foreach</span> <span style="color: #19177C">$user_id</span> (<span style="color: #19177C">@rows</span>)
</div><div id="lc114">	{
</div><div id="lc115">		<span style="color: #008000; font-weight: bold">print</span> <span style="color: #BA2121">&quot;Processing user &quot;</span> <span style="color: #666666">.</span> <span style="color: #19177C">$user_id</span> <span style="color: #666666">.</span> <span style="color: #BA2121">&quot;\n&quot;</span>;
</div><div id="lc116">		process_user_update(<span style="color: #19177C">$user_id</span>);
</div><div id="lc117">	}
</div><div id="lc118">
</div><div id="lc119">	<span style="color: #008000; font-weight: bold">print</span> <span style="color: #BA2121">&quot;process_user_update\n&quot;</span>;
</div><div id="lc120">}
</div><div id="lc121">
</div><div id="lc122"><span style="color: #008000; font-weight: bold">sub </span><span style="color: #0000FF">process_user_delete</span> {
</div><div id="lc123">	<span style="color: #008000; font-weight: bold">print</span> <span style="color: #BA2121">&quot;process_user_delete\n&quot;</span>;
</div><div id="lc124">}
</div><div id="lc125">
</div><div id="lc126"><span style="color: #008000; font-weight: bold">sub </span><span style="color: #0000FF">_log</span> {
</div><div id="lc127">	<span style="color: #008000; font-weight: bold">print</span> <span style="color: #008000">localtime</span>() <span style="color: #666666">.</span> <span style="color: #BA2121">&quot; &quot;</span> <span style="color: #666666">.</span> <span style="color: #008000">join</span>(<span style="color: #BA2121">&quot; &quot;</span>, <span style="color: #19177C">@_</span>) <span style="color: #666666">.</span> <span style="color: #BA2121">&quot;\n&quot;</span>;
</div><div id="lc128">}
</div></pre></div>
<p style="padding: 0; margin: 2em 0 1em 0; font-size: 0.8em; color: #666;"><span style="padding: 0 1em; background-color: #f5f5f5;"> Colored with <a style="color: #333" href="http://dumpz.org">dumpz.org</a></span></p>

BBCODE Copy To Clipboarddone!

[color=#408080][i]#!/usr/bin/perl[/i][/color]

[color=#008000][b]use[/b][/color] Pg;
[color=#008000][b]use[/b][/color] [color=#0000FF][b]IO::[/b][/color]Select;
[color=#008000][b]use[/b][/color] Socket [color=#008000]qw(inet_aton)[/color];

[color=#008000][b]my[/b][/color] [color=#19177C]$dbname[/color] [color=#666666]=[/color] [color=#BA2121]"xxxx"[/color];
[color=#008000][b]my[/b][/color] [color=#19177C]$dbhost[/color] [color=#666666]=[/color] [color=#BA2121]"::1"[/color];
[color=#008000][b]my[/b][/color] [color=#19177C]$dbuser[/color] [color=#666666]=[/color] [color=#BA2121]"xxxx"[/color];
[color=#008000][b]my[/b][/color] [color=#19177C]$dbpass[/color] [color=#666666]=[/color] [color=#BA2121]"xxxx"[/color];
[color=#008000][b]my[/b][/color] [color=#19177C]$max_ttl[/color] [color=#666666]=[/color] [color=#666666]1800[/color];
[color=#008000][b]my[/b][/color] [color=#19177C]$ping_ttl[/color] [color=#666666]=[/color] [color=#666666]60[/color];
[color=#008000][b]my[/b][/color] [color=#19177C]%notify[/color] [color=#666666]=[/color] ([color=#BA2121]"acl_user_insert"[/color] [color=#666666]=>[/color] [color=#BA2121]"process_user_insert"[/color], [color=#BA2121]"acl_user_update"[/color] [color=#666666]=>[/color] [color=#BA2121]"check_user_update"[/color], [color=#BA2121]"acl_user_delete"[/color] [color=#666666]=>[/color] [color=#BA2121]"process_user_delete"[/color]);
[color=#008000][b]my[/b][/color] [color=#19177C]$log[/color] [color=#666666]=[/color] [color=#BA2121]"/var/log/acl_change.log"[/color];

[color=#008000][b]my[/b][/color] [color=#19177C]$till[/color] [color=#666666]=[/color] [color=#008000]time[/color]() [color=#666666]+[/color] [color=#19177C]$max_ttl[/color] [color=#666666]-[/color] [color=#666666]3[/color];
[color=#008000][b]my[/b][/color] [color=#19177C]$last_ping[/color] [color=#666666]=[/color] [color=#008000]time[/color]();

[color=#408080][i]#daemonize();[/i][/color]

[color=#008000][b]my[/b][/color] [color=#19177C]$conn[/color];

[color=#008000][b]for[/b][/color](;;)
{
	[color=#008000][b]if[/b][/color] ([color=#008000]time[/color]() [color=#666666]>[/color] [color=#19177C]$till[/color]) { [color=#008000]exit[/color]; }
	[color=#19177C]$conn[/color] [color=#666666]=[/color] [color=#0000FF][b]Pg::[/b][/color]setdbLogin([color=#19177C]$dbhost[/color], [color=#666666]5432[/color], [color=#19177C]$pgoptions[/color], [color=#BA2121]""[/color], [color=#19177C]$dbname[/color], [color=#19177C]$dbuser[/color], [color=#19177C]$dbpass[/color]);

[color=#008000][b]if[/b][/color] (([color=#19177C]$conn[/color][color=#666666]->[/color]status [color=#666666]!=[/color] PGRES_CONNECTION_OK))
	{
		_log([color=#BA2121]"Err: $conn->errorMessage"[/color]);
		[color=#008000]undef[/color] [color=#19177C]$conn[/color];
		[color=#008000][b]next[/b][/color];
	}

[color=#008000][b]foreach[/b][/color] [color=#19177C]$event[/color] ([color=#008000]keys[/color]([color=#19177C]%notify[/color]))
	{
		[color=#008000][b]my[/b][/color] [color=#19177C]$res[/color] [color=#666666]=[/color] [color=#19177C]$conn[/color][color=#666666]->[/color][color=#008000]exec[/color]([color=#BA2121]"LISTEN $event"[/color]);
		[color=#008000][b]if[/b][/color] ([color=#19177C]$res[/color][color=#666666]->[/color]resultStatus [color=#666666]!=[/color] PGRES_COMMAND_OK)
		{
			_log([color=#BA2121]"LISTEN error: "[/color] [color=#666666].[/color] [color=#19177C]$conn[/color][color=#666666]->[/color]errorMessage [color=#666666].[/color] [color=#BA2121]""[/color]);
			[color=#008000][b]next[/b][/color];
		}
	}

[color=#008000][b]my[/b][/color] [color=#19177C]$s[/color] [color=#666666]=[/color] [color=#0000FF][b]IO::[/b][/color]Select[color=#666666]->[/color][color=#008000][b]new[/b][/color]();
	[color=#19177C]$s[/color][color=#666666]->[/color]add([color=#19177C]$conn[/color][color=#666666]->[/color][color=#008000]socket[/color]);
	[color=#008000][b]for[/b][/color](;;)
	{
		[color=#008000][b]if[/b][/color] ([color=#008000]time[/color]() [color=#666666]>[/color] [color=#19177C]$till[/color])
		{
		
			[color=#008000]exit[/color];
		}
		[color=#008000][b]my[/b][/color] [color=#19177C]@x[/color] [color=#666666]=[/color] [color=#19177C]$s[/color][color=#666666]->[/color]can_read([color=#666666]2[/color]);
		[color=#008000][b]if[/b][/color] ([color=#19177C]@x[/color] [color=#666666]>[/color] [color=#666666]0[/color])
		{
			_log([color=#BA2121]"a-ha! socket event"[/color]);
			[color=#19177C]$conn[/color][color=#666666]->[/color]consumeInput;
			[color=#008000][b]while[/b][/color] ([color=#008000][b]my[/b][/color] ([color=#19177C]$table[/color], [color=#19177C]$pid[/color]) [color=#666666]=[/color] [color=#19177C]$conn[/color][color=#666666]->[/color]notifies)
			{
				[color=#008000][b]if[/b][/color] ([color=#008000]exists[/color]([color=#19177C]$notify[/color]{[color=#19177C]$table[/color]}))
				{
					_log([color=#BA2121]"Got notify for $table!"[/color]);
					[color=#19177C]$notify[/color]{[color=#19177C]$table[/color]}();
					[color=#008000]sleep[/color] [color=#666666]1[/color]; [color=#408080][i]# Filtering too many updates/sec[/i][/color]
				}
			}
		}
		[color=#008000][b]else[/b][/color]
		{
			[color=#408080][i]# _log("empty loop..");[/i][/color]
			[color=#408080][i]# some kind of ping[/i][/color]
			[color=#008000][b]if[/b][/color] ([color=#008000]time[/color]() [color=#666666]>[/color] [color=#19177C]$last_ping[/color] [color=#666666]+[/color] [color=#19177C]$ping_ttl[/color])
			{
				[color=#19177C]$last_ping[/color] [color=#666666]=[/color] [color=#008000]time[/color]();
				[color=#008000][b]my[/b][/color] [color=#19177C]$res[/color] [color=#666666]=[/color] [color=#19177C]$conn[/color][color=#666666]->[/color][color=#008000]exec[/color]([color=#BA2121]"SELECT 42"[/color]);
				[color=#008000][b]if[/b][/color] ([color=#19177C]$res[/color][color=#666666]->[/color]resultStatus [color=#666666]!=[/color] PGRES_TUPLES_OK) {
					_log([color=#BA2121]"DB connection failed (ping check)"[/color]);
					[color=#008000][b]last[/b][/color];
				}
			}
		}

[color=#008000][b]if[/b][/color] ([color=#19177C]$conn[/color][color=#666666]->[/color]status [color=#666666]!=[/color] PGRES_CONNECTION_OK) {
			_log([color=#BA2121]"DB connection failed"[/color]);
			[color=#008000][b]last[/b][/color];
		}
	}

[color=#008000]undef[/color] [color=#19177C]$s[/color];
}

[color=#008000][b]sub [/b][/color][color=#0000FF]process_user_insert[/color] {
	[color=#008000][b]print[/b][/color] [color=#BA2121]"process_user_insert\n"[/color];
}

[color=#008000][b]sub [/b][/color][color=#0000FF]process_user_update[/color] {
	[color=#008000][b]my[/b][/color] [color=#19177C]$user_id[/color] [color=#666666]=[/color] [color=#19177C]$_[/color][[color=#666666]0[/color]];
	[color=#008000][b]my[/b][/color] [color=#19177C]$sql[/color] [color=#666666]=[/color] [color=#BA2121]"UPDATE phpbb_users SET ldap_task_status = 2 WHERE user_id = "[/color] [color=#666666].[/color] [color=#19177C]$user_id[/color];
	[color=#19177C]$conn[/color][color=#666666]->[/color][color=#008000]exec[/color]([color=#19177C]$sql[/color]);
}

[color=#008000][b]sub [/b][/color][color=#0000FF]check_user_update[/color] {
	[color=#008000][b]my[/b][/color] [color=#19177C]$sql[/color] [color=#666666]=[/color] [color=#BA2121]"SELECT user_id FROM phpbb_users WHERE ldap_task_status = 0"[/color];
	[color=#008000][b]my[/b][/color] [color=#19177C]$res[/color] [color=#666666]=[/color] [color=#19177C]$conn[/color][color=#666666]->[/color][color=#008000]exec[/color]([color=#19177C]$sql[/color]);
	[color=#008000][b]if[/b][/color] ([color=#19177C]$res[/color][color=#666666]->[/color]resultStatus [color=#666666]!=[/color] PGRES_TUPLES_OK) {
		_log([color=#BA2121]"SELECT error: $conn->errorMessage"[/color]);
		[color=#008000][b]return[/b][/color] [color=#666666]-[/color][color=#666666]1[/color];
	}
	[color=#008000][b]my[/b][/color] [color=#19177C]@rows[/color];
	[color=#008000][b]while[/b][/color] ([color=#008000][b]my[/b][/color] [color=#19177C]@row[/color] [color=#666666]=[/color] [color=#19177C]$res[/color][color=#666666]->[/color]fetchrow()) { [color=#008000]push[/color] [color=#19177C]@rows[/color], [color=#19177C]$row[/color][[color=#666666]0[/color]]; }
	[color=#008000][b]foreach[/b][/color] [color=#19177C]$user_id[/color] ([color=#19177C]@rows[/color])
	{
		[color=#008000][b]print[/b][/color] [color=#BA2121]"Processing user "[/color] [color=#666666].[/color] [color=#19177C]$user_id[/color] [color=#666666].[/color] [color=#BA2121]"\n"[/color];
		process_user_update([color=#19177C]$user_id[/color]);
	}

[color=#008000][b]print[/b][/color] [color=#BA2121]"process_user_update\n"[/color];
}

[color=#008000][b]sub [/b][/color][color=#0000FF]process_user_delete[/color] {
	[color=#008000][b]print[/b][/color] [color=#BA2121]"process_user_delete\n"[/color];
}

[color=#008000][b]sub [/b][/color][color=#0000FF]_log[/color] {
	[color=#008000][b]print[/b][/color] [color=#008000]localtime[/color]() [color=#666666].[/color] [color=#BA2121]" "[/color] [color=#666666].[/color] [color=#008000]join[/color]([color=#BA2121]" "[/color], [color=#19177C]@_[/color]) [color=#666666].[/color] [color=#BA2121]"\n"[/color];
}

--------------------------------------
Colored with http://dumpz.org

Light HTML Copy To Clipboarddone!

That method generates HTML with CSS classes. Hence you'll need the style sheet file

<div class="highlight"><pre><div id="lc1"><span class="c1">#!/usr/bin/perl</span>
</div><div id="lc2">
</div><div id="lc3"><span class="k">use</span> <span class="n">Pg</span><span class="p">;</span>
</div><div id="lc4"><span class="k">use</span> <span class="nn">IO::</span><span class="n">Select</span><span class="p">;</span>
</div><div id="lc5"><span class="k">use</span> <span class="n">Socket</span> <span class="sx">qw(inet_aton)</span><span class="p">;</span>
</div><div id="lc6">
</div><div id="lc7"><span class="k">my</span> <span class="nv">$dbname</span> <span class="o">=</span> <span class="s">&quot;xxxx&quot;</span><span class="p">;</span>
</div><div id="lc8"><span class="k">my</span> <span class="nv">$dbhost</span> <span class="o">=</span> <span class="s">&quot;::1&quot;</span><span class="p">;</span>
</div><div id="lc9"><span class="k">my</span> <span class="nv">$dbuser</span> <span class="o">=</span> <span class="s">&quot;xxxx&quot;</span><span class="p">;</span>
</div><div id="lc10"><span class="k">my</span> <span class="nv">$dbpass</span> <span class="o">=</span> <span class="s">&quot;xxxx&quot;</span><span class="p">;</span>
</div><div id="lc11"><span class="k">my</span> <span class="nv">$max_ttl</span> <span class="o">=</span> <span class="mi">1800</span><span class="p">;</span>
</div><div id="lc12"><span class="k">my</span> <span class="nv">$ping_ttl</span> <span class="o">=</span> <span class="mi">60</span><span class="p">;</span>
</div><div id="lc13"><span class="k">my</span> <span class="nv">%notify</span> <span class="o">=</span> <span class="p">(</span><span class="s">&quot;acl_user_insert&quot;</span> <span class="o">=&gt;</span> <span class="s">&quot;process_user_insert&quot;</span><span class="p">,</span> <span class="s">&quot;acl_user_update&quot;</span> <span class="o">=&gt;</span> <span class="s">&quot;check_user_update&quot;</span><span class="p">,</span> <span class="s">&quot;acl_user_delete&quot;</span> <span class="o">=&gt;</span> <span class="s">&quot;process_user_delete&quot;</span><span class="p">);</span>
</div><div id="lc14"><span class="k">my</span> <span class="nv">$log</span> <span class="o">=</span> <span class="s">&quot;/var/log/acl_change.log&quot;</span><span class="p">;</span>
</div><div id="lc15">
</div><div id="lc16"><span class="k">my</span> <span class="nv">$till</span> <span class="o">=</span> <span class="nb">time</span><span class="p">()</span> <span class="o">+</span> <span class="nv">$max_ttl</span> <span class="o">-</span> <span class="mi">3</span><span class="p">;</span>
</div><div id="lc17"><span class="k">my</span> <span class="nv">$last_ping</span> <span class="o">=</span> <span class="nb">time</span><span class="p">();</span>
</div><div id="lc18">
</div><div id="lc19"><span class="c1">#daemonize();</span>
</div><div id="lc20">
</div><div id="lc21"><span class="k">my</span> <span class="nv">$conn</span><span class="p">;</span>
</div><div id="lc22">
</div><div id="lc23"><span class="k">for</span><span class="p">(;;)</span>
</div><div id="lc24"><span class="p">{</span>
</div><div id="lc25">	<span class="k">if</span> <span class="p">(</span><span class="nb">time</span><span class="p">()</span> <span class="o">&gt;</span> <span class="nv">$till</span><span class="p">)</span> <span class="p">{</span> <span class="nb">exit</span><span class="p">;</span> <span class="p">}</span>
</div><div id="lc26">	<span class="nv">$conn</span> <span class="o">=</span> <span class="nn">Pg::</span><span class="n">setdbLogin</span><span class="p">(</span><span class="nv">$dbhost</span><span class="p">,</span> <span class="mi">5432</span><span class="p">,</span> <span class="nv">$pgoptions</span><span class="p">,</span> <span class="s">&quot;&quot;</span><span class="p">,</span> <span class="nv">$dbname</span><span class="p">,</span> <span class="nv">$dbuser</span><span class="p">,</span> <span class="nv">$dbpass</span><span class="p">);</span>
</div><div id="lc27">
</div><div id="lc28">	<span class="k">if</span> <span class="p">((</span><span class="nv">$conn</span><span class="o">-&gt;</span><span class="n">status</span> <span class="o">!=</span> <span class="n">PGRES_CONNECTION_OK</span><span class="p">))</span>
</div><div id="lc29">	<span class="p">{</span>
</div><div id="lc30">		<span class="n">_log</span><span class="p">(</span><span class="s">&quot;Err: $conn-&gt;errorMessage&quot;</span><span class="p">);</span>
</div><div id="lc31">		<span class="nb">undef</span> <span class="nv">$conn</span><span class="p">;</span>
</div><div id="lc32">		<span class="k">next</span><span class="p">;</span>
</div><div id="lc33">	<span class="p">}</span>
</div><div id="lc34">
</div><div id="lc35">	<span class="k">foreach</span> <span class="nv">$event</span> <span class="p">(</span><span class="nb">keys</span><span class="p">(</span><span class="nv">%notify</span><span class="p">))</span>
</div><div id="lc36">	<span class="p">{</span>
</div><div id="lc37">		<span class="k">my</span> <span class="nv">$res</span> <span class="o">=</span> <span class="nv">$conn</span><span class="o">-&gt;</span><span class="nb">exec</span><span class="p">(</span><span class="s">&quot;LISTEN $event&quot;</span><span class="p">);</span>
</div><div id="lc38">		<span class="k">if</span> <span class="p">(</span><span class="nv">$res</span><span class="o">-&gt;</span><span class="n">resultStatus</span> <span class="o">!=</span> <span class="n">PGRES_COMMAND_OK</span><span class="p">)</span>
</div><div id="lc39">		<span class="p">{</span>
</div><div id="lc40">			<span class="n">_log</span><span class="p">(</span><span class="s">&quot;LISTEN error: &quot;</span> <span class="o">.</span> <span class="nv">$conn</span><span class="o">-&gt;</span><span class="n">errorMessage</span> <span class="o">.</span> <span class="s">&quot;&quot;</span><span class="p">);</span>
</div><div id="lc41">			<span class="k">next</span><span class="p">;</span>
</div><div id="lc42">		<span class="p">}</span>
</div><div id="lc43">	<span class="p">}</span>
</div><div id="lc44">
</div><div id="lc45">	<span class="k">my</span> <span class="nv">$s</span> <span class="o">=</span> <span class="nn">IO::</span><span class="n">Select</span><span class="o">-&gt;</span><span class="k">new</span><span class="p">();</span>
</div><div id="lc46">	<span class="nv">$s</span><span class="o">-&gt;</span><span class="n">add</span><span class="p">(</span><span class="nv">$conn</span><span class="o">-&gt;</span><span class="nb">socket</span><span class="p">);</span>
</div><div id="lc47">	<span class="k">for</span><span class="p">(;;)</span>
</div><div id="lc48">	<span class="p">{</span>
</div><div id="lc49">		<span class="k">if</span> <span class="p">(</span><span class="nb">time</span><span class="p">()</span> <span class="o">&gt;</span> <span class="nv">$till</span><span class="p">)</span>
</div><div id="lc50">		<span class="p">{</span>
</div><div id="lc51">		
</div><div id="lc52">			<span class="nb">exit</span><span class="p">;</span>
</div><div id="lc53">		<span class="p">}</span>
</div><div id="lc54">		<span class="k">my</span> <span class="nv">@x</span> <span class="o">=</span> <span class="nv">$s</span><span class="o">-&gt;</span><span class="n">can_read</span><span class="p">(</span><span class="mi">2</span><span class="p">);</span>
</div><div id="lc55">		<span class="k">if</span> <span class="p">(</span><span class="nv">@x</span> <span class="o">&gt;</span> <span class="mi">0</span><span class="p">)</span>
</div><div id="lc56">		<span class="p">{</span>
</div><div id="lc57">			<span class="n">_log</span><span class="p">(</span><span class="s">&quot;a-ha! socket event&quot;</span><span class="p">);</span>
</div><div id="lc58">			<span class="nv">$conn</span><span class="o">-&gt;</span><span class="n">consumeInput</span><span class="p">;</span>
</div><div id="lc59">			<span class="k">while</span> <span class="p">(</span><span class="k">my</span> <span class="p">(</span><span class="nv">$table</span><span class="p">,</span> <span class="nv">$pid</span><span class="p">)</span> <span class="o">=</span> <span class="nv">$conn</span><span class="o">-&gt;</span><span class="n">notifies</span><span class="p">)</span>
</div><div id="lc60">			<span class="p">{</span>
</div><div id="lc61">				<span class="k">if</span> <span class="p">(</span><span class="nb">exists</span><span class="p">(</span><span class="nv">$notify</span><span class="p">{</span><span class="nv">$table</span><span class="p">}))</span>
</div><div id="lc62">				<span class="p">{</span>
</div><div id="lc63">					<span class="n">_log</span><span class="p">(</span><span class="s">&quot;Got notify for $table!&quot;</span><span class="p">);</span>
</div><div id="lc64">					<span class="nv">$notify</span><span class="p">{</span><span class="nv">$table</span><span class="p">}();</span>
</div><div id="lc65">					<span class="nb">sleep</span> <span class="mi">1</span><span class="p">;</span> <span class="c1"># Filtering too many updates/sec</span>
</div><div id="lc66">				<span class="p">}</span>
</div><div id="lc67">			<span class="p">}</span>
</div><div id="lc68">		<span class="p">}</span>
</div><div id="lc69">		<span class="k">else</span>
</div><div id="lc70">		<span class="p">{</span>
</div><div id="lc71">			<span class="c1"># _log(&quot;empty loop..&quot;);</span>
</div><div id="lc72">			<span class="c1"># some kind of ping</span>
</div><div id="lc73">			<span class="k">if</span> <span class="p">(</span><span class="nb">time</span><span class="p">()</span> <span class="o">&gt;</span> <span class="nv">$last_ping</span> <span class="o">+</span> <span class="nv">$ping_ttl</span><span class="p">)</span>
</div><div id="lc74">			<span class="p">{</span>
</div><div id="lc75">				<span class="nv">$last_ping</span> <span class="o">=</span> <span class="nb">time</span><span class="p">();</span>
</div><div id="lc76">				<span class="k">my</span> <span class="nv">$res</span> <span class="o">=</span> <span class="nv">$conn</span><span class="o">-&gt;</span><span class="nb">exec</span><span class="p">(</span><span class="s">&quot;SELECT 42&quot;</span><span class="p">);</span>
</div><div id="lc77">				<span class="k">if</span> <span class="p">(</span><span class="nv">$res</span><span class="o">-&gt;</span><span class="n">resultStatus</span> <span class="o">!=</span> <span class="n">PGRES_TUPLES_OK</span><span class="p">)</span> <span class="p">{</span>
</div><div id="lc78">					<span class="n">_log</span><span class="p">(</span><span class="s">&quot;DB connection failed (ping check)&quot;</span><span class="p">);</span>
</div><div id="lc79">					<span class="k">last</span><span class="p">;</span>
</div><div id="lc80">				<span class="p">}</span>
</div><div id="lc81">			<span class="p">}</span>
</div><div id="lc82">		<span class="p">}</span>
</div><div id="lc83">
</div><div id="lc84">		<span class="k">if</span> <span class="p">(</span><span class="nv">$conn</span><span class="o">-&gt;</span><span class="n">status</span> <span class="o">!=</span> <span class="n">PGRES_CONNECTION_OK</span><span class="p">)</span> <span class="p">{</span>
</div><div id="lc85">			<span class="n">_log</span><span class="p">(</span><span class="s">&quot;DB connection failed&quot;</span><span class="p">);</span>
</div><div id="lc86">			<span class="k">last</span><span class="p">;</span>
</div><div id="lc87">		<span class="p">}</span>
</div><div id="lc88">	<span class="p">}</span>
</div><div id="lc89">
</div><div id="lc90">	<span class="nb">undef</span> <span class="nv">$s</span><span class="p">;</span>
</div><div id="lc91"><span class="p">}</span>
</div><div id="lc92">
</div><div id="lc93">
</div><div id="lc94"><span class="k">sub </span><span class="nf">process_user_insert</span> <span class="p">{</span>
</div><div id="lc95">	<span class="k">print</span> <span class="s">&quot;process_user_insert\n&quot;</span><span class="p">;</span>
</div><div id="lc96"><span class="p">}</span>
</div><div id="lc97">
</div><div id="lc98"><span class="k">sub </span><span class="nf">process_user_update</span> <span class="p">{</span>
</div><div id="lc99">	<span class="k">my</span> <span class="nv">$user_id</span> <span class="o">=</span> <span class="nv">$_</span><span class="p">[</span><span class="mi">0</span><span class="p">];</span>
</div><div id="lc100">	<span class="k">my</span> <span class="nv">$sql</span> <span class="o">=</span> <span class="s">&quot;UPDATE phpbb_users SET ldap_task_status = 2 WHERE user_id = &quot;</span> <span class="o">.</span> <span class="nv">$user_id</span><span class="p">;</span>
</div><div id="lc101">	<span class="nv">$conn</span><span class="o">-&gt;</span><span class="nb">exec</span><span class="p">(</span><span class="nv">$sql</span><span class="p">);</span>
</div><div id="lc102"><span class="p">}</span>
</div><div id="lc103">
</div><div id="lc104"><span class="k">sub </span><span class="nf">check_user_update</span> <span class="p">{</span>
</div><div id="lc105">	<span class="k">my</span> <span class="nv">$sql</span> <span class="o">=</span> <span class="s">&quot;SELECT user_id FROM phpbb_users WHERE ldap_task_status = 0&quot;</span><span class="p">;</span>
</div><div id="lc106">	<span class="k">my</span> <span class="nv">$res</span> <span class="o">=</span> <span class="nv">$conn</span><span class="o">-&gt;</span><span class="nb">exec</span><span class="p">(</span><span class="nv">$sql</span><span class="p">);</span>
</div><div id="lc107">	<span class="k">if</span> <span class="p">(</span><span class="nv">$res</span><span class="o">-&gt;</span><span class="n">resultStatus</span> <span class="o">!=</span> <span class="n">PGRES_TUPLES_OK</span><span class="p">)</span> <span class="p">{</span>
</div><div id="lc108">		<span class="n">_log</span><span class="p">(</span><span class="s">&quot;SELECT error: $conn-&gt;errorMessage&quot;</span><span class="p">);</span>
</div><div id="lc109">		<span class="k">return</span> <span class="o">-</span><span class="mi">1</span><span class="p">;</span>
</div><div id="lc110">	<span class="p">}</span>
</div><div id="lc111">	<span class="k">my</span> <span class="nv">@rows</span><span class="p">;</span>
</div><div id="lc112">	<span class="k">while</span> <span class="p">(</span><span class="k">my</span> <span class="nv">@row</span> <span class="o">=</span> <span class="nv">$res</span><span class="o">-&gt;</span><span class="n">fetchrow</span><span class="p">())</span> <span class="p">{</span> <span class="nb">push</span> <span class="nv">@rows</span><span class="p">,</span> <span class="nv">$row</span><span class="p">[</span><span class="mi">0</span><span class="p">];</span> <span class="p">}</span>
</div><div id="lc113">	<span class="k">foreach</span> <span class="nv">$user_id</span> <span class="p">(</span><span class="nv">@rows</span><span class="p">)</span>
</div><div id="lc114">	<span class="p">{</span>
</div><div id="lc115">		<span class="k">print</span> <span class="s">&quot;Processing user &quot;</span> <span class="o">.</span> <span class="nv">$user_id</span> <span class="o">.</span> <span class="s">&quot;\n&quot;</span><span class="p">;</span>
</div><div id="lc116">		<span class="n">process_user_update</span><span class="p">(</span><span class="nv">$user_id</span><span class="p">);</span>
</div><div id="lc117">	<span class="p">}</span>
</div><div id="lc118">
</div><div id="lc119">	<span class="k">print</span> <span class="s">&quot;process_user_update\n&quot;</span><span class="p">;</span>
</div><div id="lc120"><span class="p">}</span>
</div><div id="lc121">
</div><div id="lc122"><span class="k">sub </span><span class="nf">process_user_delete</span> <span class="p">{</span>
</div><div id="lc123">	<span class="k">print</span> <span class="s">&quot;process_user_delete\n&quot;</span><span class="p">;</span>
</div><div id="lc124"><span class="p">}</span>
</div><div id="lc125">
</div><div id="lc126"><span class="k">sub </span><span class="nf">_log</span> <span class="p">{</span>
</div><div id="lc127">	<span class="k">print</span> <span class="nb">localtime</span><span class="p">()</span> <span class="o">.</span> <span class="s">&quot; &quot;</span> <span class="o">.</span> <span class="nb">join</span><span class="p">(</span><span class="s">&quot; &quot;</span><span class="p">,</span> <span class="nv">@_</span><span class="p">)</span> <span class="o">.</span> <span class="s">&quot;\n&quot;</span><span class="p">;</span>
</div><div id="lc128"><span class="p">}</span>
</div></pre></div>
<p style="padding: 0; margin: 2em 0 1em 0; font-size: 0.8em; color: #666;"><span style="padding: 0 1em; background-color: #f5f5f5;"> Colored with <a style="color: #333" href="http://dumpz.org">dumpz.org</a></span></p>

Habrahabr.ru HTML Copy To Clipboarddone!

Use that HTML for publications on habrahabr.ru

<font color="#008000"><strong>use</strong></font>&nbsp;Pg;
<font color="#008000"><strong>use</strong></font>&nbsp;<font color="#0000FF"><strong>IO::</strong></font>Select;
<font color="#008000"><strong>use</strong></font>&nbsp;Socket&nbsp;<font color="#008000">qw(inet_aton)</font>;

<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$dbname</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#BA2121">&quot;xxxx&quot;</font>;
<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$dbhost</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#BA2121">&quot;::1&quot;</font>;
<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$dbuser</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#BA2121">&quot;xxxx&quot;</font>;
<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$dbpass</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#BA2121">&quot;xxxx&quot;</font>;
<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$max_ttl</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#666666">1800</font>;
<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$ping_ttl</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#666666">60</font>;
<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">%notify</font>&nbsp;<font color="#666666">=</font>&nbsp;(<font color="#BA2121">&quot;acl_user_insert&quot;</font>&nbsp;<font color="#666666">=&gt;</font>&nbsp;<font color="#BA2121">&quot;process_user_insert&quot;</font>,&nbsp;<font color="#BA2121">&quot;acl_user_update&quot;</font>&nbsp;<font color="#666666">=&gt;</font>&nbsp;<font color="#BA2121">&quot;check_user_update&quot;</font>,&nbsp;<font color="#BA2121">&quot;acl_user_delete&quot;</font>&nbsp;<font color="#666666">=&gt;</font>&nbsp;<font color="#BA2121">&quot;process_user_delete&quot;</font>);
<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$log</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#BA2121">&quot;/var/log/acl_change.log&quot;</font>;

<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$till</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#008000">time</font>()&nbsp;<font color="#666666">+</font>&nbsp;<font color="#19177C">$max_ttl</font>&nbsp;<font color="#666666">-</font>&nbsp;<font color="#666666">3</font>;
<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$last_ping</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#008000">time</font>();

<font color="#408080"><em>#daemonize();</em></font>

<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$conn</font>;

<font color="#008000"><strong>for</strong></font>(;;)
{
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>if</strong></font>&nbsp;(<font color="#008000">time</font>()&nbsp;<font color="#666666">&gt;</font>&nbsp;<font color="#19177C">$till</font>)&nbsp;{&nbsp;<font color="#008000">exit</font>;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#19177C">$conn</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#0000FF"><strong>Pg::</strong></font>setdbLogin(<font color="#19177C">$dbhost</font>,&nbsp;<font color="#666666">5432</font>,&nbsp;<font color="#19177C">$pgoptions</font>,&nbsp;<font color="#BA2121">&quot;&quot;</font>,&nbsp;<font color="#19177C">$dbname</font>,&nbsp;<font color="#19177C">$dbuser</font>,&nbsp;<font color="#19177C">$dbpass</font>);

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>if</strong></font>&nbsp;((<font color="#19177C">$conn</font><font color="#666666">-&gt;</font>status&nbsp;<font color="#666666">!=</font>&nbsp;PGRES_CONNECTION_OK))
&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;_log(<font color="#BA2121">&quot;Err:&nbsp;$conn-&gt;errorMessage&quot;</font>);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000">undef</font>&nbsp;<font color="#19177C">$conn</font>;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>next</strong></font>;
&nbsp;&nbsp;&nbsp;&nbsp;}

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>foreach</strong></font>&nbsp;<font color="#19177C">$event</font>&nbsp;(<font color="#008000">keys</font>(<font color="#19177C">%notify</font>))
&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$res</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#19177C">$conn</font><font color="#666666">-&gt;</font><font color="#008000">exec</font>(<font color="#BA2121">&quot;LISTEN&nbsp;$event&quot;</font>);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>if</strong></font>&nbsp;(<font color="#19177C">$res</font><font color="#666666">-&gt;</font>resultStatus&nbsp;<font color="#666666">!=</font>&nbsp;PGRES_COMMAND_OK)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;_log(<font color="#BA2121">&quot;LISTEN&nbsp;error:&nbsp;&quot;</font>&nbsp;<font color="#666666">.</font>&nbsp;<font color="#19177C">$conn</font><font color="#666666">-&gt;</font>errorMessage&nbsp;<font color="#666666">.</font>&nbsp;<font color="#BA2121">&quot;&quot;</font>);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>next</strong></font>;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;}

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$s</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#0000FF"><strong>IO::</strong></font>Select<font color="#666666">-&gt;</font><font color="#008000"><strong>new</strong></font>();
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#19177C">$s</font><font color="#666666">-&gt;</font>add(<font color="#19177C">$conn</font><font color="#666666">-&gt;</font><font color="#008000">socket</font>);
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>for</strong></font>(;;)
&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>if</strong></font>&nbsp;(<font color="#008000">time</font>()&nbsp;<font color="#666666">&gt;</font>&nbsp;<font color="#19177C">$till</font>)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000">exit</font>;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">@x</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#19177C">$s</font><font color="#666666">-&gt;</font>can_read(<font color="#666666">2</font>);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>if</strong></font>&nbsp;(<font color="#19177C">@x</font>&nbsp;<font color="#666666">&gt;</font>&nbsp;<font color="#666666">0</font>)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;_log(<font color="#BA2121">&quot;a-ha!&nbsp;socket&nbsp;event&quot;</font>);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#19177C">$conn</font><font color="#666666">-&gt;</font>consumeInput;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>while</strong></font>&nbsp;(<font color="#008000"><strong>my</strong></font>&nbsp;(<font color="#19177C">$table</font>,&nbsp;<font color="#19177C">$pid</font>)&nbsp;<font color="#666666">=</font>&nbsp;<font color="#19177C">$conn</font><font color="#666666">-&gt;</font>notifies)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>if</strong></font>&nbsp;(<font color="#008000">exists</font>(<font color="#19177C">$notify</font>{<font color="#19177C">$table</font>}))
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;_log(<font color="#BA2121">&quot;Got&nbsp;notify&nbsp;for&nbsp;$table!&quot;</font>);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#19177C">$notify</font>{<font color="#19177C">$table</font>}();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000">sleep</font>&nbsp;<font color="#666666">1</font>;&nbsp;<font color="#408080"><em>#&nbsp;Filtering&nbsp;too&nbsp;many&nbsp;updates/sec</em></font>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>else</strong></font>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#408080"><em>#&nbsp;_log(&quot;empty&nbsp;loop..&quot;);</em></font>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#408080"><em>#&nbsp;some&nbsp;kind&nbsp;of&nbsp;ping</em></font>
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>if</strong></font>&nbsp;(<font color="#008000">time</font>()&nbsp;<font color="#666666">&gt;</font>&nbsp;<font color="#19177C">$last_ping</font>&nbsp;<font color="#666666">+</font>&nbsp;<font color="#19177C">$ping_ttl</font>)
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#19177C">$last_ping</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#008000">time</font>();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$res</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#19177C">$conn</font><font color="#666666">-&gt;</font><font color="#008000">exec</font>(<font color="#BA2121">&quot;SELECT&nbsp;42&quot;</font>);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>if</strong></font>&nbsp;(<font color="#19177C">$res</font><font color="#666666">-&gt;</font>resultStatus&nbsp;<font color="#666666">!=</font>&nbsp;PGRES_TUPLES_OK)&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;_log(<font color="#BA2121">&quot;DB&nbsp;connection&nbsp;failed&nbsp;(ping&nbsp;check)&quot;</font>);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>last</strong></font>;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>if</strong></font>&nbsp;(<font color="#19177C">$conn</font><font color="#666666">-&gt;</font>status&nbsp;<font color="#666666">!=</font>&nbsp;PGRES_CONNECTION_OK)&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;_log(<font color="#BA2121">&quot;DB&nbsp;connection&nbsp;failed&quot;</font>);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>last</strong></font>;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;}

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000">undef</font>&nbsp;<font color="#19177C">$s</font>;
}

<font color="#008000"><strong>sub&nbsp;</strong></font><font color="#0000FF">process_user_insert</font>&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>print</strong></font>&nbsp;<font color="#BA2121">&quot;process_user_insert\n&quot;</font>;
}

<font color="#008000"><strong>sub&nbsp;</strong></font><font color="#0000FF">process_user_update</font>&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$user_id</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#19177C">$_</font>[<font color="#666666">0</font>];
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$sql</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#BA2121">&quot;UPDATE&nbsp;phpbb_users&nbsp;SET&nbsp;ldap_task_status&nbsp;=&nbsp;2&nbsp;WHERE&nbsp;user_id&nbsp;=&nbsp;&quot;</font>&nbsp;<font color="#666666">.</font>&nbsp;<font color="#19177C">$user_id</font>;
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#19177C">$conn</font><font color="#666666">-&gt;</font><font color="#008000">exec</font>(<font color="#19177C">$sql</font>);
}

<font color="#008000"><strong>sub&nbsp;</strong></font><font color="#0000FF">check_user_update</font>&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$sql</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#BA2121">&quot;SELECT&nbsp;user_id&nbsp;FROM&nbsp;phpbb_users&nbsp;WHERE&nbsp;ldap_task_status&nbsp;=&nbsp;0&quot;</font>;
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">$res</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#19177C">$conn</font><font color="#666666">-&gt;</font><font color="#008000">exec</font>(<font color="#19177C">$sql</font>);
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>if</strong></font>&nbsp;(<font color="#19177C">$res</font><font color="#666666">-&gt;</font>resultStatus&nbsp;<font color="#666666">!=</font>&nbsp;PGRES_TUPLES_OK)&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;_log(<font color="#BA2121">&quot;SELECT&nbsp;error:&nbsp;$conn-&gt;errorMessage&quot;</font>);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>return</strong></font>&nbsp;<font color="#666666">-1</font>;
&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">@rows</font>;
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>while</strong></font>&nbsp;(<font color="#008000"><strong>my</strong></font>&nbsp;<font color="#19177C">@row</font>&nbsp;<font color="#666666">=</font>&nbsp;<font color="#19177C">$res</font><font color="#666666">-&gt;</font>fetchrow())&nbsp;{&nbsp;<font color="#008000">push</font>&nbsp;<font color="#19177C">@rows</font>,&nbsp;<font color="#19177C">$row</font>[<font color="#666666">0</font>];&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>foreach</strong></font>&nbsp;<font color="#19177C">$user_id</font>&nbsp;(<font color="#19177C">@rows</font>)
&nbsp;&nbsp;&nbsp;&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>print</strong></font>&nbsp;<font color="#BA2121">&quot;Processing&nbsp;user&nbsp;&quot;</font>&nbsp;<font color="#666666">.</font>&nbsp;<font color="#19177C">$user_id</font>&nbsp;<font color="#666666">.</font>&nbsp;<font color="#BA2121">&quot;\n&quot;</font>;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;process_user_update(<font color="#19177C">$user_id</font>);
&nbsp;&nbsp;&nbsp;&nbsp;}

&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>print</strong></font>&nbsp;<font color="#BA2121">&quot;process_user_update\n&quot;</font>;
}

<font color="#008000"><strong>sub&nbsp;</strong></font><font color="#0000FF">process_user_delete</font>&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>print</strong></font>&nbsp;<font color="#BA2121">&quot;process_user_delete\n&quot;</font>;
}

<font color="#008000"><strong>sub&nbsp;</strong></font><font color="#0000FF">_log</font>&nbsp;{
&nbsp;&nbsp;&nbsp;&nbsp;<font color="#008000"><strong>print</strong></font>&nbsp;<font color="#008000">localtime</font>()&nbsp;<font color="#666666">.</font>&nbsp;<font color="#BA2121">&quot;&nbsp;&quot;</font>&nbsp;<font color="#666666">.</font>&nbsp;<font color="#008000">join</font>(<font color="#BA2121">&quot;&nbsp;&quot;</font>,&nbsp;<font color="#19177C">@_</font>)&nbsp;<font color="#666666">.</font>&nbsp;<font color="#BA2121">&quot;\n&quot;</font>;
}
</code></blockquote><p><font color="gray">Colored with <a href="http://dumpz.org">dumpz.org</a></p>