invocationrunnable.java

来自「SRI international 发布的OAA框架软件」· Java 代码 · 共 60 行

/* $Id: InvocationRunnable.java,v 1.2 2003/09/27 03:01:13 giuli Exp $*/
/**************************************************************************
 * Copyright 2002, 2003 SRI International. All rights reserved.
 *
 * The material contained in this file is confidential and proprietary to SRI
 * International and may not be reproduced, published, or disclosed to others
 * without authorization from SRI International.
 *
 * DISCLAIMER OF WARRANTIES
 *
 * SRI International MAKES NO REPRESENTATIONS OR WARRANTIES ABOUT THE
 * SUITABILITY OF THE SOFTWARE, EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT
 * LIMITED TO THE IMPLIED WARRANTIES OF MERCHANTABILITY, FITNESS FOR A
 * PARTICULAR PURPOSE, OR NON-INFRINGEMENT. SRI International SHALL NOT BE
 * LIABLE FOR ANY DAMAGES SUFFERED BY LICENSEE AS A RESULT OF USING, MODIFYING
 * OR DISTRIBUTING THIS SOFTWARE
 **************************************************************************/
package com.sri.sedc.javanetbridge.io;

import com.sri.sedc.javanetbridge.JavaNetBridgeBeanImpl;

import java.net.Socket;
import java.io.IOException;

/**
 *
 */
class InvocationRunnable implements Runnable {
    private DataMarshalInputStream in;
    private DataMarshalOutputStream out;
    private JavaNetBridgeBeanImpl bean;
    private Socket socket;
    private DataMarshalServerImpl server;

    InvocationRunnable(Socket socket, DataMarshalInputStream in,
                       DataMarshalOutputStream out, JavaNetBridgeBeanImpl bean,
                       DataMarshalServerImpl server) {
        this.in = in;
        this.out = out;
        this.bean = bean;
        this.socket = socket;
        this.server = server;
    }

    public void run() {
        try {
            while (true) {
                bean.waitNextInvokeMarshalling(in, out);
            }
        } catch (Exception e) {
            e.printStackTrace();
            try {
                socket.close();
            } catch (IOException e1) {
            }
            server.notifyDisconnect(bean);
        }
    }
}