3

GLib を使用してシンプルで効率的なソケット サーバーを作成するための基礎を学んでいます。私は GSocketService を試しています。これまでのところ、接続を受け入れることしかできないようですが、すぐに閉じられます。ドキュメントから、どのステップが欠けているのかわかりません。誰かが私のためにこれに光を当ててくれることを願っています。

以下を実行する場合:

# telnet localhost 4000
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
Connection closed by foreign host.
# telnet localhost 4000
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
Connection closed by foreign host.
# telnet localhost 4000
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
Connection closed by foreign host.

サーバーからの出力:

# ./server
New Connection from 127.0.0.1:36962
New Connection from 127.0.0.1:36963
New Connection from 127.0.0.1:36965

現在のコード:

/*
 * server.c
 *
 *  Created on: Mar 10, 2010
 *      Author: mark
 */
#include <glib.h>
#include <gio/gio.h>

gchar *buffer;

gboolean
network_read(GIOChannel *source,
            GIOCondition cond,
            gpointer data)
{
  GString *s = g_string_new(NULL);
  GError *error;
  GIOStatus ret = g_io_channel_read_line_string(source, s, NULL, &error);
  if (ret == G_IO_STATUS_ERROR)
    g_error ("Error reading: %s\n", error->message);
  else
    g_print("Got: %s\n", s->str);

}

gboolean
new_connection(GSocketService *service,
              GSocketConnection *connection,
              GObject *source_object,
              gpointer user_data)
{
  GSocketAddress *sockaddr = g_socket_connection_get_remote_address(connection, NULL);
  GInetAddress *addr = g_inet_socket_address_get_address(G_INET_SOCKET_ADDRESS(sockaddr));
  guint16 port = g_inet_socket_address_get_port(G_INET_SOCKET_ADDRESS(sockaddr));

  g_print("New Connection from %s:%d\n", g_inet_address_to_string(addr), port);

  GSocket *socket = g_socket_connection_get_socket(connection);

  gint fd = g_socket_get_fd(socket);
  GIOChannel *channel = g_io_channel_unix_new(fd);
  g_io_add_watch(channel, G_IO_IN, (GIOFunc) network_read, NULL);
  return TRUE;
}

int main(int argc, char **argv) {
  g_type_init();
  GSocketService *service = g_socket_service_new();
  GInetAddress *address = g_inet_address_new_from_string("127.0.0.1");
  GSocketAddress *socket_address = g_inet_socket_address_new(address, 4000);
  g_socket_listener_add_address(G_SOCKET_LISTENER(service), socket_address, G_SOCKET_TYPE_STREAM,
          G_SOCKET_PROTOCOL_TCP, NULL, NULL, NULL);

  g_object_unref(socket_address);
  g_object_unref(address);
  g_socket_service_start(service);

  g_signal_connect(service, "incoming", G_CALLBACK(new_connection), NULL);

  GMainLoop *loop = g_main_loop_new(NULL, FALSE);
  g_main_loop_run(loop);
}
4

3 に答える 3

5

着信コールバックで GSocketConnection を参照する必要があります。これにより、接続が維持されます。データ構造、クラス、またはウォッチ コールバックへの user_data として渡すことができます。

gboolean
new_connection(...)
{
  ...

  g_object_ref (connection);
  GSocket *socket = g_socket_connection_get_socket(connection);

  gint fd = g_socket_get_fd(socket);
  GIOChannel *channel = g_io_channel_unix_new(fd);
  // Pass connection as user_data to the watch callback
  g_io_add_watch(channel, G_IO_IN, (GIOFunc) network_read, connection);
  return TRUE;
}

ウォッチ コールバック network_read() で返されていません。「return true」で終了する必要があります。ドキュメントから:「イベント ソースを削除する必要がある場合、関数は FALSE を返す必要があります」。

100% の CPU は、接続が閉じられた時点でチャネルがまだ有効であるという事実によって発生します。イベント ソースが不要になったら、必ず適切に削除してください。

gboolean
network_read(GIOChannel *source,
             GIOCondition cond,
             gpointer data)
{
  GString *s = g_string_new(NULL);
  GError *error = NULL;
  GIOStatus ret = g_io_channel_read_line_string(source, s, NULL, &error);

  if (ret == G_IO_STATUS_ERROR) {
    //g_error ("Error reading: %s\n", error->message);
    g_warning ("Error reading: %s\n", error->message);
    // Drop last reference on connection
    g_object_unref (data);
    // Remove the event source
    return FALSE;
  }
  else
    g_print("Got: %s\n", s->str);

  if (ret == G_IO_STATUS_EOF) {
    return FALSE;
  }
于 2010-07-18T05:24:18.700 に答える
2

GSocketService のドキュメントには記載されていませんが (GLib ソースを調べる必要がありました)、コールバック (この場合は new_connection) を呼び出すルーチンは、返された後に接続オブジェクトに対して *g_object_unref() を実行します。これにより、 new_connection() が返されるとすぐに接続が効果的に閉じられます。

なぜこれを行うのかわかりませんが、解決策は、コールバックに入るときに g_object_ref() を追加することです。

gboolean
new_connection(GSocketService *service,
              GSocketConnection *connection,
              GObject *source_object,
              gpointer user_data)
{

  g_object_ref(connection);    /* Tell glib not to disconnect */

  GSocketAddress *sockaddr = g_socket_connection_get_remote_address(connection, NULL);
  GInetAddress *addr =
      g_inet_socket_address_get_address(G_INET_SOCKET_ADDRESS(sockaddr));
  guint16 port = g_inet_socket_address_get_port(G_INET_SOCKET_ADDRESS(sockaddr));

その追加がなければ、接続が閉じられていたため、メイン ループでファイル記述子をポーリングすると POLLNVAL が返されました。その結果のハンドラーがない場合、それは継続的に実行されました。これが 100% の CPU 負荷を引き起こした原因です。

于 2011-10-27T18:01:47.427 に答える
1

GIO ドキュメントから:

GIOStream オブジェクトは入力ストリームと出力ストリームを所有しており、その逆ではないため、サブストリームを維持しても GIOStream オブジェクトは維持されません。GIOStream オブジェクトが解放されると、サブストリームが閉じられ、サブストリームが閉じられるため、サブストリームが生きていても、すべての操作に対して常に G_IO_ERROR_CLOSED が返されます。

于 2010-05-22T07:11:30.303 に答える