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 mail4-relais-sop.national.inria.fr (mail4-relais-sop.national.inria.fr [192.134.164.105]) by yquem.inria.fr (Postfix) with ESMTP id 98A38BBC4 for ; Sat, 4 Apr 2009 16:24:19 +0200 (CEST) X-IronPort-Anti-Spam-Filtered: true X-IronPort-Anti-Spam-Result: AkQCAF8K10nRVdykkGdsb2JhbACVZz8BAQEBCQkMBxEDpQaBCY9EAQMBA4JHAYFEBodfAQ X-IronPort-AV: E=Sophos;i="4.39,324,1235948400"; d="scan'208";a="37858520" Received: from mail-fx0-f164.google.com ([209.85.220.164]) by mail4-smtp-sop.national.inria.fr with ESMTP; 04 Apr 2009 16:24:19 +0200 Received: by fxm8 with SMTP id 8so1524377fxm.27 for ; Sat, 04 Apr 2009 07:24:18 -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=huQmZ/dI9VYEhY9ai8eBZUNhy/4GAaKKysV1dB3q9uk=; b=TgELYMrQg55ASoSZ2sw2bdFpNCxa693r0rqYghX9m7I0bh+tyXHWaozCOlBqh31w9I 23Y3eAjjVpbbmtKOVUK0gRrIlgjKI8HL+ibopd21we1AmV316+iZ+wmEkp7dKcJX0+MD iiNkSrHt7m8eEIXXUvgfP4i449mZpg6jKXqA4= 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=NKzFbhYU0DEXjtGzMm+i/+sy8xvdQ75XuBgzzXKn05YntJQLSrpa5G19s2FGOxyzhW DglFxbwnziD3zW7RSdL3wNnNTuxiBhyhuoi0m8jHnoZXy7fsillRoA+WSkANgWFbBMrM OkSCTS9oX7ohoV30o2e3guy8vvtNLaHsxD1wo= MIME-Version: 1.0 Received: by 10.204.112.11 with SMTP id u11mr838149bkp.134.1238855058583; Sat, 04 Apr 2009 07:24:18 -0700 (PDT) In-Reply-To: References: <1238773897.9723.6.camel@flake.lan.gerd-stolpmann.de> Date: Sat, 4 Apr 2009 20:24:18 +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; sexp:01 sexp:01 workload:01 ssp:98 unix:01 unix:01 rec:01 exception:01 exception:01 caml-list:01 descr:02 output:02 string:02 string:02 objects:02 Hello, why following code doesn't react to messages sent to container (and to events sent from other service)? exception BeLive exception DataArrived ... method receive_admin_message container name args = container#event_system#add_event (Extra DataArrived) ... method process ~when_done container fd proto_name = let ch = Unix.out_channel_of_descr fd in let rec aux () = let s = (Sexp.to_string (sexp_of_msg dfl_msg)) ^ "\n" in output_string ch s; flush ch; Unix.sleep 1; container#event_system#add_event (Extra BeLive) in let cb _ _ = function | Extra DataArrived -> aux() | Extra BeLive -> Unix.sleep 1; container#event_system#add_event (Extra BeLive) | _ -> raise Equeue.Reject in let g = container#event_system#new_group() in container#event_system#add_handler g cb; aux () also, i'm interesting to answers to my previous qustion :) : Does services started from one Netplex_main.startup are share same event system for case where their workload_manager sections in configuration file are identical? How can i to know does some objects to share same event queue or doesn't?