~ubuntu-branches/ubuntu/trusty/ocamlnet/trusty

<link rel="next" href="Netmcore_basics.html">

<link title="Netmcore_basics" rel="Chapter" href="Netmcore_basics.html">

<link title="Netplex_mbox" rel="Chapter" href="Netplex_mbox.html">

<link title="Netunichar" rel="Chapter" href="Netunichar.html">

<link title="Netstring_pcre" rel="Chapter" href="Netstring_pcre.html">

<link title="Netsys_sem" rel="Chapter" href="Netsys_sem.html">

<link title="Netsys_pmanage" rel="Chapter" href="Netsys_pmanage.html">

<link title="Ipv6" rel="Chapter" href="Ipv6.html">

<link title="Regexp" rel="Chapter" href="Regexp.html"><link title="Netmulticore Tutorial" rel="Section" href="#1_NetmulticoreTutorial">

<div class="navbar"><a class="pre" href="Netmcore_process.html" title="Netmcore_process">Previous</a>

&nbsp;<a class="up" href="index.html" title="Index">Up</a>

&nbsp;<a class="post" href="Netmcore_basics.html" title="Netmcore_basics">Next</a>

<h1>Netmcore_tut</h1>

<br>

<h1 id="1_NetmulticoreTutorial">Netmulticore Tutorial</h1>

<div class="remark">

Readers are encouraged to first have a look at <a href="Netmcore_basics.html"><code class="code">Netmcore_basics</code></a>,

which is more fundamental and doesn't use unsafe language features.

</div>

<p>

 

<div class="remark">

<b>Since OCaml-4.01:</b> This OCaml version changed the semantics of the

built-in primitives <code class="code">caml_modify</code> and <code class="code">caml_initialize</code>. Essentially,

it is no longer possible to modify OCaml values residing outside the

regular OCaml heap. As we do this inside Netmulticore, this change affects

this library. Fortunately, there is a workaround on systems supporting

weak symbols (all ELF systems and OS X): Here, <code class="code">caml_modify</code> and

<code class="code">caml_initialize</code> are overridden by Netmulticore so that they are again

compatible. Note that this is a global modification of the runtime

system!

<p>

 

Future versions of Ocamlnet may solve this problem differently.

</div>

<p>

 

<h2 id="design">Design</h2>

<h3 id="3_Theprocesshierarchy">The process hierarchy</h3>

<h3 id="3_Resources">Resources</h3>

Since Ocamlnet-3.6, the deletion procedure has been substantially

improved. Now, a list of the alive resources is not only kept in

memory, but also written to a file "netplex.pmanage". This allows it

to delete the resources after the program has crashed or terminated

somehow abnormally. This is automatically done when the program is

restarted, or by the user running the <code class="code">netplex-admin</code> utility with

option <code class="code">-unlink</code>. The background for this is that the mentioned

resources have kernel persistency, and continue to exist when the

program is finished.

<p>

 

<h3 id="3_Memorypools">Memory pools</h3>

<h3 id="3_Sharedheaps">Shared heaps</h3>

<h3 id="3_Camlboxes">Camlboxes</h3>

<h3 id="3_Synchronization">Synchronization</h3>

<h2 id="start_procs">How to start processes</h2>

<pre class="codepre"><code class="code">let process_fork, process_join =

<pre class="codepre"><code class="code">let pid = Netmcore_process.start process_fork arg

<pre class="codepre"><code class="code">let r_opt = Netmcore_process.join process_join pid

<pre class="codepre"><code class="code">Netmcore_process.release_join_point process_join

<pre class="codepre"><code class="code">Netmcore.startup

<pre class="codepre"><code class="code">let c = ref 0

<h2 id="camlboxes">How to use Camlboxes for passing messages</h2>

<pre class="codepre"><code class="code">let body_Y box_res =

<h2 id="mempools">How to create and use memory pools</h2>

<pre class="codepre"><code class="code">let pool = Netmcore_mempool.create_mempool size_in_bytes

<pre class="codepre"><code class="code">Netmcore.release pool

<pre class="codepre"><code class="code">let pid = 

<h2 id="sref">Shared <code class="code">ref</code>-type variables</h2>

<pre class="codepre"><code class="code">let s = Netmcore_ref.sref pool initial_value

<pre class="codepre"><code class="code">let r = ref initial_value

<pre class="codepre"><code class="code">Netmcore_ref.assign s new_value

<pre class="codepre"><code class="code">let v1 = Netmcore_ref.deref_ro s

<pre class="codepre"><code class="code">type t = { mutable data : string }

<pre class="codepre"><code class="code">(Netmcore_ref.deref_ro s).data &lt;- "new string"   (* WARNING - PROBLEMATIC CODE *)

<pre class="codepre"><code class="code">let body_Y (pool, c_descr, k) =

<h2 id="descriptors">Descriptors</h2>

<pre class="codepre"><code class="code">type 't sref_descr

<h2 id="mutation">How to mutate shared values</h2>

<pre class="codepre"><code class="code">(Netmcore_ref.deref_ro s).data &lt;- "new string"   (* WARNING - PROBLEMATIC CODE *)

<pre class="codepre"><code class="code">Netmcore_heap.modify

<pre class="codepre"><code class="code">type u = { mutable data1 : string;

<pre class="codepre"><code class="code">Netmcore_heap.modify

<pre class="codepre"><code class="code">Netmcore_heap.modify

<pre class="codepre"><code class="code">Netmcore_heap.modify

<h2 id="sdata">Shared data structures</h2>

<pre class="codepre"><code class="code">type ('e,'h) sarray

<h2 id="sync">Synchronization</h2>

<pre class="codepre"><code class="code">type t =

<pre class="codepre"><code class="code">let s = Netmcore_ref.sref { x = ...; m = ... }

<pre class="codepre"><code class="code">let s = Netmcore_ref.sref { x = ...; m = Netmcore_mutex.dummy() }

<pre class="codepre"><code class="code">Netmcore_heap.modify

<pre class="codepre"><code class="code">Netmcore_ref.deref_p (fun r -&gt; Netmcore_mutex.lock r)

<pre class="codepre"><code class="code">type t =

<pre class="codepre"><code class="code">let we =

<pre class="codepre"><code class="code">Netmcore_ref.deref_p (fun r -&gt; Netmcore_condition.wait we r.c r.m)

<h2 id="examples">Where to find examples</h2>

<h2 id="impl">Remarks on the implementation</h2>

<h2 id="diffs">Some points where Netmulticore is different from multi-threading</h2>

<h2 id="os">Operating system issues</h2>

<h3 id="3_AdministeringPOSIXsharedmemory">Administering POSIX shared memory</h3>

like files, and in deed, in many implementations I've seen the blocks

Since Ocamlnet-3.6, one can also delete shared memory administratively

with the <code class="code">netplex-admin</code> utility. See <a href="Netplex_admin.html#unlink"><i>Deleting persistent kernel objects</i></a> for

details. This method works for all OS. Also, an unlink of old memory

is automatically done when the program is restarted.

<p>