mirror of
https://github.com/haiwen/ccnet-server.git
synced 2025-06-19 10:21:54 +00:00
123 lines
3.4 KiB
C
123 lines
3.4 KiB
C
/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
|
|
|
|
#include "common.h"
|
|
|
|
#include "peer.h"
|
|
#include "service-stub-proc.h"
|
|
#include "service-proxy-proc.h"
|
|
|
|
#define DEBUG_FLAG CCNET_DEBUG_OTHER
|
|
#include "log.h"
|
|
|
|
typedef struct {
|
|
CcnetServiceProxyProc *proxy_proc;
|
|
} ServiceStubPriv;
|
|
|
|
#define GET_PRIV(o) \
|
|
(G_TYPE_INSTANCE_GET_PRIVATE ((o), CCNET_TYPE_SERVICE_STUB_PROC, ServiceStubPriv))
|
|
|
|
static int service_stub_start (CcnetProcessor *processor, int argc, char **argv);
|
|
|
|
static void handle_update (CcnetProcessor *processor,
|
|
char *code, char *code_msg,
|
|
char *content, int clen);
|
|
|
|
static void handle_response (CcnetProcessor *processor,
|
|
char *code, char *code_msg,
|
|
char *content, int clen);
|
|
|
|
G_DEFINE_TYPE (CcnetServiceStubProc, ccnet_service_stub_proc, CCNET_TYPE_PROCESSOR)
|
|
|
|
|
|
static void
|
|
ccnet_service_stub_proc_class_init (CcnetServiceStubProcClass *klass)
|
|
{
|
|
CcnetProcessorClass *proc_class = CCNET_PROCESSOR_CLASS (klass);
|
|
/* GObjectClass *object_class = G_OBJECT_CLASS (klass); */
|
|
|
|
proc_class->name = "service-stub-proc";
|
|
proc_class->start = service_stub_start;
|
|
proc_class->handle_update = handle_update;
|
|
proc_class->handle_response = handle_response;
|
|
|
|
g_type_class_add_private (klass, sizeof (ServiceStubPriv));
|
|
}
|
|
|
|
static void
|
|
ccnet_service_stub_proc_init (CcnetServiceStubProc *processor)
|
|
{
|
|
}
|
|
|
|
static void
|
|
strnjoin (int n, char **strs, GString *buf)
|
|
{
|
|
int i;
|
|
|
|
if (n == 0)
|
|
return;
|
|
|
|
g_string_append (buf, strs[0]);
|
|
|
|
for (i = 1; i < n; i++) {
|
|
g_string_append (buf, " ");
|
|
g_string_append (buf, strs[i]);
|
|
}
|
|
}
|
|
|
|
static int
|
|
service_stub_start (CcnetProcessor *processor, int argc, char **argv)
|
|
{
|
|
GString *buf;
|
|
ServiceStubPriv *priv = GET_PRIV (processor);
|
|
|
|
g_return_val_if_fail (priv->proxy_proc != NULL, -1);
|
|
buf = g_string_new (NULL);
|
|
|
|
CcnetProcessor *pproc = (CcnetProcessor *)priv->proxy_proc;
|
|
if (!pproc->peer->is_local) {
|
|
/* remote? (this may be wrong) */
|
|
g_string_append (buf, "remote ");
|
|
g_string_append (buf, pproc->peer->id);
|
|
g_string_append (buf, " ");
|
|
}
|
|
|
|
strnjoin (argc, argv, buf);
|
|
ccnet_processor_send_request (processor, buf->str);
|
|
g_string_free (buf, TRUE);
|
|
|
|
return 0;
|
|
}
|
|
|
|
void
|
|
ccnet_service_stub_proc_set_proxy_proc (CcnetServiceStubProc *proc,
|
|
CcnetProcessor *proxy_proc)
|
|
{
|
|
ServiceStubPriv *priv = GET_PRIV (proc);
|
|
|
|
priv->proxy_proc = (CcnetServiceProxyProc *)proxy_proc;
|
|
}
|
|
|
|
static void handle_response (CcnetProcessor *processor,
|
|
char *code, char *code_msg,
|
|
char *content, int clen)
|
|
{
|
|
ServiceStubPriv *priv = GET_PRIV (processor);
|
|
|
|
/* ccnet_debug ("[Svc Stub] %d handle response: %s %s\n", */
|
|
/* PRINT_ID(processor->id), code, code_msg); */
|
|
ccnet_processor_handle_response ((CcnetProcessor *)priv->proxy_proc,
|
|
code, code_msg, content, clen);
|
|
}
|
|
|
|
|
|
static
|
|
void handle_update (CcnetProcessor *processor,
|
|
char *code, char *code_msg,
|
|
char *content, int clen)
|
|
{
|
|
|
|
/* ccnet_debug ("[Svc Stub] %d handle update: %s %s\n", */
|
|
/* PRINT_ID(processor->id), code, code_msg); */
|
|
ccnet_processor_send_update (processor, code, code_msg, content, clen);
|
|
}
|