Lines Matching refs:header
83 } *header;
138 if (rec->header->msg_type >= MSG_TMP_BASE) {
140 rec->header->msg_type);
141 } else if (rec->header->msg_type < msg->num_types) {
142 d = msg->dispatch[rec->header->msg_type];
150 data.data = rec->packet.data + sizeof(*rec->header);
151 data.length = rec->header->length;
152 d->fn(msg, d->private_data, d->msg_type, rec->header->from, &data);
154 rec->header->length = 0;
171 rec->header = (struct messaging_header *)packet.data;
175 if (packet.length != sizeof(*rec->header) + rec->header->length) {
176 DEBUG(0,("messaging: bad message header size %d should be %d\n",
177 rec->header->length, (int)(packet.length - sizeof(*rec->header))));
265 cluster_id_string(debug_ctx(), rec->header->from),
266 cluster_id_string(debug_ctx(), rec->header->to),
267 rec->header->msg_type,
308 if (msize < sizeof(*rec->header)) {
322 rec->header = (struct messaging_header *)packet.data;
326 if (msize != sizeof(*rec->header) + rec->header->length) {
327 DEBUG(0,("messaging: bad message header size %d should be %d\n",
328 rec->header->length, (int)(msize - sizeof(*rec->header))));
454 rec->packet = data_blob_talloc(rec, NULL, sizeof(*rec->header) + dlength);
462 rec->header = (struct messaging_header *)rec->packet.data;
464 ZERO_STRUCTP(rec->header);
465 rec->header->version = MESSAGING_VERSION;
466 rec->header->msg_type = msg_type;
467 rec->header->from = msg->server_id;
468 rec->header->to = server;
469 rec->header->length = dlength;
471 memcpy(rec->packet.data + sizeof(*rec->header),
677 irpc = (struct irpc_request *)idr_find(msg_ctx->idr, m->header.callid);
683 irpc->status = m->header.status;
704 m->header.status = status;
713 m->header.flags |= IRPC_FLAG_REPLY;
716 ndr_err = ndr_push_irpc_header(push, NDR_SCALARS|NDR_BUFFERS, &m->header);
749 if (GUID_equal(&i->uuid, &m->header.uuid) &&
750 i->table->syntax_id.if_version == m->header.if_version &&
751 i->callnum == m->header.callnum) {
763 r = talloc_zero_size(m->ndr, i->table->calls[m->header.callnum].struct_size);
778 m->header.status = i->fn(m, r);
786 irpc_send_reply(m, m->header.status);
812 ndr_err = ndr_pull_irpc_header(m->ndr, NDR_BUFFERS|NDR_SCALARS, &m->header);
815 if (m->header.flags & IRPC_FLAG_REPLY) {
866 struct irpc_header header;
889 /* setup the header */
890 header.uuid = table->syntax_id.uuid;
892 header.if_version = table->syntax_id.if_version;
893 header.callid = irpc->callid;
894 header.callnum = callnum;
895 header.flags = 0;
896 header.status = NT_STATUS_OK;
902 ndr_err = ndr_push_irpc_header(ndr, NDR_SCALARS|NDR_BUFFERS, &header);