Sophie

Sophie

distrib > Fedora > 17 > i386 > by-pkgid > 675c8c8167236dfcf8d66da674f931e8 > files > 589

erlang-doc-R15B-03.3.fc17.noarch.rpm

<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html xmlns:fn="http://www.w3.org/2005/02/xpath-functions">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
<link rel="stylesheet" href="../../../../doc/otp_doc.css" type="text/css">
<title>Erlang -- The El Library User's Guide</title>
</head>
<body bgcolor="white" text="#000000" link="#0000ff" vlink="#ff00ff" alink="#ff0000"><div id="container">
<script id="js" type="text/javascript" language="JavaScript" src="../../../../doc/js/flipmenu/flipmenu.js"></script><script id="js2" type="text/javascript" src="../../../../doc/js/erlresolvelinks.js"></script><script language="JavaScript" type="text/javascript">
            <!--
              function getWinHeight() {
                var myHeight = 0;
                if( typeof( window.innerHeight ) == 'number' ) {
                  //Non-IE
                  myHeight = window.innerHeight;
                } else if( document.documentElement && ( document.documentElement.clientWidth ||
                                                         document.documentElement.clientHeight ) ) {
                  //IE 6+ in 'standards compliant mode'
                  myHeight = document.documentElement.clientHeight;
                } else if( document.body && ( document.body.clientWidth || document.body.clientHeight ) ) {
                  //IE 4 compatible
                  myHeight = document.body.clientHeight;
                }
                return myHeight;
              }

              function setscrollpos() {
                var objf=document.getElementById('loadscrollpos');
                 document.getElementById("leftnav").scrollTop = objf.offsetTop - getWinHeight()/2;
              }

              function addEvent(obj, evType, fn){
                if (obj.addEventListener){
                obj.addEventListener(evType, fn, true);
                return true;
              } else if (obj.attachEvent){
                var r = obj.attachEvent("on"+evType, fn);
                return r;
              } else {
                return false;
              }
             }

             addEvent(window, 'load', setscrollpos);

             //--></script><div id="leftnav"><div class="innertube">
<img alt="Erlang logo" src="../../../../doc/erlang-logo.png"><br><small><a href="users_guide.html">User's Guide</a><br><a href="index.html">Reference Manual</a><br><a href="release_notes.html">Release Notes</a><br><a href="../pdf/erl_interface-3.7.9.pdf">PDF</a><br><a href="../../../../doc/index.html">Top</a></small><p><strong>Erlang Interface</strong><br><strong>User's Guide</strong><br><small>Version 3.7.9</small></p>
<br><a href="javascript:openAllFlips()">Expand All</a><br><a href="javascript:closeAllFlips()">Contract All</a><p><small><strong>Chapters</strong></small></p>
<ul class="flipMenu" imagepath="../../../../doc/js/flipmenu"><li id="loadscrollpos" title="The El Library User's Guide" expanded="true">The El Library User's Guide<ul>
<li><a href="ei_users_guide.html">
              Top of chapter
            </a></li>
<li title="Compiling and Linking Your Code"><a href="ei_users_guide.html#id61129">Compiling and Linking Your Code</a></li>
<li title="Initializing the erl_interface Library"><a href="ei_users_guide.html#id61695">Initializing the erl_interface Library</a></li>
<li title="Encoding, Decoding and Sending Erlang Terms"><a href="ei_users_guide.html#id61800">Encoding, Decoding and Sending Erlang Terms</a></li>
<li title="Building Terms and Patterns"><a href="ei_users_guide.html#id57501">Building Terms and Patterns</a></li>
<li title="Pattern Matching"><a href="ei_users_guide.html#id60709">Pattern Matching</a></li>
<li title="Connecting to a Distributed Erlang Node"><a href="ei_users_guide.html#id61769">Connecting to a Distributed Erlang Node</a></li>
<li title="Using EPMD"><a href="ei_users_guide.html#id61888">Using EPMD</a></li>
<li title="Sending and Receiving Erlang Messages"><a href="ei_users_guide.html#id60806">Sending and Receiving Erlang Messages</a></li>
<li title="Remote Procedure Calls"><a href="ei_users_guide.html#id58293">Remote Procedure Calls</a></li>
<li title="Using Global Names"><a href="ei_users_guide.html#id60911">Using Global Names</a></li>
<li title="The Registry"><a href="ei_users_guide.html#id61049">The Registry</a></li>
</ul>
</li></ul>
</div></div>
<div id="content">
<div class="innertube">
<h1>1 The El Library User's Guide</h1>
  
  <p>The Erl_Interface library contains functions. which help you
    integrate programs written in C and Erlang. The functions in
    Erl_Interface support the following:</p>
  <ul>
    <li>manipulation of data represented as Erlang data types</li>
    <li>conversion of data between C and Erlang formats</li>
    <li>encoding and decoding of Erlang data types for transmission or storage</li>
    <li>communication between C nodes and Erlang processes</li>
    <li>backup and restore of C node state to and from Mnesia</li>
  </ul>
  <p>In the following sections, these topics are described:</p>
  <ul>
    <li>compiling your code for use with Erl_Interface</li>
    <li>initializing Erl_Interface</li>
    <li>encoding, decoding, and sending Erlang terms</li>
    <li>building terms and patterns</li>
    <li>pattern matching</li>
    <li>connecting to a distributed Erlang node</li>
    <li>using EPMD</li>
    <li>sending and receiving Erlang messages</li>
    <li>remote procedure calls</li>
    <li>global names</li>
    <li>the registry</li>
  </ul>

  <h3><a name="id61129">1.1 
        Compiling and Linking Your Code</a></h3>
    
    <p>In order to use any of the Erl_Interface functions, include the
      following lines in your code:</p>
    <div class="example"><pre>
#include "erl_interface.h"
#include "ei.h"    </pre></div>
    <p>Determine where the top directory of your OTP installation is. You
      can find this out by starting Erlang and entering the following
      command at the Eshell prompt:</p>
    <div class="example"><pre>
Eshell V4.7.4  (abort with ^G)
1&gt; code:root_dir().
/usr/local/otp    </pre></div>
    <p>To compile your code, make sure that your C compiler knows where
      to find <span class="code">erl_interface.h</span> by specifying an appropriate <span class="code">-I</span>
      argument on the command line, or by adding it to the <span class="code">CFLAGS</span>
      definition in your <span class="code">Makefile</span>. The correct value for this path is
      <span class="code">$OTPROOT/lib/erl_interface</span><strong>Vsn</strong><span class="code">/include</span>, where <span class="code">$OTPROOT</span> is the path
      reported by <span class="code">code:root_dir/0</span> in the above example, and <strong>Vsn</strong> is
      the version of the Erl_interface application, for example 
      <span class="code">erl_interface-3.2.3</span></p>
    <div class="example"><pre>
$ cc -c -I/usr/local/otp/lib/erl_interface-3.2.3/include myprog.c    </pre></div>
    <p>When linking, you will need to specify the path to
      <span class="code">liberl_interface.a</span> and <span class="code">libei.a</span> with
      <span class="code">-L$OTPROOT/lib/erl_interface-3.2.3/lib</span>, and you will need to specify the
      name of the libraries with <span class="code">-lerl_interface -lei</span>. You can do
      this on the command line or by adding the flags to the <span class="code">LDFLAGS</span>
      definition in your <span class="code">Makefile</span>.</p>
    <div class="example"><pre>
$ ld -L/usr/local/otp/lib/erl_interface-3.2.3/
                            lib myprog.o -lerl_interface -lei -o myprog    </pre></div>
    <p>Also, on some systems it may be necessary to link with some
      additional libraries (e.g. <span class="code">libnsl.a</span> and <span class="code">libsocket.a</span> on
      Solaris, or <span class="code">wsock32.lib</span> on Windows) in order to use the
      communication facilities of Erl_Interface.</p>
    <p>If you are using Erl_Interface functions in a threaded
      application based on POSIX threads or Solaris threads, then
      Erl_Interface needs access to some of the synchronization
      facilities in your threads package, and you will need to specify
      additional compiler flags in order to indicate which of the packages
      you are using. Define <span class="code">_REENTRANT</span> and either <span class="code">STHREADS</span> or
      <span class="code">PTHREADS</span>. The default is to use POSIX threads if
      <span class="code">_REENTRANT</span> is specified.</p>
  

  <h3><a name="id61695">1.2 
        Initializing the erl_interface Library</a></h3>
    
    <p>Before calling any of the other Erl_Interface functions, you
      must call <span class="code">erl_init()</span> exactly once to initialize the library.
      <span class="code">erl_init()</span> takes two arguments, however the arguments are no
      longer used by Erl_Interface, and should therefore be specified
      as <span class="code">erl_init(NULL,0)</span>.</p>
  

  <h3><a name="id61800">1.3 
        Encoding, Decoding and Sending Erlang Terms</a></h3>
    
    <p>Data sent between distributed Erlang nodes is encoded in the
      Erlang external format. Consequently, you have to encode and decode
      Erlang terms into byte streams if you want to use the distribution
      protocol to communicate between a C program and Erlang. </p>
    <p>The Erl_Interface library supports this activity. It has a
      number of C functions which create and manipulate Erlang data
      structures. The library also contains an encode and a decode function.
      The example below shows how to create and encode an Erlang tuple
      <span class="code">{tobbe,3928}</span>:</p>
    <div class="example"><pre>

ETERM *arr[2], *tuple;
char buf[BUFSIZ];
int i;
  
arr[0] = erl_mk_atom("tobbe");
arr[1] = erl_mk_integer(3928);
tuple  = erl_mk_tuple(arr, 2);
i = erl_encode(tuple, buf);    </pre></div>
    <p>Alternatively, you can use <span class="code">erl_send()</span> and
      <span class="code">erl_receive_msg</span>, which handle the encoding and decoding of
      messages transparently.</p>
    <p>Refer to the Reference Manual for a complete description of the
      following modules:</p>
    <ul>
      <li>the <span class="code">erl_eterm</span> module for creating Erlang terms</li>
      <li>the <span class="code">erl_marshal</span> module for encoding and decoding routines.</li>
    </ul>
  

  <h3><a name="id57501">1.4 
        Building Terms and Patterns</a></h3>
    
    <p>The previous example can be simplified by using 
      <span class="code">erl_format()</span> to create an Erlang term.</p>
    <div class="example"><pre>

ETERM *ep;
ep = erl_format("{~a,~i}", "tobbe", 3928);    </pre></div>
    <p>Refer to the Reference Manual, the <span class="code">erl_format</span> module, for a
      full description of the different format directives. The following
      example is more complex:</p>
    <div class="example"><pre>

ETERM *ep;
ep = erl_format("[{name,~a},{age,~i},{data,~w}]",
                 "madonna", 
                 21, 
                 erl_format("[{adr,~s,~i}]", "E-street", 42));
erl_free_compound(ep);      </pre></div>
    <p>As in previous examples, it is your responsibility to free the
      memory allocated for Erlang terms. In this example, 
      <span class="code">erl_free_compound()</span> ensures that the complete term pointed to
      by <span class="code">ep</span> is released. This is necessary, because the pointer from
      the second call to <span class="code">erl_format()</span> is lost. </p>
    <p>The following
      example shows a slightly different solution:</p>
    <div class="example"><pre>

ETERM *ep,*ep2;
ep2 = erl_format("[{adr,~s,~i}]","E-street",42);
ep  = erl_format("[{name,~a},{age,~i},{data,~w}]",
                 "madonna", 21, ep2);
erl_free_term(ep);  
erl_free_term(ep2);      </pre></div>
    <p>In this case, you free the two terms independently. The order in
      which you free the terms <span class="code">ep</span> and <span class="code">ep2</span> is not important,
      because the Erl_Interface library uses reference counting to
      determine when it is safe to actually remove objects. </p>
    <p>If you are not sure whether you have freed the terms properly, you
      can use the following function to see the status of the fixed term
      allocator:</p>
    <div class="example"><pre>
long allocated, freed;

erl_eterm_statistics(&amp;allocated,&amp;freed);
printf("currently allocated blocks: %ld\n",allocated);
printf("length of freelist: %ld\n",freed);

/* really free the freelist */
erl_eterm_release();
    </pre></div>
    <p>Refer to the Reference Manual, the <span class="code">erl_malloc</span> module for more
      information.</p>
  

  <h3><a name="id60709">1.5 
        Pattern Matching</a></h3>
    
    <p>An Erlang pattern is a term that may contain unbound variables or
      <span class="code">"do not care"</span> symbols. Such a pattern can be matched against a
      term and, if the match is successful, any unbound variables in the
      pattern will be bound as a side effect. The content of a bound
      variable can then be retrieved.</p>
    <div class="example"><pre>

ETERM *pattern;
pattern = erl_format("{madonna,Age,_}");    </pre></div>
    <p><span class="code">erl_match()</span> is used to perform pattern matching. It takes a
      pattern and a term and tries to match them. As a side effect any unbound
      variables in the pattern will be bound. In the following example, we
      create a pattern with a variable <strong>Age</strong> which appears at two
      positions in the tuple. The pattern match is performed as follows:</p>
    <ul>
      <li>
<span class="code">erl_match()</span> will bind the contents of
      <strong>Age</strong> to <strong>21</strong> the first time it reaches the variable</li>
      <li>the second occurrence of <strong>Age</strong> will cause a test for
       equality between the terms since <strong>Age</strong> is already bound to
      <strong>21</strong>. Since <strong>Age</strong> is bound to 21, the equality test will
       succeed and the match continues until the end of the pattern.</li>
      <li>if the end of the pattern is reached, the match succeeds and you
       can retrieve the contents of the variable</li>
    </ul>
    <div class="example"><pre>
ETERM *pattern,*term;
pattern = erl_format("{madonna,Age,Age}");
term    = erl_format("{madonna,21,21}");
if (erl_match(pattern, term)) {
  fprintf(stderr, "Yes, they matched: Age = ");
  ep = erl_var_content(pattern, "Age"); 
  erl_print_term(stderr, ep);
  fprintf(stderr,"\n");
  erl_free_term(ep);
}
erl_free_term(pattern);
erl_free_term(term);    </pre></div>
    <p>Refer to the Reference Manual, the <span class="code">erl_match()</span> function for
      more information.</p>
  

  <h3><a name="id61769">1.6 
        Connecting to a Distributed Erlang Node</a></h3>
    
    <p>In order to connect to a distributed Erlang node you need to first
      initialize the connection routine with <span class="code">erl_connect_init()</span>,
      which stores information such as the host name, node name, and IP
      address for later use:</p>
    <div class="example"><pre>
int identification_number = 99;
int creation=1;
char *cookie="a secret cookie string"; /* An example */
erl_connect_init(identification_number, cookie, creation);    </pre></div>
    <p>Refer to the Reference Manual, the <span class="code">erl_connect</span> module for more information.</p>
    <p>After initialization, you set up the connection to the Erlang node.
      Use <span class="code">erl_connect()</span> to specify the Erlang node you want to
      connect to. The following example sets up the connection and should
      result in a valid socket file descriptor:</p>
    <div class="example"><pre>
int sockfd;
char *nodename="xyz@chivas.du.etx.ericsson.se"; /* An example */
if ((sockfd = erl_connect(nodename)) &lt; 0)
  erl_err_quit("ERROR: erl_connect failed");    </pre></div>
    <p><span class="code">erl_err_quit()</span> prints the specified string and terminates
      the program. Refer to the Reference Manual, the <span class="code">erl_error()</span>
      function for more information.</p>
  

  <h3><a name="id61888">1.7 
        Using EPMD</a></h3>
    
    <p><span class="code">Epmd</span> is the Erlang Port Mapper Daemon. Distributed Erlang nodes
      register with <span class="code">epmd</span> on the localhost to indicate to other nodes that
      they exist and can accept connections. <span class="code">Epmd</span> maintains a register of
      node and port number information, and when a node wishes to connect to
      another node, it first contacts <span class="code">epmd</span> in order to find out the correct
      port number to connect to.</p>
    <p>When you use <span class="code">erl_connect()</span> to connect to an Erlang node, a
      connection is first made to <span class="code">epmd</span> and, if the node is known, a
      connection is then made to the Erlang node.</p>
    <p>C nodes can also register themselves with <span class="code">epmd</span> if they want other
      nodes in the system to be able to find and connect to them.</p>
    <p>Before registering with <span class="code">epmd</span>, you need to first create a listen socket
      and bind it to a port. Then:</p>
    <div class="example"><pre>
int pub;

pub = erl_publish(port);    </pre></div>
    <p><span class="code">pub</span> is a file descriptor now connected to <span class="code">epmd</span>. <span class="code">Epmd</span>
      monitors the other end of the connection, and if it detects that the
      connection has been closed, the node will be unregistered. So, if you
      explicitly close the descriptor or if your node fails, it will be
      unregistered from <span class="code">epmd</span>.</p>
    <p>Be aware that on some systems (such as VxWorks), a failed node will
      not be detected by this mechanism since the operating system does not
      automatically close descriptors that were left open when the node
      failed. If a node has failed in this way, <span class="code">epmd</span> will prevent you from
      registering a new node with the old name, since it thinks that the old
      name is still in use. In this case, you must unregister the name
      explicitly:</p>
    <div class="example"><pre>
erl_unpublish(node);    </pre></div>
    <p>This will cause <span class="code">epmd</span> to close the connection from the far end. Note
      that if the name was in fact still in use by a node, the results of
      this operation are unpredictable. Also, doing this does not cause the
      local end of the connection to close, so resources may be consumed.</p>
  

  <h3><a name="id60806">1.8 
        Sending and Receiving Erlang Messages</a></h3>
    
    <p>Use one of the following two functions to send messages:</p>
    <ul>
      <li><span class="code">erl_send()</span></li>
      <li><span class="code">erl_reg_send()</span></li>
    </ul>
    <p>As in Erlang, it is possible to send messages to a 
      <strong>Pid</strong> or to a registered name. It is easier to send a
      message to a registered name because it avoids the problem of finding
      a suitable <strong>Pid</strong>.</p>
    <p>Use one of the following two functions to receive messages:</p>
    <ul>
      <li><span class="code">erl_receive()</span></li>
      <li><span class="code">erl_receive_msg()</span></li>
    </ul>
    <p><span class="code">erl_receive()</span> receives the message into a buffer, while
      <span class="code">erl_receive_msg()</span> decodes the message into an Erlang term. </p>

    <h4>Example of Sending Messages</h4>
      
      <p>In the following example, <span class="code">{Pid, hello_world}</span> is
        sent to a registered process <span class="code">my_server</span>. The message is encoded
        by <span class="code">erl_send()</span>:</p>
      <div class="example"><pre>
extern const char *erl_thisnodename(void);
extern short erl_thiscreation(void);
#define SELF(fd) erl_mk_pid(erl_thisnodename(),fd,0,erl_thiscreation())
ETERM *arr[2], *emsg;
int sockfd, creation=1;
  
arr[0] = SELF(sockfd);
arr[1] = erl_mk_atom("Hello world");
emsg   = erl_mk_tuple(arr, 2);
  
erl_reg_send(sockfd, "my_server", emsg);
erl_free_term(emsg);      </pre></div>
      <p>The first element of the tuple that is sent is your own
        <strong>Pid</strong>. This enables <span class="code">my_server</span> to reply. Refer to the
        Reference Manual, the <span class="code">erl_connect</span> module for more information
        about send primitives.</p>
    

    <h4>Example of Receiving Messages</h4>
      
      <p>In this example <span class="code">{Pid, Something}</span> is received. The
        received Pid is then used to return <span class="code">{goodbye,Pid}</span></p>
      <div class="example"><pre>
ETERM *arr[2], *answer;
int sockfd,rc;
char buf[BUFSIZE];
ErlMessage emsg;
  
if ((rc = erl_receive_msg(sockfd , buf, BUFSIZE, &amp;emsg)) == ERL_MSG) {
   arr[0] = erl_mk_atom("goodbye");
   arr[1] = erl_element(1, emsg.msg); 
   answer = erl_mk_tuple(arr, 2);
   erl_send(sockfd, arr[1], answer);
   erl_free_term(answer);
   erl_free_term(emsg.msg);
   erl_free_term(emsg.to);
}      </pre></div>
      <p>In order to provide robustness, a distributed Erlang node
        occasionally polls all its connected neighbours in an attempt to
        detect failed nodes or communication links. A node which receives such
        a message is expected to respond immediately with an <span class="code">ERL_TICK</span> message.
        This is done automatically by <span class="code">erl_receive()</span>, however when this
        has occurred <span class="code">erl_receive</span> returns <span class="code">ERL_TICK</span> to the caller
        without storing a message into the <span class="code">ErlMessage</span> structure.</p>
      <p>When a message has been received, it is the caller's responsibility
        to free the received message <span class="code">emsg.msg</span> as well as <span class="code">emsg.to</span>
        or <span class="code">emsg.from</span>, depending on the type of message received.</p>
      <p>Refer to the Reference Manual for additional information about the
        following modules:</p>
      <ul>
        <li><span class="code">erl_connect</span></li>
        <li>
<span class="code">erl_eterm</span>.</li>
      </ul>
    
  

  <h3><a name="id58293">1.9 
        Remote Procedure Calls</a></h3>
    
    <p>An Erlang node acting as a client to another Erlang node
      typically sends a request and waits for a reply. Such a request is
      included in a function call at a remote node and is called a remote
      procedure call. The following example shows how the
      Erl_Interface library supports remote procedure calls:</p>
    <div class="example"><pre>

char modname[]=THE_MODNAME;
ETERM *reply,*ep;
ep = erl_format("[~a,[]]", modname);
if (!(reply = erl_rpc(fd, "c", "c", ep)))
  erl_err_msg("&lt;ERROR&gt; when compiling file: %s.erl !\n", modname);
erl_free_term(ep);
ep = erl_format("{ok,_}");
if (!erl_match(ep, reply))
  erl_err_msg("&lt;ERROR&gt; compiler errors !\n");
erl_free_term(ep);
erl_free_term(reply);    </pre></div>
    <p><span class="code">c:c/1</span> is called to compile the specified module on the
      remote node. <span class="code">erl_match()</span> checks that the compilation was
      successful by testing for the expected <span class="code">ok</span>.</p>
    <p>Refer to the Reference Manual, the <span class="code">erl_connect</span> module for
      more information about <span class="code">erl_rpc()</span>, and its companions
      <span class="code">erl_rpc_to()</span> and <span class="code">erl_rpc_from()</span>.</p>
  

  <h3><a name="id60911">1.10 
        Using Global Names</a></h3>
    
    <p>A C node has access to names registered through the Erlang Global
      module. Names can be looked up, allowing the C node to send messages
      to named Erlang services. C nodes can also register global names,
      allowing them to provide named services to Erlang processes or other C
      nodes. </p>
    <p>Erl_Interface does not provide a native implementation of the global
      service. Instead it uses the global services provided by a "nearby"
      Erlang node. In order to use the services described in this section,
      it is necessary to first open a connection to an Erlang node.</p>
    <p>To see what names there are:</p>
    <div class="example"><pre>
char **names;
int count;
int i;

names = erl_global_names(fd,&amp;count);

if (names) 
  for (i=0; i&lt;count; i++) 
    printf("%s\n",names[i]);

free(names);    </pre></div>
    <p><span class="code">erl_global_names()</span> allocates and returns a buffer containing
      all the names known to global. <span class="code">count</span> will be initialized to
      indicate how many names are in the array. The array of strings in
      names is terminated by a NULL pointer, so it is not necessary to use
      <span class="code">count</span> to determine when the last name is reached.</p>
    <p>It is the caller's responsibility to free the array.
      <span class="code">erl_global_names()</span> allocates the array and all of the strings
      using a single call to <span class="code">malloc()</span>, so <span class="code">free(names)</span> is all
      that is necessary.</p>
    <p>To look up one of the names:</p>
    <div class="example"><pre>
ETERM *pid;
char node[256];

pid = erl_global_whereis(fd,"schedule",node);    </pre></div>
    <p>If <span class="code">"schedule"</span> is known to global, an Erlang pid is returned
      that can be used to send messages to the schedule service.
      Additionally, <span class="code">node</span> will be initialized to contain the name of
      the node where the service is registered, so that you can make a
      connection to it by simply passing the variable to <span class="code">erl_connect()</span>.</p>
    <p>Before registering a name, you should already have registered your
      port number with <span class="code">epmd</span>. This is not strictly necessary, but if you
      neglect to do so, then other nodes wishing to communicate with your
      service will be unable to find or connect to your process.</p>
    <p>Create a pid that Erlang processes can use to communicate with your
      service:</p>
    <div class="example"><pre>
ETERM *pid;

pid = erl_mk_pid(thisnode,14,0,0);
erl_global_register(fd,servicename,pid);    </pre></div>
    <p>After registering the name, you should use <span class="code">erl_accept()</span> to wait for
      incoming connections.</p>
    <p>Do not forget to free <span class="code">pid</span> later with <span class="code">erl_free_term()</span>!</p>
    <p>To unregister a name:</p>
    <div class="example"><pre>
erl_global_unregister(fd,servicename);    </pre></div>
  

  <h3><a name="id61049">1.11 
        The Registry</a></h3>
    
    <p>This section describes the use of the registry, a simple mechanism
      for storing key-value pairs in a C-node, as well as backing them up or
      restoring them from a Mnesia table on an Erlang node. More detailed
      information about the individual API functions can be found in the
      Reference Manual.</p>
    <p>Keys are strings, i.e. 0-terminated arrays of characters, and values
      are arbitrary objects. Although integers and floating point numbers
      are treated specially by the registry, you can store strings or binary
      objects of any type as pointers.</p>
    <p>To start, you need to open a registry:</p>
    <div class="example"><pre>
ei_reg *reg;

reg = ei_reg_open(45);    </pre></div>
    <p>The number 45 in the example indicates the approximate number of
      objects that you expect to store in the registry. Internally the
      registry uses hash tables with collision chaining, so there is no
      absolute upper limit on the number of objects that the registry can
      contain, but if performance or memory usage are important, then you
      should choose a number accordingly. The registry can be resized later.</p>
    <p>You can open as many registries as you like (if memory permits).</p>
    <p>Objects are stored and retrieved through set and get functions. In
      the following examples you see how to store integers, floats, strings
      and arbitrary binary objects:</p>
    <div class="example"><pre>
struct bonk *b = malloc(sizeof(*b));
char *name = malloc(7);

ei_reg_setival(reg,"age",29); 
ei_reg_setfval(reg,"height",1.85);

strcpy(name,"Martin");
ei_reg_setsval(reg,"name",name); 

b-&gt;l = 42;
b-&gt;m = 12;
ei_reg_setpval(reg,"jox",b,sizeof(*b));    </pre></div>
    <p>If you attempt to store an object in the registry and there is an
      existing object with the same key, the new value will replace the old
      one. This is done regardless of whether the new object and the old one
      have the same type, so you can, for example, replace a string with an
      integer. If the existing value is a string or binary, it will be freed
      before the new value is assigned.</p>
    <p>Stored values are retrieved from the registry as follows:</p>
    <div class="example"><pre>
long i;
double f;
char *s;
struct bonk *b;
int size;

i = ei_reg_getival(reg,"age");
f = ei_reg_getfval(reg,"height");
s = ei_reg_getsval(reg,"name");
b = ei_reg_getpval(reg,"jox",&amp;size);    </pre></div>
    <p>In all of the above examples, the object must exist and it must be of
      the right type for the specified operation. If you do not know the
      type of a given object, you can ask:</p>
    <div class="example"><pre>
struct ei_reg_stat buf;

ei_reg_stat(reg,"name",&amp;buf);    </pre></div>
    <p>Buf will be initialized to contain object attributes.</p>
    <p>Objects can be removed from the registry:</p>
    <div class="example"><pre>
ei_reg_delete(reg,"name");    </pre></div>
    <p>When you are finished with a registry, close it to remove all the
      objects and free the memory back to the system:</p>
    <div class="example"><pre>
ei_reg_close(reg);    </pre></div>

    <h4>Backing Up the Registry to Mnesia</h4>
      
      <p>The contents of a registry can be backed up to Mnesia on a "nearby"
        Erlang node. You need to provide an open connection to the Erlang node
        (see <span class="code">erl_connect()</span>). Also, Mnesia 3.0 or later must be running
        on the Erlang node before the backup is initiated:</p>
      <div class="example"><pre>
ei_reg_dump(fd, reg, "mtab", dumpflags);      </pre></div>
      <p>The example above will backup the contents of the registry to the
        specified Mnesia table <span class="code">"mtab"</span>. Once a registry has been backed
        up to Mnesia in this manner, additional backups will only affect
        objects that have been modified since the most recent backup, i.e.
        objects that have been created, changed or deleted. The backup
        operation is done as a single atomic transaction, so that the entire
        backup will be performed or none of it will.</p>
      <p>In the same manner, a registry can be restored from a Mnesia table:</p>
      <div class="example"><pre>
ei_reg_restore(fd, reg, "mtab");      </pre></div>
      <p>This will read the entire contents of <span class="code">"mtab"</span> into the specified
        registry. After the restore, all of the objects in the registry will
        be marked as unmodified, so a subsequent backup will only affect
        objects that you have modified since the restore.</p>
      <p>Note that if you restore to a non-empty registry, objects in the
        table will overwrite objects in the registry with the same keys. Also,
        the <strong>entire</strong> contents of the registry is marked as unmodified
        after the restore, including any modified objects that were not
        overwritten by the restore operation. This may not be your intention.</p>
    

    <h4>Storing Strings and Binaries</h4>
      
      <p>When string or binary objects are stored in the registry it is
        important that a number of simple guidelines are followed. </p>
      <p>Most importantly, the object must have been created with a single call
        to <span class="code">malloc()</span> (or similar), so that it can later be removed by a
        single call to <span class="code">free()</span>. Objects will be freed by the registry
        when it is closed, or when you assign a new value to an object that
        previously contained a string or binary.</p>
      <p>You should also be aware that if you store binary objects that are
        context-dependent (e.g. containing pointers or open file descriptors),
        they will lose their meaning if they are backed up to a Mnesia table
        and subsequently restored in a different context.</p>
      <p>When you retrieve a stored string or binary value from the registry,
        the registry maintains a pointer to the object and you are passed a
        copy of that pointer. You should never free an object retrieved in
        this manner because when the registry later attempts to free it, a
        runtime error will occur that will likely cause the C-node to crash.</p>
      <p>You are free to modify the contents of an object retrieved this way.
        However when you do so, the registry will not be aware of the changes
        you make, possibly causing it to be missed the next time you make a
        Mnesia backup of the registry contents. This can be avoided if you
        mark the object as dirty after any such changes with
        <span class="code">ei_reg_markdirty()</span>, or pass appropriate flags to
        <span class="code">ei_reg_dump()</span>.</p>
    
  
</div>
<div class="footer">
<hr>
<p>Copyright © 1998-2012 Ericsson AB. All Rights Reserved.</p>
</div>
</div>
</div></body>
</html>