stuff

1 files changed, 64 insertions, 0 deletions

diff --git a/src/fs/gnunet-service-fs_lc.c b/src/fs/gnunet-service-fs_lc.c
index 9c9c0d568..ea33580f9 100644
--- a/src/fs/gnunet-service-fs_lc.c
+++ b/src/fs/gnunet-service-fs_lc.c
@@ -179,6 +179,70 @@ GSF_local_client_lookup_ (struct GNUNET_SERVER_Client *client)
 
 
 /**
+ * Handle a reply to a pending request.  Also called if a request
+ * expires (then with data == NULL).  The handler may be called
+ * many times (depending on the request type), but will not be
+ * called during or after a call to GSF_pending_request_cancel 
+ * and will also not be called anymore after a call signalling
+ * expiration.
+ *
+ * @param cls user-specified closure
+ * @param pr handle to the original pending request
+ * @param data response data, NULL on request expiration
+ * @param data_len number of bytes in data
+ */
+static void
+client_response_handler (void *cls,
+                         struct GSF_PendingRequest *pr,
+                         const void *data,
+                         size_t data_len)
+{
+  /* FIXME: adapt old code below to new API! */
+
+      GNUNET_STATISTICS_update (stats,
+                                gettext_noop ("# replies received for local clients"),
+                                1,
+                                GNUNET_NO);
+      cl = pr->client_request_list->client_list;
+      msize = sizeof (struct PutMessage) + prq->size;
+      creply = GNUNET_malloc (msize + sizeof (struct ClientResponseMessage));
+      creply->msize = msize;
+      creply->client_list = cl;
+      GNUNET_CONTAINER_DLL_insert_after (cl->res_head,
+                                         cl->res_tail,
+                                         cl->res_tail,
+                                         creply);      
+      pm = (struct PutMessage*) &creply[1];
+      pm->header.type = htons (GNUNET_MESSAGE_TYPE_FS_PUT);
+      pm->header.size = htons (msize);
+      pm->type = htonl (prq->type);
+      pm->expiration = GNUNET_TIME_absolute_hton (prq->expiration);
+      memcpy (&pm[1], prq->data, prq->size);      
+      if (NULL == cl->th)
+        {
+#if DEBUG_FS
+          GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+                      "Transmitting result for query `%s' to client\n",
+                      GNUNET_h2s (key));
+#endif  
+          cl->th = GNUNET_SERVER_notify_transmit_ready (cl->client,
+                                                        msize,
+                                                        GNUNET_TIME_UNIT_FOREVER_REL,
+                                                        &transmit_to_client,
+                                                        cl);
+        }
+      GNUNET_break (cl->th != NULL);
+      if (pr->do_remove)                
+        {
+          prq->finished = GNUNET_YES;
+          destroy_pending_request (pr);         
+        }
+
+}
+
+
+
+/**
  * Handle START_SEARCH-message (search request from local client).
  *
  * @param client identification of the client