为EFS提供C API

问题:

EFS是我最近学习Erlang的过程中写的一个mini分布式文件系统,仿GoogleFileSystem。希望给它提供一套CAPI,以方便利用现有的C库,如与NFSv3,或Fuse的整合。用Erl_interface库可以很easy的做到这一点,这是否从C调用Erlang的唯一方法?Port或linked-inPort是Erlang调C实现的功能,Port是在Erlang一方启动外部程序的,反过来行吗?(由port所启动的外部程序作为server,提供capi,也是可行的,按面向对象的理解,进程作为对象,提供服务作为接口)。

本质上,不管Port,还是Erl_interface,不同语言都是通过IPC机制来实现通信的,类似socket通信,要处理的是通信协议,链接管理,数据的编码和解码等。Erl_interface能极大的简化这些任务。

引用

Portsprovidethebasicmechanismforcommunicationwiththeexternalworld,fromErlang'spointofview.Theyprovideabyte-orientedinterfacetoanexternalprogram.Whenaporthasbeencreated,Erlangcancommunicatewithitbysendingandreceivinglistsofbytes(notErlangterms).Thismeansthattheprogrammermayhavetoinventasuitableencodinganddecodingscheme.

ACprogramwhichusestheErl_InterfacefunctionsforsettingupaconnectiontoandcommunicatingwithadistributedErlangnodeiscalledaCnode,orahiddennode.ThemainadvantagewithaCnodeisthatthecommunicationfromtheErlangprogrammer'spointofviewisextremelyeasy,sincetheCprogrambehavesasadistributedErlangnode.

大概思路如下:

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <errno.h>

#include "erl_interface.h"
#include "ei.h"

#include "efs.h"

int erlang_fd = -1;

/* -------------------------------------------------- */
/* API                                                */
/* -------------------------------------------------- */
int efs_init()
{
        int ret, fd;

        erl_init(NULL, 0);
        
        if (erl_connect_init(1, "secretcookie", 0) == -1)
                erl_err_quit("erl_connect_init");

        if ((fd = erl_connect("e1@uss")) < 0)
                erl_err_quit("erl_connect");

        fprintf(stderr, "Connected to e1@uss\n\r");
        erlang_fd = fd;

        return 0;
}

int efs_destroy()
{
        return 0;
}

int efs_create(const char *path, int mode)
{
        int ret;
        ETERM *args;
        ETERM *reply;

        args = erl_format("[~s]", path);

        reply = erl_rpc(erlang_fd, "efs", "create", args);
        if (reply == NULL) {
                ret = EINVAL;
                fprintf(stderr, "error %d\n", ret);
                goto err_ret;
        }

        erl_free_term(reply);
        erl_free_term(args);

        return 0;
err_ret:
        erl_free_term(args);
        return ret;
}

int efs_close(int fd)
{
        return 0;
}

/**
 * test utilities.
 * create fcount files, every file size is fsize.
 */
int efs_shell_ww(int fcount, int fsize)
{
        int ret;
        ETERM *args;
        ETERM *reply;

        args = erl_format("[~i,~i]", fcount, fsize);

        reply = erl_rpc(erlang_fd, "efs_shell", "ww", args);
        if (reply == NULL) {
                ret = EINVAL;
                fprintf(stderr, "error %d\n", ret);
                goto err_ret;
        }

        erl_free_term(reply);
        erl_free_term(args);

        return 0;
err_ret:
        erl_free_term(args);
        return ret;
}

/* -------------------------------------------------- */
/* Entry point                                        */
/* -------------------------------------------------- */
int main(int argc, char **argv)
{
        int ret;

        efs_init();

        ret = efs_create("afile", 0644);

        ret = efs_shell_ww(100, 1024*1024);


        return 0;
}

相关推荐