From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.1.3 (2006-06-01) on yquem.inria.fr X-Spam-Level: ** X-Spam-Status: No, score=2.8 required=5.0 tests=DNS_FROM_RFC_POST,SPF_NEUTRAL autolearn=disabled version=3.1.3 X-Original-To: caml-list@yquem.inria.fr Delivered-To: caml-list@yquem.inria.fr Received: from mail1-relais-roc.national.inria.fr (mail1-relais-roc.national.inria.fr [192.134.164.82]) by yquem.inria.fr (Postfix) with ESMTP id 3A820BBAF for ; Sun, 5 Apr 2009 18:27:30 +0200 (CEST) X-IronPort-Anti-Spam-Filtered: true X-IronPort-Anti-Spam-Result: AiwDAO942EnRVdq0kGdsb2JhbACVZj8BAQEBCQkMBxEDoy6BCY4AAQMBA4JIgUQG X-IronPort-AV: E=Sophos;i="4.38,431,1233529200"; d="scan'208";a="27068145" Received: from mail-bw0-f180.google.com ([209.85.218.180]) by mail1-smtp-roc.national.inria.fr with ESMTP; 05 Apr 2009 18:27:30 +0200 Received: by bwz28 with SMTP id 28so1808552bwz.27 for ; Sun, 05 Apr 2009 09:27:29 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:received:in-reply-to:references :date:message-id:subject:from:to:cc:content-type :content-transfer-encoding; bh=UjJfsC3rWR3G+rfDUOXRbNQ91dfhDbQF58eX/OthaUE=; b=TsFWvT9Q0me/EXhyBS1HHkXGvJrnuiqqqXgAVyM7/kP7fuToo8/cMCuz3K6+kB+2sz vxgYtR10tox1LOl8vZsBlIj7tz2K+Y98mwL8NswmtT8iOuEMteq9IyV5U9h3FhkZy5r1 7Qbq9DL7jRxOyILM7zQG7O9f1txaW2+kSKQto= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :cc:content-type:content-transfer-encoding; b=RuYIniDhz0ZQnQRbXOPCS/FBVysEGOJSVTYFNyB132cbJkciaAWudY3zV+JUKe/2ix 6Li5v/wrxivGzOsQiiqSJAfHtI9uU8EPi/u20zbvKMJQ+PqQcn8/WH9q3yLkV1AC5q6N 3K4Mk9h8eojzM9VnHBDZCNzRhqCJg4ciAr7MI= MIME-Version: 1.0 Received: by 10.204.119.133 with SMTP id z5mr1286297bkq.86.1238948849745; Sun, 05 Apr 2009 09:27:29 -0700 (PDT) In-Reply-To: References: <1238773897.9723.6.camel@flake.lan.gerd-stolpmann.de> Date: Sun, 5 Apr 2009 22:27:29 +0600 Message-ID: Subject: Re: [Caml-list] netplex multi-thread asynchronous processor for passive clients From: Serge Sivkov To: Gerd Stolpmann Cc: caml-list@yquem.inria.fr Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit X-Spam: no; 0.00; async:01 assertion:01 async:01 ssp:98 exception:01 caml-list:01 usable:02 silently:02 objects:02 asynchronous:03 let:03 serge:05 queue:07 queue:07 processor:08 So, i got my service runing, partly. Currently i'm using ORPC and synchronius calls to my RPC server. I simply can't start async RPC client from processor's #process: just after: let clnt = Protocol_clnt.create_client ~esys: container#event_system (Rpc_client.Inet ("localhost", 9007)) Rpc.Tcp in Protocol_clnt.new_signal'async clnt () cb; i see in log: Exception File "unixqueue.ml", line 954, characters 6-12: Assertion failed But synchronious client works. So here is my list of questions: - why i may not to use nice netflex message bus from processor? - how can i to know does some objects to share same event queue or doesn't? - why i can't start async rpc client from processor by using container#even_queue? (that queue is usable from processor: i can send and receive events by using it) - how can i use container#send_message from processor? (simple call to it silently hungs container's rpc)