Quelle  zmq.g   Sprache: unbekannt

#############################################################################
##
#W  zmq.g                    GAP library                  Reimer Behrends
##
#Y  Copyright (C)  1997,  Lehrstuhl D fuer Mathematik,  RWTH Aachen,  Germany
#Y  (C) 1998 School Math and Comp. Sci., University of St.  Andrews, Scotland
#Y  Copyright (C) 2002 The GAP Group
##
##  Additional ease-of-use primitives for using ZeroMQ.
##


DeclareFilter("IsZmqSocket", IsObject and IsInternalRep);
BindGlobal("TYPE_ZMQ_SOCKET", NewType(NewFamily("ZmqFamily", IsObject), IsZmqSocket));

BindGlobal("ZmqAttach", function(socket, addr)
  if addr <> "" and addr[1] = '+' then
    ZmqConnect(socket, addr{[2..Length(addr)]});
  else
    ZmqBind(socket, addr);
  fi;
end);

BindGlobal("ZmqAttachedSocket", function(type, args)
  local socket, nargs;
  nargs := Length(args);
  socket := ZmqSocket(type);
  if nargs = 0 then
  elif nargs = 1 then
    ZmqAttach(socket, args[1]);
  elif nargs = 2 then
    ZmqSetIdentity(socket, args[2]);
    ZmqAttach(socket, args[1]);
  else
    Error("ZmqAttachedSocket: Too many arguments");
  fi;
  return socket;
end);

BindGlobal("ZmqPushSocket", function(arg)
  return ZmqAttachedSocket("PUSH", arg);
end);

BindGlobal("ZmqPullSocket", function(arg)
  return ZmqAttachedSocket("PULL", arg);
end);

BindGlobal("ZmqRequestSocket", function(arg)
  return ZmqAttachedSocket("REQ", arg);
end);

BindGlobal("ZmqReplySocket", function(arg)
  return ZmqAttachedSocket("REP", arg);
end);

BindGlobal("ZmqDealerSocket", function(arg)
  return ZmqAttachedSocket("DEALER", arg);
end);

BindGlobal("ZmqRouterSocket", function(arg)
  return ZmqAttachedSocket("ROUTER", arg);
end);

BindGlobal("ZmqPublisherSocket", function(arg)
  return ZmqAttachedSocket("PUB", arg);
end);

BindGlobal("ZmqSubscriberSocket", function(arg)
  return ZmqAttachedSocket("SUB", arg);
end);

BindGlobal("ZmqReceiveListAsString", function(socket, sep)
  local parts;
  parts := ZmqReceiveList(socket);
  return JoinStringsWithSeparator(parts, sep);
end);

InstallMethod( PrintObj,
  "for zmq socket",
  true,
  [ IsZmqSocket ],
  0,
function(socket)
  Print(String(socket));
end);

InstallMethod( ViewObj,
  "for zmq socket",
  true,
  [ IsZmqSocket ],
  0,
function(socket)
  Print(String(socket));
end);

InstallMethod( String,
  "for zmq socket",
  true,
  [ IsZmqSocket ],
  0,
function(socket)
  local uri, result;
  if not ZmqIsOpen(socket) then
    return MakeImmutable("<zmq socket (closed)>");
  else
    result := "<zmq ";
    Append(result, LowercaseString(ZmqSocketType(socket)));
    Append(result, " socket");
    uri := ZmqSocketURI(socket);
    if uri <> fail then
      if ZmqIsBound(socket) then
 Append(result, " bound to ");
      else
 Append(result, " connected to ");
      fi;
      Append(result, uri);
    fi;
    Append(result, ">");
    return MakeImmutable(result);
  fi;
end);

[ Dauer der Verarbeitung: 0.33 Sekunden  (vorverarbeitet)  ]