这篇教程C++ zmsg_is函数代码示例写得很实用,希望能帮到您。
本文整理汇总了C++中zmsg_is函数的典型用法代码示例。如果您正苦于以下问题:C++ zmsg_is函数的具体用法?C++ zmsg_is怎么用?C++ zmsg_is使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。 在下文中一共展示了zmsg_is函数的28个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的C++代码示例。 示例1: zmsg_sendintzmsg_send (zmsg_t **self_p, void *dest){ assert (self_p); assert (dest); zmsg_t *self = *self_p; int rc = 0; void *handle = zsock_resolve (dest); if (self) { assert (zmsg_is (self)); if (zlist_size (self->frames) == 0) return -1; // Sending an empty message is an error zframe_t *frame = (zframe_t *) zlist_pop (self->frames); while (frame) { rc = zframe_send (&frame, handle, zlist_size (self->frames)? ZFRAME_MORE: 0); if (rc != 0) break; frame = (zframe_t *) zlist_pop (self->frames); } zmsg_destroy (self_p); } return rc;}
开发者ID:HunterChen,项目名称:czmq,代码行数:26,
示例2: zmsg_lastzframe_t *zmsg_last (zmsg_t *self){ assert (self); assert (zmsg_is (self)); return (zframe_t *) zlist_last (self->frames);}
开发者ID:dadavita,项目名称:stalk,代码行数:7,
示例3: zmsg_sendmintzmsg_sendm (zmsg_t **self_p, void *dest){ assert (self_p); assert (dest); zmsg_t *self = *self_p; int rc = 0; if (self) { assert (zmsg_is (self)); bool sent_some = false; zframe_t *frame; while ((frame = (zframe_t *) zlist_head (self->frames))) { rc = zframe_send (&frame, dest, ZFRAME_MORE); if (rc != 0) { if (errno == EINTR && sent_some) continue; else break; } sent_some = true; (void) zlist_pop (self->frames); } if (rc == 0) zmsg_destroy (self_p); } return rc;}
开发者ID:hellermf,项目名称:lstore-release,代码行数:28,
示例4: zmsg_content_sizesize_tzmsg_content_size (zmsg_t *self){ assert (self); assert (zmsg_is (self)); return self->content_size;}
开发者ID:dadavita,项目名称:stalk,代码行数:8,
示例5: get_message_to_deliverstatic voidget_message_to_deliver (client_t *self){ assert (zmsg_is (self->msg)); if (self->callee) xrap_traffic_set_sender (self->message, self->callee->id); xrap_traffic_set_content (self->message, &self->msg);}
开发者ID:oikosdev,项目名称:zwebrap,代码行数:8,
示例6: zmsg_sizesize_tzmsg_size (zmsg_t *self){ assert (self); assert (zmsg_is (self)); return zlist_size (self->frames);}
开发者ID:dadavita,项目名称:stalk,代码行数:8,
示例7: zmsg_removevoidzmsg_remove (zmsg_t *self, zframe_t *frame){ assert (self); assert (zmsg_is (self)); self->content_size -= zframe_size (frame); zlist_remove (self->frames, frame);}
开发者ID:dadavita,项目名称:stalk,代码行数:9,
示例8: zmsg_addstrintzmsg_addstr (zmsg_t *self, const char *string){ assert (self); assert (zmsg_is (self)); assert (string); self->content_size += strlen (string); zlist_append (self->frames, zframe_new (string, strlen (string))); return 0;}
开发者ID:HunterChen,项目名称:czmq,代码行数:11,
示例9: zmsg_appendintzmsg_append (zmsg_t *self, zframe_t **frame_p){ assert (self); assert (zmsg_is (self)); assert (frame_p); zframe_t *frame = *frame_p; *frame_p = NULL; // We now own frame self->content_size += zframe_size (frame); return zlist_append (self->frames, frame);}
开发者ID:dadavita,项目名称:stalk,代码行数:12,
示例10: zmsg_popzframe_t *zmsg_pop (zmsg_t *self){ assert (self); assert (zmsg_is (self)); zframe_t *frame = (zframe_t *) zlist_pop (self->frames); if (frame) self->content_size -= zframe_size (frame); return frame;}
开发者ID:dadavita,项目名称:stalk,代码行数:12,
示例11: zmsg_addmemintzmsg_addmem (zmsg_t *self, const void *src, size_t size){ assert (self); assert (zmsg_is (self)); zframe_t *frame = zframe_new (src, size); if (frame) { self->content_size += size; return zlist_append (self->frames, frame); } else return -1;}
开发者ID:dadavita,项目名称:stalk,代码行数:14,
示例12: zmsg_popstrchar *zmsg_popstr (zmsg_t *self){ assert (self); assert (zmsg_is (self)); zframe_t *frame = (zframe_t *) zlist_pop (self->frames); char *string = NULL; if (frame) { self->content_size -= zframe_size (frame); string = zframe_strdup (frame); zframe_destroy (&frame); } return string;}
开发者ID:dadavita,项目名称:stalk,代码行数:15,
示例13: zmsg_addstrintzmsg_addstr (zmsg_t *self, const char *string){ assert (self); assert (zmsg_is (self)); assert (string); size_t len = strlen (string); zframe_t *frame = zframe_new (string, len); if (frame) { self->content_size += len; return zlist_append (self->frames, frame); } else return -1;}
开发者ID:dadavita,项目名称:stalk,代码行数:16,
示例14: zmsg_destroyvoidzmsg_destroy (zmsg_t **self_p){ assert (self_p); if (*self_p) { zmsg_t *self = *self_p; assert (zmsg_is (self)); zframe_t *frame; while ((frame = (zframe_t *) zlist_pop (self->frames))) zframe_destroy (&frame); zlist_destroy (&self->frames); self->tag = 0xDeadBeef; free (self); *self_p = NULL; }}
开发者ID:dadavita,项目名称:stalk,代码行数:16,
示例15: zmsg_printvoidzmsg_print (zmsg_t *self){ assert (self); assert (zmsg_is (self)); if (!self) { zsys_debug ("(NULL)"); return; } zframe_t *frame = zmsg_first (self); while (frame) { zframe_print (frame, NULL); frame = zmsg_next (self); }}
开发者ID:dadavita,项目名称:stalk,代码行数:16,
示例16: zmsg_popmsgzmsg_t *zmsg_popmsg (zmsg_t *self){ assert (self); assert (zmsg_is (self)); zframe_t *frame = zmsg_pop (self); if (!frame) return NULL; size_t len = zframe_size (frame); byte *data = zframe_data (frame); zmsg_t *msg = zmsg_decode (data, len); zframe_destroy (&frame); return msg;}
开发者ID:dadavita,项目名称:stalk,代码行数:16,
示例17: zmsg_encodesize_tzmsg_encode (zmsg_t *self, byte **buffer){ assert (self); assert (zmsg_is (self)); // Calculate real size of buffer size_t buffer_size = 0; zframe_t *frame = zmsg_first (self); while (frame) { size_t frame_size = zframe_size (frame); if (frame_size < 255) buffer_size += frame_size + 1; else buffer_size += frame_size + 1 + 4; frame = zmsg_next (self); } *buffer = (byte *) zmalloc (buffer_size); if (*buffer) { // Encode message now byte *dest = *buffer; frame = zmsg_first (self); while (frame) { size_t frame_size = zframe_size (frame); if (frame_size < 255) { *dest++ = (byte) frame_size; memcpy (dest, zframe_data (frame), frame_size); dest += frame_size; } else { *dest++ = 0xFF; *dest++ = (frame_size >> 24) & 255; *dest++ = (frame_size >> 16) & 255; *dest++ = (frame_size >> 8) & 255; *dest++ = frame_size & 255; memcpy (dest, zframe_data (frame), frame_size); dest += frame_size; } frame = zmsg_next (self); } assert ((dest - *buffer) == buffer_size); } return buffer_size;}
开发者ID:dadavita,项目名称:stalk,代码行数:45,
示例18: zmsg_addmsgintzmsg_addmsg (zmsg_t *self, zmsg_t **msg_p){ assert (self); assert (zmsg_is (self)); assert (msg_p); zmsg_t *msg = *msg_p; byte *data; size_t len = zmsg_encode (msg, &data); int r = zmsg_addmem (self, data, len); if (r == 0) { zmsg_destroy (&msg); *msg_p = NULL; } free (data); return r;}
开发者ID:dadavita,项目名称:stalk,代码行数:18,
示例19: zmsg_fprintvoidzmsg_fprint (zmsg_t *self, FILE *file){ assert (self); assert (zmsg_is (self)); fprintf (file, "--------------------------------------/n"); if (!self) { fprintf (file, "NULL"); return; } zframe_t *frame = zmsg_first (self); int frame_nbr = 0; while (frame && frame_nbr++ < 10) { zframe_fprint (frame, NULL, file); frame = zmsg_next (self); }}
开发者ID:dadavita,项目名称:stalk,代码行数:18,
示例20: zmsg_saveintzmsg_save (zmsg_t *self, FILE *file){ assert (self); assert (zmsg_is (self)); assert (file); zframe_t *frame = zmsg_first (self); while (frame) { size_t frame_size = zframe_size (frame); if (fwrite (&frame_size, sizeof (frame_size), 1, file) != 1) return -1; if (fwrite (zframe_data (frame), frame_size, 1, file) != 1) return -1; frame = zmsg_next (self); } return 0;}
开发者ID:dadavita,项目名称:stalk,代码行数:18,
示例21: zmsg_addstrfintzmsg_addstrf (zmsg_t *self, const char *format, ...){ assert (self); assert (zmsg_is (self)); assert (format); va_list argptr; va_start (argptr, format); char *string = zsys_vprintf (format, argptr); va_end (argptr); self->content_size += strlen (string); zlist_append (self->frames, zframe_new (string, strlen (string))); free (string); return 0;}
开发者ID:HunterChen,项目名称:czmq,代码行数:18,
示例22: zmsg_dupzmsg_t *zmsg_dup (zmsg_t *self){ assert (self); assert (zmsg_is (self)); zmsg_t *copy = zmsg_new (); if (!copy) return NULL; zframe_t *frame = zmsg_first (self); while (frame) { if (zmsg_addmem (copy, zframe_data (frame), zframe_size (frame))) { zmsg_destroy (©); return NULL; } frame = zmsg_next (self); } return copy;}
开发者ID:HunterChen,项目名称:czmq,代码行数:20,
示例23: zmsg_dupzmsg_t *zmsg_dup (zmsg_t *self){ if (self) { assert (zmsg_is (self)); zmsg_t *copy = zmsg_new (); if (copy) { zframe_t *frame = zmsg_first (self); while (frame) { if (zmsg_addmem (copy, zframe_data (frame), zframe_size (frame))) { zmsg_destroy (©); break; // Abandon attempt to copy message } frame = zmsg_next (self); } } return copy; } else return NULL;}
开发者ID:dadavita,项目名称:stalk,代码行数:21,
示例24: zmsg_sendmintzmsg_sendm (zmsg_t **self_p, void *dest){ assert (self_p); assert (dest); zmsg_t *self = *self_p; int rc = 0; if (self) { assert (zmsg_is (self)); zframe_t *frame = (zframe_t *) zlist_pop (self->frames); while (frame) { rc = zframe_send (&frame, dest, ZFRAME_MORE); if (rc != 0) break; frame = (zframe_t *) zlist_pop (self->frames); } if (rc == 0) zmsg_destroy (self_p); } return rc;}
开发者ID:jemc,项目名称:czmq,代码行数:22,
示例25: zmsg_addstrfintzmsg_addstrf (zmsg_t *self, const char *format, ...){ assert (self); assert (zmsg_is (self)); assert (format); va_list argptr; va_start (argptr, format); char *string = zsys_vprintf (format, argptr); va_end (argptr); if (!string) return -1; size_t len = strlen (string); zframe_t *frame = zframe_new (string, len); free (string); if (frame) { self->content_size += len; return zlist_append (self->frames, frame); } else return -1;}
开发者ID:dadavita,项目名称:stalk,代码行数:24,
示例26: zmsg_is///// Probe the supplied object, and report if it looks like a zmsg_t.bool QmlZmsgAttached::is (void *self) { return zmsg_is (self);};
开发者ID:dadavita,项目名称:stalk,代码行数:5,
示例27: K1Z K1(zmsgis){PC(x); R kb(zmsg_is(VSK(x)));}
开发者ID:jaeheum,项目名称:qzmq,代码行数:1,
示例28: zmsg_is///// Probe the supplied object, and report if it looks like a zmsg_t.bool QZmsg::is (void *self){ bool rv = zmsg_is (self); return rv;}
开发者ID:chsticksel,项目名称:ocamlczmq,代码行数:7,
注:本文中的zmsg_is函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 C++ zmsg_new函数代码示例 C++ zmsg_first函数代码示例 |