627   XENSTORE_MESSAGE *Message;  in XenStoreProcessMessage()  local
631   Message = AllocateZeroPool (sizeof (XENSTORE_MESSAGE));  in XenStoreProcessMessage()
632   Message->Signature = XENSTORE_MESSAGE_SIGNATURE;  in XenStoreProcessMessage()
633   Status = XenStoreReadStore (&Message->Header, sizeof (Message->Header));  in XenStoreProcessMessage()
635     FreePool (Message);  in XenStoreProcessMessage()
640   Body = AllocatePool (Message->Header.len + 1);  in XenStoreProcessMessage()
641   Status = XenStoreReadStore (Body, Message->Header.len);  in XenStoreProcessMessage()
644     FreePool (Message);  in XenStoreProcessMessage()
648   Body[Message->Header.len] = '\0';  in XenStoreProcessMessage()
650   if (Message->Header.type == XS_WATCH_EVENT) {  in XenStoreProcessMessage()
651     Message->u.Watch.Vector = Split(Body, Message->Header.len,  in XenStoreProcessMessage()
652                                     &Message->u.Watch.VectorSize);  in XenStoreProcessMessage()
655     Message->u.Watch.Handle =  in XenStoreProcessMessage()
656       XenStoreFindWatch (Message->u.Watch.Vector[XS_WATCH_TOKEN]);  in XenStoreProcessMessage()
658             Message->u.Watch.Vector[XS_WATCH_TOKEN]));  in XenStoreProcessMessage()
659     if (Message->u.Watch.Handle != NULL) {  in XenStoreProcessMessage()
661       InsertHeadList (&xs.WatchEvents, &Message->Link);  in XenStoreProcessMessage()
665               Message->u.Watch.Vector[XS_WATCH_TOKEN]));  in XenStoreProcessMessage()
666       FreePool((VOID*)Message->u.Watch.Vector);  in XenStoreProcessMessage()
667       FreePool(Message);  in XenStoreProcessMessage()
671     Message->u.Reply.Body = Body;  in XenStoreProcessMessage()
673     InsertTailList (&xs.ReplyList, &Message->Link);  in XenStoreProcessMessage()
749   XENSTORE_MESSAGE *Message;  in XenStoreReadReply()  local
764   Message = XENSTORE_MESSAGE_FROM_LINK (Entry);  in XenStoreReadReply()
768   *TypePtr = Message->Header.type;  in XenStoreReadReply()
770     *LenPtr = Message->Header.len;  in XenStoreReadReply()
772   Body = Message->u.Reply.Body;  in XenStoreReadReply()
774   FreePool (Message);  in XenStoreReadReply()
803   struct xsd_sockmsg Message;  in XenStoreTalkv()  local
809     Message.tx_id = 0;  in XenStoreTalkv()
811     Message.tx_id = Transaction->Id;  in XenStoreTalkv()
813   Message.req_id = 0;  in XenStoreTalkv()
814   Message.type = RequestType;  in XenStoreTalkv()
815   Message.len = 0;  in XenStoreTalkv()
817     Message.len += WriteRequest[Index].Len;  in XenStoreTalkv()
820   Status = XenStoreWriteStore (&Message, sizeof (Message));  in XenStoreTalkv()
834   Status = XenStoreReadReply ((enum xsd_sockmsg_type *)&Message.type, LenPtr, &Return);  in XenStoreTalkv()
841   if (Message.type == XS_ERROR) {  in XenStoreTalkv()
848   ASSERT ((enum xsd_sockmsg_type)Message.type == RequestType);  in XenStoreTalkv()
956   XENSTORE_MESSAGE *Message;  in XenStoreWaitWatch()  local
976       Message = XENSTORE_MESSAGE_FROM_LINK (Entry);  in XenStoreWaitWatch()
977       if (Message->u.Watch.Handle == Token) {  in XenStoreWaitWatch()
980         FreePool((VOID*)Message->u.Watch.Vector);  in XenStoreWaitWatch()
981         FreePool(Message);  in XenStoreWaitWatch()
1117       XENSTORE_MESSAGE *Message = XENSTORE_MESSAGE_FROM_LINK (Entry);  in XenStoreDeinit()  local
1119       RemoveEntryList (&Message->Link);  in XenStoreDeinit()
1120       FreePool ((VOID*)Message->u.Watch.Vector);  in XenStoreDeinit()
1121       FreePool (Message);  in XenStoreDeinit()
1126     XENSTORE_MESSAGE *Message;  in XenStoreDeinit()  local
1130       Message = XENSTORE_MESSAGE_FROM_LINK (Entry);  in XenStoreDeinit()
1132       RemoveEntryList (&Message->Link);  in XenStoreDeinit()
1133       FreePool (Message->u.Reply.Body);  in XenStoreDeinit()
1134       FreePool (Message);  in XenStoreDeinit()
1420     XENSTORE_MESSAGE *Message = XENSTORE_MESSAGE_FROM_LINK (Entry);  in XenStoreUnregisterWatch()  local
1422     if (Message->u.Watch.Handle == Watch) {  in XenStoreUnregisterWatch()
1423       RemoveEntryList (&Message->Link);  in XenStoreUnregisterWatch()
1424       FreePool ((VOID*)Message->u.Watch.Vector);  in XenStoreUnregisterWatch()
1425       FreePool (Message);  in XenStoreUnregisterWatch()