Дополнение Firefox: зависание TCP-соединений

Question

Я создаю надстройку Firefox, которая содержит прослушивание сервером TCP-соединений на одном порту. Проблема в том, что он не всегда закрывает соединение: после отправки FIN-ACK и получения ACK сеанс TCP остается открытым, если клиент не отправляет взамен FIN-ACK.

Только некоторые соединения закрыты не полностью. Но через некоторое время они перестают зависать, и Firefox не может открыть новый дескриптор файла или получить новое соединение.

TCP localhost.localdomain:commtact-https->localhost.localdomain:46951 (CLOSE_WAIT)

Я не смог найти способ, желательно в надстройке (но я также пытался на стороне клиента), чтобы убедиться, что все TCP-соединения закрыты правильно. Вот как выглядит функциональность сервера в дополнении:

init_server: function(port) {
server.result = {};
server.listener = {
    onSocketAccepted : function(serverSocket, transport) {
        server.result.sout = transport.openOutputStream(0,0,0);
        var instream = transport.openInputStream(0,0,0);
        server.result.sin = Components.classes["@mozilla.org/binaryinputstream;1"].
            createInstance(Components.interfaces.nsIBinaryInputStream);
        server.result.sin.setInputStream(instream);

        server.debug("New incoming connection");

        var dataListener = {
            onStartRequest: function(request, context) {
                server.debug("onStartRequest");
            },
            onStopRequest: function(request, context, status) {
                server.debug("onStopRequest");
//              instream.close();
//          delete instream;
//              server.result.sout.close();
//          server.result.sin.close();
            },
            onDataAvailable: function(request, context, inputStream, offset, count) {
              var sis = Components.classes ["@mozilla.org/scriptableinputstream;1"].createInstance (Components.interfaces.nsIScriptableInputStream);
              sis.init(inputStream);
              var str = sis.read(count);
              var suc = Components.classes ["@mozilla.org/intlscriptableunicodeconverter"].createInstance(Components.interfaces.nsIScriptableUnicodeConverter);
              suc.charset = "utf-8";
              var line = suc. ConvertToUnicode (str);
              server.debug(line);

              [ ... process data ... ]

//        instream.close();
//        server.result.sout.close();
//        server.result.sin.close();
//        delete instream;
            },
        };

        // Listen to new data
        var pump = Components.classes["@mozilla.org/network/input-stream-pump;1"].createInstance(Components.interfaces.nsIInputStreamPump);
        pump.init(instream, -1, -1, 0, 0, false); //screenserver.result.sin
        pump.asyncRead(dataListener, null);
    },
    onStopListening : function(serverSocket, status){
        server.debug("Client dead?");
        server.init_server(server.PORT);
    },
};

  server.socket = null;
  server.socket = Components.classes["@mozilla.org/network/server-socket;1"].getService(Components.interfaces.nsIServerSocket); 
  server.socket.init(port, true, -1); 
  server.socket.asyncListen(server.listener);
}

Answer 1

Я думаю, вам нужно сохранить транспорт, который вы передали в вызове onSocketAccepted, а затем вызвать close() для этого.